DocsReference@proto-kit/persistanceClassesPrismaTransactionStorage

@proto-kit/persistanceDocs


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