Class EthereumIndexerLogFetcher

Hierarchy

BaseIndexerEntityFetcher<EthereumParsedLog>
- EthereumIndexerLogFetcher

Index

Constructors

constructor

Constructors

constructor

new EthereumIndexerLogFetcher(fetcherMsClient: FetcherMsClient, logRequestDAL: EntityRequestStorage, logRequestIncomingLogDAL: EntityRequestIncomingEntityStorage<EthereumParsedLog>, logRequestPendingSignatureDAL: EntityRequestPendingEntityStorage, logRequestResponseDAL: EntityRequestResponseStorage<EthereumParsedLog>, blockchainId?: Blockchain, nonce?: NonceTimestamp): EthereumIndexerLogFetcher
Parameters
- fetcherMsClient: FetcherMsClient
- logRequestDAL: EntityRequestStorage
- logRequestIncomingLogDAL: EntityRequestIncomingEntityStorage<EthereumParsedLog>
- logRequestPendingSignatureDAL: EntityRequestPendingEntityStorage
- logRequestResponseDAL: EntityRequestResponseStorage<EthereumParsedLog>
- blockchainId: Blockchain = Blockchain.Ethereum
- nonce: NonceTimestamp = ...
Returns EthereumIndexerLogFetcher
Overrides BaseIndexerEntityFetcher<EthereumParsedLog>.constructor
- Defined in packages/ethereum/src/services/indexer/src/logFetcher.ts:17

Properties

`Protected` blockchainId

blockchainId: Blockchain = Blockchain.Ethereum

`Protected` checkCompletionJob

checkCompletionJob: DebouncedJob<void, unknown>

`Protected` checkPendingRetriesJob

checkPendingRetriesJob: JobRunner

`Protected` entityRequestDAL

entityRequestDAL: EntityRequestStorage

`Protected` entityRequestIncomingEntityDAL

entityRequestIncomingEntityDAL: EntityRequestIncomingEntityStorage<EthereumParsedLog>

`Protected` entityRequestPendingEntityDAL

entityRequestPendingEntityDAL: EntityRequestPendingEntityStorage

`Protected` entityRequestResponseDAL

entityRequestResponseDAL: EntityRequestResponseStorage<EthereumParsedLog>

`Protected` events

events: EventEmitter

`Protected` fetcherMsClient

fetcherMsClient: FetcherMsClient

`Protected` incomingEntities

incomingEntities: PendingWorkPool<EthereumParsedLog>

`Protected` logRequestDAL

logRequestDAL: EntityRequestStorage

`Protected` logRequestIncomingLogDAL

logRequestIncomingLogDAL: EntityRequestIncomingEntityStorage<EthereumParsedLog>

`Protected` logRequestPendingSignatureDAL

logRequestPendingSignatureDAL: EntityRequestPendingEntityStorage

`Protected` logRequestResponseDAL

logRequestResponseDAL: EntityRequestResponseStorage<EthereumParsedLog>

`Protected` nonce

nonce: NonceTimestamp = ...

`Protected` requestFutures

requestFutures: Record<number, Future<number>>

`Protected` requestMutex

requestMutex: Mutex

`Protected` toRemoveBuffer

toRemoveBuffer: BufferExec<EntityRequestPendingEntity>

`Protected` toRetryBuffer

toRetryBuffer: BufferExec<EntityRequestPendingEntity>

`Protected` type

type: IndexableEntityType

Methods

awaitRequestComplete

awaitRequestComplete(nonce: number): Promise<void>
Parameters
- nonce: number
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.awaitRequestComplete
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:44

`Protected` checkAllPendingSignatures

checkAllPendingSignatures(): Promise<void>
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.checkAllPendingSignatures
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:56

`Protected` checkAllRequestCompletion

checkAllRequestCompletion(): Promise<void>
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.checkAllRequestCompletion
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:54

`Protected` checkPendingSignatures

checkPendingSignatures(request: EntityRequest, drain?: boolean): Promise<void>
Parameters
- request: EntityRequest
- Optional drain: boolean
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.checkPendingSignatures
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:57

`Protected` checkRequestCompletion

checkRequestCompletion(request: EntityRequest): Promise<void>
Parameters
- request: EntityRequest
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.checkRequestCompletion
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:55

`Protected` drainPendingSignaturesBuffer

drainPendingSignaturesBuffer(): Promise<void>
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.drainPendingSignaturesBuffer
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:58

fetchAccountEntitiesByDate

fetchAccountEntitiesByDate(params: AccountDateRange): Promise<number>
Parameters
- params: AccountDateRange
Returns Promise<number>
Inherited from BaseIndexerEntityFetcher.fetchAccountEntitiesByDate
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:38

fetchEntitiesById

fetchEntitiesById(params: IdRange): Promise<number>
Parameters
- params: IdRange
Returns Promise<number>
Inherited from BaseIndexerEntityFetcher.fetchEntitiesById
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:37

`Protected` fetchEntityIds

fetchEntityIds(requestParams: EntityRequestParams): Promise<void | AsyncIterable<string[]> | string[][]>
Parameters
- requestParams: EntityRequestParams
Returns Promise<void | AsyncIterable<string[]> | string[][]>
Inherited from BaseIndexerEntityFetcher.fetchEntityIds
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:53

`Protected` filterIncomingEntitiesByRequest

filterIncomingEntitiesByRequest(entities: EthereumParsedLog[], request: EntityRequest): {
filteredEntities: EthereumParsedLog[];
remainingEntities: EthereumParsedLog[];
}
Parameters
- entities: EthereumParsedLog[]
- request: EntityRequest
Returns {
filteredEntities: EthereumParsedLog[];
remainingEntities: EthereumParsedLog[];
}
- filteredEntities: EthereumParsedLog[]
- remainingEntities: EthereumParsedLog[]
Overrides BaseIndexerEntityFetcher.filterIncomingEntitiesByRequest
- Defined in packages/ethereum/src/services/indexer/src/logFetcher.ts:38

`Protected` getFuture

getFuture(nonce: number): Future<number>
Parameters
- nonce: number
Returns Future<number>
Inherited from BaseIndexerEntityFetcher.getFuture
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:60

getRequests

getRequests(filters?: GetEntityPendingRequestsRequestArgs): Promise<EntityRequest[]>
Parameters
- Optional filters: GetEntityPendingRequestsRequestArgs
Returns Promise<EntityRequest[]>
Inherited from BaseIndexerEntityFetcher.getRequests
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:41

getResponse

getResponse(nonce: number): Promise<TransactionResponse<EthereumParsedLog>>
Parameters
- nonce: number
Returns Promise<TransactionResponse<EthereumParsedLog>>
Inherited from BaseIndexerEntityFetcher.getResponse
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:45

`Protected` handleEntityRequest

handleEntityRequest(requestParams: EntityRequestParams, waitForResponse?: boolean): Promise<number>
Parameters
- requestParams: EntityRequestParams
- Optional waitForResponse: boolean
Returns Promise<number>
Inherited from BaseIndexerEntityFetcher.handleEntityRequest
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:52

`Protected` handleIncomingEntities

handleIncomingEntities(works: PendingWork<EthereumParsedLog>[]): Promise<number | void>
Parameters
- works: PendingWork<EthereumParsedLog>[]
Returns Promise<number | void>
Inherited from BaseIndexerEntityFetcher.handleIncomingEntities
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:47

`Protected` handlePendingRetries

handlePendingRetries(): Promise<void>
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.handlePendingRetries
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:59

`Protected` handleRemovePendingTransactions

handleRemovePendingTransactions(pendings: EntityRequestPendingEntity[]): Promise<void>
Parameters
- pendings: EntityRequestPendingEntity[]
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.handleRemovePendingTransactions
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:63

`Protected` handleRetryPendingEntities

handleRetryPendingEntities(pendings: EntityRequestPendingEntity[]): Promise<void>
Parameters
- pendings: EntityRequestPendingEntity[]
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.handleRetryPendingEntities
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:62

isRequestComplete

isRequestComplete(nonce: number): Promise<boolean>
Parameters
- nonce: number
Returns Promise<boolean>
Inherited from BaseIndexerEntityFetcher.isRequestComplete
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:43

`Protected` log

log(...msgs: any[]): void
Parameters
- Rest ...msgs: any[]
Returns void
Inherited from BaseIndexerEntityFetcher.log
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:64

offResponse

offResponse(handler: ((nonce: number) => void)): void
Parameters
- handler: ((nonce: number) => void)
  - - (nonce: number): void
    - Parameters
      
      nonce: number
      
      Returns void
Returns void
Inherited from BaseIndexerEntityFetcher.offResponse
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:40

onEntities

onEntities(chunk: EthereumParsedLog[]): Promise<void>
Parameters
- chunk: EthereumParsedLog[]
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.onEntities
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:42

onResponse

onResponse(handler: ((nonce: number) => void)): void
Parameters
- handler: ((nonce: number) => void)
  - - (nonce: number): void
    - Parameters
      
      nonce: number
      
      Returns void
Returns void
Inherited from BaseIndexerEntityFetcher.onResponse
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:39

`Protected` resolveFuture

resolveFuture(nonce: number): void
Parameters
- nonce: number
Returns void
Inherited from BaseIndexerEntityFetcher.resolveFuture
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:61

start

start(): Promise<void>
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.start
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:35

stop

stop(): Promise<void>
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.stop
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:36

`Protected` storeIncomingEntities

storeIncomingEntities(chunk: EthereumParsedLog[]): Promise<void>
Parameters
- chunk: EthereumParsedLog[]
Returns Promise<void>
Inherited from BaseIndexerEntityFetcher.storeIncomingEntities
- Defined in packages/framework/dist/src/services/indexer/src/entityFetcher.d.ts:46

Class EthereumIndexerLogFetcher

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

fetcherMsClient: FetcherMsClient

logRequestDAL: EntityRequestStorage

logRequestIncomingLogDAL: EntityRequestIncomingEntityStorage<EthereumParsedLog>

logRequestPendingSignatureDAL: EntityRequestPendingEntityStorage

logRequestResponseDAL: EntityRequestResponseStorage<EthereumParsedLog>

blockchainId: Blockchain = Blockchain.Ethereum

nonce: NonceTimestamp = ...

Returns EthereumIndexerLogFetcher

Properties

Protected blockchainId

Protected checkCompletionJob

Protected checkPendingRetriesJob

Protected entityRequestDAL

Protected entityRequestIncomingEntityDAL

Protected entityRequestPendingEntityDAL

Protected entityRequestResponseDAL

Protected events

Protected fetcherMsClient

Protected incomingEntities

Protected logRequestDAL

Protected logRequestIncomingLogDAL

Protected logRequestPendingSignatureDAL

Protected logRequestResponseDAL

Protected nonce

Protected requestFutures

Protected requestMutex

Protected toRemoveBuffer

Protected toRetryBuffer

Protected type

Methods

awaitRequestComplete

Parameters

nonce: number

Returns Promise<void>

Protected checkAllPendingSignatures

Returns Promise<void>

Protected checkAllRequestCompletion

Returns Promise<void>

Protected checkPendingSignatures

Parameters

request: EntityRequest

Optional drain: boolean

Returns Promise<void>

Protected checkRequestCompletion

Parameters

request: EntityRequest

Returns Promise<void>

Protected drainPendingSignaturesBuffer

Returns Promise<void>

fetchAccountEntitiesByDate

Parameters

params: AccountDateRange

Returns Promise<number>

fetchEntitiesById

Parameters

params: IdRange

Returns Promise<number>

Protected fetchEntityIds

Parameters

requestParams: EntityRequestParams

Returns Promise<void | AsyncIterable<string[]> | string[][]>

Protected filterIncomingEntitiesByRequest

Parameters

entities: EthereumParsedLog[]

request: EntityRequest

Returns { filteredEntities: EthereumParsedLog[]; remainingEntities: EthereumParsedLog[]; }

filteredEntities: EthereumParsedLog[]

remainingEntities: EthereumParsedLog[]

Protected getFuture

Parameters

nonce: number

`Protected` blockchainId

`Protected` checkCompletionJob

`Protected` checkPendingRetriesJob

`Protected` entityRequestDAL

`Protected` entityRequestIncomingEntityDAL

`Protected` entityRequestPendingEntityDAL

`Protected` entityRequestResponseDAL

`Protected` events

`Protected` fetcherMsClient

`Protected` incomingEntities

`Protected` logRequestDAL

`Protected` logRequestIncomingLogDAL

`Protected` logRequestPendingSignatureDAL

`Protected` logRequestResponseDAL

`Protected` nonce

`Protected` requestFutures

`Protected` requestMutex

`Protected` toRemoveBuffer

`Protected` toRetryBuffer

`Protected` type

`Protected` checkAllPendingSignatures

`Protected` checkAllRequestCompletion

`Protected` checkPendingSignatures

`Optional` drain: boolean

`Protected` checkRequestCompletion

`Protected` drainPendingSignaturesBuffer

`Protected` fetchEntityIds

`Protected` filterIncomingEntitiesByRequest

Returns {
filteredEntities: EthereumParsedLog[];
remainingEntities: EthereumParsedLog[];
}

`Protected` getFuture

`Optional` filters: GetEntityPendingRequestsRequestArgs

`Protected` handleEntityRequest

`Optional` waitForResponse: boolean

`Protected` handleIncomingEntities

`Protected` handlePendingRetries

`Protected` handleRemovePendingTransactions

`Protected` handleRetryPendingEntities

`Protected` log

`Rest` ...msgs: any[]

`Protected` resolveFuture

`Protected` storeIncomingEntities