WIP

Author: kamilwylegala

packages/outbox-prisma-adapter/lib/outbox-prisma-adapter.ts

@@ -1,6 +1,6 @@
 import type { OutboxAccumulator, OutboxEntry } from '@message-queue-toolkit/outbox-core'
 import type { OutboxStorage } from '@message-queue-toolkit/outbox-core/dist/lib/storage'
-import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
+import { type CommonEventDefinition, getMessageType } from '@message-queue-toolkit/schemas'
 import type { PrismaClient } from '@prisma/client'
 
 export class OutboxPrismaAdapter<SupportedEvents extends CommonEventDefinition[]>
@@ -17,7 +17,7 @@ export class OutboxPrismaAdapter<SupportedEvents extends CommonEventDefinition[]
     const prismaModel: PrismaClient[typeof this.modelName] = this.prisma[this.modelName]
 
     return prismaModel.create({
-      data: outboxEntry,
+      data: getMessageType(outboxEntry.event),
     })
   }
 

packages/outbox-prisma-adapter/package.json

@@ -38,6 +38,7 @@
     "del-cli": "^5.1.0",
     "prisma": "^5.19.1",
     "typescript": "^5.5.3",
+    "uuidv7": "^1.0.2",
     "vitest": "^2.0.4",
     "zod": "^3.23.8"
   },

packages/outbox-prisma-adapter/test/outbox-prisma-adapter.spec.ts

@@ -1,12 +1,36 @@
+import type { OutboxEntry } from '@message-queue-toolkit/outbox-core'
+import {
+  type CommonEventDefinition,
+  enrichMessageSchemaWithBase,
+} from '@message-queue-toolkit/schemas'
 import { PrismaClient } from '@prisma/client'
+import { uuidv7 } from 'uuidv7'
 import { afterAll, beforeAll, describe, expect, it } from 'vitest'
+import { z } from 'zod'
+import { OutboxPrismaAdapter } from '../lib/outbox-prisma-adapter'
+
+const events = {
+  created: {
+    ...enrichMessageSchemaWithBase(
+      'entity.created',
+      z.object({
+        message: z.string(),
+      }),
+    ),
+  },
+} satisfies Record<string, CommonEventDefinition>
+
+type SupportedEvents = (typeof events)[keyof typeof events][]
 
 describe('outbox-prisma-adapter', () => {
   let prisma: PrismaClient
+  let outboxPrismaAdapter: OutboxPrismaAdapter<SupportedEvents>
 
   beforeAll(async () => {
     prisma = new PrismaClient()
 
+    outboxPrismaAdapter = new OutboxPrismaAdapter<SupportedEvents>(prisma, 'OutboxEntry')
+
     await prisma.$queryRaw`create schema if not exists prisma;`
     await prisma.$queryRaw`
       CREATE TABLE prisma.outbox_entry (
@@ -39,4 +63,20 @@ describe('outbox-prisma-adapter', () => {
       },
     ])
   })
+
+  it('creates entry in DB via outbox storage implementation', async () => {
+    await outboxPrismaAdapter.createEntry({
+      id: uuidv7(),
+      event: events.created,
+      status: 'CREATED',
+      data: {
+        id: uuidv7(),
+        payload: {
+          message: 'TEST EVENT',
+        },
+        metadata: {},
+        timestamp: new Date().toISOString(),
+      },
+    } satisfies OutboxEntry<SupportedEvents[number]>)
+  })
 })