Dynamic Credential Support

Author: davidcorrigan714

azuredevops/v7/client.go

@@ -84,7 +84,7 @@ func NewClientWithOptions(connection *Connection, baseUrl string, options ...Cli
 type Client struct {
 	baseUrl                 string
 	client                  *http.Client
-	authorization           string
+	authorization           func() (string, error)
 	suppressFedAuthRedirect bool
 	forceMsaPassThrough     bool
 	userAgent               string
@@ -169,8 +169,12 @@ func (client *Client) CreateRequestMessage(ctx context.Context,
 		req = req.WithContext(ctx)
 	}
 
-	if client.authorization != "" {
-		req.Header.Add(headerKeyAuthorization, client.authorization)
+	if client.authorization != nil {
+		authorizationHeader, err := client.authorization()
+		if err != nil {
+			return nil, err
+		}
+		req.Header.Add(headerKeyAuthorization, authorizationHeader)
 	}
 	accept := acceptMediaType
 	if apiVersion != "" {

azuredevops/v7/connection.go

@@ -19,7 +19,19 @@ func NewPatConnection(organizationUrl string, personalAccessToken string) *Conne
 	authorizationString := CreateBasicAuthHeaderValue("", personalAccessToken)
 	organizationUrl = normalizeUrl(organizationUrl)
 	return &Connection{
-		AuthorizationString:     authorizationString,
+		AuthorizationString:     func() (string, error) {
+		                               return authorizationString, nil
+							     },
+		BaseUrl:                 organizationUrl,
+		SuppressFedAuthRedirect: true,
+	}
+}
+
+// Creates a new Azure DevOps connection instance using a function that returns an authorization header string.
+func NewDynamicAuthorizationConnection(organizationUrl string, authProvider func() (string, error)) *Connection {
+	organizationUrl = normalizeUrl(organizationUrl)
+	return &Connection{
+		AuthorizationString:     authProvider,
 		BaseUrl:                 organizationUrl,
 		SuppressFedAuthRedirect: true,
 	}
@@ -34,7 +46,7 @@ func NewAnonymousConnection(organizationUrl string) *Connection {
 }
 
 type Connection struct {
-	AuthorizationString     string
+	AuthorizationString     func() (string, error)
 	BaseUrl                 string
 	UserAgent               string
 	SuppressFedAuthRedirect bool