Method waitForDeviceFlow

src/node/services/codexOauthService.ts:267–308

(
    flowId: string,
    opts?: { timeoutMs?: number }
  )

  }

  async waitForDeviceFlow(
    flowId: string,
    opts?: { timeoutMs?: number }
  ): Promise<Result<void, string>> {
    const flow = this.deviceFlows.get(flowId);
    if (!flow) {
      return Err("OAuth flow not found");
    }

    if (!flow.pollingStarted) {
      flow.pollingStarted = true;
      this.pollDeviceFlow(flowId).catch((error) => {
        // The polling loop is responsible for resolving the flow; if we reach
        // here something unexpected happened.
        const message = getErrorMessage(error);
        log.warn(`[Codex OAuth] Device polling crashed (flowId=${flowId}): ${message}`);
        void this.finishDeviceFlow(flowId, Err(`Device polling crashed: ${message}`));
      });
    }

    const timeoutMs = opts?.timeoutMs ?? DEFAULT_DEVICE_TIMEOUT_MS;

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

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

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

    if (!result.success) {
      // Ensure polling is cancelled on timeout/errors.
      void this.finishDeviceFlow(flowId, result);
    }

    return result;
  }

  async cancelDeviceFlow(flowId: string): Promise<void> {
    const flow = this.deviceFlows.get(flowId);