Add status diff for routing

api/v1alpha1/routing_types.go

@@ -5,6 +5,7 @@ import (
 	"github.com/nais/liberator/pkg/namegen"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/validation"
+	"time"
 )
 
 //+kubebuilder:object:root=true
@@ -117,3 +118,27 @@ func (in *Routing) GetDefaultLabels() map[string]string {
 func (in *Routing) GetCommonSpec() *CommonSpec {
 	panic("common spec not available for routing resource type")
 }
+
+func (in *Routing) SetDefaultStatus() {
+	var msg string
+
+	if in.Status.Summary.Status == "" {
+		msg = "Default Routing status, it has not initialized yet"
+	} else {
+		msg = "Routing is trying to reconcile"
+	}
+
+	in.Status.Summary = Status{
+		Status:    PENDING,
+		Message:   msg,
+		TimeStamp: time.Now().String(),
+	}
+
+	if in.Status.SubResources == nil {
+		in.Status.SubResources = make(map[string]Status)
+	}
+
+	if len(in.Status.Conditions) == 0 {
+		in.Status.Conditions = make([]metav1.Condition, 0)
+	}
+}

api/v1alpha1/status_types.go

@@ -5,7 +5,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/client"
 )
 
-// ApplicationStatus
+// SkiperatorStatus
 //
 // A status field shown on a Skiperator resource which contains information regarding deployment of the resource.
 // +kubebuilder:object:generate=true

config/crd/skiperator.kartverket.no_applications.yaml

@@ -1098,7 +1098,7 @@ spec:
             type: object
           status:
             description: |-
-              ApplicationStatus
+              SkiperatorStatus
 
               A status field shown on a Skiperator resource which contains information regarding deployment of the resource.
             properties:

config/crd/skiperator.kartverket.no_routings.yaml

@@ -72,7 +72,7 @@ spec:
             type: object
           status:
             description: |-
-              ApplicationStatus
+              SkiperatorStatus
 
               A status field shown on a Skiperator resource which contains information regarding deployment of the resource.
             properties:

config/crd/skiperator.kartverket.no_skipjobs.yaml

@@ -840,7 +840,7 @@ spec:
             type: object
           status:
             description: |-
-              ApplicationStatus
+              SkiperatorStatus
 
               A status field shown on a Skiperator resource which contains information regarding deployment of the resource.
             properties:

internal/controllers/application.go

@@ -123,7 +123,7 @@ func (r *ApplicationReconciler) Reconcile(ctx context.Context, req reconcile.Req
 		return common.RequeueWithError(err)
 	}
 
-	//TODO do we need this actually?
+	// TODO do we need this actually?
 	isApplicationMarkedToBeDeleted := application.GetDeletionTimestamp() != nil
 	if isApplicationMarkedToBeDeleted {
 		if err = r.finalizeApplication(application, ctx); err != nil {

internal/controllers/routing.go

@@ -68,6 +68,20 @@ func (r *RoutingReconciler) Reconcile(ctx context.Context, req reconcile.Request
 		return common.DoNotRequeue()
 	}
 
+	tmpStatus := routing.GetStatus().DeepCopy()
+
+	routing.SetDefaultStatus()
+	statusDiff, err := common.GetObjectDiff(tmpStatus, routing.GetStatus())
+	if err != nil {
+		return common.RequeueWithError(err)
+	}
+
+	if len(statusDiff) > 0 {
+		rLog.Info("Status has changed", "diff", statusDiff)
+		err = r.GetClient().Status().Update(ctx, routing)
+		return reconcile.Result{Requeue: true}, err
+	}
+
 	if err := r.setDefaultSpec(ctx, routing); err != nil {
 		rLog.Error(err, "error when trying to set default spec")
 		r.SetErrorState(ctx, routing, err, "error when trying to set default spec", "DefaultSpecFailure")