reconcilers: include artifact digest in event meta

hiddeco · hiddeco · commit a72badf16b44 · 2023-02-14T12:48:36.000+01:00
Signed-off-by: Hidde Beydals &lt;hello@hidde.co&gt;
diff --git a/controllers/bucket_controller.go b/controllers/bucket_controller.go
@@ -405,6 +405,9 @@ func (r *BucketReconciler) notify(ctx context.Context, oldObj, newObj *sourcev1.
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,
 		}
+		if newObj.Status.Artifact.Digest != "" {
+			annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
+		}
 
 		var oldChecksum string
 		if oldObj.GetArtifact() != nil {
diff --git a/controllers/gitrepository_controller.go b/controllers/gitrepository_controller.go
@@ -327,6 +327,9 @@ func (r *GitRepositoryReconciler) notify(ctx context.Context, oldObj, newObj *so
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,
 		}
+		if newObj.Status.Artifact.Digest != "" {
+			annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
+		}
 
 		var oldChecksum string
 		if oldObj.GetArtifact() != nil {
diff --git a/controllers/helmchart_controller.go b/controllers/helmchart_controller.go
@@ -330,6 +330,9 @@ func (r *HelmChartReconciler) notify(ctx context.Context, oldObj, newObj *source
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,
 		}
+		if newObj.Status.Artifact.Digest != "" {
+			annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
+		}
 
 		var oldChecksum string
 		if oldObj.GetArtifact() != nil {
diff --git a/controllers/helmrepository_controller.go b/controllers/helmrepository_controller.go
@@ -291,6 +291,9 @@ func (r *HelmRepositoryReconciler) notify(ctx context.Context, oldObj, newObj *s
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,
 		}
+		if newObj.Status.Artifact.Digest != "" {
+			annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
+		}
 
 		humanReadableSize := "unknown size"
 		if size := newObj.Status.Artifact.Size; size != nil {
diff --git a/controllers/ocirepository_controller.go b/controllers/ocirepository_controller.go
@@ -1140,6 +1140,9 @@ func (r *OCIRepositoryReconciler) notify(ctx context.Context, oldObj, newObj *so
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,
 			fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,
 		}
+		if newObj.Status.Artifact.Digest != "" {
+			annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest
+		}
 
 		var oldChecksum string
 		if oldObj.GetArtifact() != nil {

Original file line number	Diff line number	Diff line change
`@@ -405,6 +405,9 @@ func (r BucketReconciler) notify(ctx context.Context, oldObj, newObj sourcev1.`
`405`	`405`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,`
`406`	`406`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,`
`407`	`407`	`}`
	`408`	`+ if newObj.Status.Artifact.Digest != "" {`
	`409`	`+ annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest`
	`410`	`+ }`
`408`	`411`
`409`	`412`	`var oldChecksum string`
`410`	`413`	`if oldObj.GetArtifact() != nil {`
Original file line number	Diff line number	Diff line change
`@@ -327,6 +327,9 @@ func (r GitRepositoryReconciler) notify(ctx context.Context, oldObj, newObj so`
`327`	`327`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,`
`328`	`328`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,`
`329`	`329`	`}`
	`330`	`+ if newObj.Status.Artifact.Digest != "" {`
	`331`	`+ annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest`
	`332`	`+ }`
`330`	`333`
`331`	`334`	`var oldChecksum string`
`332`	`335`	`if oldObj.GetArtifact() != nil {`
Original file line number	Diff line number	Diff line change
`@@ -330,6 +330,9 @@ func (r HelmChartReconciler) notify(ctx context.Context, oldObj, newObj source`
`330`	`330`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,`
`331`	`331`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,`
`332`	`332`	`}`
	`333`	`+ if newObj.Status.Artifact.Digest != "" {`
	`334`	`+ annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest`
	`335`	`+ }`
`333`	`336`
`334`	`337`	`var oldChecksum string`
`335`	`338`	`if oldObj.GetArtifact() != nil {`
Original file line number	Diff line number	Diff line change
`@@ -291,6 +291,9 @@ func (r HelmRepositoryReconciler) notify(ctx context.Context, oldObj, newObj s`
`291`	`291`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,`
`292`	`292`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,`
`293`	`293`	`}`
	`294`	`+ if newObj.Status.Artifact.Digest != "" {`
	`295`	`+ annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest`
	`296`	`+ }`
`294`	`297`
`295`	`298`	`humanReadableSize := "unknown size"`
`296`	`299`	`if size := newObj.Status.Artifact.Size; size != nil {`
Original file line number	Diff line number	Diff line change
`@@ -1140,6 +1140,9 @@ func (r OCIRepositoryReconciler) notify(ctx context.Context, oldObj, newObj so`
`1140`	`1140`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaRevisionKey): newObj.Status.Artifact.Revision,`
`1141`	`1141`	`fmt.Sprintf("%s/%s", sourcev1.GroupVersion.Group, eventv1.MetaChecksumKey): newObj.Status.Artifact.Checksum,`
`1142`	`1142`	`}`
	`1143`	`+ if newObj.Status.Artifact.Digest != "" {`
	`1144`	`+ annotations[sourcev1.GroupVersion.Group+"/digest"] = newObj.Status.Artifact.Digest`
	`1145`	`+ }`
`1143`	`1146`
`1144`	`1147`	`var oldChecksum string`
`1145`	`1148`	`if oldObj.GetArtifact() != nil {`