fixup PR comments

Signed-off-by: Joe Lanford <[email protected]>

Author: joelanford

catalogd/internal/controllers/core/clustercatalog_controller.go

@@ -234,12 +234,14 @@ func (r *ClusterCatalogReconciler) reconcile(ctx context.Context, catalog *catal
 	}
 
 	if catalog.Spec.Source.Type != catalogdv1.SourceTypeImage {
-		panic(fmt.Sprintf("programmer error: source type %q is unable to handle specified catalog source type %q", catalogdv1.SourceTypeImage, catalog.Spec.Source.Type))
+		err := reconcile.TerminalError(fmt.Errorf("unknown source type %q", catalog.Spec.Source.Type))
+		updateStatusProgressing(&catalog.Status, catalog.GetGeneration(), err)
+		return ctrl.Result{}, err
 	}
 	if catalog.Spec.Source.Image == nil {
-		unpackErr := reconcile.TerminalError(fmt.Errorf("error parsing catalog, catalog %s has a nil image source", catalog.Name))
-		updateStatusProgressing(&catalog.Status, catalog.GetGeneration(), unpackErr)
-		return ctrl.Result{}, unpackErr
+		err := reconcile.TerminalError(fmt.Errorf("error parsing catalog, catalog %s has a nil image source", catalog.Name))
+		updateStatusProgressing(&catalog.Status, catalog.GetGeneration(), err)
+		return ctrl.Result{}, err
 	}
 
 	fsys, canonicalRef, unpackTime, err := r.ImagePuller.Pull(ctx, catalog.Name, catalog.Spec.Source.Image.Ref, r.ImageCache)
@@ -271,7 +273,7 @@ func (r *ClusterCatalogReconciler) reconcile(ctx context.Context, catalog *catal
 		observedGeneration: catalog.GetGeneration(),
 	}
 	r.storedCatalogsMu.Unlock()
-	return nextPollResult(time.Now(), catalog), nil
+	return nextPollResult(lastSuccessfulPoll, catalog), nil
 }
 
 func (r *ClusterCatalogReconciler) getCurrentState(catalog *catalogdv1.ClusterCatalog) (*catalogdv1.ClusterCatalogStatus, storedCatalogData, bool) {
@@ -450,7 +452,7 @@ func (r *ClusterCatalogReconciler) deleteCatalogCache(ctx context.Context, catal
 		return err
 	}
 	updateStatusNotServing(&catalog.Status, catalog.GetGeneration())
-	if err := r.ImageCache.DeleteID(ctx, catalog.Name); err != nil {
+	if err := r.ImageCache.Delete(ctx, catalog.Name); err != nil {
 		updateStatusProgressing(&catalog.Status, catalog.GetGeneration(), err)
 		return err
 	}

catalogd/internal/controllers/core/clustercatalog_controller_test.go

@@ -5,7 +5,6 @@ import (
 	"errors"
 	"fmt"
 	"io/fs"
-	"iter"
 	"net/http"
 	"testing"
 	"testing/fstest"
@@ -14,7 +13,6 @@ import (
 	"github.com/containers/image/v5/docker/reference"
 	"github.com/google/go-cmp/cmp"
 	"github.com/google/go-cmp/cmp/cmpopts"
-	ocispecv1 "github.com/opencontainers/image-spec/specs-go/v1"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 	"k8s.io/apimachinery/pkg/api/meta"
@@ -28,50 +26,6 @@ import (
 	imageutil "github.com/operator-framework/operator-controller/internal/util/image"
 )
 
-var _ imageutil.Puller = &MockPuller{}
-
-// MockPuller is a utility for mocking out an imageutil.Puller interface
-type MockPuller struct {
-	// result is the result that should be returned when MockPuller.Unpack is called
-	fsys    fs.FS
-	ref     reference.Canonical
-	modTime time.Time
-
-	// error is the error to be returned when MockPuller.Unpack is called
-	pullError error
-}
-
-func (ms *MockPuller) Pull(_ context.Context, _, _ string, _ imageutil.Cache) (fs.FS, reference.Canonical, time.Time, error) {
-	if ms.pullError != nil {
-		return nil, nil, time.Time{}, ms.pullError
-	}
-
-	return ms.fsys, ms.ref, ms.modTime, nil
-}
-
-var _ imageutil.Cache = (*MockCache)(nil)
-
-type MockCache struct {
-	// cleanupError is the error to be returned when MockPuller.Cleanup is called
-	cleanupError error
-}
-
-func (ms *MockCache) Fetch(_ context.Context, _ string, _ reference.Canonical) (fs.FS, time.Time, error) {
-	panic("not implemented")
-}
-
-func (ms *MockCache) Store(_ context.Context, _ string, _ reference.Named, _ reference.Canonical, _ ocispecv1.Image, _ iter.Seq[imageutil.LayerData]) (fs.FS, time.Time, error) {
-	panic("not implemented")
-}
-
-func (ms *MockCache) GarbageCollect(_ context.Context, _ string, _ reference.Canonical) error {
-	panic("not implemented")
-}
-
-func (ms *MockCache) DeleteID(_ context.Context, _ string) error {
-	return ms.cleanupError
-}
-
 var _ storage.Instance = &MockStore{}
 
 type MockStore struct {
@@ -111,13 +65,13 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		expectedError   error
 		shouldPanic     bool
 		expectedCatalog *catalogdv1.ClusterCatalog
-		source          imageutil.Puller
+		puller          imageutil.Puller
 		cache           imageutil.Cache
 		store           storage.Instance
 	}{
 		{
 			name:   "invalid source type, panics",
-			source: &MockPuller{},
+			puller: &imageutil.MockPuller{},
 			store:  &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
 				ObjectMeta: metav1.ObjectMeta{
@@ -154,9 +108,9 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name:          "valid source type, unpack returns error, status updated to reflect error state and error is returned",
-			expectedError: fmt.Errorf("source catalog content: %w", fmt.Errorf("mocksource error")),
-			source: &MockPuller{
-				pullError: errors.New("mocksource error"),
+			expectedError: fmt.Errorf("source catalog content: %w", fmt.Errorf("mockpuller error")),
+			puller: &imageutil.MockPuller{
+				Error: errors.New("mockpuller error"),
 			},
 			store: &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
@@ -199,9 +153,9 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name:          "valid source type, unpack returns terminal error, status updated to reflect terminal error state(Blocked) and error is returned",
-			expectedError: fmt.Errorf("source catalog content: %w", reconcile.TerminalError(fmt.Errorf("mocksource terminal error"))),
-			source: &MockPuller{
-				pullError: reconcile.TerminalError(errors.New("mocksource terminal error")),
+			expectedError: fmt.Errorf("source catalog content: %w", reconcile.TerminalError(fmt.Errorf("mockpuller terminal error"))),
+			puller: &imageutil.MockPuller{
+				Error: reconcile.TerminalError(errors.New("mockpuller terminal error")),
 			},
 			store: &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
@@ -244,9 +198,9 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name: "valid source type, unpack state == Unpacked, should reflect in status that it's progressing, and is serving",
-			source: &MockPuller{
-				fsys: &fstest.MapFS{},
-				ref:  mustRef(t, "my.org/someimage@sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"),
+			puller: &imageutil.MockPuller{
+				ImageFS: &fstest.MapFS{},
+				Ref:     mustRef(t, "my.org/someimage@sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"),
 			},
 			store: &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
@@ -303,8 +257,8 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		{
 			name:          "valid source type, unpack state == Unpacked, storage fails, failure reflected in status and error returned",
 			expectedError: fmt.Errorf("error storing fbc: mockstore store error"),
-			source: &MockPuller{
-				fsys: &fstest.MapFS{},
+			puller: &imageutil.MockPuller{
+				ImageFS: &fstest.MapFS{},
 			},
 			store: &MockStore{
 				shouldError: true,
@@ -349,8 +303,8 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name: "storage finalizer not set, storage finalizer gets set",
-			source: &MockPuller{
-				fsys: &fstest.MapFS{},
+			puller: &imageutil.MockPuller{
+				ImageFS: &fstest.MapFS{},
 			},
 			store: &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
@@ -383,8 +337,8 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name: "storage finalizer set, catalog deletion timestamp is not zero (or nil), finalizer removed",
-			source: &MockPuller{
-				fsys: &fstest.MapFS{},
+			puller: &imageutil.MockPuller{
+				ImageFS: &fstest.MapFS{},
 			},
 			store: &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
@@ -456,8 +410,8 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		{
 			name:          "storage finalizer set, catalog deletion timestamp is not zero (or nil), storage delete failed, error returned, finalizer not removed and catalog continues serving",
 			expectedError: fmt.Errorf("finalizer %q failed: %w", fbcDeletionFinalizer, fmt.Errorf("mockstore delete error")),
-			source: &MockPuller{
-				fsys: &fstest.MapFS{},
+			puller: &imageutil.MockPuller{
+				ImageFS: &fstest.MapFS{},
 			},
 			store: &MockStore{
 				shouldError: true,
@@ -525,9 +479,9 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name:          "storage finalizer set, catalog deletion timestamp is not zero (or nil), unpack cleanup failed, error returned, finalizer not removed but catalog stops serving",
-			expectedError: fmt.Errorf("finalizer %q failed: %w", fbcDeletionFinalizer, fmt.Errorf("mocksource cleanup error")),
-			source:        &MockPuller{},
-			cache:         &MockCache{fmt.Errorf("mocksource cleanup error")},
+			expectedError: fmt.Errorf("finalizer %q failed: %w", fbcDeletionFinalizer, fmt.Errorf("mockcache delete error")),
+			puller:        &imageutil.MockPuller{},
+			cache:         &imageutil.MockCache{DeleteErr: fmt.Errorf("mockcache delete error")},
 			store: &MockStore{
 				shouldError: false,
 			},
@@ -592,8 +546,8 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name: "catalog availability set to disabled, status.urls should get unset",
-			source: &MockPuller{
-				fsys: &fstest.MapFS{},
+			puller: &imageutil.MockPuller{
+				ImageFS: &fstest.MapFS{},
 			},
 			store: &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
@@ -663,8 +617,8 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		},
 		{
 			name: "catalog availability set to disabled, finalizer should get removed",
-			source: &MockPuller{
-				fsys: &fstest.MapFS{},
+			puller: &imageutil.MockPuller{
+				ImageFS: &fstest.MapFS{},
 			},
 			store: &MockStore{},
 			catalog: &catalogdv1.ClusterCatalog{
@@ -738,13 +692,13 @@ func TestCatalogdControllerReconcile(t *testing.T) {
 		t.Run(tt.name, func(t *testing.T) {
 			reconciler := &ClusterCatalogReconciler{
 				Client:         nil,
-				ImagePuller:    tt.source,
+				ImagePuller:    tt.puller,
 				ImageCache:     tt.cache,
 				Storage:        tt.store,
 				storedCatalogs: map[string]storedCatalogData{},
 			}
 			if reconciler.ImageCache == nil {
-				reconciler.ImageCache = &MockCache{}
+				reconciler.ImageCache = &imageutil.MockCache{}
 			}
 			require.NoError(t, reconciler.setupFinalizers())
 			ctx := context.Background()
@@ -818,9 +772,9 @@ func TestPollingRequeue(t *testing.T) {
 		t.Run(name, func(t *testing.T) {
 			reconciler := &ClusterCatalogReconciler{
 				Client: nil,
-				ImagePuller: &MockPuller{
-					fsys: &fstest.MapFS{},
-					ref:  mustRef(t, "my.org/someimage@sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"),
+				ImagePuller: &imageutil.MockPuller{
+					ImageFS: &fstest.MapFS{},
+					Ref:     mustRef(t, "my.org/someimage@sha256:e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"),
 				},
 				Storage:        &MockStore{},
 				storedCatalogs: map[string]storedCatalogData{},
@@ -1037,7 +991,7 @@ func TestPollingReconcilerUnpack(t *testing.T) {
 			}
 			reconciler := &ClusterCatalogReconciler{
 				Client:         nil,
-				ImagePuller:    &MockPuller{pullError: errors.New("mocksource error")},
+				ImagePuller:    &imageutil.MockPuller{Error: errors.New("mockpuller error")},
 				Storage:        &MockStore{},
 				storedCatalogs: scd,
 			}

cmd/operator-controller/main.go

@@ -28,7 +28,6 @@ import (
 	"time"
 
 	"github.com/containers/image/v5/types"
-	"github.com/go-logr/logr"
 	"github.com/spf13/pflag"
 	corev1 "k8s.io/api/core/v1"
 	apiextensionsv1client "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1"
@@ -47,6 +46,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 	crfinalizer "sigs.k8s.io/controller-runtime/pkg/finalizer"
 	"sigs.k8s.io/controller-runtime/pkg/healthz"
+	"sigs.k8s.io/controller-runtime/pkg/log"
 	"sigs.k8s.io/controller-runtime/pkg/metrics/filters"
 	"sigs.k8s.io/controller-runtime/pkg/metrics/server"
 
@@ -313,7 +313,7 @@ func main() {
 				DockerCertPath: pullCasDir,
 				OCICertPath:    pullCasDir,
 			}
-			logger := logr.FromContextOrDiscard(ctx)
+			logger := log.FromContext(ctx)
 			if _, err := os.Stat(authFilePath); err == nil && globalPullSecretKey != nil {
 				logger.Info("using available authentication information for pulling image")
 				srcContext.AuthFilePath = authFilePath
@@ -328,7 +328,7 @@ func main() {
 
 	clusterExtensionFinalizers := crfinalizer.NewFinalizers()
 	if err := clusterExtensionFinalizers.Register(controllers.ClusterExtensionCleanupUnpackCacheFinalizer, finalizers.FinalizerFunc(func(ctx context.Context, obj client.Object) (crfinalizer.Result, error) {
-		return crfinalizer.Result{}, imageCache.DeleteID(ctx, obj.GetName())
+		return crfinalizer.Result{}, imageCache.Delete(ctx, obj.GetName())
 	})); err != nil {
 		setupLog.Error(err, "unable to register finalizer", "finalizerKey", controllers.ClusterExtensionCleanupUnpackCacheFinalizer)
 		os.Exit(1)