From 6e136e198cf363f7d3934d4ef55912642fdcc37d Mon Sep 17 00:00:00 2001
From: Derek Brown <6845676+DerekTBrown@users.noreply.github.comn>
Date: Fri, 3 Jan 2025 16:43:44 -0800
Subject: [PATCH] address comments

---
 pkg/cluster/admin_kind.go      | 15 +++++++++------
 pkg/cluster/admin_kind_test.go |  3 ++-
 2 files changed, 11 insertions(+), 7 deletions(-)

diff --git a/pkg/cluster/admin_kind.go b/pkg/cluster/admin_kind.go
index 836b884..0d3e305 100644
--- a/pkg/cluster/admin_kind.go
+++ b/pkg/cluster/admin_kind.go
@@ -57,7 +57,7 @@ func (a *kindAdmin) EnsureInstalled(ctx context.Context) error {
 	return nil
 }
 
-func (a *kindAdmin) kindClusterConfig(desired *api.Cluster, registry *api.Registry, registryAPI containerdRegistryAPI) *v1alpha4.Cluster {
+func (a *kindAdmin) kindClusterConfig(desired *api.Cluster, registry *api.Registry, registryAPI containerdRegistryAPI) (*v1alpha4.Cluster, error) {
 	kindConfig := desired.KindV1Alpha4Cluster
 	if kindConfig == nil {
 		kindConfig = &v1alpha4.Cluster{}
@@ -90,8 +90,7 @@ func (a *kindAdmin) kindClusterConfig(desired *api.Cluster, registry *api.Regist
 		// Parse the endpoint
 		parsedEndpoint, err := url.Parse(reg.Endpoint)
 		if err != nil {
-			klog.Warningf("Failed to parse registry URL %s: %v", reg.Endpoint, err)
-			continue
+			return nil, errors.Wrapf(err, "Error parsing registry endpoint: %s", reg.Endpoint)
 		}
 
 		// Add the registry to the list of mirrors.
@@ -113,7 +112,7 @@ func (a *kindAdmin) kindClusterConfig(desired *api.Cluster, registry *api.Regist
 		}
 	}
 
-	return kindConfig
+	return kindConfig, nil
 }
 
 func (a *kindAdmin) Create(ctx context.Context, desired *api.Cluster, registry *api.Registry) error {
@@ -168,7 +167,11 @@ func (a *kindAdmin) Create(ctx context.Context, desired *api.Cluster, registry *
 		args = append(args, "--image", node)
 	}
 
-	kindConfig := a.kindClusterConfig(desired, registry, registryAPI)
+	kindConfig, err := a.kindClusterConfig(desired, registry, registryAPI)
+	if err != nil {
+		return errors.Wrap(err, "generating kind config")
+	}
+
 	buf := bytes.NewBuffer(nil)
 	encoder := yaml.NewEncoder(buf)
 	err = encoder.Encode(kindConfig)
@@ -196,7 +199,7 @@ func (a *kindAdmin) Create(ctx context.Context, desired *api.Cluster, registry *
 			}
 		}
 
-		if registryAPI == containerdRegistryV2 {
+		if registryAPI == containerdRegistryV2 && len(desired.RegistryAuths) == 0 {
 			err = a.applyContainerdPatchRegistryApiV2(ctx, desired, registry)
 			if err != nil {
 				return err
diff --git a/pkg/cluster/admin_kind_test.go b/pkg/cluster/admin_kind_test.go
index 71e4c6a..1302e3e 100644
--- a/pkg/cluster/admin_kind_test.go
+++ b/pkg/cluster/admin_kind_test.go
@@ -105,7 +105,8 @@ func TestKindClusterConfigWithPullThroughRegistries(t *testing.T) {
 		},
 	}
 
-	kindConfig := a.kindClusterConfig(desired, nil, containerdRegistryV2)
+	kindConfig, err := a.kindClusterConfig(desired, nil, containerdRegistryV2)
+	assert.NoError(t, err)
 
 	expectedMirror := `[plugins."io.containerd.grpc.v1.cri".registry.mirrors."example.com"]
   endpoint = ["http://example.com:5000"]