Method constructor

packages/oauth/src/oauth-manager.ts:121–156

(options: OAuthManagerOptions)

  private inFlightRefresh: { promise: Promise<string>; force: boolean } | undefined;

  constructor(options: OAuthManagerOptions) {
    this.config = options.config;
    this.storage = options.storage;
    this.refreshThresholdFn = options.refreshThreshold ?? defaultRefreshThreshold;
    this.deviceCodeTimeoutMs = options.deviceCodeTimeoutMs ?? DEFAULT_DEVICE_CODE_TIMEOUT_MS;
    this.now = options.now ?? (() => Math.floor(Date.now() / 1000));
    this.sleep = options.sleep ?? defaultSleep;
    this.deviceHeaders = options.deviceHeaders;
    this.onRefresh = options.onRefresh;
    this.refreshImpl =
      options.refreshTokenImpl ??
      ((config, refreshToken, refreshOptions) =>
        refreshAccessToken(config, refreshToken, {
          ...refreshOptions,
          deviceHeaders: this.resolveDeviceHeaders(),
        }));
    this.requestImpl =
      options.requestDeviceImpl ??
      ((config) =>
        requestDeviceAuthorization(config, {
          deviceHeaders: this.resolveDeviceHeaders(),
        }));
    this.pollImpl =
      options.pollDeviceImpl ??
      ((config, deviceCode) =>
        pollDeviceToken(config, deviceCode, {
          deviceHeaders: this.resolveDeviceHeaders(),
        }));
    // The `KIMI_CODE_HOME` fallback MUST stay test-only so production
    // entry points can't silently run without a lock just because the
    // env happens to be unset. vitest sets `NODE_ENV='test'` by default,
    // so multi-process test workers still pick up the test home path.
    const envConfigDir =
      process.env['NODE_ENV'] === 'test' ? process.env['KIMI_CODE_HOME'] : undefined;
    this.configDir = options.configDir ?? envConfigDir;
  }

  private resolveDeviceHeaders(): DeviceHeaders | undefined {
    return this.deviceHeaders?.();