Function waitForOAuthResult

apps/local/src/oauth-result-store.ts:106–134

(
  sessionId: string,
  opts: { readonly timeoutMs: number; readonly signal?: AbortSignal },
)

 * this answers `null` immediately instead of holding.
 */
export const waitForOAuthResult = (
  sessionId: string,
  opts: { readonly timeoutMs: number; readonly signal?: AbortSignal },
): Promise<AnyResult | null> => {
  const immediate = consumeOAuthResult(sessionId);
  if (immediate !== null) return Promise.resolve(immediate);
  if (opts.timeoutMs <= 0 || opts.signal?.aborted === true) return Promise.resolve(null);
  if (waiters.has(sessionId) || waiters.size >= MAX_HELD_WAITERS_TOTAL) {
    return Promise.resolve(null);
  }

  return new Promise((resolve) => {
    let done = false;
    const finish = (result: AnyResult | null) => {
      if (done) return;
      done = true;
      clearTimeout(timer);
      opts.signal?.removeEventListener("abort", onAbort);
      removeWaiter(sessionId, wake);
      resolve(result);
    };
    const wake = () => finish(consumeOAuthResult(sessionId));
    const onAbort = () => finish(null);
    const timer = setTimeout(() => finish(null), opts.timeoutMs);

    waiters.set(sessionId, wake);
    opts.signal?.addEventListener("abort", onAbort, { once: true });
  });
};

/** Test-only — clears the store and resolves any held waiters as pending. */
export const __resetOAuthResultStoreForTests = (): void => {