Fixed tests to new version of outbox entry.

Author: kamilwylegala

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

@@ -3,7 +3,7 @@ import type {
   OutboxEntry,
   OutboxStorage,
 } from '@message-queue-toolkit/outbox-core'
-import { type CommonEventDefinition, getMessageType } from '@message-queue-toolkit/schemas'
+import type { CommonEventDefinition } from '@message-queue-toolkit/schemas'
 import type { PrismaClient } from '@prisma/client'
 
 type ModelDelegate = {
@@ -33,14 +33,13 @@ export class OutboxPrismaAdapter<
     const prismaModel = this.prisma[this.modelName] as unknown as ModelDelegate
 
     // @ts-ignore
-    const messageType = getMessageType(outboxEntry.event)
     return prismaModel.create({
       data: {
         id: outboxEntry.id,
-        type: messageType,
+        type: outboxEntry.event.type,
         created: outboxEntry.created,
         updated: outboxEntry.updated,
-        data: outboxEntry.data,
+        event: outboxEntry.event,
         status: outboxEntry.status,
         retryCount: outboxEntry.retryCount,
       },
@@ -84,10 +83,10 @@ export class OutboxPrismaAdapter<
         data: toCreate.map((entry) => ({
           id: entry.id,
           // @ts-ignore
-          type: getMessageType(entry.event),
+          type: entry.event.type,
           created: entry.created,
           updated: new Date(),
-          data: entry.data,
+          event: entry.event,
           status: 'SUCCESS',
         })),
       })
@@ -124,11 +123,10 @@ export class OutboxPrismaAdapter<
       await prismaModel.createMany({
         data: toCreate.map((entry) => ({
           id: entry.id,
-          // @ts-ignore
-          type: getMessageType(entry.event),
+          type: entry.event.type,
           created: entry.created,
           updated: new Date(),
-          data: entry.data,
+          event: entry.event,
           status: 'FAILED',
           retryCount: 1,
         })),

packages/outbox-prisma-adapter/prisma/schema.prisma

@@ -9,7 +9,7 @@ model OutboxEntry {
   updated    DateTime @default(now()) @updatedAt
   type       String
   retryCount Int      @default(0) @map("retry_count")
-  data       Json
+  event      Json
   status     String
 
   @@map("outbox_entry")

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

@@ -28,29 +28,29 @@ describe('outbox-prisma-adapter', () => {
 
   const ENTRY_1 = {
     id: uuidv7(),
-    event: events.created,
     status: 'CREATED',
-    data: {
+    event: {
       id: uuidv7(),
       payload: {
         message: 'TEST EVENT',
       },
       metadata: {},
       timestamp: new Date().toISOString(),
+      type: 'entity.created',
     },
     retryCount: 0,
     created: new Date(),
   } satisfies OutboxEntry<SupportedEvents[number]>
 
   const ENTRY_2 = {
     id: uuidv7(),
-    event: events.created,
     status: 'CREATED',
-    data: {
+    event: {
       id: uuidv7(),
       payload: {
         message: 'TEST EVENT 2',
       },
+      type: 'entity.created',
       metadata: {},
       timestamp: new Date().toISOString(),
     },
@@ -76,7 +76,7 @@ describe('outbox-prisma-adapter', () => {
         created TIMESTAMP NOT NULL,
         updated TIMESTAMP,
         retry_count INT NOT NULL DEFAULT 0,
-        data JSONB NOT NULL,
+        event JSONB NOT NULL,
         status TEXT NOT NULL
       )
     `
@@ -95,13 +95,13 @@ 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: {
+      event: {
         id: uuidv7(),
         payload: {
           message: 'TEST EVENT',
         },
+        type: 'entity.created',
         metadata: {},
         timestamp: new Date().toISOString(),
       },
@@ -118,11 +118,12 @@ describe('outbox-prisma-adapter', () => {
         created: expect.any(Date),
         updated: expect.any(Date),
         retryCount: 0,
-        data: {
+        event: {
           id: expect.any(String),
           payload: {
             message: 'TEST EVENT',
           },
+          type: 'entity.created',
           metadata: {},
           timestamp: expect.any(String),
         },