| 282 | } |
| 283 | |
| 284 | func (ts *azureTokenSource) refreshToken(token *azureToken) (*azureToken, error) { |
| 285 | env, err := azure.EnvironmentFromName(token.environment) |
| 286 | if err != nil { |
| 287 | return nil, err |
| 288 | } |
| 289 | |
| 290 | oauthConfig, err := adal.NewOAuthConfig(env.ActiveDirectoryEndpoint, token.tenantID) |
| 291 | if err != nil { |
| 292 | return nil, fmt.Errorf("building the OAuth configuration for token refresh: %v", err) |
| 293 | } |
| 294 | |
| 295 | callback := func(t adal.Token) error { |
| 296 | return nil |
| 297 | } |
| 298 | spt, err := adal.NewServicePrincipalTokenFromManualToken( |
| 299 | *oauthConfig, |
| 300 | token.clientID, |
| 301 | token.apiserverID, |
| 302 | token.token, |
| 303 | callback) |
| 304 | if err != nil { |
| 305 | return nil, fmt.Errorf("creating new service principal for token refresh: %v", err) |
| 306 | } |
| 307 | |
| 308 | if err := spt.Refresh(); err != nil { |
| 309 | return nil, fmt.Errorf("refreshing token: %v", err) |
| 310 | } |
| 311 | |
| 312 | return &azureToken{ |
| 313 | token: spt.Token(), |
| 314 | environment: token.environment, |
| 315 | clientID: token.clientID, |
| 316 | tenantID: token.tenantID, |
| 317 | apiserverID: token.apiserverID, |
| 318 | }, nil |
| 319 | } |
| 320 | |
| 321 | type azureTokenSourceDeviceCode struct { |
| 322 | environment azure.Environment |