@proto-kit/persistance • Docs
Documentation / @proto-kit/persistance / PrismaMessageStorage
Class: PrismaMessageStorage
Interface to store Messages previously fetched by a IncomingMessageadapter
Implements
Constructors
new PrismaMessageStorage()
new PrismaMessageStorage(
connection,transactionMapper):PrismaMessageStorage
Parameters
• connection: PrismaConnection
• transactionMapper: TransactionMapper
Returns
Defined in
packages/persistance/src/services/prisma/PrismaMessageStorage.ts:10
Methods
getMessageBatches()
getMessageBatches(
fromMessagesHash,toMessagesHash):Promise<object[]>
Parameters
• fromMessagesHash: string
• toMessagesHash: string
Returns
Promise<object[]>
Implementation of
MessageStorage.getMessageBatches
Defined in
packages/persistance/src/services/prisma/PrismaMessageStorage.ts:15
getNextMessagesBatch()
getNextMessagesBatch(
fromMessageHash):Promise<undefined|object>
Parameters
• fromMessageHash: string
Returns
Promise<undefined | object>
Implementation of
MessageStorage.getNextMessagesBatch
Defined in
packages/persistance/src/services/prisma/PrismaMessageStorage.ts:42
pushMessages()
pushMessages(
fromMessageHash,toMessageHash,messages):Promise<void>
Parameters
• fromMessageHash: string
• toMessageHash: string
• messages: PendingTransaction[]
Returns
Promise<void>
Implementation of
Defined in
packages/persistance/src/services/prisma/PrismaMessageStorage.ts:84