Update PkgManifest upon catsrc update

The catsrc update sync triggered by the informer does not update pkgmanifest. This commit adds an update mechanism.

pkg/package-server/provider/registry.go

@@ -9,8 +9,6 @@ import (
 	"sync"
 	"time"
 
-	utillabels "github.com/operator-framework/operator-lifecycle-manager/pkg/lib/kubernetes/pkg/util/labels"
-	"github.com/operator-framework/operator-registry/pkg/api"
 	"github.com/sirupsen/logrus"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/connectivity"
@@ -26,9 +24,11 @@ import (
 	operatorslisters "github.com/operator-framework/operator-lifecycle-manager/pkg/api/client/listers/operators/v1alpha1"
 	registrygrpc "github.com/operator-framework/operator-lifecycle-manager/pkg/controller/registry/grpc"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/controller/registry/resolver"
+	utillabels "github.com/operator-framework/operator-lifecycle-manager/pkg/lib/kubernetes/pkg/util/labels"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/lib/queueinformer"
 	"github.com/operator-framework/operator-lifecycle-manager/pkg/package-server/apis/operators"
 	pkglisters "github.com/operator-framework/operator-lifecycle-manager/pkg/package-server/client/listers/operators/internalversion"
+	"github.com/operator-framework/operator-registry/pkg/api"
 )
 
 const (
@@ -189,7 +189,18 @@ func (p *RegistryProvider) syncCatalogSource(obj interface{}) (syncError error)
 		Namespace: source.GetNamespace(),
 		Name:      source.GetName(),
 	}
+
 	if sourceMeta := p.sources.GetMeta(key); sourceMeta != nil && sourceMeta.Address == address {
+		logger.Infof("updating PackageManifest based on CatalogSource changes: %v", key)
+		timeout, cancel := context.WithTimeout(context.Background(), cacheTimeout)
+		defer cancel()
+		client, err := p.registryClient(key)
+		if err != nil {
+			syncError = err
+			return
+		}
+		syncError = p.refreshCache(timeout, client)
+
 		// If the address hasn't changed, don't bother creating a new source
 		logger.Debug("catalog address unchanged, skipping source creation")
 		return

test/e2e/packagemanifest_e2e_test.go

@@ -3,6 +3,7 @@ package e2e
 import (
 	"context"
 	"encoding/json"
+
 	"github.com/blang/semver"
 	. "github.com/onsi/ginkgo"
 	. "github.com/onsi/gomega"
@@ -145,12 +146,13 @@ var _ = Describe("Package Manifest API lists available Operators from Catalog So
 
 	Context("Given a CatalogSource created using gRPC catalog source type", func() {
 		var (
-			packageName   string
-			catalogSource *v1alpha1.CatalogSource
+			packageName, displayName string
+			catalogSource            *v1alpha1.CatalogSource
 		)
 		BeforeEach(func() {
 			sourceName := genName("catalog-")
 			packageName = "etcd-test"
+			displayName = "etcd test catalog"
 			image := "quay.io/olmtest/catsrc-update-test:related"
 
 			catalogSource = &v1alpha1.CatalogSource{
@@ -164,8 +166,9 @@ var _ = Describe("Package Manifest API lists available Operators from Catalog So
 					Labels:    map[string]string{"olm.catalogSource": sourceName},
 				},
 				Spec: v1alpha1.CatalogSourceSpec{
-					SourceType: v1alpha1.SourceTypeGrpc,
-					Image:      image,
+					SourceType:  v1alpha1.SourceTypeGrpc,
+					Image:       image,
+					DisplayName: displayName,
 				},
 			}
 
@@ -195,6 +198,27 @@ var _ = Describe("Package Manifest API lists available Operators from Catalog So
 				"quay.io/coreos/etcd-operator@sha256:c0301e4686c3ed4206e370b42de5a3bd2229b9fb4906cf85f3f30650424abec2",
 			}), "Expected images to exist in the related images list\n")
 		})
+
+		It("updating CatalogSource", func() {
+
+			updatedDisplayName := "updated Name"
+			pm, err := fetchPackageManifest(pmc, testNamespace, packageName, packageManifestHasStatus)
+			Expect(err).NotTo(HaveOccurred(), "error getting package manifest")
+			Expect(pm).ShouldNot(BeNil())
+			Expect(pm.GetName()).Should(Equal(packageName))
+			Expect(pm.Status.CatalogSourceDisplayName).Should(Equal(displayName))
+
+			catalogSource, err = crc.OperatorsV1alpha1().CatalogSources(catalogSource.GetNamespace()).Get(context.TODO(), catalogSource.GetName(), metav1.GetOptions{})
+			Expect(err).NotTo(HaveOccurred(), "error getting catalogSource")
+			catalogSource.Spec.DisplayName = updatedDisplayName
+
+			_, err = crc.OperatorsV1alpha1().CatalogSources(catalogSource.GetNamespace()).Update(context.TODO(), catalogSource, metav1.UpdateOptions{})
+			Expect(err).NotTo(HaveOccurred(), "error updating catalogSource")
+
+			pm, err = fetchPackageManifest(pmc, testNamespace, packageName, packageManifestHasStatus)
+			Expect(err).NotTo(HaveOccurred(), "error getting package manifest after updating catsrc")
+			Expect(pm.Status.CatalogSourceDisplayName).Should(Equal(updatedDisplayName))
+		})
 	})
 })