Method waitFor

src/node/utils/oauthFlowManager.ts:113–143

* Wait for a flow to complete with a caller-facing timeout race. * * Mirrors the `waitForDesktopFlow` pattern shared across all four services: * - Creates a local timeout promise for this wait call only. * - Races that local timeout against `flow.resultDeferred.promise`. * - Registrat

(flowId: string, timeoutMs: number)

   * - On any error result (caller timeout or flow error), calls `finish` for shared cleanup.
   */
  async waitFor(flowId: string, timeoutMs: number): Promise<Result<void, string>> {
    const flow = this.flows.get(flowId);
    if (!flow) {
      const completed = this.completed.get(flowId);
      if (completed) {
        return completed.result;
      }

      return Err("OAuth flow not found");
    }

    let timeoutHandle: ReturnType<typeof setTimeout> | null = null;
    const timeoutPromise = new Promise<Result<void, string>>((resolve) => {
      timeoutHandle = setTimeout(() => {
        resolve(Err("Timed out waiting for OAuth callback"));
      }, timeoutMs);
    });

    const result = await Promise.race([flow.resultDeferred.promise, timeoutPromise]);

    if (timeoutHandle !== null) {
      clearTimeout(timeoutHandle);
    }

    if (!result.success) {
      // Ensure listener is closed on timeout/errors.
      void this.finish(flowId, result);
    }

    return result;
  }

  /**
   * Cancel a flow — resolves the deferred with an error and cleans up.