WIP prisma adapter.

Author: kamilwylegala

packages/outbox-prisma-adapter/docker-compose.yml

@@ -0,0 +1,10 @@
+services:
+
+    postgres:
+        image: postgres:16.2
+        environment:
+            POSTGRES_USER: prisma
+            POSTGRES_PASSWORD: prisma
+            POSTGRES_DB: prisma
+        ports:
+            - 5432:5432

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

@@ -0,0 +1,26 @@
+import { PrismaClient } from '@prisma/client'
+import { beforeAll, describe, it } from 'vitest'
+
+describe('outbox-prisma-adapter', () => {
+  let prisma: PrismaClient
+
+  beforeAll(async () => {
+    prisma = new PrismaClient()
+
+    await prisma.$queryRaw`
+      CREATE TABLE prisma.outbox_entry (id UUID PRIMARY KEY, created TIMESTAMP NOT NULL)`
+  })
+
+  it('created outbox entry', async () => {
+    const result = await prisma.$queryRaw`SELECT 1 as counter;`
+
+    console.log(result)
+
+    await prisma.outboxEntry.create({
+      data: {
+        id: 'ce08b43b-6162-4913-86ea-fa9367875e3b',
+        created: new Date(),
+      },
+    })
+  })
+})

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

@@ -1,14 +1,24 @@
 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 { PrismaClient } from '@prisma/client'
 
 export class OutboxPrismaAdapter<SupportedEvents extends CommonEventDefinition[]>
   implements OutboxStorage<SupportedEvents>
 {
+  constructor(
+    private readonly prisma: PrismaClient,
+    private readonly modelName: string,
+  ) {}
+
   createEntry(
     outboxEntry: OutboxEntry<SupportedEvents[number]>,
   ): Promise<OutboxEntry<SupportedEvents[number]>> {
-    return Promise.resolve(undefined)
+    const prismaModel: PrismaClient[typeof this.modelName] = this.prisma[this.modelName]
+
+    return prismaModel.create({
+      data: outboxEntry,
+    })
   }
 
   flush(outboxAccumulator: OutboxAccumulator<SupportedEvents>): Promise<void> {

packages/outbox-prisma-adapter/package.json

@@ -24,18 +24,19 @@
     "docker:stop:dev": "docker compose down",
     "prepublishOnly": "npm run build:release"
   },
-  "dependencies": {},
   "peerDependencies": {
     "@message-queue-toolkit/core": ">=14.0.0",
+    "@message-queue-toolkit/outbox-core": ">=0.1.0",
     "@message-queue-toolkit/schemas": ">=4.0.0",
-    "@message-queue-toolkit/outbox-core": ">=0.1.0"
+    "@prisma/client": "^5.19.1"
   },
   "devDependencies": {
     "@biomejs/biome": "1.8.3",
     "@kibertoad/biome-config": "^1.2.1",
     "@types/node": "^22.0.0",
     "@vitest/coverage-v8": "^2.0.4",
     "del-cli": "^5.1.0",
+    "prisma": "^5.19.1",
     "typescript": "^5.5.3",
     "vitest": "^2.0.4",
     "zod": "^3.23.8"
@@ -56,5 +57,9 @@
     "outbox",
     "pattern"
   ],
-  "files": ["README.md", "LICENSE", "dist/*"]
+  "files": [
+    "README.md",
+    "LICENSE",
+    "dist/*"
+  ]
 }

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

@@ -0,0 +1,15 @@
+datasource db {
+  provider = "postgresql"
+  url      = "postgresql://prisma:prisma@localhost:5432/prisma?schema=testdb"
+}
+
+model OutboxEntry {
+  id      String   @id @default(uuid()) @db.Uuid
+  created DateTime @default(now())
+
+  @@map("outbox_entry")
+}
+
+generator client {
+  provider = "prisma-client-js"
+}