handle Entra auth for ASO API managed clusters

controllers/aso_credential_cache.go

@@ -0,0 +1,221 @@
+/*
+Copyright 2024 The Kubernetes Authors.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package controllers
+
+import (
+	"context"
+	"os"
+	"strconv"
+
+	"github.com/Azure/azure-sdk-for-go/sdk/azcore"
+	"github.com/Azure/azure-sdk-for-go/sdk/azcore/cloud"
+	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
+	"github.com/Azure/azure-sdk-for-go/sdk/tracing/azotel"
+	asoannotations "github.com/Azure/azure-service-operator/v2/pkg/common/annotations"
+	"github.com/Azure/azure-service-operator/v2/pkg/common/config"
+	corev1 "k8s.io/api/core/v1"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	"sigs.k8s.io/cluster-api-provider-azure/azure"
+	"sigs.k8s.io/cluster-api-provider-azure/pkg/ot"
+	"sigs.k8s.io/cluster-api-provider-azure/util/tele"
+)
+
+const (
+	asoNamespaceSecretName = "aso-credential" //nolint:gosec // This is not a secret, only a reference to one.
+	asoGlobalSecretName    = "aso-controller-settings"
+	asoNamespaceAnnotation = "serviceoperator.azure.com/operator-namespace"
+)
+
+// ASOCredentialCache caches credentials defined for ASO resources.
+type ASOCredentialCache interface {
+	authTokenForASOResource(context.Context, client.Object) (azcore.TokenCredential, error)
+}
+
+type asoCredentialCache struct {
+	cache  azure.CredentialCache
+	client client.Client
+}
+
+// NewASOCredentialCache creates a new ASOCredentialCache.
+func NewASOCredentialCache(cache azure.CredentialCache, client client.Client) ASOCredentialCache {
+	return &asoCredentialCache{
+		cache:  cache,
+		client: client,
+	}
+}
+
+func (c *asoCredentialCache) authTokenForASOResource(ctx context.Context, obj client.Object) (azcore.TokenCredential, error) {
+	ctx, _, done := tele.StartSpanWithLogger(ctx, "controllers.asoCredentialCache.authTokenForASOResource")
+	defer done()
+
+	clientOpts, err := c.clientOptsForASOResource(ctx, obj)
+	if err != nil {
+		return nil, err
+	}
+
+	secretName := asoNamespaceSecretName
+	if resourceSecretName := obj.GetAnnotations()[asoannotations.PerResourceSecret]; resourceSecretName != "" {
+		secretName = resourceSecretName
+	}
+	secret := &corev1.Secret{}
+	err = c.client.Get(ctx, client.ObjectKey{Namespace: obj.GetNamespace(), Name: secretName}, secret)
+	if client.IgnoreNotFound(err) != nil {
+		return nil, err
+	}
+	if err == nil {
+		return c.authTokenForScopedASOSecret(secret, clientOpts)
+	}
+
+	secretNamespace := obj.GetAnnotations()[asoNamespaceAnnotation]
+	err = c.client.Get(ctx, client.ObjectKey{Namespace: secretNamespace, Name: asoGlobalSecretName}, secret)
+	if err != nil {
+		return nil, err
+	}
+
+	return c.authTokenForGlobalASOSecret(secret, clientOpts)
+}
+
+func (c *asoCredentialCache) clientOptsForASOResource(ctx context.Context, obj client.Object) (azcore.ClientOptions, error) {
+	secretNamespace := obj.GetAnnotations()[asoNamespaceAnnotation]
+	secret := &corev1.Secret{}
+	err := c.client.Get(ctx, client.ObjectKey{Namespace: secretNamespace, Name: asoGlobalSecretName}, secret)
+	if client.IgnoreNotFound(err) != nil {
+		return azcore.ClientOptions{}, err
+	}
+
+	otelTP, err := ot.OTLPTracerProvider(ctx)
+	if err != nil {
+		return azcore.ClientOptions{}, err
+	}
+
+	opts := azcore.ClientOptions{
+		TracingProvider: azotel.NewTracingProvider(otelTP, nil),
+		Cloud: cloud.Configuration{
+			ActiveDirectoryAuthorityHost: string(secret.Data[config.AzureAuthorityHost]),
+		},
+	}
+
+	if len(secret.Data[config.ResourceManagerAudience]) > 0 ||
+		len(secret.Data[config.ResourceManagerEndpoint]) > 0 {
+		opts.Cloud.Services = map[cloud.ServiceName]cloud.ServiceConfiguration{
+			cloud.ResourceManager: {
+				Audience: string(secret.Data[config.ResourceManagerAudience]),
+				Endpoint: string(secret.Data[config.ResourceManagerEndpoint]),
+			},
+		}
+	}
+
+	return opts, nil
+}
+
+func (c *asoCredentialCache) authTokenForScopedASOSecret(secret *corev1.Secret, clientOpts azcore.ClientOptions) (azcore.TokenCredential, error) {
+	d := secret.Data
+
+	if _, hasSecret := d[config.AzureClientSecret]; hasSecret {
+		return c.cache.GetOrStoreClientSecret(
+			string(d[config.AzureTenantID]),
+			string(d[config.AzureClientID]),
+			string(d[config.AzureClientSecret]),
+			&azidentity.ClientSecretCredentialOptions{
+				ClientOptions: clientOpts,
+			},
+		)
+	}
+
+	if _, hasCert := d[config.AzureClientCertificate]; hasCert {
+		return c.cache.GetOrStoreClientCert(
+			string(d[config.AzureTenantID]),
+			string(d[config.AzureClientID]),
+			d[config.AzureClientCertificate],
+			d[config.AzureClientCertificatePassword],
+			&azidentity.ClientCertificateCredentialOptions{
+				ClientOptions: clientOpts,
+			},
+		)
+	}
+
+	if authMode := d[config.AuthMode]; config.AuthModeOption(authMode) == config.PodIdentityAuthMode {
+		return c.cache.GetOrStoreManagedIdentity(
+			&azidentity.ManagedIdentityCredentialOptions{
+				ClientOptions: clientOpts,
+				ID:            azidentity.ClientID(d[config.AzureClientID]),
+			},
+		)
+	}
+
+	return c.cache.GetOrStoreWorkloadIdentity(
+		&azidentity.WorkloadIdentityCredentialOptions{
+			ClientOptions: clientOpts,
+			TenantID:      string(d[config.AzureTenantID]),
+			ClientID:      string(d[config.AzureClientID]),
+			TokenFilePath: federatedTokenFilePath(),
+		},
+	)
+}
+
+func (c *asoCredentialCache) authTokenForGlobalASOSecret(secret *corev1.Secret, clientOpts azcore.ClientOptions) (azcore.TokenCredential, error) {
+	d := secret.Data
+
+	if workloadID, _ := strconv.ParseBool(string(d[config.UseWorkloadIdentityAuth])); workloadID {
+		return c.cache.GetOrStoreWorkloadIdentity(
+			&azidentity.WorkloadIdentityCredentialOptions{
+				ClientOptions: clientOpts,
+				TenantID:      string(d[config.AzureTenantID]),
+				ClientID:      string(d[config.AzureClientID]),
+				TokenFilePath: federatedTokenFilePath(),
+			},
+		)
+	}
+
+	if _, hasSecret := d[config.AzureClientSecret]; hasSecret {
+		return c.cache.GetOrStoreClientSecret(
+			string(d[config.AzureTenantID]),
+			string(d[config.AzureClientID]),
+			string(d[config.AzureClientSecret]),
+			&azidentity.ClientSecretCredentialOptions{
+				ClientOptions: clientOpts,
+			},
+		)
+	}
+
+	if _, hasCert := d[config.AzureClientCertificate]; hasCert {
+		return c.cache.GetOrStoreClientCert(
+			string(d[config.AzureTenantID]),
+			string(d[config.AzureClientID]),
+			d[config.AzureClientCertificate],
+			d[config.AzureClientCertificatePassword],
+			&azidentity.ClientCertificateCredentialOptions{
+				ClientOptions: clientOpts,
+			},
+		)
+	}
+
+	return c.cache.GetOrStoreManagedIdentity(
+		&azidentity.ManagedIdentityCredentialOptions{
+			ClientOptions: clientOpts,
+			ID:            azidentity.ClientID(d[config.AzureClientID]),
+		},
+	)
+}
+
+func federatedTokenFilePath() string {
+	if env, ok := os.LookupEnv("AZURE_FEDERATED_TOKEN_FILE"); ok {
+		return env
+	}
+	return "/var/run/secrets/azure/tokens/azure-identity-token"
+}