added drizzle kit

Author: matthew-sessions

packages/cloudflare/src/database.ts

@@ -12,11 +12,7 @@ import { PgDrizzle, make as makePgDrizzle } from "@effect/sql-drizzle/Pg"
 import * as Reactivity from "@effect/experimental/Reactivity"
 import * as SqlClient from "@effect/sql/SqlClient"
 
-/**
- * Default database URL for local development.
- */
-export const LOCAL_DATABASE_URL =
-  "postgres://postgres:postgres@localhost:5432/effect_worker"
+
 
 /**
  * Creates a scoped PgDrizzle instance for request-scoped database access.

packages/cloudflare/src/index.ts

@@ -32,6 +32,5 @@ export { CloudflareBindingsError, DatabaseConnectionError } from "./errors"
 // Database utilities
 export {
   makeDrizzle,
-  LOCAL_DATABASE_URL,
   PgDrizzle
 } from "./database"

packages/db/drizzle.config.ts

@@ -0,0 +1,10 @@
+import { defineConfig } from "drizzle-kit"
+
+export default defineConfig({
+  schema: "./src/schema.ts",
+  out: "./drizzle",
+  dialect: "postgresql",
+  dbCredentials: {
+    url: process.env.DATABASE_URL ?? ""
+  }
+})

packages/db/package.json

@@ -3,7 +3,7 @@
   "version": "0.0.0",
   "type": "module",
   "license": "MIT",
-  "description": "Database schema for Effect Worker",
+  "description": "Database schema and queries for Effect Worker",
   "main": "./dist/index.js",
   "types": "./dist/index.d.ts",
   "exports": {
@@ -20,9 +20,19 @@
     "build": "tsc -p tsconfig.build.json",
     "check": "tsc --noEmit",
     "test": "vitest",
-    "clean": "rm -rf dist"
+    "clean": "rm -rf dist",
+    "db:push": "drizzle-kit push",
+    "db:studio": "drizzle-kit studio",
+    "db:generate": "drizzle-kit generate",
+    "db:migrate": "drizzle-kit migrate"
   },
   "dependencies": {
-    "drizzle-orm": "^0.45.0"
+    "drizzle-orm": "^0.45.0",
+    "effect": "latest",
+    "@effect/sql-drizzle": "latest",
+    "@backpine/domain": "workspace:*"
+  },
+  "devDependencies": {
+    "drizzle-kit": "^0.31.8"
   }
 }

packages/db/src/index.ts

@@ -1,10 +1,16 @@
 /**
  * @backpine/db
  *
- * Database schema for Effect Worker.
+ * Database schema and queries for Effect Worker.
  *
- * This package contains Drizzle ORM schema definitions shared across all apps.
+ * This package contains Drizzle ORM schema definitions and
+ * reusable Effect query programs shared across all apps.
  *
  * @module
  */
-export { users, type User, type NewUser } from "./schema"
+
+// Schema exports
+export { users, type User as DbUser, type NewUser } from "./schema"
+
+// Query exports
+export * from "./queries"

packages/db/src/queries/index.ts

@@ -0,0 +1,6 @@
+/**
+ * Query Exports
+ *
+ * @module
+ */
+export * as UserQueries from "./users"

packages/db/src/queries/users.ts

@@ -0,0 +1,120 @@
+/**
+ * User Queries
+ *
+ * Reusable Effect programs for user database operations.
+ *
+ * @module
+ */
+import { DateTime, Effect } from "effect"
+import { PgDrizzle } from "@effect/sql-drizzle/Pg"
+import { eq } from "drizzle-orm"
+
+import { users } from "../schema"
+import type { UserId, Email, User, CreateUser } from "@backpine/domain"
+import { UserNotFoundError, UserCreationError } from "@backpine/domain"
+
+// ============================================================================
+// Internal Helpers
+// ============================================================================
+
+/** Convert database ID to branded UserId */
+const toUserId = (id: number): UserId => `usr_${id}` as UserId
+
+/** Parse UserId to database ID, returns null if invalid format */
+const parseUserId = (id: UserId): number | null => {
+  const match = id.match(/^usr_(\d+)$/)
+  return match ? parseInt(match[1]!, 10) : null
+}
+
+/** Map database row to domain User */
+const toDomainUser = (row: typeof users.$inferSelect): User => ({
+  id: toUserId(row.id),
+  email: row.email as Email,
+  name: row.name,
+  createdAt: DateTime.unsafeFromDate(row.createdAt)
+})
+
+// ============================================================================
+// Query Programs
+// ============================================================================
+
+/**
+ * Find all users.
+ *
+ * @returns Effect that yields array of domain Users
+ */
+export const findAllUsers: Effect.Effect<
+  User[],
+  never,
+  PgDrizzle
+> = Effect.gen(function* () {
+  const drizzle = yield* PgDrizzle
+  const rows = yield* drizzle
+    .select()
+    .from(users)
+    .pipe(Effect.orElseSucceed(() => []))
+
+  return rows.map(toDomainUser)
+})
+
+/**
+ * Find user by ID.
+ *
+ * @param id - Branded UserId
+ * @returns Effect that yields User or fails with UserNotFoundError
+ */
+export const findUserById = (
+  id: UserId
+): Effect.Effect<User, UserNotFoundError, PgDrizzle> =>
+  Effect.gen(function* () {
+    const dbId = parseUserId(id)
+
+    if (dbId === null) {
+      return yield* Effect.fail(
+        new UserNotFoundError({ id, message: `Invalid user ID format: ${id}` })
+      )
+    }
+
+    const drizzle = yield* PgDrizzle
+    const rows = yield* drizzle
+      .select()
+      .from(users)
+      .where(eq(users.id, dbId))
+      .pipe(Effect.orElseSucceed(() => []))
+
+    const row = rows[0]
+
+    if (!row) {
+      return yield* Effect.fail(
+        new UserNotFoundError({ id, message: `User not found: ${id}` })
+      )
+    }
+
+    return toDomainUser(row)
+  })
+
+/**
+ * Create a new user.
+ *
+ * @param data - CreateUser payload (email, name)
+ * @returns Effect that yields created User or fails with UserCreationError
+ */
+export const createUser = (
+  data: CreateUser
+): Effect.Effect<User, UserCreationError, PgDrizzle> =>
+  Effect.gen(function* () {
+    const drizzle = yield* PgDrizzle
+    const rows = yield* drizzle
+      .insert(users)
+      .values({ email: data.email, name: data.name })
+      .returning()
+      .pipe(Effect.mapError(() => new UserCreationError(data)))
+
+    const row = rows[0]
+
+    if (!row) {
+      return yield* Effect.fail(new UserCreationError(data))
+    }
+
+    return toDomainUser(row)
+  })