Add RolloutError unit test

Signed-off-by: Per Goncalves da Silva <[email protected]>

Author: Per Goncalves da Silva

internal/operator-controller/controllers/clusterextensionrevision_controller_test.go

@@ -2,13 +2,14 @@ package controllers_test
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"testing"
 	"time"
 
 	"github.com/stretchr/testify/require"
 	corev1 "k8s.io/api/core/v1"
-	"k8s.io/apimachinery/pkg/api/errors"
+	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	"k8s.io/apimachinery/pkg/api/meta"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
@@ -32,18 +33,19 @@ import (
 	"github.com/operator-framework/operator-controller/internal/operator-controller/labels"
 )
 
-func Test_ClusterExtensionRevisionReconciler_Reconcile_RevisionProgression(t *testing.T) {
+func Test_ClusterExtensionRevisionReconciler_Reconcile_RevisionReconciliation(t *testing.T) {
 	const (
 		clusterExtensionRevisionName = "test-ext-1"
 	)
 
 	testScheme := newScheme(t)
 
 	for _, tc := range []struct {
-		name           string
-		existingObjs   func() []client.Object
-		revisionResult machinery.RevisionResult
-		validate       func(*testing.T, client.Client)
+		name                 string
+		existingObjs         func() []client.Object
+		revisionResult       machinery.RevisionResult
+		revisionReconcileErr error
+		validate             func(*testing.T, client.Client)
 	}{
 		{
 			name:           "sets teardown finalizer",
@@ -175,6 +177,30 @@ func Test_ClusterExtensionRevisionReconciler_Reconcile_RevisionProgression(t *te
 				require.Equal(t, int64(1), cond.ObservedGeneration)
 			},
 		},
+		{
+			name:                 "set Progressing:True:RolloutError when there's an error reconciling the revision",
+			revisionReconcileErr: errors.New("some error"),
+
+			existingObjs: func() []client.Object {
+				ext := newTestClusterExtension()
+				rev1 := newTestClusterExtensionRevision(clusterExtensionRevisionName)
+				require.NoError(t, controllerutil.SetControllerReference(ext, rev1, testScheme))
+				return []client.Object{ext, rev1}
+			},
+			validate: func(t *testing.T, c client.Client) {
+				rev := &ocv1.ClusterExtensionRevision{}
+				err := c.Get(t.Context(), client.ObjectKey{
+					Name: clusterExtensionRevisionName,
+				}, rev)
+				require.NoError(t, err)
+				cond := meta.FindStatusCondition(rev.Status.Conditions, ocv1.TypeProgressing)
+				require.NotNil(t, cond)
+				require.Equal(t, metav1.ConditionTrue, cond.Status)
+				require.Equal(t, ocv1.ClusterExtensionRevisionReasonRolloutError, cond.Reason)
+				require.Equal(t, "some error", cond.Message)
+				require.Equal(t, int64(1), cond.ObservedGeneration)
+			},
+		},
 		{
 			name: "set Progressing:True:RollingOut condition while revision is transitioning",
 			revisionResult: mockRevisionResult{
@@ -317,7 +343,7 @@ func Test_ClusterExtensionRevisionReconciler_Reconcile_RevisionProgression(t *te
 				Client: testClient,
 				RevisionEngine: &mockRevisionEngine{
 					reconcile: func(ctx context.Context, rev machinerytypes.Revision, opts ...machinerytypes.RevisionReconcileOption) (machinery.RevisionResult, error) {
-						return tc.revisionResult, nil
+						return tc.revisionResult, tc.revisionReconcileErr
 					},
 				},
 				TrackingCache: &mockTrackingCache{},
@@ -327,9 +353,13 @@ func Test_ClusterExtensionRevisionReconciler_Reconcile_RevisionProgression(t *te
 				},
 			})
 
-			// reconcile cluster extensionr evision
+			// reconcile cluster extension revision
 			require.Equal(t, ctrl.Result{}, result)
-			require.NoError(t, err)
+			if tc.revisionReconcileErr == nil {
+				require.NoError(t, err)
+			} else {
+				require.Contains(t, err.Error(), tc.revisionReconcileErr.Error())
+			}
 
 			// validate test case
 			tc.validate(t, testClient)
@@ -517,7 +547,7 @@ func Test_ClusterExtensionRevisionReconciler_Reconcile_Deletion(t *testing.T) {
 					Name: clusterExtensionRevisionName,
 				}, rev)
 				require.Error(t, err)
-				require.True(t, errors.IsNotFound(err))
+				require.True(t, apierrors.IsNotFound(err))
 			},
 		},
 		{