feat: separate db package

Author: ochmanski

apps/api/package.json

@@ -33,12 +33,7 @@
     "dev": "TZ=UTC wrangler dev --test-scheduled",
     "dev:remote": "wrangler dev --remote",
     "deploy": "wrangler deploy --minify",
-    "dev:turso": "TZ=UTC turso dev --db-file ./src/db/local-db",
     "dev:stripe": "stripe listen --load-from-webhooks-api --forward-to localhost:8787/stripe/webhooks",
-    "migrate": "drizzle-kit migrate",
-    "migrate:push": "drizzle-kit push",
-    "migrate:generate": "drizzle-kit generate",
-    "studio": "drizzle-kit studio",
     "lint": "eslint . --max-warnings 0",
     "lint:fix": "eslint . --max-warnings 0 --fix",
     "format": "prettier --write .",
@@ -48,11 +43,9 @@
     "@anthropic-ai/sdk": "0.55.1",
     "@asyncstatus/dayjs": "workspace:*",
     "@asyncstatus/email": "workspace:*",
+    "@asyncstatus/db": "workspace:*",
     "@asyncstatus/typed-handlers": "workspace:*",
-    "@gitbeaker/rest": "43.4.0",
     "@hono-rate-limiter/cloudflare": "0.2.2",
-    "@langchain/textsplitters": "0.1.0",
-    "@libsql/client": "0.15.10",
     "@linear/sdk": "^28.0.0",
     "@noble/ed25519": "2.3.0",
     "@octokit/auth-oauth-user": "6.0.0",
@@ -62,14 +55,12 @@
     "@slack/web-api": "7.9.3",
     "ai": "4.3.18",
     "better-auth": "catalog:",
-    "drizzle-orm": "0.44.3",
-    "drizzle-zod": "0.8.2",
+    "drizzle-orm": "catalog:",
     "hono": "catalog:",
     "hono-rate-limiter": "0.4.2",
     "jose": "6.0.12",
     "nanoid": "catalog:",
     "octokit": "5.0.3",
-    "random-words": "2.0.1",
     "resend": "4.7.0",
     "stripe": "^17.3.1",
     "voyageai": "0.0.4",
@@ -80,7 +71,6 @@
     "@cloudflare/workers-types": "catalog:",
     "@octokit/openapi-webhooks-types": "12.0.3",
     "@types/bun": "catalog:",
-    "drizzle-kit": "0.31.4",
     "wrangler": "catalog:"
   }
 }

apps/api/src/durable-objects/discord-gateway.ts

@@ -1,7 +1,7 @@
 import { DurableObject } from "cloudflare:workers";
+import * as schema from "@asyncstatus/db";
+import { createDb } from "@asyncstatus/db/create-db";
 import { eq } from "drizzle-orm";
-import * as schema from "../db";
-import { createDb } from "../db/db";
 import type { Bindings } from "../lib/env";
 
 // Discord Gateway API constants

apps/api/src/errors/index.ts

@@ -9,11 +9,6 @@ import type { SlackEvent } from "@slack/web-api";
 import { Hono } from "hono";
 import { cors } from "hono/cors";
 import type { ContentfulStatusCode } from "hono/utils/http-status";
-import {
-  AsyncStatusApiError,
-  type AsyncStatusApiJsonError,
-  AsyncStatusUnexpectedApiError,
-} from "./errors";
 import { createContext, type HonoEnv } from "./lib/env";
 import { verifySlackRequest } from "./lib/slack";
 import { handleStripeWebhook } from "./lib/stripe-webhook";
@@ -405,17 +400,7 @@ const app = new Hono<HonoEnv>()
         ] as ContentfulStatusCode,
       );
     }
-    if (err instanceof AsyncStatusUnexpectedApiError) {
-      return c.json({ type: err.name, message: err.message }, err.status);
-    }
-    if (err instanceof AsyncStatusApiError) {
-      return c.json({ type: err.name, message: err.message }, err.status);
-    }
-    const error = {
-      type: "ASAPIUnexpectedError",
-      message: "An unexpected error occurred. Please try again later.",
-    } satisfies AsyncStatusApiJsonError;
-    return c.json(error, 500);
+    return c.json({ message: "Unknown error", code: "INTERNAL_SERVER_ERROR", cause: err }, 500);
   });
 
 const typedHandlersApp = typedHandlersHonoServer(

apps/api/src/index.ts

@@ -1,12 +1,12 @@
+import * as schema from "@asyncstatus/db";
+import type { Db } from "@asyncstatus/db/create-db";
 import ResetPassword from "@asyncstatus/email/auth/reset-password-email";
 import VerificationEmail from "@asyncstatus/email/auth/verification-email";
 import { betterAuth } from "better-auth";
 import { drizzleAdapter } from "better-auth/adapters/drizzle";
 import { customSession, jwt } from "better-auth/plugins";
 import { desc, eq } from "drizzle-orm";
 import type { Resend } from "resend";
-import * as schema from "../db";
-import type { Db } from "../db/db";
 import { authCookiesPlugin } from "./auth-cookies-plugin";
 import type { Bindings } from "./env";
 

apps/api/src/lib/auth.tsx

@@ -1,5 +1,5 @@
 import { dayjs } from "@asyncstatus/dayjs";
-import type { Schedule } from "../db";
+import type { Schedule } from "@asyncstatus/db";
 
 export function calculateNextScheduleExecution(schedule: Schedule): Date | null {
   const now = dayjs().tz(schedule.config.timezone);

apps/api/src/lib/calculate-next-schedule-execution.ts

@@ -1,14 +1,14 @@
 import Anthropic from "@anthropic-ai/sdk";
+import type * as schema from "@asyncstatus/db";
+import type { Db } from "@asyncstatus/db/create-db";
+import { createDb } from "@asyncstatus/db/create-db";
 import { Webhooks as GithubWebhooks } from "@octokit/webhooks";
 import { createOpenRouter, type OpenRouterProvider } from "@openrouter/ai-sdk-provider";
 import type { SlackEvent } from "@slack/web-api";
 import type { InferSelectModel } from "drizzle-orm";
 import type { Context, Next } from "hono";
 import { Resend } from "resend";
 import { VoyageAIClient } from "voyageai";
-import type * as schema from "../db";
-import type { Db } from "../db/db";
-import { createDb } from "../db/db";
 import type { DiscordGatewayDurableObject } from "../durable-objects/discord-gateway";
 import type { DeleteGithubIntegrationWorkflowParams } from "../workflows/github/delete-github-integration";
 import type { SyncGithubWorkflowParams } from "../workflows/github/sync-github";

apps/api/src/lib/env.ts

@@ -1,7 +1,7 @@
+import * as schema from "@asyncstatus/db";
+import type { Db } from "@asyncstatus/db/create-db";
 import { eq } from "drizzle-orm";
 import type Stripe from "stripe";
-import * as schema from "../db";
-import type { Db } from "../db/db";
 import { syncStripeDataToKV } from "./stripe";
 
 export type UserPlan = "basic" | "startup" | "enterprise";

apps/api/src/lib/get-organization-plan.ts

@@ -1,7 +1,7 @@
+import * as schema from "@asyncstatus/db";
+import type { Db } from "@asyncstatus/db/create-db";
 import { eq } from "drizzle-orm";
 import type Stripe from "stripe";
-import * as schema from "../db";
-import type { Db } from "../db/db";
 
 type GetOrCreateOrganizationStripeCustomerIdOptions = {
   db: Db;