Method constructor

src/gateway/bindingRuntime.ts:44–283

(params: {
    db: Db;
    config: AppConfig;
    toolAuth: ToolAuth;
    sessionKey: string;
    bindingKey: string;
    workspaceRoot: string;
    agentCommand?: string;
    agentArgs?: string[];
    acpRpc?: import('../acp/stdio.js').StdioProcess;
  })

  private readonly agentArgs: string[];

  constructor(params: {
    db: Db;
    config: AppConfig;
    toolAuth: ToolAuth;
    sessionKey: string;
    bindingKey: string;
    workspaceRoot: string;
    agentCommand?: string;
    agentArgs?: string[];
    acpRpc?: import('../acp/stdio.js').StdioProcess;
  }) {
    this.db = params.db;
    this.config = params.config;
    this.toolAuth = params.toolAuth;
    this.sessionKey = params.sessionKey;
    this.bindingKey = params.bindingKey;
    this.workspaceRoot = params.workspaceRoot;
    this.agentCommand = params.agentCommand ?? this.config.acpAgentCommand;
    this.agentArgs = params.agentArgs ?? this.config.acpAgentArgs;

    this.client = new AcpClient({
      db: this.db,
      workspaceRoot: this.workspaceRoot,
      agentCommand: this.agentCommand,
      agentArgs: this.agentArgs,
      toolAuth: this.toolAuth,
      rpc: params.acpRpc,
      events: {
        onSessionUpdate: (run, _sessionId, update, eventSeq) => {
          if (run.runId === this.currentRunId) {
            this.currentRunLastSeq = Math.max(this.currentRunLastSeq, eventSeq);
          }

          this.enqueueSinkWrite(async () => {
            if (run.runId !== this.currentRunId) return;

            const sink = this.activeSink;
            if (!sink) return;

            if (update?.sessionUpdate === 'agent_message_chunk') {
              const block = update?.content;
              const text = block?.text ?? '';
              if (!text) return;
              if (sink.sendAgentText) {
                await sink.sendAgentText(text);
              } else {
                await sink.sendText(text);
              }
            }

            if (
              update?.sessionUpdate === 'tool_call' ||
              update?.sessionUpdate === 'tool_call_update'
            ) {
              const ui = this.buildToolUiEvent(update);
              if (!ui) return;

              if (this.shouldBreakTextStreamForToolUpdate(update, ui.toolCallId)) {