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<
32
32
) : Promise < OutboxEntry < SupportedEvents [ number ] > > {
33
33
const prismaModel = this . prisma [ this . modelName ] as unknown as ModelDelegate
34
34
35
+ // @ts -ignore
35
36
const messageType = getMessageType ( outboxEntry . event )
36
37
return prismaModel . create ( {
37
38
data : {
@@ -59,7 +60,7 @@ export class OutboxPrismaAdapter<
59
60
} ,
60
61
} )
61
62
62
- await this . prisma . $transaction ( async ( prisma : { [ x : string ] : ModelDelegate } ) => {
63
+ await this . prisma . $transaction ( async ( prisma ) => {
63
64
const prismaModel = prisma [ this . modelName ] as ModelDelegate
64
65
await this . handleSuccesses ( prismaModel , entries , existingEntries )
65
66
await this . handleFailures ( prismaModel , failedEntries , existingEntries )
@@ -82,6 +83,7 @@ export class OutboxPrismaAdapter<
82
83
await prismaModel . createMany ( {
83
84
data : toCreate . map ( ( entry ) => ( {
84
85
id : entry . id ,
86
+ // @ts -ignore
85
87
type : getMessageType ( entry . event ) ,
86
88
created : entry . created ,
87
89
updated : new Date ( ) ,
@@ -122,6 +124,7 @@ export class OutboxPrismaAdapter<
122
124
await prismaModel . createMany ( {
123
125
data : toCreate . map ( ( entry ) => ( {
124
126
id : entry . id ,
127
+ // @ts -ignore
125
128
type : getMessageType ( entry . event ) ,
126
129
created : entry . created ,
127
130
updated : new Date ( ) ,
You can’t perform that action at this time.
0 commit comments