@@ -18,3 +22,4 @@ export default async function ProtectedLayout({
);
}
+
diff --git a/db/index.ts b/db/index.ts
new file mode 100644
index 0000000..413f42b
--- /dev/null
+++ b/db/index.ts
@@ -0,0 +1,26 @@
+import { neon } from "@neondatabase/serverless";
+import { drizzle } from "drizzle-orm/neon-http";
+import * as schema from "./schema";
+
+const databaseUrl = process.env.DATABASE_URL;
+
+if (!databaseUrl) {
+ if (process.env.NODE_ENV === "production") {
+ throw new Error(
+ "DATABASE_URL environment variable is required in production."
+ );
+ } else {
+ console.warn(
+ "\x1b[33m%s\x1b[0m",
+ "[db] Warning: DATABASE_URL is missing in environment variables. Add your Neon PostgreSQL URL to .env.local to enable database features."
+ );
+ }
+}
+
+// Dummy fallback to prevent build-time crashes when DATABASE_URL is not set during initial setup
+const connectionString =
+ databaseUrl || "postgresql://placeholder:placeholder@ep-placeholder.neon.tech/neondb?sslmode=require";
+
+const sql = neon(connectionString);
+
+export const db = drizzle(sql, { schema });
diff --git a/db/migrate.ts b/db/migrate.ts
new file mode 100644
index 0000000..64acb3a
--- /dev/null
+++ b/db/migrate.ts
@@ -0,0 +1,25 @@
+import { neon } from "@neondatabase/serverless";
+import { drizzle } from "drizzle-orm/neon-http";
+import { migrate } from "drizzle-orm/neon-http/migrator";
+import "dotenv/config";
+
+async function runMigration() {
+ if (!process.env.DATABASE_URL) {
+ console.error("❌ DATABASE_URL environment variable is not defined.");
+ process.exit(1);
+ }
+
+ console.log("⏳ Running Neon PostgreSQL migrations...");
+ const sql = neon(process.env.DATABASE_URL);
+ const db = drizzle(sql);
+
+ try {
+ await migrate(db, { migrationsFolder: "./drizzle" });
+ console.log("✅ Migrations completed successfully!");
+ } catch (error) {
+ console.error("❌ Migration failed:", error);
+ process.exit(1);
+ }
+}
+
+runMigration();
diff --git a/db/queries/users.ts b/db/queries/users.ts
new file mode 100644
index 0000000..00f9ce4
--- /dev/null
+++ b/db/queries/users.ts
@@ -0,0 +1,77 @@
+import { eq } from "drizzle-orm";
+import { db } from "../index";
+import { users, type User } from "../schema/users";
+
+export interface UpsertUserInput {
+ clerkId: string;
+ email: string;
+ username?: string | null;
+ firstName?: string | null;
+ lastName?: string | null;
+ imageUrl?: string | null;
+}
+
+/**
+ * Retrieves a user by their Clerk ID.
+ */
+export async function getUserByClerkId(clerkId: string): Promise