Function waitForChildToStop

src/utils/video_capture.ts:46–81

(session: Session, timeoutMs: number)

}

async function waitForChildToStop(session: Session, timeoutMs: number): Promise<void> {
  const child = session.process as ChildProcess | undefined;
  if (!child) {
    return;
  }

  const alreadyEnded = session.ended || child.exitCode !== null;
  const hasSignal = (child as unknown as { signalCode?: string | null }).signalCode != null;
  if (alreadyEnded || hasSignal) {
    session.ended = true;
    return;
  }

  const closePromise = new Promise<'closed'>((resolve) => {
    let resolved = false;
    const finish = (): void => {
      if (!resolved) {
        resolved = true;
        session.ended = true;
        resolve('closed');
      }
    };

    child.once('close', finish);
    child.once('exit', finish);
  }).catch(() => 'closed' as const);

  const outcome = await Promise.race([closePromise, createTimeoutPromise(timeoutMs)]);
  if (outcome === 'timed_out') {
    try {
      child.kill('SIGKILL');
    } catch {
      // ignore
    }
  }
}

type StopSessionSuccess = { sessionId: string; stdout: string; parsedPath?: string };
type StopSessionError = { error: string };