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:175

Methods

clear()

clear(): Promise<void>

Returns

Promise<void>

Implementation of

ExecutorStorage.clear

Defined in

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

---

createBroadcaster()

createBroadcaster(broadcaster): Promise<void>

Parameters

broadcaster

BroadcasterData

Returns

Promise<void>

Implementation of

ExecutorStorage.createBroadcaster

Defined in

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

---

createOrUpdatePendingExecution()

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

Parameters

executionToStore

PendingExecutionStored<TransactionDataType>

__namedParameters

debtOffset

bigint

updateNonceIfNeeded

{ broadcaster: String0x; lock: string; }

updateNonceIfNeeded.broadcaster

String0x

updateNonceIfNeeded.lock

string

asPaymentFor?

account

String0x

batchIndex

number

chainId

IntegerString

helpedForUpToGasPrice

{ upToGasPrice: bigint; valueSent: bigint; }

helpedForUpToGasPrice.upToGasPrice

bigint

helpedForUpToGasPrice.valueSent

bigint

slot

string

Returns

Promise<PendingExecutionStored<TransactionDataType>>

Implementation of

ExecutorStorage.createOrUpdatePendingExecution

Defined in

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

---

deleteFinalizedPendingExecutions()

deleteFinalizedPendingExecutions(params): Promise<void>

Parameters

params

chainId

IntegerString

upTo

number

Returns

Promise<void>

Implementation of

ExecutorStorage.deleteFinalizedPendingExecutions

Defined in

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

---

deletePendingExecution()

deletePendingExecution(params): Promise<void>

Parameters

params

account

String0x

batchIndex

number

chainId

IntegerString

slot

string

Returns

Promise<void>

Implementation of

ExecutorStorage.deletePendingExecution

Defined in

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

---

getAllExecutions()

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

Parameters

params

limit

number

order

"ASC" | "DESC"

Returns

Promise<PendingExecutionStored<TransactionDataType>[]>

Implementation of

ExecutorStorage.getAllExecutions

Defined in

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

---

getBroadcaster()

getBroadcaster(params): Promise<undefined | BroadcasterData>

Parameters

params

address

string

chainId

IntegerString

Returns

Promise<undefined | BroadcasterData>

Implementation of

ExecutorStorage.getBroadcaster

Defined in

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

---

getChainConfiguration()

getChainConfiguration(chainId): Promise<ChainConfiguration>

Parameters

chainId

IntegerString

Returns

Promise<ChainConfiguration>

Implementation of

ExecutorStorage.getChainConfiguration

Defined in

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

---

getPendingExecution()

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

Parameters

params

account

String0x

batchIndex

number

chainId

IntegerString

slot

string

Returns

Promise<undefined | PendingExecutionStored<TransactionDataType>>

Implementation of

ExecutorStorage.getPendingExecution

Defined in

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

---

getPendingExecutionBatch()

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

Parameters

params

account

String0x

chainId

IntegerString

slot

string

Returns

Promise<undefined | PendingExecutionStored<TransactionDataType>[]>

Implementation of

ExecutorStorage.getPendingExecutionBatch

Defined in

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

---

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:405

---

getPendingExecutionsPerBroadcaster()

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

Parameters

broadcasterData

broadcaster

String0x

chainId

IntegerString

params

limit

number

Returns

Promise<PendingExecutionStored<TransactionDataType>[]>

Implementation of

ExecutorStorage.getPendingExecutionsPerBroadcaster

Defined in

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

---

lockBroadcaster()

lockBroadcaster(params): Promise<undefined | BroadcasterDataWithLock>

Parameters

params

address

string

chainId

IntegerString

nonceFromNetwork

number

Returns

Promise<undefined | BroadcasterDataWithLock>

Implementation of

ExecutorStorage.lockBroadcaster

Defined in

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

---

setup()

setup(): Promise<void>

Returns

Promise<void>

Implementation of

ExecutorStorage.setup

Defined in

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

---

unlockBroadcaster()

unlockBroadcaster(params): Promise<void>

Parameters

params

address

string

chainId

IntegerString

Returns

Promise<void>

Implementation of

ExecutorStorage.unlockBroadcaster

Defined in

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

---

updateExpectedWorstCaseGasPrice()

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

Parameters

chainId

IntegerString

timestamp

number

newGasPrice

bigint

Returns

Promise<ChainConfiguration>

Implementation of

ExecutorStorage.updateExpectedWorstCaseGasPrice

Defined in

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

---

updateFees()

updateFees(chainId, timestamp, newFees): Promise<ChainConfiguration>

Parameters

chainId

IntegerString

timestamp

number

newFees

Fees

Returns

Promise<ChainConfiguration>

Implementation of

ExecutorStorage.updateFees

Defined in

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