Method pollDeviceFlow

src/node/services/codexOauthService.ts:601–644

(flowId: string)

  }

  private async pollDeviceFlow(flowId: string): Promise<void> {
    const flow = this.deviceFlows.get(flowId);
    if (!flow || flow.settled) {
      return;
    }

    const intervalSeconds = flow.intervalSeconds;

    while (Date.now() < flow.expiresAtMs) {
      if (flow.abortController.signal.aborted) {
        await this.finishDeviceFlow(flowId, Err("OAuth flow cancelled"));
        return;
      }

      const attempt = await this.pollDeviceTokenOnce(flow);
      if (attempt.kind === "success") {
        const persistResult = await this.persistAuth(attempt.auth);
        if (!persistResult.success) {
          await this.finishDeviceFlow(flowId, Err(persistResult.error));
          return;
        }

        log.debug(`[Codex OAuth] Device authorization completed (flowId=${flowId})`);
        this.windowService?.focusMainWindow();
        await this.finishDeviceFlow(flowId, Ok(undefined));
        return;
      }

      if (attempt.kind === "fatal") {
        await this.finishDeviceFlow(flowId, Err(attempt.message));
        return;
      }

      try {
        // OpenCode guide: intervalSeconds * 1000 + 3000
        await sleepWithAbort(intervalSeconds * 1000 + 3000, flow.abortController.signal);
      } catch {
        // Abort is handled via cancelDeviceFlow()/finishDeviceFlow().
        return;
      }
    }

    await this.finishDeviceFlow(flowId, Err("Device code expired"));
  }

  private async pollDeviceTokenOnce(
    flow: DeviceFlow