wip

Signed-off-by: Bryan Cox <[email protected]>

Author: bryan-cox

pkg/storage/azure/azure.go

@@ -334,6 +334,17 @@ func NewDriver(ctx context.Context, c *imageregistryv1.ImageRegistryConfigStorag
 }
 
 func (d *driver) newAzClient(cfg *Azure, environment autorestazure.Environment, tagset map[string]*string) (*azureclient.Client, error) {
+	// Check if we have cached credentials for UserAssignedIdentityCredentials
+	var cachedCreds azcore.TokenCredential
+	userAssignedIdentityCredentialsFilePath := os.Getenv("MANAGED_AZURE_HCP_CREDENTIALS_FILE_PATH")
+	if userAssignedIdentityCredentialsFilePath != "" {
+		if storedCreds, found := d.azureCredentials.Load(azureCredentialsKey); found {
+			if creds, ok := storedCreds.(azcore.TokenCredential); ok {
+				cachedCreds = creds
+			}
+		}
+	}
+
 	client, err := azureclient.New(&azureclient.Options{
 		Environment:        environment,
 		TenantID:           cfg.TenantID,
@@ -343,6 +354,7 @@ func (d *driver) newAzClient(cfg *Azure, environment autorestazure.Environment,
 		SubscriptionID:     cfg.SubscriptionID,
 		TagSet:             tagset,
 		Policies:           d.policies,
+		Creds:              cachedCreds,
 	})
 	if err != nil {
 		return nil, err