Function onStdout

apps/desktop/src/main/sidecar.ts:307–351

(chunk: Buffer)

    };

    const onStdout = (chunk: Buffer) => {
      const text = chunk.toString("utf8");
      process.stdout.write(`[executor-server] ${text}`);
      logStdoutLine(text);
      stdoutControlBuffer += text;
      const rawControlLines = stdoutControlBuffer.split(/\r?\n/);
      stdoutControlBuffer = rawControlLines.pop() ?? "";
      const stdoutLines = rawControlLines
        .map((line) => line.trim())
        .filter((line) => line.length > 0);
      const readyLine = stdoutLines.find((line) => line.startsWith(`${READY_SENTINEL}:`));
      if (readyLine && !resolved) {
        if (!child.pid) {
          reject(
            // oxlint-disable-next-line executor/no-error-constructor -- boundary: sidecar startup failure surfaces here as a rejected start promise
            new Error("Sidecar became ready before Electron reported a child pid."),
          );
          return;
        }
        resolved = true;
        const port = parseInt(readyLine.slice(`${READY_SENTINEL}:`.length), 10);
        const baseUrl = `http://${hostname}:${port}`;
        if (!cliManagedManifest) {
          writeSidecarManifest({
            dataDir,
            scopeDir,
            baseUrl,
            authToken,
            childPid: child.pid,
          });
        }
        resolveStart({
          baseUrl,
          hostname,
          port,
          username: SERVER_SETTINGS_USERNAME,
          authToken,
          child,
          supervisedDaemon: false,
          ownerVersion: app.getVersion() || null,
          ownerClient: "desktop",
          ownerExecutablePath: command,
        });
      }
    };

    const onStderr = (chunk: Buffer) => {
      const text = chunk.toString("utf8");