Setting lastest revision to pipeline status

api/v1alpha1/pipeline_types.go

@@ -137,6 +137,10 @@ type PipelineStatus struct {
 	// +optional
 	Conditions []metav1.Condition `json:"conditions,omitempty"`
 
+	// LatestRevision is the latest revision that's been promoted to the environments.
+	// +optional
+	LatestRevision string `json:"latestRevision,omitempty"`
+
 	// Environments holds environment statuses.
 	// +optional
 	Environments map[string]*EnvironmentStatus `json:"environments"`

controllers/leveltriggered/controller.go

@@ -232,6 +232,10 @@ func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 		return ctrl.Result{}, fmt.Errorf("error removing pending condition: %w", err)
 	}
 
+	if err := r.setLatestRevision(ctx, pipeline, latestRevision); err != nil {
+		return ctrl.Result{}, fmt.Errorf("error setting latest revision: %w", err)
+	}
+
 	for _, env := range pipeline.Spec.Environments[1:] {
 		// if all targets run the latest revision and are ready, we can skip this environment
 		if checkAllTargetsRunRevision(pipeline.Status.Environments[env.Name], latestRevision) && checkAllTargetsAreReady(pipeline.Status.Environments[env.Name]) {
@@ -253,6 +257,24 @@ func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 	return ctrl.Result{}, nil
 }
 
+func (r *PipelineReconciler) setLatestRevision(ctx context.Context, pipeline v1alpha1.Pipeline, revision string) error {
+	pipeline.Status.LatestRevision = revision
+
+	fmt.Println("setting latest revision to", revision)
+	if err := r.patchStatus(ctx, client.ObjectKeyFromObject(&pipeline), pipeline.Status); err != nil {
+		r.emitEventf(
+			&pipeline,
+			corev1.EventTypeWarning,
+			"SetStatus", "Failed to set LatestRevision status for pipeline %s/%s: %s",
+			pipeline.GetNamespace(), pipeline.GetName(),
+			err,
+		)
+		return err
+	}
+
+	return nil
+}
+
 func (r *PipelineReconciler) setPendingCondition(ctx context.Context, pipeline v1alpha1.Pipeline, reason, message string) error {
 	condition := metav1.Condition{
 		Type:    conditions.PromotionPendingCondition,

controllers/leveltriggered/controller_test.go

@@ -122,6 +122,28 @@ func TestReconcile(t *testing.T) {
 		g.Expect(targetStatus.Revision).To(Equal(appRevision))
 	})
 
+	t.Run("sets the lastestRevision status field", func(t *testing.T) {
+		g := testingutils.NewGomegaWithT(t)
+		name := "pipeline-" + rand.String(5)
+		ns := testingutils.NewNamespace(ctx, g, k8sClient)
+		t.Cleanup(deleteObjectCleanup(ctx, g, ns))
+
+		const appRevision = "v1.0.1"
+
+		hr := createApp(ctx, k8sClient, g, name, ns.Name)
+		setAppRevisionAndReadyStatus(ctx, g, hr, appRevision)
+
+		pipeline := newPipeline(name, ns.Name, nil)
+		g.Expect(k8sClient.Create(ctx, pipeline)).To(Succeed())
+
+		checkCondition(ctx, g, client.ObjectKeyFromObject(pipeline), meta.ReadyCondition, metav1.ConditionTrue, v1alpha1.ReconciliationSucceededReason)
+
+		g.Eventually(func() string {
+			p := getPipeline(ctx, g, client.ObjectKeyFromObject(pipeline))
+			return p.Status.LatestRevision
+		}, "5s", "0.2s").Should(Equal(appRevision))
+	})
+
 	t.Run("promotes revision to all environments", func(t *testing.T) {
 		g := testingutils.NewGomegaWithT(t)
 		mockStrategy := setStrategyRegistry(t, pipelineReconciler)