Skip to content

FUZD / fuzd-server / RemoteSQLExecutorStorage

Class: RemoteSQLExecutorStorage<TransactionDataType>

Type Parameters

TransactionDataType

Implements

Constructors

new RemoteSQLExecutorStorage()

new RemoteSQLExecutorStorage<TransactionDataType>(db): RemoteSQLExecutorStorage<TransactionDataType>

Parameters

db: RemoteSQL

Returns

RemoteSQLExecutorStorage<TransactionDataType>

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:140

Methods

clear()

clear(): Promise<void>

Returns

Promise<void>

Implementation of

ExecutorStorage.clear

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:290


createBroadcaster()

createBroadcaster(broadcaster): Promise<void>

Parameters

broadcaster: BroadcasterData

Returns

Promise<void>

Implementation of

ExecutorStorage.createBroadcaster

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:283


createOrUpdatePendingExecutionAndUpdateNonceIfNeeded()

createOrUpdatePendingExecutionAndUpdateNonceIfNeeded(executionToStore, asPaymentFor?): Promise<PendingExecutionStored<TransactionDataType>>

Parameters

executionToStore: PendingExecutionStored<TransactionDataType>

asPaymentFor?

asPaymentFor.account?: String0x

asPaymentFor.batchIndex?: number

asPaymentFor.chainId?: String0x

asPaymentFor.slot?: string

asPaymentFor.upToGasPrice?: bigint

Returns

Promise<PendingExecutionStored<TransactionDataType>>

Implementation of

ExecutorStorage.createOrUpdatePendingExecutionAndUpdateNonceIfNeeded

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:186


deletePendingExecution()

deletePendingExecution(params): Promise<void>

Parameters

params

params.account: String0x

params.batchIndex: number

params.chainId: String0x

params.slot: string

Returns

Promise<void>

Implementation of

ExecutorStorage.deletePendingExecution

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:173


getAllExecutions()

getAllExecutions(params): Promise<PendingExecutionStored<TransactionDataType>[]>

Parameters

params

params.limit: number

Returns

Promise<PendingExecutionStored<TransactionDataType>[]>

Implementation of

ExecutorStorage.getAllExecutions

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:250


getBroadcaster()

getBroadcaster(params): Promise<undefined | BroadcasterData>

Parameters

params

params.address: string

params.chainId: String0x

Returns

Promise<undefined | BroadcasterData>

Implementation of

ExecutorStorage.getBroadcaster

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:274


getExpectedWorstCaseGasPrice()

getExpectedWorstCaseGasPrice(chainId): Promise<ExpectedWorstCaseGasPrice>

Parameters

chainId: String0x

Returns

Promise<ExpectedWorstCaseGasPrice>

Implementation of

ExecutorStorage.getExpectedWorstCaseGasPrice

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:301


getPendingExecution()

getPendingExecution(params): Promise<undefined | PendingExecutionStored<TransactionDataType>>

Parameters

params

params.account: String0x

params.batchIndex: number

params.chainId: String0x

params.slot: string

Returns

Promise<undefined | PendingExecutionStored<TransactionDataType>>

Implementation of

ExecutorStorage.getPendingExecution

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:142


getPendingExecutionBatch()

getPendingExecutionBatch(params): Promise<undefined | PendingExecutionStored<TransactionDataType>[]>

Parameters

params

params.account: String0x

params.chainId: String0x

params.slot: string

Returns

Promise<undefined | PendingExecutionStored<TransactionDataType>[]>

Implementation of

ExecutorStorage.getPendingExecutionBatch

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:160


getPendingExecutions()

getPendingExecutions(params): Promise<PendingExecutionStored<TransactionDataType>[]>

Parameters

params

params.limit: number

Returns

Promise<PendingExecutionStored<TransactionDataType>[]>

Implementation of

ExecutorStorage.getPendingExecutions

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:242


getPendingExecutionsPerBroadcaster()

getPendingExecutionsPerBroadcaster(broadcasterData, params): Promise<PendingExecutionStored<TransactionDataType>[]>

Parameters

broadcasterData

broadcasterData.broadcaster: String0x

broadcasterData.chainId: String0x

params

params.limit: number

Returns

Promise<PendingExecutionStored<TransactionDataType>[]>

Implementation of

ExecutorStorage.getPendingExecutionsPerBroadcaster

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:258


setup()

setup(): Promise<void>

Returns

Promise<void>

Implementation of

ExecutorStorage.setup

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:296


updateExpectedWorstCaseGasPrice()

updateExpectedWorstCaseGasPrice(chainId, timestamp, newGasPrice): Promise<ExpectedWorstCaseGasPrice>

Parameters

chainId: String0x

timestamp: number

newGasPrice: bigint

Returns

Promise<ExpectedWorstCaseGasPrice>

Implementation of

ExecutorStorage.updateExpectedWorstCaseGasPrice

Defined in

packages/server/src/storage/RemoteSQLExecutorStorage.ts:311