1 files changed, 66 insertions, 0 deletions
diff --git a/packages/function/src/api.ts b/packages/function/src/api.ts
index 6f00dae9a..d08e9e49a 100644
--- a/packages/function/src/api.ts
+++ b/packages/function/src/api.ts
@@ -12,6 +12,20 @@ type Env = {
   WEB_DOMAIN: string
 }
 
+async function getFeishuTenantToken(): Promise<string> {
+  const response = await fetch("https://open.feishu.cn/open-apis/auth/v3/tenant_access_token/internal", {
+    method: "POST",
+    headers: { "Content-Type": "application/json" },
+    body: JSON.stringify({
+      app_id: Resource.FEISHU_APP_ID.value,
+      app_secret: Resource.FEISHU_APP_SECRET.value,
+    }),
+  })
+  const data = (await response.json()) as { tenant_access_token?: string }
+  if (!data.tenant_access_token) throw new Error("Failed to get Feishu tenant token")
+  return data.tenant_access_token
+}
+
 export class SyncServer extends DurableObject<Env> {
   constructor(ctx: DurableObjectState, env: Env) {
     super(ctx, env)
@@ -200,6 +214,58 @@ export default new Hono<{ Bindings: Env }>()
 
     return c.json({ info, messages })
   })
+  .post("/feishu", async (c) => {
+    const body = (await c.req.json()) as {
+    challenge?: string
+  event?: {
+    message?: {
+      message_id?: string
+      root_id?: string
+      parent_id?: string
+      chat_id?: string
+      content?: string
+    }
+  }
+}
+    console.log(JSON.stringify(body, null, 2))
+    const challenge = body.challenge
+    if (challenge) return c.json({ challenge })
+
+    const content = body.event?.message?.content
+    const parsed =
+      typeof content === "string" && content.trim().startsWith("{") ? (JSON.parse(content) as {
+  text?: string
+}) : undefined
+    const text = typeof parsed?.text === "string" ? parsed.text : typeof content === "string" ? content : ""
+
+    let message = text.trim().replace(/^@_user_\d+\s*/, "")
+    message = message.replace(/^aiden,?\s*/i, "<@759257817772851260> ")
+    if (!message) return c.json({ ok: true })
+
+    const threadId = body.event?.message?.root_id || body.event?.message?.message_id
+    if (threadId) message = `${message} [${threadId}]`
+
+    const response = await fetch(
+      `https://discord.com/api/v10/channels/${Resource.DISCORD_SUPPORT_CHANNEL_ID.value}/messages`,
+      {
+        method: "POST",
+        headers: {
+          "Content-Type": "application/json",
+          Authorization: `Bot ${Resource.DISCORD_SUPPORT_BOT_TOKEN.value}`,
+        },
+        body: JSON.stringify({
+          content: `${message}`,
+        }),
+      },
+    )
+
+    if (!response.ok) {
+      console.error(await response.text())
+      return c.json({ error: "Discord bot message failed" }, { status: 502 })
+    }
+
+    return c.json({ ok: true })
+  })
   /**
    * Used by the GitHub action to get GitHub installation access token given the OIDC token
    */