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

Methods

clear()

clear(): Promise<void>

Returns

Promise<void>

Implementation of

ExecutorStorage.clear

Defined in

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

---

createBroadcaster()

createBroadcaster(broadcaster): Promise<void>

Parameters

broadcaster

BroadcasterData

Returns

Promise<void>

Implementation of

ExecutorStorage.createBroadcaster

Defined in

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

---

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

slot

string

upToGasPrice

bigint

Returns

Promise<PendingExecutionStored<TransactionDataType>>

Implementation of

ExecutorStorage.createOrUpdatePendingExecution

Defined in

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

---

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

---

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

---

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

---

getChainConfiguration()

getChainConfiguration(chainId): Promise<ChainConfiguration>

Parameters

chainId

IntegerString

Returns

Promise<ChainConfiguration>

Implementation of

ExecutorStorage.getChainConfiguration

Defined in

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

---

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

---

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

---

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

---

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

---

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

---

setup()

setup(): Promise<void>

Returns

Promise<void>

Implementation of

ExecutorStorage.setup

Defined in

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

---

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

---

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

---

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