Add Devin CLI provider

.github/workflows/ci.yml

@@ -106,6 +106,8 @@ jobs:
         uses: actions/setup-node@v4
         with:
           node-version: "20"
+          cache: "npm"
+          cache-dependency-path: cao_mcp_apps/package-lock.json
 
       - name: Install uv
         uses: astral-sh/setup-uv@v4
@@ -181,6 +183,8 @@ jobs:
         uses: actions/setup-node@v4
         with:
           node-version: "20"
+          cache: "npm"
+          cache-dependency-path: cao_mcp_apps/package-lock.json
 
       - name: Install MCP-apps deps
         run: npm install

CHANGELOG.md

@@ -44,6 +44,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 - bundle built-in memory plugins for Claude Code, Kiro, and Codex (#269)
 
+- add Devin CLI (`devin`) provider (#336)
+
 - Web UI support for the memory system (#290)
 
 - Phase 3 — LLM wiki compile, cross-references, lint, audit log, scoring (#285)

README.md

@@ -139,6 +139,7 @@ CAO drives existing CLI agent tools — it does not replace them. Before using C
 | **OpenCode CLI** *(experimental — temporary inbox polling fallback for multi-agent callbacks, [#203](https://github.com/awslabs/cli-agent-orchestrator/issues/203))* | [Provider docs](docs/opencode-cli.md) · [Installation](https://opencode.ai) | Per-model API key |
 | **Cursor CLI** | [Provider docs](docs/cursor-cli.md) · [Installation](https://cursor.com/cli) | Cursor subscription / API key |
 | **Antigravity CLI** | [Provider docs](docs/antigravity-cli.md) · [Installation](https://antigravity.google) | Google account (shared with the Antigravity IDE login) |
+| **Devin CLI** | [Provider docs](docs/devin-cli.md) · [Installation](https://devin.ai) | Devin CLI auth |
 
 ## Quick Start
 
@@ -185,7 +186,7 @@ cao launch --agents code_supervisor
 
 # Or specify a provider
 cao launch --agents code_supervisor --provider claude_code
-# Valid: kiro_cli | claude_code | codex | antigravity_cli | hermes | kimi_cli | copilot_cli | opencode_cli | cursor_cli
+# Valid: kiro_cli | claude_code | codex | antigravity_cli | devin_cli | hermes | kimi_cli | copilot_cli | opencode_cli | cursor_cli
 
 # Unrestricted access, skip confirmation (DANGEROUS)
 cao launch --agents code_supervisor --yolo
@@ -295,7 +296,7 @@ provider: claude_code
 ---
 ```
 
-Valid values: `kiro_cli`, `claude_code`, `codex`, `antigravity_cli`, `hermes`, `kimi_cli`, `copilot_cli`, `opencode_cli`, `cursor_cli`. The `cao launch --provider` flag always takes precedence for the initial session. See [`examples/cross-provider/`](examples/cross-provider/).
+Valid values: `kiro_cli`, `claude_code`, `codex`, `antigravity_cli`, `devin_cli`, `hermes`, `kimi_cli`, `copilot_cli`, `opencode_cli`, `cursor_cli`. The `cao launch --provider` flag always takes precedence for the initial session. See [`examples/cross-provider/`](examples/cross-provider/).
 
 ### Tool Restrictions
 

cao_mcp_apps/e2e/host.js

@@ -459,6 +459,48 @@
     return { success: true, kind };
   }
 
+  function handleInitialize(winInfo, id) {
+    replyTo(winInfo, id, {
+      hostContext: { theme: "light", uiSurface: true },
+      // Advertise host-delegated capabilities so the views surface them
+      // (e.g. the dashboard's "Open full Web UI" → ui/open-link).
+      hostCapabilities: { openLinks: {} },
+    });
+  }
+
+  function handleNotificationsInitialized(winInfo) {
+    winInfo.initialized = true;
+    // Deliver the "tool result that opened the view" so views needing an
+    // initial payload (the agent view needs a terminal_id) hydrate.
+    if (winInfo.view === "agent") {
+      pushTo(winInfo, "ui/notifications/tool-result", {
+        structuredContent: agentSnapshot(AGENT_VIEW_ID),
+      });
+    }
+    if (winInfo.view === "graph") {
+      pushTo(winInfo, "ui/notifications/tool-result", {
+        structuredContent: graphSnapshot(),
+      });
+    }
+    if (winInfo.resolve) winInfo.resolve();
+  }
+
+  function handleUpdateModelContext(winInfo, id, params) {
+    state.modelNotes.push(params);
+    replyTo(winInfo, id, {});
+  }
+
+  function sendUnknownMethodError(winInfo, id, method) {
+    winInfo.win.postMessage(
+      {
+        jsonrpc: "2.0",
+        id,
+        error: { code: -32601, message: `unknown ${method}` },
+      },
+      "*",
+    );
+  }
+
   function onMessage(event) {
     const data = event.data;
     if (!data || data.jsonrpc !== "2.0") return;
@@ -473,50 +515,23 @@
     if (!winInfo) return;
 
     const { id, method, params } = data;
-    if (method === "ui/initialize") {
-      replyTo(winInfo, id, {
-        hostContext: { theme: "light", uiSurface: true },
-        // Advertise host-delegated capabilities so the views surface them
-        // (e.g. the dashboard's "Open full Web UI" → ui/open-link).
-        hostCapabilities: { openLinks: {} },
-      });
-      return;
-    }
-    if (method === "ui/notifications/initialized") {
-      winInfo.initialized = true;
-      // Deliver the "tool result that opened the view" so views needing an
-      // initial payload (the agent view needs a terminal_id) hydrate.
-      if (winInfo.view === "agent") {
-        pushTo(winInfo, "ui/notifications/tool-result", {
-          structuredContent: agentSnapshot(AGENT_VIEW_ID),
-        });
-      }
-      if (winInfo.view === "graph") {
-        pushTo(winInfo, "ui/notifications/tool-result", {
-          structuredContent: graphSnapshot(),
-        });
-      }
-      if (winInfo.resolve) winInfo.resolve();
-      return;
-    }
-    if (method === "ui/update-model-context") {
-      state.modelNotes.push(params);
-      replyTo(winInfo, id, {});
-      return;
-    }
-    if (method === "tools/call") {
-      handleToolCall(winInfo, id, params.name, params.arguments || {});
-      return;
-    }
-    if (id !== undefined && id !== null) {
-      winInfo.win.postMessage(
-        {
-          jsonrpc: "2.0",
-          id,
-          error: { code: -32601, message: `unknown ${method}` },
-        },
-        "*",
-      );
+    switch (method) {
+      case "ui/initialize":
+        handleInitialize(winInfo, id);
+        break;
+      case "ui/notifications/initialized":
+        handleNotificationsInitialized(winInfo);
+        break;
+      case "ui/update-model-context":
+        handleUpdateModelContext(winInfo, id, params);
+        break;
+      case "tools/call":
+        handleToolCall(winInfo, id, params.name, params.arguments || {});
+        break;
+      default:
+        if (id !== undefined && id !== null) {
+          sendUnknownMethodError(winInfo, id, method);
+        }
     }
   }
 

cao_mcp_apps/src/agent/AgentView.tsx

@@ -32,10 +32,9 @@ export function AgentView({
     if (!app) return;
     let stop: (() => void) | undefined;
 
-    app.onToolResult((result) => {
+    const unsubscribe = app.onToolResult((result) => {
       const snap = (result?.structuredContent ?? result) as
-        | AgentDetailSnapshot
-        | undefined;
+        AgentDetailSnapshot | undefined;
       if (snap && snap.terminal_id) {
         tidRef.current = snap.terminal_id;
         setSnapshot(snap);
@@ -58,6 +57,7 @@ export function AgentView({
     });
 
     return () => {
+      unsubscribe();
       if (stop) stop();
     };
     // eslint-disable-next-line react-hooks/exhaustive-deps

cao_mcp_apps/src/dashboard/Dashboard.tsx

@@ -73,7 +73,7 @@ export function Dashboard({
     let stop: (() => void) | undefined;
 
     // Register handlers BEFORE connect (lifecycle invariant).
-    app.onToolResult((result) => {
+    const unsubscribe = app.onToolResult((result) => {
       const snap = (result?.structuredContent ?? result) as
         DashboardSnapshot | undefined;
       if (snap && Array.isArray(snap.terminals)) applyDelta(snap);
@@ -98,6 +98,7 @@ export function Dashboard({
     });
 
     return () => {
+      unsubscribe();
       if (stop) stop();
     };
     // eslint-disable-next-line react-hooks/exhaustive-deps

cao_mcp_apps/src/graph/GraphView.tsx

@@ -60,14 +60,14 @@
   return graph;
 }
 
 export function GraphView({
   app,
   initialSnapshot,
   provider = "memory",
   scope,
   scopeId,
   onOpenTopic,
 }: GraphViewProps): JSX.Element {
   const [snapshot, setSnapshot] = useState<GraphViewData | null>(
     initialSnapshot ?? null,
   );
@@ -80,7 +80,7 @@
     let stop: (() => void) | undefined;
 
     // Register handlers BEFORE connect (lifecycle invariant).
-    app.onToolResult((result) => {
+    const unsubscribe = app.onToolResult((result) => {
       const snap = (result?.structuredContent ?? result) as
         GraphViewData | undefined;
       if (snap && Array.isArray(snap.nodes)) {
@@ -105,6 +105,7 @@
     });
 
     return () => {
+      unsubscribe();
       if (stop) stop();
     };
     // eslint-disable-next-line react-hooks/exhaustive-deps

cao_mcp_apps/src/shared/mcpApp.ts

@@ -46,8 +46,12 @@ export class McpApp {
   private target: Window;
   private scope: Window;
   private nextId: JsonRpcId = 1;
+  private nextHandlerId = 0;
   private pending = new Map<JsonRpcId, PendingRequest>();
-  private notificationHandlers = new Map<string, NotificationHandler[]>();
+  private notificationHandlers = new Map<
+    string,
+    { id: number; handler: NotificationHandler }[]
+  >();
   private listener?: (event: MessageEvent) => void;
   private connected = false;
   /** Host context (theme, container dimensions, etc.) from initialize. */
@@ -70,15 +74,26 @@ export class McpApp {
   // ---- handler registration (call BEFORE connect) ------------------------
 
   /** Register a notification handler. MUST be called before `connect()`. */
-  on(method: string, handler: NotificationHandler): void {
+  on(method: string, handler: NotificationHandler): () => void {
+    const id = ++this.nextHandlerId;
     const list = this.notificationHandlers.get(method) ?? [];
-    list.push(handler);
+    list.push({ id, handler });
     this.notificationHandlers.set(method, list);
+    return () => {
+      const updated = (this.notificationHandlers.get(method) ?? []).filter(
+        (entry) => entry.id !== id,
+      );
+      if (updated.length) {
+        this.notificationHandlers.set(method, updated);
+      } else {
+        this.notificationHandlers.delete(method);
+      }
+    };
   }
 
   /** Convenience: the tool result that instantiated/refreshed the View. */
-  onToolResult(handler: (result: any) => void): void {
-    this.on("ui/notifications/tool-result", handler);
+  onToolResult(handler: (result: any) => void): () => void {
+    return this.on("ui/notifications/tool-result", handler);
   }
 
   /** Convenience: the tool input (arguments) for the current tool call. */
@@ -340,7 +355,7 @@ export class McpApp {
       }
       const handlers = this.notificationHandlers.get(data.method);
       if (handlers) {
-        for (const handler of handlers) handler(data.params);
+        for (const { handler } of handlers) handler(data.params);
       }
     }
   }

cao_mcp_apps/src/test/lifecycle.test.tsx

@@ -52,6 +52,23 @@ function buildHost(opts: MockHostOptions = {}): MockHost {
 }
 
 describe("McpApp convenience notification handlers", () => {
+  it("returns an unsubscribe that removes only its handler", async () => {
+    const host = buildHost({ tools: {} });
+    const app = makeApp(host);
+
+    const shared = vi.fn();
+    const offFirst = app.on("ui/notifications/tool-result", shared);
+    app.on("ui/notifications/tool-result", shared);
+
+    offFirst();
+
+    await app.connect();
+    host.pushNotification("ui/notifications/tool-result", {
+      structuredContent: { nodes: [] },
+    });
+    expect(shared).toHaveBeenCalledOnce();
+  });
+
   it("delivers tool-input arguments, host-context changes, and teardown reason", async () => {
     const host = buildHost({ tools: {} });
     const app = makeApp(host);