Integrate OpenAI API and update translate endpoint

Author: bigint

apps/api/.env.example

@@ -6,3 +6,4 @@ PRIVATE_KEY="0x1d65a3183f35ecef73ce8f7d47920d58abdf3766debc2ff0b4c653b7633707fd"
 EVER_ACCESS_KEY=""
 EVER_ACCESS_SECRET=""
 SHARED_SECRET=""
+OPENROUTER_API_KEY=""

apps/api/env.d.ts

@@ -9,5 +9,6 @@ declare namespace NodeJS {
     EVER_ACCESS_SECRET: string;
     SHARED_SECRET: string;
     LIVEPEER_KEY: string;
+    OPENROUTER_API_KEY: string;
   }
 }

apps/api/package.json

@@ -31,6 +31,7 @@
     "hono-rate-limiter": "^0.4.2",
     "jose": "^6.0.11",
     "linkedom": "^0.18.10",
+    "openai": "^5.0.2",
     "pg-promise": "^11.13.0",
     "redis": "^5.1.1",
     "tsx": "^4.19.4",

apps/api/src/routes/ai/index.ts

@@ -7,7 +7,7 @@ const app = new Hono();
 
 app.post(
   "/translate",
-  zValidator("json", z.object({ text: z.string() })),
+  zValidator("json", z.object({ post: z.string() })),
   translate
 );
 

apps/api/src/routes/ai/translate.ts

@@ -1,25 +1,48 @@
 import { Errors } from "@hey/data/errors";
 import type { Context } from "hono";
+import lensPg from "src/utils/lensPg";
+import openRouter from "src/utils/openRouter";
+import { z } from "zod";
+
+const OpenAIResponseSchema = z.object({
+  choices: z.array(z.object({ message: z.object({ content: z.string() }) }))
+});
 
 const translate = async (ctx: Context) => {
   try {
-    const authHeader = ctx.req.raw.headers.get("authorization");
+    const { post } = await ctx.req.json();
 
-    if (!authHeader || !authHeader.startsWith("Bearer ")) {
-      return ctx.json({ success: false, error: "Unauthorized" }, 401);
-    }
+    const metadata = await lensPg.query(
+      `
+        SELECT content, language
+        FROM post.metadata
+        WHERE post = $1;
+      `,
+      [`\\x${post}`]
+    );
 
-    const token = authHeader.split(" ")[1];
+    const text = metadata[0]?.content;
 
-    if (token !== process.env.SHARED_SECRET) {
-      return ctx.json({ success: false, error: "Invalid shared secret" }, 401);
+    if (!text) {
+      return ctx.json({ success: false, error: "No content found" }, 400);
     }
 
-    return ctx.json({
-      allowed: true,
-      sponsored: true,
-      signingKey: process.env.PRIVATE_KEY
+    const completion = await openRouter.chat.completions.create({
+      model: "google/gemma-3n-e4b-it:free",
+      messages: [
+        {
+          role: "user",
+          content:
+            "You are a translation assistant. Translate all incoming text to English, and return only the translated output."
+        },
+        { role: "user", content: text }
+      ]
     });
+
+    const parsed = OpenAIResponseSchema.parse(completion);
+    const translatedText = parsed.choices[0].message.content;
+
+    return ctx.json({ text: translatedText });
   } catch {
     return ctx.json({ success: false, error: Errors.SomethingWentWrong }, 500);
   }

apps/api/src/utils/openRouter.ts

@@ -0,0 +1,12 @@
+import OpenAI from "openai";
+
+const openRouter = new OpenAI({
+  baseURL: "https://openrouter.ai/api/v1",
+  apiKey: process.env.OPENROUTER_API_KEY,
+  defaultHeaders: {
+    "HTTP-Referer": "https://hey.xyz",
+    "X-Title": "Hey"
+  }
+});
+
+export default openRouter;