FUZD / fuzd-server / RemoteSQLExecutorStorage

Class: RemoteSQLExecutorStorage<TransactionDataType>

Type Parameters

• TransactionDataType

Implements

• ExecutorStorage<TransactionDataType>

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?

account

String0x

batchIndex

number

chainId

String0x

slot

string

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

account

String0x

batchIndex

number

chainId

String0x

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

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

address

string

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

account

String0x

batchIndex

number

chainId

String0x

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

account

String0x

chainId

String0x

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

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

broadcaster

String0x

chainId

String0x

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