File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
packages/outbox-prisma-adapter/lib Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -32,6 +32,7 @@ export class OutboxPrismaAdapter<
3232 ) : Promise < OutboxEntry < SupportedEvents [ number ] > > {
3333 const prismaModel = this . prisma [ this . modelName ] as unknown as ModelDelegate
3434
35+ // @ts -ignore
3536 const messageType = getMessageType ( outboxEntry . event )
3637 return prismaModel . create ( {
3738 data : {
@@ -59,7 +60,7 @@ export class OutboxPrismaAdapter<
5960 } ,
6061 } )
6162
62- await this . prisma . $transaction ( async ( prisma : { [ x : string ] : ModelDelegate } ) => {
63+ await this . prisma . $transaction ( async ( prisma ) => {
6364 const prismaModel = prisma [ this . modelName ] as ModelDelegate
6465 await this . handleSuccesses ( prismaModel , entries , existingEntries )
6566 await this . handleFailures ( prismaModel , failedEntries , existingEntries )
@@ -82,6 +83,7 @@ export class OutboxPrismaAdapter<
8283 await prismaModel . createMany ( {
8384 data : toCreate . map ( ( entry ) => ( {
8485 id : entry . id ,
86+ // @ts -ignore
8587 type : getMessageType ( entry . event ) ,
8688 created : entry . created ,
8789 updated : new Date ( ) ,
@@ -122,6 +124,7 @@ export class OutboxPrismaAdapter<
122124 await prismaModel . createMany ( {
123125 data : toCreate . map ( ( entry ) => ( {
124126 id : entry . id ,
127+ // @ts -ignore
125128 type : getMessageType ( entry . event ) ,
126129 created : entry . created ,
127130 updated : new Date ( ) ,
You can’t perform that action at this time.
0 commit comments