Function waitForReadyPort

apps/cli/scripts/smoke-packed-apps.ts:31–74

(proc: Subprocess<"ignore", "pipe", "pipe">)

};

const waitForReadyPort = async (proc: Subprocess<"ignore", "pipe", "pipe">): Promise<number> =>
  new Promise((resolveReady, rejectReady) => {
    const timer = setTimeout(
      () => rejectReady(new Error("packed binary did not report ready in time")),
      READY_TIMEOUT_MS,
    );
    let stdout = "";
    let stderr = "";
    const finish = (result: number | Error): void => {
      clearTimeout(timer);
      if (result instanceof Error) rejectReady(result);
      else resolveReady(result);
    };
    void proc.exited.then((code) => {
      finish(new Error(`packed binary exited before ready with code ${code}: ${stderr}`));
    });
    void (async () => {
      const reader = proc.stdout.getReader();
      const decoder = new TextDecoder();
      try {
        while (true) {
          const chunk = await reader.read();
          if (chunk.done) return;
          stdout += decoder.decode(chunk.value);
          const match = stdout.match(/EXECUTOR_READY:(\d+)/);
          if (match) {
            finish(Number(match[1]));
            return;
          }
        }
      } catch (cause) {
        finish(cause instanceof Error ? cause : new Error(String(cause)));
      }
    })();
    void (async () => {
      const reader = proc.stderr.getReader();
      const decoder = new TextDecoder();
      while (true) {
        const chunk = await reader.read();
        if (chunk.done) return;
        stderr += decoder.decode(chunk.value);
      }
    })().catch(() => undefined);
  });

const main = async (): Promise<void> => {
  const fixture = await mkdtemp(join(tmpdir(), "executor-packed-apps-fixture-"));