Method refreshToken

backend/plugins/github/token/token_provider.go:141–224

()

}

func (tp *TokenProvider) refreshToken() errors.Error {
	if tp.refreshFn != nil {
		return tp.refreshFn(tp)
	}
	tp.logger.Info("Refreshing GitHub token for connection %d", tp.conn.ID)

	data := map[string]string{
		"refresh_token": tp.conn.RefreshToken,
		"grant_type":    "refresh_token",
		"client_id":     tp.conn.AppId,
		"client_secret": tp.conn.SecretKey,
	}
	jsonData, _ := json.Marshal(data)

	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()

	req, err := http.NewRequestWithContext(ctx, "POST", tp.refreshURL, bytes.NewBuffer(jsonData))
	if err != nil {
		return errors.Convert(err)
	}
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Accept", "application/json")

	resp, err := tp.httpClient.Do(req)
	if err != nil {
		return errors.Convert(err)
	}
	defer resp.Body.Close()

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		return errors.Convert(err)
	}

	if resp.StatusCode != http.StatusOK {
		// Log the response body to aid in debugging token refresh failures.
		if tp.logger != nil {
			tp.logger.Error(nil, "failed to refresh token from GitHub, status=%d, body=%s", resp.StatusCode, string(body))
		}
		return errors.Default.New(fmt.Sprintf("failed to refresh token: %d, body: %s", resp.StatusCode, string(body)))
	}
	var result struct {
		AccessToken           string `json:"access_token"`
		RefreshToken          string `json:"refresh_token"`
		ExpiresIn             int    `json:"expires_in"`
		RefreshTokenExpiresIn int    `json:"refresh_token_expires_in"`
	}
	if err := json.Unmarshal(body, &result); err != nil {
		return errors.Convert(err)
	}

	if result.AccessToken == "" {
		bodyStr := string(body)
		const maxBodySnippet = 512
		if len(bodyStr) > maxBodySnippet {
			bodyStr = bodyStr[:maxBodySnippet] + "…"
		}