Function createSocketServer

src/daemon/server/transport.ts:30–134

(handleRequest: DaemonInvokeFn)

};

export function createSocketServer(handleRequest: DaemonInvokeFn): DaemonServer {
  const sockets = new Set<net.Socket>();
  const server: DaemonServer = net.createServer((socket) => {
    sockets.add(socket);
    socket.on('close', () => sockets.delete(socket));
    let buffer = '';
    let inFlightRequests = 0;
    const activeRequestIds = new Set<string>();
    let canceledInFlight = false;
    const cancelInFlightRunnerSessions = () => {
      if (canceledInFlight || inFlightRequests === 0) return;
      canceledInFlight = true;
      for (const requestId of activeRequestIds) {
        markRequestCanceled(requestId);
      }
      emitDiagnostic({
        level: 'warn',
        phase: 'request_client_disconnected',
        data: {
          inFlightRequests,
        },
      });
      void (async () => {
        try {
          const deadline = Date.now() + disconnectAbortMaxWindowMs;
          while (inFlightRequests > 0 && Date.now() < deadline) {
            const { abortAllIosRunnerSessions } =
              await import('../../platforms/apple/core/runner/runner-client.ts');
            await abortAllIosRunnerSessions();
            if (inFlightRequests <= 0) break;
            await sleep(disconnectAbortPollIntervalMs);
          }
        } catch (err) {
          emitDiagnostic({
            level: 'error',
            phase: 'request_client_disconnect_abort_failed',
            data: {
              message: err instanceof Error ? err.message : String(err),
              inFlightRequests,
            },
          });
        }
      })();
    };
    socket.setEncoding('utf8');
    socket.on('close', cancelInFlightRunnerSessions);
    socket.on('error', cancelInFlightRunnerSessions);
    socket.on('data', async (chunk) => {
      const parsed = consumeTextLines(buffer, chunk);
      buffer = parsed.buffer;
      for (const line of parsed.lines) {
        let response: DaemonResponse;
        inFlightRequests += 1;
        let requestIdForCleanup: string | undefined;
        let streamProgress = false;
        try {
          const req = JSON.parse(line) as DaemonRequest;
          streamProgress = shouldStreamRequestProgress(req);