Method waitFor

packages/e2e-tests/src/harness.ts:302–322

Poll until `predicate` returns true or `timeoutMs` elapses.

(
        predicate: () => T | null | undefined | false,
        opts: { timeoutMs?: number; intervalMs?: number; label?: string } = {},
    )

    /** Poll until `predicate` returns true or `timeoutMs` elapses. */
    async waitFor<T>(
        predicate: () => T | null | undefined | false,
        opts: { timeoutMs?: number; intervalMs?: number; label?: string } = {},
    ): Promise<T> {
        // Default bumped from 10s → 60s for CI. waitFor is called by tests
        // to poll for DB rows / queued ops to appear; on CI shared runners
        // there can be material latency between an event firing and the
        // SQLite row being visible. Individual tests can still pass a
        // smaller timeoutMs.
        const timeoutMs = opts.timeoutMs ?? 60_000;
        const intervalMs = opts.intervalMs ?? 100;
        const deadline = Date.now() + timeoutMs;
        while (Date.now() < deadline) {
            const value = predicate();
            if (value) return value as T;
            await Bun.sleep(intervalMs);
        }
        throw new Error(
            `waitFor timed out after ${timeoutMs}ms${opts.label ? ` (${opts.label})` : ""}`,
        );
    }

    /**
     * Count compartments for a session. Returns 0 if the table is empty or missing.