Function streamCoderCommand

src/node/services/coderService.ts:141–257

* Stream output from a coder CLI command line by line. * Yields lines as they arrive from stdout/stderr. * Throws on non-zero exit with stderr content in the error message. * * @param args Command arguments (e.g., ["start", "-y", "my-ws"]) * @param errorPrefix Prefix for error messages (e.g., "

(
  args: string[],
  errorPrefix: string,
  abortSignal?: AbortSignal,
  abortMessage = "Coder command aborted"
)

 * @param abortMessage Message to throw when aborted
 */
async function* streamCoderCommand(
  args: string[],
  errorPrefix: string,
  abortSignal?: AbortSignal,
  abortMessage = "Coder command aborted"
): AsyncGenerator<string, void, unknown> {
  if (abortSignal?.aborted) {
    throw new Error(abortMessage);
  }

  // Yield the command we're about to run so it's visible in UI
  yield `$ coder ${args.join(" ")}`;

  const child = spawn("coder", args, {
    stdio: ["ignore", "pipe", "pipe"],
  });

  const exitPromise = new Promise<number | null>((resolve) => {
    child.on("close", resolve);
    child.on("error", () => resolve(null));
  });

  const terminator = createGracefulTerminator(child);

  const abortHandler = () => {
    terminator.terminate();
  };
  abortSignal?.addEventListener("abort", abortHandler, { once: true });
  if (abortSignal?.aborted) {
    abortHandler();
  }

  try {
    // Use an async queue to stream lines as they arrive
    const lineQueue: string[] = [];
    const stderrLines: string[] = [];
    let streamsDone = false;
    let resolveNext: (() => void) | null = null;

    const pushLine = (line: string) => {
      lineQueue.push(line);
      if (resolveNext) {
        resolveNext();
        resolveNext = null;
      }
    };

    let pending = 2;
    const markDone = () => {
      pending--;
      if (pending === 0) {
        streamsDone = true;
        if (resolveNext) {
          resolveNext();
          resolveNext = null;
        }
      }
    };