Class EthereumLogHistoryFetcher

Hierarchy

BaseEntityHistoryFetcher<EthereumAccountLogHistoryPaginationCursor, EthereumAccountLogHistoryEntity>
- EthereumLogHistoryFetcher

Constructors

constructor

new EthereumLogHistoryFetcher(ethereumClient: EthereumClient, fetcherStateDAL: FetcherStateLevelStorage<any>, blockHistoryFetcher: EthereumBlockHistoryFetcher, rawLogDAL: EthereumRawLogStorage, fetcherClient: FetcherMsClient, accountDAL: PendingAccountStorage, accountLogHistoryDAL: EthereumAccountLogHistoryStorage, blockchainId?: Blockchain): EthereumLogHistoryFetcher
Initialize the fetcher service.
Parameters
- ethereumClient: EthereumClient
  
  The ethereum mainnet public RPC client to use.
- fetcherStateDAL: FetcherStateLevelStorage<any>
  
  The fetcher state storage.
- blockHistoryFetcher: EthereumBlockHistoryFetcher
- rawLogDAL: EthereumRawLogStorage
- fetcherClient: FetcherMsClient
- accountDAL: PendingAccountStorage
- accountLogHistoryDAL: EthereumAccountLogHistoryStorage
- blockchainId: Blockchain = Blockchain.Ethereum
Returns EthereumLogHistoryFetcher
Overrides BaseEntityHistoryFetcher< EthereumAccountLogHistoryPaginationCursor, EthereumAccountLogHistoryEntity >.constructor
- Defined in packages/ethereum/src/services/fetcher/src/log/logHistoryFetcher.ts:32

Properties

`Protected` accountDAL

accountDAL: PendingAccountStorage

`Protected` accountEntityHistoryDAL

accountEntityHistoryDAL: AccountEntityHistoryStorage<EthereumAccountLogHistoryStorageEntity>

`Protected` accountLogHistoryDAL

accountLogHistoryDAL: EthereumAccountLogHistoryStorage

`Protected` blockHistoryFetcher

blockHistoryFetcher: EthereumBlockHistoryFetcher

`Protected` blockchainId

blockchainId: Blockchain = Blockchain.Ethereum

`Protected` ethereumClient

ethereumClient: EthereumClient

The ethereum mainnet public RPC client to use.

`Protected` fetcherClient

fetcherClient: FetcherMsClient

`Protected` fetcherStateDAL

fetcherStateDAL: FetcherStateLevelStorage<any>

The fetcher state storage.

`Protected` id

id: string

`Protected` pendingAccounts

pendingAccounts: FetcherPool<string[]>

`Protected` rawLogDAL

rawLogDAL: EthereumRawLogStorage

`Protected` type

type: IndexableEntityType

Methods

addAccount

addAccount(args: AddAccountEntityRequestArgs): Promise<void>
Assigns to a fetcher instance an account owned by the specific program and initializes it.
Parameters
- args: AddAccountEntityRequestArgs
  
  Account address to asign to the fetcher instance,
Returns Promise<void>
Inherited from BaseEntityHistoryFetcher.addAccount
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:34

delAccount

delAccount(args: DelAccountEntityRequestArgs): Promise<void>
Stops the fetching process of that instance of the fetcher for that account.
Parameters
- args: DelAccountEntityRequestArgs
Returns Promise<void>
Inherited from BaseEntityHistoryFetcher.delAccount
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:39

fetchAccountEntitiesByDate

fetchAccountEntitiesByDate(args: FetchAccountEntitiesByDateRequestArgs): Promise<void | AsyncIterable<string[]>>
Parameters
- args: FetchAccountEntitiesByDateRequestArgs
Returns Promise<void | AsyncIterable<string[]>>
Inherited from BaseEntityHistoryFetcher.fetchAccountEntitiesByDate
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:41

`Protected` fetchAccountEntitiesByIdFromDateRange

fetchAccountEntitiesByIdFromDateRange(ids: string[], byDateArgs: FetchAccountEntitiesByDateRequestArgs): Promise<void>
Parameters
- ids: string[]
- byDateArgs: FetchAccountEntitiesByDateRequestArgs
Returns Promise<void>
Inherited from BaseEntityHistoryFetcher.fetchAccountEntitiesByIdFromDateRange
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:42

`Protected` getAccountFetcher

getAccountFetcher(account: string): EthereumAccountLogHistoryFetcher
Parameters
- account: string
Returns EthereumAccountLogHistoryFetcher
Overrides BaseEntityHistoryFetcher.getAccountFetcher
- Defined in packages/ethereum/src/services/fetcher/src/log/logHistoryFetcher.ts:78

getAccountState

getAccountState(args: GetAccountEntityStateRequestArgs): Promise<undefined | EthereumAccountLogHistoryState>
Returns the state of the transaction fetch process of a given account.
Parameters
- args: GetAccountEntityStateRequestArgs
  
  The account address to get its fetch status.
Returns Promise<undefined | EthereumAccountLogHistoryState>
Overrides BaseEntityHistoryFetcher.getAccountState
- Defined in packages/ethereum/src/services/fetcher/src/log/logHistoryFetcher.ts:55

`Protected` getPartialAccountState

getPartialAccountState(args: GetAccountEntityStateRequestArgs): Promise<undefined | AccountEntityHistoryState<EthereumAccountLogHistoryPaginationCursor>>
Parameters
- args: GetAccountEntityStateRequestArgs
Returns Promise<undefined | AccountEntityHistoryState<EthereumAccountLogHistoryPaginationCursor>>
Inherited from BaseEntityHistoryFetcher.getPartialAccountState
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:43

getState

getState(): Promise<AccountEntityHistoryFetcherState>
Returns Promise<AccountEntityHistoryFetcherState>
Inherited from BaseEntityHistoryFetcher.getState
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:40

`Protected` queryEntitiesByDate

queryEntitiesByDate(args: FetchAccountEntitiesByDateRequestArgs): Promise<StorageStream<string, EthereumAccountLogHistoryStorageEntity>>
Parameters
- args: FetchAccountEntitiesByDateRequestArgs
Returns Promise<StorageStream<string, EthereumAccountLogHistoryStorageEntity>>
Inherited from BaseEntityHistoryFetcher.queryEntitiesByDate
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:44

start

start(): Promise<void>
Returns Promise<void>
Inherited from BaseEntityHistoryFetcher.start
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:27

stop

stop(): Promise<void>
Returns Promise<void>
Inherited from BaseEntityHistoryFetcher.stop
- Defined in packages/framework/dist/src/services/fetcher/src/entityHistoryFetcher.d.ts:28

Class EthereumLogHistoryFetcher

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

ethereumClient: EthereumClient

fetcherStateDAL: FetcherStateLevelStorage<any>

blockHistoryFetcher: EthereumBlockHistoryFetcher

rawLogDAL: EthereumRawLogStorage

fetcherClient: FetcherMsClient

accountDAL: PendingAccountStorage

accountLogHistoryDAL: EthereumAccountLogHistoryStorage

blockchainId: Blockchain = Blockchain.Ethereum

Returns EthereumLogHistoryFetcher

Properties

Protected accountDAL

Protected accountEntityHistoryDAL

Protected accountLogHistoryDAL

Protected blockHistoryFetcher

Protected blockchainId

Protected ethereumClient

Protected fetcherClient

Protected fetcherStateDAL

Protected id

Protected pendingAccounts

Protected rawLogDAL

Protected type

Methods

addAccount

Parameters

args: AddAccountEntityRequestArgs

Returns Promise<void>

delAccount

Parameters

args: DelAccountEntityRequestArgs

Returns Promise<void>

fetchAccountEntitiesByDate

Parameters

args: FetchAccountEntitiesByDateRequestArgs

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

Protected fetchAccountEntitiesByIdFromDateRange

Parameters

ids: string[]

byDateArgs: FetchAccountEntitiesByDateRequestArgs

Returns Promise<void>

Protected getAccountFetcher

Parameters

account: string

Returns EthereumAccountLogHistoryFetcher

getAccountState

Parameters

args: GetAccountEntityStateRequestArgs

Returns Promise<undefined | EthereumAccountLogHistoryState>

Protected getPartialAccountState

Parameters

args: GetAccountEntityStateRequestArgs

Returns Promise<undefined | AccountEntityHistoryState<EthereumAccountLogHistoryPaginationCursor>>

getState

Returns Promise<AccountEntityHistoryFetcherState>

Protected queryEntitiesByDate

Parameters

args: FetchAccountEntitiesByDateRequestArgs

Returns Promise<StorageStream<string, EthereumAccountLogHistoryStorageEntity>>

start

Returns Promise<void>

stop

Returns Promise<void>

Settings

Member Visibility

Theme

`Protected` accountDAL

`Protected` accountEntityHistoryDAL

`Protected` accountLogHistoryDAL

`Protected` blockHistoryFetcher

`Protected` blockchainId

`Protected` ethereumClient

`Protected` fetcherClient

`Protected` fetcherStateDAL

`Protected` id

`Protected` pendingAccounts

`Protected` rawLogDAL

`Protected` type

`Protected` fetchAccountEntitiesByIdFromDateRange

`Protected` getAccountFetcher

`Protected` getPartialAccountState

`Protected` queryEntitiesByDate