check the underlying storage for existing cluster catalog content

Signed-off-by: Igor Troyanovsky <itroyano@redhat.com>

pkg/controllers/core/clustercatalog_controller.go

@@ -132,13 +132,11 @@ func (r *ClusterCatalogReconciler) reconcile(ctx context.Context, catalog *v1alp
 		controllerutil.RemoveFinalizer(catalog, fbcDeletionFinalizer)
 		return ctrl.Result{}, nil
 	}
-	// if ResolvedSource is not nil, it indicates that this is not the first time we're
-	// unpacking this catalog.
-	if catalog.Status.ResolvedSource != nil {
-		if !unpackAgain(catalog) {
-			return ctrl.Result{}, nil
-		}
+
+	if !r.needsUnpacking(catalog) {
+		return ctrl.Result{}, nil
 	}
+
 	unpackResult, err := r.Unpacker.Unpack(ctx, catalog)
 	if err != nil {
 		return ctrl.Result{}, updateStatusUnpackFailing(&catalog.Status, fmt.Errorf("source bundle content: %v", err))
@@ -247,7 +245,15 @@ func updateStatusStorageDeleteError(status *v1alpha1.ClusterCatalogStatus, err e
 	return err
 }
 
-func unpackAgain(catalog *v1alpha1.ClusterCatalog) bool {
+func (r *ClusterCatalogReconciler) needsUnpacking(catalog *v1alpha1.ClusterCatalog) bool {
+	// if ResolvedSource is nil, it indicates that this is the first time we're
+	// unpacking this catalog.
+	if catalog.Status.ResolvedSource == nil {
+		return true
+	}
+	if !r.Storage.ContentExists(catalog.Name) {
+		return true
+	}
 	// if the spec.Source.Image.Ref was changed, unpack the new ref
 	if catalog.Spec.Source.Image.Ref != catalog.Status.ResolvedSource.Image.Ref {
 		return true

pkg/controllers/core/clustercatalog_controller_test.go

@@ -75,6 +75,10 @@ func (m MockStore) StorageServerHandler() http.Handler {
 	panic("not needed")
 }
 
+func (m MockStore) ContentExists(_ string) bool {
+	return true
+}
+
 func TestCatalogdControllerReconcile(t *testing.T) {
 	for _, tt := range []struct {
 		name            string

pkg/storage/localdir.go

@@ -60,6 +60,18 @@ func (s LocalDir) StorageServerHandler() http.Handler {
 	return mux
 }
 
+func (s LocalDir) ContentExists(catalog string) bool {
+	file, err := os.Stat(s.ContentURL(catalog))
+	if err != nil {
+		return false
+	}
+	if !file.Mode().IsRegular() {
+		// path is not valid content
+		return false
+	}
+	return true
+}
+
 // filesOnlyFilesystem is a file system that can open only regular
 // files from the underlying filesystem. All other file types result
 // in os.ErrNotExists

pkg/storage/storage.go

@@ -15,4 +15,5 @@ type Instance interface {
 	Delete(catalog string) error
 	ContentURL(catalog string) string
 	StorageServerHandler() http.Handler
+	ContentExists(catalog string) bool
 }