@proto-kit/persistance • Docs


Documentation / @proto-kit/persistance / PrismaTransactionStorage

Class: PrismaTransactionStorage

Implements

Constructors

new PrismaTransactionStorage()

new PrismaTransactionStorage(connection, transactionMapper, tracer): PrismaTransactionStorage

Parameters

• connection: PrismaConnection

• transactionMapper: TransactionMapper

• tracer: Tracer

Returns

PrismaTransactionStorage

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:16

Properties

tracer

readonly tracer: Tracer

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:19

Methods

countPendingUserTransactions()

countPendingUserTransactions(): Promise<number>

Returns

Promise<number>

Implementation of

TransactionStorage.countPendingUserTransactions

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:52


findTransaction()

findTransaction(hash): Promise<undefined | object>

Finds a transaction by its hash. It returns both pending transaction and already included transactions In case the transaction has been included, it also returns the block hash and batch number where applicable.

Parameters

• hash: string

Returns

Promise<undefined | object>

Implementation of

TransactionStorage.findTransaction

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:111


getPendingUserTransactions()

getPendingUserTransactions(offset, limit?): Promise<PendingTransaction[]>

Parameters

• offset: number

• limit?: number

Returns

Promise<PendingTransaction[]>

Implementation of

TransactionStorage.getPendingUserTransactions

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:23


pushUserTransaction()

pushUserTransaction(tx, priority): Promise<boolean>

Parameters

• tx: PendingTransaction

• priority: number

Returns

Promise<boolean>

Implementation of

TransactionStorage.pushUserTransaction

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:86


removeTx()

removeTx(hashes, type): Promise<void>

Parameters

• hashes: string[]

• type: "included" | "dropped"

Returns

Promise<void>

Implementation of

TransactionStorage.removeTx

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:70


reportChangedPaths()

reportChangedPaths(paths): Promise<void>

Parameters

• paths: bigint[]

Returns

Promise<void>

Implementation of

TransactionStorage.reportChangedPaths

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:166


reportSkippedTransactions()

reportSkippedTransactions(paths): Promise<void>

Mapping hash => path[]

Parameters

• paths: Record<string, bigint[]>

Returns

Promise<void>

Implementation of

TransactionStorage.reportSkippedTransactions

Defined in

packages/persistance/src/services/prisma/PrismaTransactionStorage.ts:153