Function ensureAgentSocket

src/agent-backend.ts:438–488

()

  }

  async function ensureAgentSocket(): Promise<net.Socket> {
    if (agentSocket && !agentSocket.destroyed) return agentSocket;

    try {
      agentSocket = await connectToAgent();
    } catch {
      await maybeStartAgentDaemon(connection, session);
      for (let attempt = 0; attempt < 20; attempt++) {
        await sleep(100);
        try {
          agentSocket = await connectToAgent();
          break;
        } catch {}
      }
    }

    if (!agentSocket || agentSocket.destroyed) {
      const target =
        connection.type === "unix" ? connection.path : `${connection.host}:${connection.port}`;
      throw new Error(`Could not connect to agent-browser daemon at ${target}.`);
    }

    agentSocket.setNoDelay(true);
    agentSocket.on(
      "data",
      createJsonLineParser((msg) => {
        if (!msg || msg.id === undefined) return;
        const messageId = typeof msg.id === "string" ? msg.id : String(msg.id);
        const pending = agentPending.get(messageId);
        if (!pending) return;
        agentPending.delete(messageId);
        const res = msg as AgentResponse;
        if (!res.success) pending.reject(new Error(res.error || "Agent browser error"));
        else pending.resolve(res.data);
      })
    );

    agentSocket.on("close", () => {
      for (const pending of agentPending.values()) {
        pending.reject(new Error("Agent browser connection closed"));
      }
      agentPending.clear();
      agentSocket = null;
    });

    agentSocket.on("error", () => {
      agentSocket = null;
    });

    return agentSocket;
  }

  async function agentRequest(action: string, payload: Record<string, any>): Promise<any> {
    const socket = await ensureAgentSocket();