Add error coverage

Author: josvazg

internal/generated/controller/flexcluster/handler_v20250312_test.go

@@ -70,6 +70,27 @@ func TestHandleInitial(t *testing.T) {
 			},
 			want: reenqueueResult(state.StateCreating, "Creating Flex Cluster."),
 		},
+		{
+			title:       "corrupt flex type cluster",
+			flexCluster: withFlexGVK(defaultTestFlexCluster("test-cluster1", "ns"), "bad-kind", "bad-api-version"),
+			kubeObjects: []client.Object{
+				defaultTestGroup("some-group", "ns1", nil),
+			},
+			want:    ctrlstate.Result{NextState: state.StateInitial},
+			wantErr: "failed to get dependencies: nil flex cluster",
+		},
+		{
+			title:       "corrupt api reply",
+			flexCluster: defaultTestFlexCluster("test-cluster", "ns1"),
+			kubeObjects: []client.Object{
+				defaultTestGroup("test-group", "ns1", nil),
+			},
+			atlasCreateFlexClusterFunc: func() (*v20250312sdk.FlexClusterDescription20241113, *http.Response, error) {
+				return nil, nil, nil
+			},
+			want:    ctrlstate.Result{NextState: state.StateInitial},
+			wantErr: "failed to get dependencies: nil flex cluster",
+		},
 		{
 			title:       "missing group",
 			flexCluster: setGroupRef(defaultTestFlexCluster("test-cluster1", "ns"), "not-found"),
@@ -99,12 +120,15 @@ func TestHandleInitial(t *testing.T) {
 		},
 	} {
 		t.Run(tc.title, func(t *testing.T) {
-			allObjects := append([]client.Object{tc.flexCluster}, tc.kubeObjects...)
-			fakeClient := fake.NewClientBuilder().
-				WithScheme(scheme).
-				WithObjects(allObjects...).
-				WithStatusSubresource(tc.flexCluster).
-				Build()
+			allObjects := tc.kubeObjects
+			clientBuilder := fake.NewClientBuilder().WithScheme(scheme)
+			if tc.flexCluster != nil {
+				allObjects = append([]client.Object{tc.flexCluster}, tc.kubeObjects...)
+				clientBuilder = clientBuilder.WithObjects(allObjects...).WithStatusSubresource(tc.flexCluster)
+			} else {
+				clientBuilder = clientBuilder.WithObjects(allObjects...)
+			}
+			fakeClient := clientBuilder.Build()
 
 			flexAPI := mockadmin.NewFlexClustersApi(t)
 			if tc.atlasCreateFlexClusterFunc != nil {
@@ -197,6 +221,12 @@ func defaultTestFlexCluster(name, namespace string) *akov2generated.FlexCluster
 	}
 }
 
+func withFlexGVK(flexCluster *akov2generated.FlexCluster, kind string, apiVersion string) *akov2generated.FlexCluster {
+	flexCluster.TypeMeta.Kind = kind
+	flexCluster.TypeMeta.APIVersion = apiVersion
+	return flexCluster
+}
+
 func reenqueueResult(state state.ResourceState, msg string) ctrlstate.Result {
 	return ctrlstate.Result{
 		Result:    reconcile.Result{RequeueAfter: result.DefaultRequeueTIme},