update api

Author: yujonglee

apps/api/package.json

@@ -7,7 +7,10 @@
     "cf-typegen": "wrangler types --env-interface CloudflareBindings"
   },
   "dependencies": {
-    "hono": "^4.9.10"
+    "@supabase/supabase-js": "^2.58.0",
+    "@t3-oss/env-core": "^0.13.8",
+    "hono": "^4.9.10",
+    "zod": "^4.1.12"
   },
   "devDependencies": {
     "wrangler": "^4.42.0"

apps/api/src/env.ts

@@ -0,0 +1,18 @@
+import { createEnv } from "@t3-oss/env-core";
+import type { Context } from "hono";
+import { env } from "hono/adapter";
+import { z } from "zod";
+
+export const getEnv = (c: Context) =>
+  createEnv({
+    server: {
+      PORT: z.coerce.number().default(3000),
+      OPENAI_DEFAULT_MODEL: z.string().min(1),
+      OPENAI_BASE_URL: z.string().min(1),
+      OPENAI_API_KEY: z.string().min(1),
+      SUPABASE_URL: z.string().min(1),
+      SUPABASE_SERVICE_ROLE_KEY: z.string().min(1),
+    },
+    runtimeEnv: env(c),
+    emptyStringAsUndefined: true,
+  });

apps/api/src/index.ts

@@ -1,9 +1,38 @@
 import { Hono } from "hono";
+import { proxy } from "hono/proxy";
+
+import { getEnv } from "./env";
+import { supabaseMiddleware } from "./middleware/supabase";
 
 const app = new Hono();
+app.use("/v1", supabaseMiddleware());
+
+app.get("/health", (c) => c.text("OK"));
+
+app.post("/v1/write", async (c) => {
+  return c.json({ message: "OK" });
+});
+
+app.post("/v1/chat/completions", async (c) => {
+  const { OPENAI_BASE_URL, OPENAI_DEFAULT_MODEL, OPENAI_API_KEY } = getEnv(c);
+
+  const data = await c.req.json();
+
+  const res = await proxy(
+    `${OPENAI_BASE_URL}/chat/completions`,
+    {
+      method: "POST",
+      body: JSON.stringify({
+        ...data,
+        model: OPENAI_DEFAULT_MODEL,
+      }),
+      headers: {
+        Authorization: `Bearer ${OPENAI_API_KEY}`,
+      },
+    },
+  );
 
-app.get("/", (c) => {
-  return c.text("Hello Hono!");
+  return res;
 });
 
 export default app;

apps/api/src/middleware/supabase.ts

@@ -0,0 +1,26 @@
+import { createClient } from "@supabase/supabase-js";
+import { createMiddleware } from "hono/factory";
+
+import { getEnv } from "../env";
+
+export const supabaseMiddleware = () => {
+  return createMiddleware(async (c, next) => {
+    const authHeader = c.req.header("Authorization");
+    const token = authHeader?.replace("Bearer ", "");
+
+    if (!token) {
+      return c.json({ error: "missing_authorization_header" }, 401);
+    }
+
+    const { SUPABASE_URL, SUPABASE_SERVICE_ROLE_KEY } = getEnv(c);
+    const supabase = createClient(SUPABASE_URL, SUPABASE_SERVICE_ROLE_KEY);
+    const { data, error } = await supabase.auth.getUser(token);
+    if (error || !data?.user) {
+      return c.json({ error: "invalid_authorization_header" }, 401);
+    }
+
+    c.set("supabase", supabase);
+    c.set("user", data.user);
+    await next();
+  });
+};