fix(acp): use single global event subscription and route by sessionID (#5628)

Co-authored-by: noamzbr <noamzbr@users.noreply.github.com> Co-authored-by: noam-v <noam@bespo.ai>
2026-01-18 09:29:42 +02:00
parent f67c381bc8
commit 5e991f33d3
3 changed files with 758 additions and 272 deletions
@@ -13,6 +13,10 @@ export class ACPSessionManager {
    this.sdk = sdk
  }

+  tryGet(sessionId: string): ACPSessionState | undefined {
+    return this.sessions.get(sessionId)
+  }
+
  async create(cwd: string, mcpServers: McpServer[], model?: ACPSessionState["model"]): Promise<ACPSessionState> {
    const session = await this.sdk.session
      .create(