Function waitForSessionStatus

packages/server-e2e/src/wait.ts:32–52

(
  http: HttpClient,
  sid: string,
  status: SessionStatus,
  opts?: { timeoutMs?: number; pollMs?: number },
)

 * must poll.
 */
export async function waitForSessionStatus(
  http: HttpClient,
  sid: string,
  status: SessionStatus,
  opts?: { timeoutMs?: number; pollMs?: number },
): Promise<Session> {
  const timeoutMs = opts?.timeoutMs ?? DEFAULT_FRAME_TIMEOUT_MS;
  const pollMs = opts?.pollMs ?? 250;
  const deadline = Date.now() + timeoutMs;
  let last: Session | null = null;
  while (Date.now() < deadline) {
    const session = await http.getSession(sid);
    last = session;
    if (session.status === status) return session;
    await sleep(pollMs);
  }
  throw new Error(
    `session ${sid} did not reach status="${status}" within ${timeoutMs}ms ` +
      `(last status="${last?.status ?? 'unknown'}")`,
  );
}

function sleep(ms: number): Promise<void> {
  return new Promise((resolve) => setTimeout(resolve, ms));