Class EthereumAccountLogHistoryFetcher

Handles the fetching and processing of signatures on an account.

Hierarchy

BaseHistoryFetcher<EthereumAccountLogHistoryPaginationCursor>
- EthereumAccountLogHistoryFetcher

Constructors

constructor

new EthereumAccountLogHistoryFetcher(account: string, accountLogHistoryDAL: EthereumAccountLogHistoryStorage, rawLogDAL: EthereumRawLogStorage, fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountLogHistoryPaginationCursor>, ethereumClient: EthereumClient, blockHistoryFetcher: EthereumBlockHistoryFetcher, blockchainId?: Blockchain, times?: number): EthereumAccountLogHistoryFetcher
Initializes the signature fetcher.
Parameters
- account: string
  
  The account account to fetch related signatures for.
- accountLogHistoryDAL: EthereumAccountLogHistoryStorage
- rawLogDAL: EthereumRawLogStorage
- fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountLogHistoryPaginationCursor>
  
  The fetcher state storage.
- ethereumClient: EthereumClient
  
  The Solana RPC client.
- blockHistoryFetcher: EthereumBlockHistoryFetcher
- blockchainId: Blockchain = Blockchain.Ethereum
- times: number = 1
Returns EthereumAccountLogHistoryFetcher
Overrides BaseHistoryFetcher<EthereumAccountLogHistoryPaginationCursor>.constructor
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:37

Properties

`Protected` account

account: string

The account account to fetch related signatures for.

`Protected` accountLogHistoryDAL

accountLogHistoryDAL: EthereumAccountLogHistoryStorage

`Protected` backwardJob

backwardJob: undefined | JobRunner

`Protected` blockHistoryFetcher

blockHistoryFetcher: EthereumBlockHistoryFetcher

`Protected` blockchainId

blockchainId: Blockchain = Blockchain.Ethereum

`Protected` ethereumClient

ethereumClient: EthereumClient

The Solana RPC client.

`Protected` fetcherState

fetcherState: BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>

`Protected` fetcherStateDAL

fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountLogHistoryPaginationCursor>

The fetcher state storage.

`Protected` forwardJob

forwardJob: undefined | JobRunner

`Protected` isContract

isContract: boolean = false

`Protected` iterationLimit

iterationLimit: number = 100

`Protected` options

options: BaseFetcherOptions<EthereumAccountLogHistoryPaginationCursor>

`Protected` pageLimit

pageLimit: number = 10

`Protected` rawLogDAL

rawLogDAL: EthereumRawLogStorage

`Protected` times

times: number = 1

Methods

`Protected` _checkComplete

_checkComplete(type: "forward" | "backward", ctx: {
    error?: Error;
    jobState: BaseFetcherJobState;
    newItems: boolean;
}): Promise<boolean>
Parameters
- type: "forward" | "backward"
- ctx: {
      error?: Error;
      jobState: BaseFetcherJobState;
      newItems: boolean;
  }
  - Optional error?: Error
  - jobState: BaseFetcherJobState
  - newItems: boolean
Returns Promise<boolean>
Inherited from BaseHistoryFetcher._checkComplete
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:47

`Protected` _runJob

_runJob(fetcherType: "forward" | "backward", ctx: {
firstRun: boolean;
interval: number;
}): Promise<number>
Parameters
- fetcherType: "forward" | "backward"
- ctx: {
  firstRun: boolean;
  interval: number;
  }
  - firstRun: boolean
  - interval: number
Returns Promise<number>
Inherited from BaseHistoryFetcher._runJob
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:39

`Protected` _updateCursors

_updateCursors(type: "forward" | "backward", ctx: {
lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
prevCursors?: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
}): Promise<FetcherJobRunnerUpdateCursorResult<EthereumAccountLogHistoryPaginationCursor>>
Parameters
- type: "forward" | "backward"
- ctx: {
  lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
  prevCursors?: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
  }
  - lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>
  - Optional prevCursors?: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>
Returns Promise<FetcherJobRunnerUpdateCursorResult<EthereumAccountLogHistoryPaginationCursor>>
Inherited from BaseHistoryFetcher._updateCursors
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:43

`Protected` checkCompleteBackward

checkCompleteBackward(ctx: {
    error?: Error;
    fetcherState: BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>;
    jobState: BaseFetcherJobState;
    newItems: boolean;
}): Promise<boolean>
Parameters
- ctx: {
      error?: Error;
      fetcherState: BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>;
      jobState: BaseFetcherJobState;
      newItems: boolean;
  }
  - Optional error?: Error
  - fetcherState: BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>
  - jobState: BaseFetcherJobState
  - newItems: boolean
Returns Promise<boolean>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:194

complete

complete(fetcherType: "forward" | "backward"): Promise<void>
Parameters
- fetcherType: "forward" | "backward"
Returns Promise<void>
Inherited from BaseHistoryFetcher.complete
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:24

`Protected` continueFetchingBackward

continueFetchingBackward(): Promise<boolean>
Returns Promise<boolean>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:229

`Protected` fetchBackward

fetchBackward(__namedParameters: {
firstRun: boolean;
interval: number;
}): Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountLogHistoryPaginationCursor>>
Parameters
- __namedParameters: {
  firstRun: boolean;
  interval: number;
  }
  - firstRun: boolean
  - interval: number
Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountLogHistoryPaginationCursor>>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:112

`Protected` fetchForward

fetchForward(): Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountLogHistoryPaginationCursor>>
Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountLogHistoryPaginationCursor>>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:88

`Protected` fetchLogs

fetchLogs(options: EthereumFetchLogsOptions, goingForward: boolean): Promise<{
    count: number;
    error?: Error;
    lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
}>
Parameters
- options: EthereumFetchLogsOptions
- goingForward: boolean
Returns Promise<{
    count: number;
    error?: Error;
    lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
}>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:149

`Protected` getFetcherState

getFetcherState(): Promise<BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>>
Initialises the fetcherState class property of the Fetcher instance, could get the data from the data access layer when the fetching progress is restarted.

Returns Promise<BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>>
Inherited from BaseHistoryFetcher.getFetcherState
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:33

getId

getId(): string
Returns string
Inherited from BaseHistoryFetcher.getId
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:19

`Protected` getLastBackwardBlockHeight

getLastBackwardBlockHeight(): Promise<number>
Returns Promise<number>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:235

`Protected` getLastBackwardLogHeight

getLastBackwardLogHeight(): Promise<number>
Returns Promise<number>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:240

getLastRun

getLastRun(fetcherType?: "forward" | "backward"): Promise<number>
Parameters
- Optional fetcherType: "forward" | "backward"
Returns Promise<number>
Inherited from BaseHistoryFetcher.getLastRun
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:26

getNextRun

getNextRun(fetcherType?: "forward" | "backward"): Promise<number>
Parameters
- Optional fetcherType: "forward" | "backward"
Returns Promise<number>
Overrides BaseHistoryFetcher.getNextRun
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:75

getPendingRuns

getPendingRuns(fetcherType?: "forward" | "backward"): Promise<number>
Parameters
- Optional fetcherType: "forward" | "backward"
Returns Promise<number>
Inherited from BaseHistoryFetcher.getPendingRuns
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:28

getState

getState(): Promise<BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>>
Returns Promise<BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>>
Inherited from BaseHistoryFetcher.getState
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:23

`Protected` indexLogs

indexLogs(logs: EthereumRawLog[], goingForward: boolean): Promise<void>
Parameters
- logs: EthereumRawLog[]
- goingForward: boolean
Returns Promise<void>
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:213

init

init(): Promise<void>
Returns Promise<void>
Overrides BaseHistoryFetcher.init
- Defined in packages/ethereum/src/services/fetcher/src/log/accountLogHistoryFetcher.ts:70

`Protected` initJobsFrequencyState

initJobsFrequencyState(jobType: "forward" | "backward"): void
Parameters
- jobType: "forward" | "backward"
Returns void
Inherited from BaseHistoryFetcher.initJobsFrequencyState
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:34

isComplete

isComplete(fetcherType?: "forward" | "backward"): Promise<boolean>
Parameters
- Optional fetcherType: "forward" | "backward"
Returns Promise<boolean>
Inherited from BaseHistoryFetcher.isComplete
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:25

run

run(): Promise<unknown>
Returns Promise<unknown>
Inherited from BaseHistoryFetcher.run
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:21

`Protected` saveFetcherState

saveFetcherState(): Promise<void>
Saves the fetcher state in the data access layer.

Returns Promise<void>
Inherited from BaseHistoryFetcher.saveFetcherState
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:38

stop

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

Class EthereumAccountLogHistoryFetcher

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

account: string

accountLogHistoryDAL: EthereumAccountLogHistoryStorage

rawLogDAL: EthereumRawLogStorage

fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountLogHistoryPaginationCursor>

ethereumClient: EthereumClient

blockHistoryFetcher: EthereumBlockHistoryFetcher

blockchainId: Blockchain = Blockchain.Ethereum

times: number = 1

Returns EthereumAccountLogHistoryFetcher

Properties

Protected account

Protected accountLogHistoryDAL

Protected backwardJob

Protected blockHistoryFetcher

Protected blockchainId

Protected ethereumClient

Protected fetcherState

Protected fetcherStateDAL

Protected forwardJob

Protected isContract

Protected iterationLimit

Protected options

Protected pageLimit

Protected rawLogDAL

Protected times

Methods

Protected _checkComplete

Parameters

type: "forward" | "backward"

ctx: { error?: Error; jobState: BaseFetcherJobState; newItems: boolean; }

Optional error?: Error

jobState: BaseFetcherJobState

newItems: boolean

Returns Promise<boolean>

Protected _runJob

Parameters

fetcherType: "forward" | "backward"

ctx: { firstRun: boolean; interval: number; }

firstRun: boolean

interval: number

Returns Promise<number>

Protected _updateCursors

Parameters

type: "forward" | "backward"

ctx: { lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>; prevCursors?: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>; }

lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>

Optional prevCursors?: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>

Returns Promise<FetcherJobRunnerUpdateCursorResult<EthereumAccountLogHistoryPaginationCursor>>

Protected checkCompleteBackward

Parameters

ctx: { error?: Error; fetcherState: BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>; jobState: BaseFetcherJobState; newItems: boolean; }

Optional error?: Error

fetcherState: BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>

jobState: BaseFetcherJobState

newItems: boolean

Returns Promise<boolean>

complete

Parameters

fetcherType: "forward" | "backward"

Returns Promise<void>

Protected continueFetchingBackward

Returns Promise<boolean>

Protected fetchBackward

Parameters

__namedParameters: { firstRun: boolean; interval: number; }

firstRun: boolean

interval: number

Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountLogHistoryPaginationCursor>>

Protected fetchForward

Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountLogHistoryPaginationCursor>>

Protected fetchLogs

`Protected` account

`Protected` accountLogHistoryDAL

`Protected` backwardJob

`Protected` blockHistoryFetcher

`Protected` blockchainId

`Protected` ethereumClient

`Protected` fetcherState

`Protected` fetcherStateDAL

`Protected` forwardJob

`Protected` isContract

`Protected` iterationLimit

`Protected` options

`Protected` pageLimit

`Protected` rawLogDAL

`Protected` times

`Protected` _checkComplete

ctx: {
error?: Error;
jobState: BaseFetcherJobState;
newItems: boolean;
}

`Optional` error?: Error

`Protected` _runJob

ctx: {
firstRun: boolean;
interval: number;
}

`Protected` _updateCursors

ctx: {
lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
prevCursors?: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
}

`Optional` prevCursors?: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>

`Protected` checkCompleteBackward

ctx: {
error?: Error;
fetcherState: BaseFetcherState<EthereumAccountLogHistoryPaginationCursor>;
jobState: BaseFetcherJobState;
newItems: boolean;
}

`Optional` error?: Error

`Protected` continueFetchingBackward

`Protected` fetchBackward

__namedParameters: {
firstRun: boolean;
interval: number;
}

`Protected` fetchForward

`Protected` fetchLogs

Returns Promise<{
count: number;
error?: Error;
lastCursors: BaseFetcherPaginationCursors<EthereumAccountLogHistoryPaginationCursor>;
}>

`Protected` getFetcherState

`Protected` getLastBackwardBlockHeight

`Protected` getLastBackwardLogHeight

`Optional` fetcherType: "forward" | "backward"

`Optional` fetcherType: "forward" | "backward"

`Optional` fetcherType: "forward" | "backward"

`Protected` indexLogs

`Protected` initJobsFrequencyState

`Optional` fetcherType: "forward" | "backward"

`Protected` saveFetcherState