refactor: migrate core web server to Elysia with modular routes

Split the monolithic server into focused route and utility modules so API behavior stays stable while reducing maintenance risk. Also unify onboarding agent detection with the shared agent-check implementation and add regression coverage for web routing contracts.

Author: LIU9293

bun.lock

@@ -36,6 +36,7 @@
     "@slack/web-api": "^7.13.0",
     "@supabase/supabase-js": "^2.90.1",
     "discord.js": "^14.25.1",
+    "elysia": "^1.4.25",
     "ioredis": "^5.9.2",
     "pino": "^10.1.1",
     "pino-pretty": "^13.1.3",

package.json

@@ -10,6 +10,7 @@ import {
   type OdeConfig,
   type WorkspaceConfig,
 } from "@/config";
+import { getInstalledAgentStatus } from "@/core/web/agent-check";
 import { discoverDiscordWorkspace, discoverLarkWorkspace, discoverSlackWorkspace } from "./web/local-settings";
 
 type AgentId = "opencode" | "claudecode" | "codex" | "kimi" | "kiro" | "kilo" | "qwen" | "goose" | "gemini";
@@ -33,13 +34,6 @@ const agentOptions: Omit<AgentOption, "installed">[] = [
   { id: "gemini", label: "Gemini CLI", command: "gemini" },
 ];
 
-function isAgentCommandAvailable(agent: Omit<AgentOption, "installed">): boolean {
-  if (agent.id === "qwen") {
-    return Boolean(Bun.which("qwen") || Bun.which("qwen-code"));
-  }
-  return Boolean(Bun.which(agent.command));
-}
-
 function isInteractiveTerminal(): boolean {
   return Boolean(process.stdin.isTTY && process.stdout.isTTY);
 }
@@ -153,9 +147,10 @@ async function askRequired(rl: Interface, prompt: string): Promise<string> {
 }
 
 function detectAgents(): AgentOption[] {
+  const installed = getInstalledAgentStatus();
   return agentOptions.map((agent) => ({
     ...agent,
-    installed: isAgentCommandAvailable(agent),
+    installed: installed[agent.id],
   }));
 }
 

packages/core/onboarding.ts

@@ -0,0 +1,91 @@
+import { describe, expect, it } from "bun:test";
+import type { SessionEvent } from "@/config/local/redis";
+import { createWebApp } from "@/core/web/app";
+import { collapseTextDeltas } from "@/core/web/session-events";
+
+describe("web app routing", () => {
+  it("redirects /local-setting to root", async () => {
+    const app = createWebApp();
+    const response = await app.handle(new Request("http://localhost/local-setting"));
+    expect(response.status).toBe(307);
+    expect(response.headers.get("location")).toBe("/");
+  });
+
+  it("redirects /local-setting/* to root-relative path", async () => {
+    const app = createWebApp();
+    const response = await app.handle(new Request("http://localhost/local-setting/sessions/abc"));
+    expect(response.status).toBe(307);
+    expect(response.headers.get("location")).toBe("/sessions/abc");
+  });
+
+  it("returns 400 for workspace sync without workspaceId", async () => {
+    const app = createWebApp();
+    const response = await app.handle(new Request("http://localhost/api/slack-sync", {
+      method: "POST",
+      headers: { "content-type": "application/json" },
+      body: JSON.stringify({}),
+    }));
+
+    expect(response.status).toBe(400);
+    const payload = await response.json() as { ok: boolean; error?: string };
+    expect(payload.ok).toBe(false);
+    expect(payload.error).toBe("Missing workspaceId");
+  });
+
+  it("returns 400 for workspace discover without required credentials", async () => {
+    const app = createWebApp();
+    const response = await app.handle(new Request("http://localhost/api/slack-discover", {
+      method: "POST",
+      headers: { "content-type": "application/json" },
+      body: JSON.stringify({}),
+    }));
+
+    expect(response.status).toBe(400);
+    const payload = await response.json() as { ok: boolean; error?: string };
+    expect(payload.ok).toBe(false);
+    expect(payload.error?.startsWith("Missing Slack")).toBe(true);
+  });
+});
+
+describe("collapseTextDeltas", () => {
+  it("keeps only latest text delta for each part id", () => {
+    const base = {
+      sessionId: "s1",
+      channelId: "C1",
+      threadId: "T1",
+      agentProvider: "opencode",
+    };
+    const events = [
+      {
+        ...base,
+        timestamp: 1,
+        type: "message.part.updated",
+        data: { properties: { part: { id: "p1", type: "text", text: "a" } } },
+      },
+      {
+        ...base,
+        timestamp: 2,
+        type: "message.part.updated",
+        data: { properties: { part: { id: "p1", type: "text", text: "ab" } } },
+      },
+      {
+        ...base,
+        timestamp: 3,
+        type: "tool.started",
+        data: { id: "t1" },
+      },
+      {
+        ...base,
+        timestamp: 4,
+        type: "message.part.updated",
+        data: { properties: { part: { id: "p2", type: "text", text: "x" } } },
+      },
+    ] as SessionEvent[];
+
+    const collapsed = collapseTextDeltas(events);
+    expect(collapsed).toHaveLength(3);
+    expect(collapsed[0]?.timestamp).toBe(2);
+    expect(collapsed[1]?.type).toBe("tool.started");
+    expect(collapsed[2]?.timestamp).toBe(4);
+  });
+});