Merge pull request #26 from odefun/ode_1770346674.753639

refactor runtime into modular services + split Slack routing

Author: LIU9293

.github/workflows/ci.yml

@@ -0,0 +1,33 @@
+name: CI
+
+on:
+  pull_request:
+  push:
+    branches-ignore:
+      - main
+
+jobs:
+  fast-checks:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Setup Bun
+        uses: oven-sh/setup-bun@v2
+
+      - name: Install dependencies
+        run: bun install
+
+      - name: Install web-ui deps
+        run: bun install --cwd packages/web-ui
+
+      - name: Typecheck
+        run: bun run typecheck
+
+      - name: Core tests
+        run: bun test packages/core/test
+
+      - name: Agent fast tests
+        run: bun test packages/agents/test/cli-command.test.ts packages/agents/test/agent-registry.test.ts

.github/workflows/live-smoke.yml

@@ -0,0 +1,30 @@
+name: Live Smoke Tests
+
+on:
+  workflow_dispatch:
+    inputs:
+      run_live:
+        description: Run live smoke tests
+        required: true
+        default: false
+        type: boolean
+  schedule:
+    - cron: "0 4 * * *"
+
+jobs:
+  live-smoke:
+    if: ${{ (github.event_name == 'workflow_dispatch' && inputs.run_live) || (github.event_name == 'schedule' && vars.LIVE_SMOKE_ENABLED == 'true') }}
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Setup Bun
+        uses: oven-sh/setup-bun@v2
+
+      - name: Install dependencies
+        run: bun install
+
+      - name: Run live smoke tests
+        run: bun test packages/agents/test/*.live.test.ts

.github/workflows/release.yml

@@ -35,6 +35,9 @@ jobs:
       - name: Install dependencies
         run: bun install
 
+      - name: Run core tests
+        run: bun test packages/core/test
+
       - name: Build web UI
         run: bun run build:web
 

packages/agents/adapter.ts

@@ -1,6 +1,7 @@
 import type { AgentAdapter, NormalizedQuestion } from "@/core/types";
 import type { QuestionInfo } from "@opencode-ai/sdk/v2";
 import {
+  selectedAgent,
   getOrCreateSession,
   sendMessage,
   abortSession,
@@ -19,6 +20,9 @@ export function createAgentAdapter(): AgentAdapter {
     ensureSession,
     subscribeToSession,
     async replyToQuestion({ requestId, sessionId, directory, answers }) {
+      if (selectedAgent !== "opencode") {
+        throw new Error(`Question replies are not supported for agent: ${selectedAgent}`);
+      }
       const client = await getSessionClient(sessionId);
       const response = await client.question.reply({
         requestID: requestId,
@@ -30,6 +34,7 @@ export function createAgentAdapter(): AgentAdapter {
       }
     },
     normalizeQuestions(questions: unknown): NormalizedQuestion[] {
+      if (selectedAgent !== "opencode") return [];
       if (!Array.isArray(questions) || questions.length === 0) return [];
       return (questions as QuestionInfo[])
         .map((question) => {

packages/agents/index.ts

@@ -1,5 +1,4 @@
-import * as claude from "./claude";
-import * as opencode from "./opencode";
+import { getSelectedAgentProvider } from "./registry";
 
 export type {
   OpenCodeMessage,
@@ -9,10 +8,10 @@ export type {
   OpenCodeSessionInfo,
 } from "./types";
 
-const agent = opencode;
+const agent = getSelectedAgentProvider();
 
-export const selectedAgent = "opencode";
-export const supportsEventStream = true;
+export const selectedAgent = agent.id;
+export const supportsEventStream = agent.supportsEventStream;
 
 export const startServer = agent.startServer;
 export const stopServer = agent.stopServer;

packages/agents/registry.ts

@@ -0,0 +1,79 @@
+import * as claude from "./claude";
+import * as opencode from "./opencode";
+import type {
+  OpenCodeMessage,
+  OpenCodeMessageContext,
+  OpenCodeOptions,
+  OpenCodeSessionInfo,
+} from "./types";
+
+export type AgentProviderId = "opencode" | "claude";
+
+export type AgentProvider = {
+  id: AgentProviderId;
+  supportsEventStream: boolean;
+  startServer: () => Promise<void>;
+  stopServer: () => void | Promise<void>;
+  createSession: (workingPath: string, env?: Record<string, string>) => Promise<string>;
+  getOrCreateSession: (
+    channelId: string,
+    threadId: string,
+    workingPath: string,
+    env?: Record<string, string>
+  ) => Promise<OpenCodeSessionInfo>;
+  sendMessage: (
+    channelId: string,
+    sessionId: string,
+    message: string,
+    workingPath: string,
+    options?: OpenCodeOptions,
+    context?: OpenCodeMessageContext
+  ) => Promise<OpenCodeMessage[]>;
+  abortSession: (sessionId: string, directory?: string) => Promise<void>;
+  cancelActiveRequest: (channelId: string, sessionId: string, directory?: string) => Promise<boolean>;
+  ensureSession: (sessionId: string) => Promise<void>;
+  subscribeToSession: (sessionId: string, handler: (event: unknown) => void) => () => void;
+};
+
+const providers: Record<AgentProviderId, AgentProvider> = {
+  opencode: {
+    id: "opencode",
+    supportsEventStream: true,
+    startServer: opencode.startServer,
+    stopServer: opencode.stopServer,
+    createSession: opencode.createSession,
+    getOrCreateSession: opencode.getOrCreateSession,
+    sendMessage: opencode.sendMessage,
+    abortSession: opencode.abortSession,
+    cancelActiveRequest: opencode.cancelActiveRequest,
+    ensureSession: opencode.ensureSession,
+    subscribeToSession: opencode.subscribeToSession,
+  },
+  claude: {
+    id: "claude",
+    supportsEventStream: false,
+    startServer: claude.startServer,
+    stopServer: claude.stopServer,
+    createSession: claude.createSession,
+    getOrCreateSession: claude.getOrCreateSession,
+    sendMessage: claude.sendMessage,
+    abortSession: claude.abortSession,
+    cancelActiveRequest: claude.cancelActiveRequest,
+    ensureSession: claude.ensureSession,
+    subscribeToSession: claude.subscribeToSession,
+  },
+};
+
+export function getSelectedAgentProviderId(): AgentProviderId {
+  const raw = process.env.ODE_AGENT_PROVIDER?.trim().toLowerCase();
+  if (raw === "claude") return "claude";
+  return "opencode";
+}
+
+export function getSelectedAgentProvider(): AgentProvider {
+  return providers[getSelectedAgentProviderId()];
+}
+
+export function getAgentProvider(providerId: AgentProviderId): AgentProvider {
+  return providers[providerId];
+}

packages/agents/shared.ts

@@ -11,6 +11,7 @@ export function buildSlackSystemPrompt(slack?: SlackContext): string {
     "- Be concise and conversational - this is chat, not documentation",
     "- Use short paragraphs, avoid walls of text",
     "- Get straight to the point",
+    "- Do not truncate final answers for brevity; include complete results when details matter",
     "",
     "PROGRESS CHECKLIST:",
     "- Share a short checklist of what you're doing",

packages/agents/test/agent-registry.test.ts

@@ -0,0 +1,31 @@
+import { afterEach, describe, expect, it } from "bun:test";
+import { getAgentProvider, getSelectedAgentProviderId } from "../registry";
+
+describe("agent registry", () => {
+  const original = process.env.ODE_AGENT_PROVIDER;
+
+  afterEach(() => {
+    if (original === undefined) {
+      delete process.env.ODE_AGENT_PROVIDER;
+    } else {
+      process.env.ODE_AGENT_PROVIDER = original;
+    }
+  });
+
+  it("defaults to opencode", () => {
+    delete process.env.ODE_AGENT_PROVIDER;
+    expect(getSelectedAgentProviderId()).toBe("opencode");
+  });
+
+  it("selects claude from env", () => {
+    process.env.ODE_AGENT_PROVIDER = "claude";
+    expect(getSelectedAgentProviderId()).toBe("claude");
+  });
+
+  it("returns provider metadata", () => {
+    const opencode = getAgentProvider("opencode");
+    const claude = getAgentProvider("claude");
+    expect(opencode.supportsEventStream).toBe(true);
+    expect(claude.supportsEventStream).toBe(false);
+  });
+});