Add more stupid tests without value

pkg/clustermanager/kube_proxy_test.go

@@ -221,6 +221,18 @@ func TestKubeProxyUpgraderPrepareForUpgradeNoKCP(t *testing.T) {
 	).To(MatchError(ContainSubstring("reading the kubeadm control plane for an upgrade")))
 }
 
+func TestKubeProxyUpgraderPrepareForUpgradeNoKubeProxy(t *testing.T) {
+	g := NewWithT(t)
+	tt := newPrepareKubeProxyTest()
+	tt.kubeProxy = &appsv1.DaemonSet{} // no kube-proxy
+	tt.initClients(t)
+	u := clustermanager.NewKubeProxyUpgrader()
+
+	g.Expect(
+		u.PrepareForUpgrade(tt.ctx, tt.log, tt.managementClient, tt.workloadClient, tt.spec),
+	).To(MatchError(ContainSubstring("reading kube-proxy for upgrade")))
+}
+
 func TestKubeProxyUpgraderPrepareForUpgradeinvalidEKDDTag(t *testing.T) {
 	g := NewWithT(t)
 	tt := newPrepareKubeProxyTest()
@@ -359,6 +371,30 @@ func TestKubeProxyUpgraderCleanupAfterUpgradeSuccessWithReentry(t *testing.T) {
 	).To(Succeed())
 }
 
+func TestKubeProxyCleanupAfterUpgradeNoKubeProxy(t *testing.T) {
+	g := NewWithT(t)
+	tt := newPrepareKubeProxyTest()
+	tt.kubeProxy = &appsv1.DaemonSet{} // no kube-proxy
+	tt.initClients(t)
+	u := clustermanager.NewKubeProxyUpgrader()
+
+	g.Expect(
+		u.CleanupAfterUpgrade(tt.ctx, tt.log, tt.managementClient, tt.workloadClient, tt.spec),
+	).To(MatchError(ContainSubstring("reading kube-proxy for upgrade")))
+}
+
+func TestKubeProxyCleanupAfterUpgradeNoKCP(t *testing.T) {
+	g := NewWithT(t)
+	tt := newPrepareKubeProxyTest()
+	tt.kcp = &controlplanev1.KubeadmControlPlane{} // no kcp
+	tt.initClients(t)
+	u := clustermanager.NewKubeProxyUpgrader()
+
+	g.Expect(
+		u.CleanupAfterUpgrade(tt.ctx, tt.log, tt.managementClient, tt.workloadClient, tt.spec),
+	).To(MatchError(ContainSubstring("reading the kubeadm control plane to cleanup the skip annotations")))
+}
+
 func TestEKSDVersionAndNumberFromTag(t *testing.T) {
 	tests := []struct {
 		name            string
@@ -576,3 +612,21 @@ func TestKubeProxyCLIUpgraderCleanupAfterUpgradeSuccess(t *testing.T) {
 		u.CleanupAfterUpgrade(tt.ctx, tt.spec, managementKubeConfig, workloadKubeConfig),
 	).To(Succeed())
 }
+
+func TestKubeProxyCLICleanupAfterUpgradeErrorWorkloadClusterClient(t *testing.T) {
+	g := NewWithT(t)
+	tt := newPrepareKubeProxyTest()
+	tt.initClients(t)
+	managementKubeConfig := "mngmt.yaml"
+	workloadKubeConfig := "workload.yaml"
+	ctrl := gomock.NewController(t)
+	factory := mocks.NewMockClientFactory(ctrl)
+	factory.EXPECT().BuildClientFromKubeconfig(managementKubeConfig).Return(tt.managementClient, nil)
+	factory.EXPECT().BuildClientFromKubeconfig(workloadKubeConfig).Return(nil, errors.New("building workload client"))
+
+	u := clustermanager.NewKubeProxyCLIUpgrader(test.NewNullLogger(), factory)
+
+	g.Expect(
+		u.CleanupAfterUpgrade(tt.ctx, tt.spec, managementKubeConfig, workloadKubeConfig),
+	).To(MatchError(ContainSubstring("building workload client")))
+}