Class EthereumAccountTransactionHistoryFetcher

Handles the fetching and processing of signatures on an account.

Hierarchy

BaseHistoryFetcher<EthereumAccountTransactionHistoryPaginationCursor>
- EthereumAccountTransactionHistoryFetcher

Constructors

constructor

new EthereumAccountTransactionHistoryFetcher(account: string, fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountTransactionHistoryPaginationCursor>, ethereumClient: EthereumClient, blockHistoryFetcher: EthereumBlockHistoryFetcher, blockchainId?: Blockchain, times?: number): EthereumAccountTransactionHistoryFetcher
Initializes the signature fetcher.
Parameters
- account: string
  
  The account account to fetch related signatures for.
- fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountTransactionHistoryPaginationCursor>
  
  The fetcher state storage.
- ethereumClient: EthereumClient
  
  The Solana RPC client.
- blockHistoryFetcher: EthereumBlockHistoryFetcher
- blockchainId: Blockchain = Blockchain.Ethereum
- times: number = 1
Returns EthereumAccountTransactionHistoryFetcher
Overrides BaseHistoryFetcher<EthereumAccountTransactionHistoryPaginationCursor>.constructor
- Defined in packages/ethereum/src/services/fetcher/src/transaction/accountTransactionHistoryFetcher.ts:33

Properties

`Protected` account

account: string

The account account to fetch related signatures for.

`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<EthereumAccountTransactionHistoryPaginationCursor>

`Protected` fetcherStateDAL

fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountTransactionHistoryPaginationCursor>

The fetcher state storage.

`Protected` forwardJob

forwardJob: undefined | JobRunner

`Protected` options

options: BaseFetcherOptions<EthereumAccountTransactionHistoryPaginationCursor>

`Protected` previousBackwardBlockCursor

previousBackwardBlockCursor: number = Number.MAX_SAFE_INTEGER

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

`Protected` areThereNewBlocks

areThereNewBlocks(): Promise<boolean>
Returns Promise<boolean>
- Defined in packages/ethereum/src/services/fetcher/src/transaction/accountTransactionHistoryFetcher.ts:219

`Protected` checkCompleteBackward

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

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` fetchBackward

fetchBackward(__namedParameters: {
firstRun: boolean;
interval: number;
}): Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountTransactionHistoryPaginationCursor>>
Parameters
- __namedParameters: {
  firstRun: boolean;
  interval: number;
  }
  - firstRun: boolean
  - interval: number
Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountTransactionHistoryPaginationCursor>>
- Defined in packages/ethereum/src/services/fetcher/src/transaction/accountTransactionHistoryFetcher.ts:106

`Protected` fetchForward

fetchForward(): Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountTransactionHistoryPaginationCursor>>
Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountTransactionHistoryPaginationCursor>>
- Defined in packages/ethereum/src/services/fetcher/src/transaction/accountTransactionHistoryFetcher.ts:83

`Protected` fetchTransactionHistory

fetchTransactionHistory(options: EthereumFetchSignaturesOptions, goingForward: boolean): Promise<{
    count: number;
    error?: Error;
    lastCursors: BaseFetcherPaginationCursors<EthereumAccountTransactionHistoryPaginationCursor>;
}>
Parameters
- options: EthereumFetchSignaturesOptions
- goingForward: boolean
Returns Promise<{
    count: number;
    error?: Error;
    lastCursors: BaseFetcherPaginationCursors<EthereumAccountTransactionHistoryPaginationCursor>;
}>
- Defined in packages/ethereum/src/services/fetcher/src/transaction/accountTransactionHistoryFetcher.ts:144

`Protected` getFetcherState

getFetcherState(): Promise<BaseFetcherState<EthereumAccountTransactionHistoryPaginationCursor>>
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<EthereumAccountTransactionHistoryPaginationCursor>>
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/transaction/accountTransactionHistoryFetcher.ts:228

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/transaction/accountTransactionHistoryFetcher.ts:69

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<EthereumAccountTransactionHistoryPaginationCursor>>
Returns Promise<BaseFetcherState<EthereumAccountTransactionHistoryPaginationCursor>>
Inherited from BaseHistoryFetcher.getState
- Defined in packages/framework/dist/src/services/fetcher/src/baseHistoryFetcher.d.ts:23

`Protected` indexSignatures

indexSignatures(signatures: EthereumAccountTransactionHistoryStorageEntity[], goingForward: boolean): Promise<void>
Parameters
- signatures: EthereumAccountTransactionHistoryStorageEntity[]
- goingForward: boolean
Returns Promise<void>
- Defined in packages/ethereum/src/services/fetcher/src/transaction/accountTransactionHistoryFetcher.ts:210

init

init(): Promise<void>
Returns Promise<void>
Overrides BaseHistoryFetcher.init
- Defined in packages/ethereum/src/services/fetcher/src/transaction/accountTransactionHistoryFetcher.ts:64

`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 EthereumAccountTransactionHistoryFetcher

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

account: string

fetcherStateDAL: FetcherStateLevelStorage<EthereumAccountTransactionHistoryPaginationCursor>

ethereumClient: EthereumClient

blockHistoryFetcher: EthereumBlockHistoryFetcher

blockchainId: Blockchain = Blockchain.Ethereum

times: number = 1

Returns EthereumAccountTransactionHistoryFetcher

Properties

Protected account

Protected backwardJob

Protected blockHistoryFetcher

Protected blockchainId

Protected ethereumClient

Protected fetcherState

Protected fetcherStateDAL

Protected forwardJob

Protected options

Protected previousBackwardBlockCursor

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<EthereumAccountTransactionHistoryPaginationCursor>; prevCursors?: BaseFetcherPaginationCursors<EthereumAccountTransactionHistoryPaginationCursor>; }

lastCursors: BaseFetcherPaginationCursors<EthereumAccountTransactionHistoryPaginationCursor>

Optional prevCursors?: BaseFetcherPaginationCursors<EthereumAccountTransactionHistoryPaginationCursor>

Returns Promise<FetcherJobRunnerUpdateCursorResult<EthereumAccountTransactionHistoryPaginationCursor>>

Protected areThereNewBlocks

Returns Promise<boolean>

Protected checkCompleteBackward

Parameters

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

Optional error?: Error

fetcherState: BaseFetcherState<EthereumAccountTransactionHistoryPaginationCursor>

jobState: BaseFetcherJobState

newItems: boolean

Returns Promise<boolean>

complete

Parameters

fetcherType: "forward" | "backward"

Returns Promise<void>

Protected fetchBackward

Parameters

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

firstRun: boolean

interval: number

Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountTransactionHistoryPaginationCursor>>

Protected fetchForward

Returns Promise<FetcherJobRunnerHandleFetchResult<EthereumAccountTransactionHistoryPaginationCursor>>

Protected fetchTransactionHistory

Parameters

options: EthereumFetchSignaturesOptions

goingForward: boolean

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

Protected getFetcherState

Returns Promise<BaseFetcherState<EthereumAccountTransactionHistoryPaginationCursor>>

`Protected` account

`Protected` backwardJob

`Protected` blockHistoryFetcher

`Protected` blockchainId

`Protected` ethereumClient

`Protected` fetcherState

`Protected` fetcherStateDAL

`Protected` forwardJob

`Protected` options

`Protected` previousBackwardBlockCursor

`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<EthereumAccountTransactionHistoryPaginationCursor>;
prevCursors?: BaseFetcherPaginationCursors<EthereumAccountTransactionHistoryPaginationCursor>;
}

`Optional` prevCursors?: BaseFetcherPaginationCursors<EthereumAccountTransactionHistoryPaginationCursor>

`Protected` areThereNewBlocks

`Protected` checkCompleteBackward

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

`Optional` error?: Error

`Protected` fetchBackward

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

`Protected` fetchForward

`Protected` fetchTransactionHistory

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

`Protected` getFetcherState

`Protected` getLastBackwardBlockHeight

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

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

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

`Protected` indexSignatures

`Protected` initJobsFrequencyState

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

`Protected` saveFetcherState