Feat: database

.gitignore

@@ -23,6 +23,9 @@ dev-dist
 # vscode
 .vscode/settings.json
 
+# zed
+.zed/settings.json
+
 # mise
 mise.local.toml
 .mise.local.toml

packages/database/drizzle.config.ts

@@ -0,0 +1,14 @@
+import { defineConfig } from "drizzle-kit";
+
+export default defineConfig({
+  casing: "snake_case",
+  dbCredentials: {
+    url: "file:database.sqlite",
+  },
+  dialect: "sqlite",
+  migrations: {
+    prefix: "timestamp",
+  },
+  out: "./src/migrations",
+  schema: "./src/schemas",
+});

packages/database/package.json

@@ -0,0 +1,27 @@
+{
+  "dependencies": {
+    "drizzle-orm": "^0.44.6",
+    "kysely": "0.28.11",
+    "kysely-d1": "0.4.0"
+  },
+  "devDependencies": {
+    "@types/pg": "8.16.0",
+    "drizzle-kit": "0.31.8"
+  },
+  "exports": {
+    ".": "./src/index.ts",
+    "./client": "./src/client.ts"
+  },
+  "name": "@roppoh/database",
+  "peerDependencies": {
+    "@types/better-sqlite3": "7.6.13",
+    "better-sqlite3": "12.6.2",
+    "typescript": "^5.0.0"
+  },
+  "private": true,
+  "scripts": {
+    "check:type": "tsc --noEmit",
+    "generate:migration": "drizzle-kit generate --config='./drizzle.config.ts'"
+  },
+  "type": "module"
+}

packages/database/src/client.ts

@@ -0,0 +1,34 @@
+import type { Database as SqliteDatabase } from "better-sqlite3";
+import type { Kyselify } from "drizzle-orm/kysely";
+import { Kysely, SqliteDialect } from "kysely";
+import { D1Dialect } from "kysely-d1";
+import type { member, organization } from "./schemas";
+
+export interface Database {
+  organization: Kyselify<typeof organization>;
+  member: Kyselify<typeof member>;
+}
+
+export type DatabaseClient = Kysely<Database>;
+
+export const createDatabaseClient = (
+  args:
+    | {
+        type: "d1";
+        database: ConstructorParameters<typeof D1Dialect>[0]["database"];
+      }
+    | { type: "sqlite"; database: SqliteDatabase },
+): DatabaseClient => {
+  switch (args.type) {
+    case "d1": {
+      return new Kysely<Database>({
+        dialect: new D1Dialect({ database: args.database }),
+      });
+    }
+    case "sqlite": {
+      return new Kysely<Database>({
+        dialect: new SqliteDialect({ database: args.database }),
+      });
+    }
+  }
+};

packages/database/src/index.ts

@@ -0,0 +1 @@
+export * from "./schemas";

packages/database/src/schemas/index.ts

@@ -0,0 +1,2 @@
+export * from "./member";
+export * from "./organization";

packages/database/src/schemas/member.ts

@@ -0,0 +1,28 @@
+/** biome-ignore-all assist/source/useSortedKeys: for reachability */
+import { relations } from "drizzle-orm";
+import { index, integer, sqliteTable, text } from "drizzle-orm/sqlite-core";
+import { organization } from "./organization";
+
+export const member = sqliteTable(
+  "member",
+  {
+    id: text("id").primaryKey(),
+    organizationId: text("organization_id")
+      .notNull()
+      .references(() => organization.id, { onDelete: "cascade" }),
+    role: text("role").default("member").notNull(),
+    userId: text("user_id").notNull(),
+    createdAt: integer("created_at", { mode: "timestamp_ms" }).notNull(),
+  },
+  (table) => [
+    index("member_organizationId_idx").on(table.organizationId),
+    index("member_userId_idx").on(table.userId),
+  ],
+);
+
+export const memberRelation = relations(member, ({ one }) => ({
+  organization: one(organization, {
+    fields: [member.organizationId],
+    references: [organization.id],
+  }),
+}));

packages/database/src/schemas/organization.ts

@@ -0,0 +1,26 @@
+/** biome-ignore-all assist/source/useSortedKeys: for reachability */
+import { relations, sql } from "drizzle-orm";
+import {
+  integer,
+  sqliteTable,
+  text,
+  uniqueIndex,
+} from "drizzle-orm/sqlite-core";
+import { member } from "./member";
+
+export const organization = sqliteTable(
+  "organization",
+  {
+    id: text("id").primaryKey(),
+    slug: text("slug").notNull().unique(),
+    name: text("name").notNull(),
+    createdAt: integer("created_at", { mode: "timestamp" })
+      .default(sql`now()`)
+      .notNull(),
+  },
+  (table) => [uniqueIndex("organization_slug_uidx").on(table.slug)],
+);
+
+export const organizationRelation = relations(organization, ({ many }) => ({
+  members: many(member),
+}));

packages/database/tsconfig.json

@@ -0,0 +1,9 @@
+{
+  "compilerOptions": {
+    "baseUrl": ".",
+    "rootDir": "."
+  },
+  "exclude": [],
+  "extends": "../../tsconfig.json",
+  "include": ["src", "./*.ts"]
+}

packages/database/turbo.json

@@ -0,0 +1,14 @@
+{
+  "$schema": "https://turborepo.com/schema.json",
+  "extends": ["//"],
+  "tasks": {
+    "check:type": {
+      "inputs": [
+        "src",
+        "$TURBO_ROOT$/tsconfig.json",
+        "./*.ts",
+        "./tsconfig.json"
+      ]
+    }
+  }
+}