Function connect

packages/plugin/src/tui/data/notification-socket.ts:102–148

()

}

async function connect(): Promise<void> {
    if (closed) return;
    if (socket) return; // already connected/connecting

    const client = getRpcClient();
    if (!client) {
        scheduleReconnect();
        return;
    }
    const endpoint = await client.resolveEndpoint();
    // The generation may have bumped (dispose/reinit) while resolving — abandon.
    if (closed || getRpcGeneration() !== connectGeneration) return;
    if (!endpoint) {
        scheduleReconnect();
        return;
    }

    let ws: WebSocket;
    try {
        ws = new WebSocket(`ws://127.0.0.1:${endpoint.port}/ws`);
    } catch {
        scheduleReconnect();
        return;
    }
    socket = ws;

    ws.addEventListener("open", () => {
        if (socket !== ws) return;
        reconnectAttempt = 0;
        sendHello(ws, endpoint.token);
    });

    ws.addEventListener("message", (event) => {
        if (socket !== ws) return;
        void handleSocketMessage(ws, String((event as MessageEvent).data));
    });

    const onDown = () => {
        if (socket === ws) {
            socket = null;
            helloedSession = null;
        }
        scheduleReconnect();
    };
    ws.addEventListener("close", onDown);
    ws.addEventListener("error", onDown);
}

function sendHello(ws: WebSocket, token: string | null): void {
    const sessionId = opts?.getSessionId() ?? undefined;