feat: /adapter/prisma

Author: tonyfromundefined

.changeset/fruity-bikes-care.md

@@ -0,0 +1,5 @@
+---
+"ventyd": minor
+---
+
+feat: prisma adapter (undocumented)

package.json

@@ -37,6 +37,11 @@
       "types": "./dist/arktype.d.ts",
       "import": "./dist/arktype.js",
       "require": "./dist/arktype.cjs"
+    },
+    "./adapter/prisma": {
+      "types": "./dist/adapter/prisma.d.ts",
+      "import": "./dist/adapter/prisma.js",
+      "require": "./dist/adapter/prisma.cjs"
     }
   },
   "main": "./dist/index.js",

src/adapter/prisma.ts

@@ -0,0 +1,113 @@
+import type {
+  Adapter,
+  BaseEventType,
+  InferEventFromSchema,
+  InferStateFromSchema,
+} from "../types";
+
+type BaseEventTypeRow = Omit<BaseEventType, "eventCreatedAt" | "body"> & {
+  eventCreatedAt: Date;
+  body: unknown;
+};
+
+export type VentydAdapterOptions<
+  $$Schema,
+  $$PrismaEventRow extends BaseEventTypeRow,
+  $$PrismaEventRowInput,
+  $$PrismaSnapshotRowInput,
+> = {
+  prisma: {
+    $transaction: (commands: unknown[]) => Promise<unknown[]>;
+  };
+  tables: {
+    event: {
+      findMany(args?: {
+        where: { entityName: string; entityId: string };
+      }): Promise<$$PrismaEventRow[]>;
+      createMany(args?: { data: $$PrismaEventRowInput[] }): Promise<unknown>;
+    };
+    snapshot: {
+      upsert(args: {
+        where: { id?: string };
+        update: $$PrismaSnapshotRowInput;
+        create: $$PrismaSnapshotRowInput;
+      }): Promise<unknown>;
+    };
+  };
+  entityToRow(args: {
+    entityId: string;
+    state: InferStateFromSchema<$$Schema>;
+  }): $$PrismaSnapshotRowInput;
+};
+
+export default function prismaAdapter<
+  $$Schema,
+  $$PrismaEventRow extends BaseEventTypeRow,
+  $$PrismaEventRowInput,
+  $$PrismaSnapshotRowInput,
+>(
+  options: VentydAdapterOptions<
+    $$Schema,
+    $$PrismaEventRow,
+    $$PrismaEventRowInput,
+    $$PrismaSnapshotRowInput
+  >,
+): Adapter<$$Schema> {
+  function eventToRow(_event: InferEventFromSchema<$$Schema>) {
+    const event = _event as BaseEventType;
+
+    const row = {
+      eventId: event.eventId,
+      eventName: event.eventName,
+      entityId: event.entityId,
+      entityName: event.entityName,
+      eventCreatedAt: new Date(event.eventCreatedAt),
+      body: event.body,
+    } as $$PrismaEventRowInput;
+
+    return row;
+  }
+
+  function rowToEvent(row: $$PrismaEventRow) {
+    const event = {
+      eventId: row.eventId,
+      eventName: row.eventName,
+      entityId: row.entityId,
+      entityName: row.entityName,
+      eventCreatedAt: row.eventCreatedAt.toISOString(),
+      body: row.body,
+    } as InferEventFromSchema<$$Schema>;
+
+    return event;
+  }
+
+  return {
+    async getEventsByEntityId({ entityName, entityId }) {
+      const rows = await options.tables.event.findMany({
+        where: {
+          entityName,
+          entityId,
+        },
+      });
+
+      return rows.map(rowToEvent);
+    },
+    async commitEvents({ events, entityId, state }) {
+      const snapshotRow = options.entityToRow({
+        entityId,
+        state,
+      });
+
+      await options.prisma.$transaction([
+        options.tables.event.createMany({
+          data: events.map(eventToRow),
+        }),
+        options.tables.snapshot.upsert({
+          where: { id: entityId },
+          update: snapshotRow,
+          create: snapshotRow,
+        }),
+      ]);
+    },
+  };
+}

tsconfig.json

@@ -29,5 +29,6 @@
     "module": "ESNext",
     "moduleResolution": "Bundler",
     "types": ["vitest/globals"]
-  }
+  },
+  "exclude": ["dist"]
 }