Send an update notification after the latest package revision is deleted

Author: kushnaidu

pkg/cache/dbcache/dbpackage.go

@@ -25,6 +25,7 @@ import (
 	"go.opentelemetry.io/otel/trace"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
+	"k8s.io/apimachinery/pkg/watch"
 	"k8s.io/klog/v2"
 )
 
@@ -134,9 +135,35 @@ func (p *dbPackage) DeletePackageRevision(ctx context.Context, old repository.Pa
 		return pkgDeleteFromDB(ctx, p.Key())
 	}
 
+	if dbPR.IsLatestRevision() {
+		updateCtx, cancel := context.WithTimeout(context.Background(), 3*time.Minute)
+		defer cancel()
+		go p.sendLatestPkgUpdateNotification(updateCtx)
+	}
+
 	return nil
 }
 
+func (p *dbPackage) sendLatestPkgUpdateNotification(ctx context.Context) {
+	_, span := tracer.Start(ctx, "dbPackage:sendLatestPkgUpdateNotification", trace.WithAttributes())
+	defer span.End()
+
+	klog.V(2).Infoln("dbPackage: sending latest PackageRevision update notification if found")
+
+	latestRevision, err := pkgRevReadLatestPRFromDB(ctx, p.Key())
+	if err != nil {
+		klog.Error(err)
+		return
+	} else if latestRevision == nil {
+		klog.Infof("dbPackage %+v: no new latest PackageRevision found. Notification not sent.", p.Key())
+		return
+	}
+
+	sent := p.repo.repoPRChangeNotifier.NotifyPackageRevisionChange(watch.Modified, latestRevision)
+	klog.Infof("dbcache: sent %d for latest PackageRevision %s/%s", sent, latestRevision.KubeObjectNamespace(), latestRevision.KubeObjectName())
+
+}
+
 func (p *dbPackage) GetLatestRevision(ctx context.Context) int {
 	_, span := tracer.Start(ctx, "dbPackage:GetLatestRevision", trace.WithAttributes())
 	defer span.End()