Function createAbortController

src/node/runtime/SSHRuntime.ts:269–303

(
  timeoutMs: number | undefined,
  abortSignal?: AbortSignal
)

}

function createAbortController(
  timeoutMs: number | undefined,
  abortSignal?: AbortSignal
): { signal: AbortSignal; dispose: () => void; didTimeout: () => boolean } {
  const controller = new AbortController();
  let timedOut = false;

  const onAbort = () => controller.abort();
  if (abortSignal) {
    if (abortSignal.aborted) {
      controller.abort();
    } else {
      abortSignal.addEventListener("abort", onAbort, { once: true });
    }
  }

  const timeoutHandle =
    timeoutMs === undefined
      ? undefined
      : setTimeout(() => {
          timedOut = true;
          controller.abort();
        }, timeoutMs);

  return {
    signal: controller.signal,
    didTimeout: () => timedOut,
    dispose: () => {
      if (timeoutHandle) {
        clearTimeout(timeoutHandle);
      }
      abortSignal?.removeEventListener("abort", onAbort);
    },
  };
}
async function waitForProcessExit(proc: ChildProcess): Promise<number> {
  // Callers often consume stdout before awaiting the process. Tiny git helpers
  // can close in that window, so make the helper safe even when subscribed late.