(fix) erroring when replacement not found

Author: gallettilance

pkg/registry/populator.go

@@ -302,15 +302,11 @@ func (i *DirectoryPopulator) getNextReplacesImagesToAdd(imagesToAdd []*ImageInpu
 		// no new images can be added, the current iteration aggregates all the
 		// errors that describe invalid bundles
 		if pkgFoundImages == 0 && pkgRemainingImages > 0 {
-			errs = append(errs, utilerrors.NewAggregate(pkgErrs))
+			errs = append(errs, pkgErrs...)
 		}
 	}
 
-	if len(errs) > 0 {
-		return nil, nil, utilerrors.NewAggregate(errs)
-	}
-
-	return foundImages, remainingImages, nil
+	return foundImages, remainingImages, utilerrors.NewAggregate(errs)
 }
 
 func (i *DirectoryPopulator) loadManifestsSemver(bundle *Bundle, annotations *AnnotationsFile, skippatch bool) error {

pkg/registry/populator_test.go

@@ -686,6 +686,39 @@ func CheckBundlesHaveContentsIfNoPath(t *testing.T, db *sql.DB) {
 	}
 }
 
+func TestDirectoryPopulator(t *testing.T) {
+	db, cleanup := CreateTestDb(t)
+	defer cleanup()
+
+	loader, err := sqlite.NewSQLLiteLoader(db)
+	require.NoError(t, err)
+	require.NoError(t, loader.Migrate(context.TODO()))
+
+	graphLoader, err := sqlite.NewSQLGraphLoaderFromDB(db)
+	require.NoError(t, err)
+
+	query := sqlite.NewSQLLiteQuerierFromDb(db)
+
+	populate := func(bundles map[image.Reference]string) error {
+		return registry.NewDirectoryPopulator(
+			loader,
+			graphLoader,
+			query,
+			bundles,
+			make(map[string]map[image.Reference]string),
+			false).Populate(registry.ReplacesMode)
+	}
+	add := map[image.Reference]string{
+		image.SimpleReference("quay.io/test/etcd.0.9.2"):        "../../bundles/etcd.0.9.2",
+		image.SimpleReference("quay.io/test/prometheus.0.22.2"): "../../bundles/prometheus.0.22.2",
+	}
+	expectedErr := errors.NewAggregate([]error{
+		fmt.Errorf("Invalid bundle %s, bundle specifies a non-existent replacement %s", "etcdoperator.v0.9.2", "etcdoperator.v0.9.0"),
+		fmt.Errorf("Invalid bundle %s, bundle specifies a non-existent replacement %s", "prometheusoperator.0.22.2", "prometheusoperator.0.15.0"),
+	})
+	require.ElementsMatch(t, expectedErr, populate(add))
+}
+
 func TestDeprecateBundle(t *testing.T) {
 	type args struct {
 		bundles []string
@@ -898,6 +931,34 @@ func TestOverwrite(t *testing.T) {
 		args        args
 		expected    expected
 	}{
+		{
+			description: "OverwriteBundle/DefaultBehavior",
+			args: args{
+				firstAdd: getBundleRefs([]string{"prometheus.0.14.0"}),
+				secondAdd: map[image.Reference]string{
+					image.SimpleReference("quay.io/test/etcd.0.9.2"):        "../../bundles/etcd.0.9.2",
+					image.SimpleReference("quay.io/test/prometheus.0.22.2"): "../../bundles/prometheus.0.22.2",
+				},
+				overwrites: nil,
+			},
+			expected: expected{
+				err: errors.NewAggregate([]error{
+					fmt.Errorf("Invalid bundle %s, bundle specifies a non-existent replacement %s", "etcdoperator.v0.9.2", "etcdoperator.v0.9.0"),
+					fmt.Errorf("Invalid bundle %s, bundle specifies a non-existent replacement %s", "prometheusoperator.0.22.2", "prometheusoperator.0.15.0"),
+				}),
+				remainingBundles: []string{
+					"quay.io/test/prometheus.0.14.0/preview",
+				},
+				remainingPkgChannels: pkgChannel{
+					"prometheus": []string{
+						"preview",
+					},
+				},
+				remainingDefaultChannels: map[string]string{
+					"prometheus": "preview",
+				},
+			},
+		},
 		{
 			description: "OverwriteBundle/SimpleCsvChange",
 			args: args{

pkg/registry/replacesgraphloader.go

@@ -21,5 +21,10 @@ func (r *ReplacesGraphLoader) CanAdd(bundle *Bundle, graph *Package) (bool, erro
 	}
 
 	// check that the bundle can be added
-	return graph.HasCsv(replaces), nil
+	if !graph.HasCsv(replaces) {
+		return false, fmt.Errorf("Invalid bundle %s, bundle specifies a non-existent replacement %s", bundle.Name, replaces)
+	}
+
+	return true, nil
+
 }