add db implemetation

Author: adityachoudhari26

apps/event-queue/package.json

@@ -20,6 +20,7 @@
     "zod": "catalog:"
   },
   "devDependencies": {
+    "@ctrlplane/db": "workspace:*",
     "@ctrlplane/eslint-config": "workspace:^",
     "@ctrlplane/prettier-config": "workspace:^",
     "@ctrlplane/tsconfig": "workspace:*",

apps/event-queue/src/repository/db-resource-repository.ts

@@ -0,0 +1,65 @@
+import type { Tx } from "@ctrlplane/db";
+
+import { and, eq, takeFirst, takeFirstOrNull } from "@ctrlplane/db";
+import { db } from "@ctrlplane/db/client";
+import * as schema from "@ctrlplane/db/schema";
+
+import type { Repository } from "./repository.js";
+
+export class DbResourceRepository implements Repository<schema.Resource> {
+  private readonly db: Tx;
+  private readonly workspaceId: string;
+  constructor(workspaceId: string, tx?: Tx) {
+    this.db = tx ?? db;
+    this.workspaceId = workspaceId;
+  }
+
+  async get(id: string) {
+    return this.db
+      .select()
+      .from(schema.resource)
+      .where(
+        and(
+          eq(schema.resource.id, id),
+          eq(schema.resource.workspaceId, this.workspaceId),
+        ),
+      )
+      .then(takeFirstOrNull);
+  }
+  async getAll() {
+    return this.db
+      .select()
+      .from(schema.resource)
+      .where(eq(schema.resource.workspaceId, this.workspaceId));
+  }
+  async create(entity: schema.Resource) {
+    return this.db
+      .insert(schema.resource)
+      .values({ ...entity, workspaceId: this.workspaceId })
+      .returning()
+      .then(takeFirst);
+  }
+  async update(entity: schema.Resource) {
+    return this.db
+      .update(schema.resource)
+      .set(entity)
+      .where(eq(schema.resource.id, entity.id))
+      .returning()
+      .then(takeFirst);
+  }
+  async delete(id: string) {
+    return this.db
+      .delete(schema.resource)
+      .where(eq(schema.resource.id, id))
+      .returning()
+      .then(takeFirstOrNull);
+  }
+  async exists(id: string) {
+    return this.db
+      .select()
+      .from(schema.resource)
+      .where(eq(schema.resource.id, id))
+      .then(takeFirstOrNull)
+      .then((r) => r != null);
+  }
+}

apps/event-queue/src/repository.ts …event-queue/src/repository/repository.tsapps/event-queue/src/repository.ts renamed to apps/event-queue/src/repository/repository.ts apps/event-queue/src/repository.ts renamed to apps/event-queue/src/repository/repository.ts

@@ -1,12 +1,12 @@
 type Entity = { id: string };
 
-interface Repository<T extends Entity> {
-  get(id: string): T | null;
-  getAll(): T[];
-  create(entity: T): T;
-  update(entity: T): T;
-  delete(id: string): T | null;
-  exists(id: string): boolean;
+export interface Repository<T extends Entity> {
+  get(id: string): Promise<T | null> | T | null;
+  getAll(): Promise<T[]> | T[];
+  create(entity: T): Promise<T> | T;
+  update(entity: T): Promise<T> | T;
+  delete(id: string): Promise<T | null> | T | null;
+  exists(id: string): Promise<boolean> | boolean;
 }
 
 export class RepositoryWithID<T extends Entity> implements Repository<T> {