Method backgroundLoop

auth/token_provider.go:337–375

()

}

func (p *oauthTokenProvider) backgroundLoop() {
	defer close(p.bgDone)
	for {
		p.mu.Lock()
		expires := p.cred.Expires
		refresh := p.cred.Refresh
		p.mu.Unlock()

		if refresh == "" || expires <= 0 {
			return
		}

		wait := time.Until(time.UnixMilli(expires)) - p.refreshLead
		if wait < p.refreshMinWait {
			wait = p.refreshMinWait
		}

		timer := time.NewTimer(wait)
		select {
		case <-p.bgCtx.Done():
			timer.Stop()
			return
		case <-timer.C:
		}

		if _, err := p.Token(p.bgCtx); err != nil {
			if p.logger != nil {
				p.logger.Warn(i18n.T("auth.token_provider.background_refresh_failed"),
					zap.String("provider", string(p.cred.Provider)),
					zap.Error(err))
			}
			select {
			case <-p.bgCtx.Done():
				return
			case <-time.After(p.refreshErrorBackoff):
			}
		}
	}
}

func (p *oauthTokenProvider) Mode() AuthMode       { return AuthModeOAuth }
func (p *oauthTokenProvider) Provider() ProviderID { return p.cred.Provider }