add heart beat

controllers/collector.go

@@ -68,6 +68,7 @@ type AppAPIInfo struct {
 	AppName      string       `json:"app_name"`
 	Type         string       `json:"type"`
 	HosstedHelm  bool         `json:"hossted_helm"`
+	HeartBeat    bool         `json:"heart_beat,omitempty"`
 	OptionsState OptionsState `json:"options_state,omitempty"`
 }
 

controllers/heart_beat.go

@@ -0,0 +1,59 @@
+package controllers
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"log"
+	"os"
+	"time"
+
+	"github.com/go-logr/logr"
+	hosstedcomv1 "github.com/hossted/hossted-operator/api/v1"
+	internalHTTP "github.com/hossted/hossted-operator/pkg/http"
+)
+
+func (r *HosstedProjectReconciler) StartPeriodicUpdate(ctx context.Context, instance *hosstedcomv1.Hosstedproject, logger logr.Logger) {
+	ticker := time.NewTicker(10 * time.Minute)
+	defer ticker.Stop()
+
+	for {
+		select {
+		case <-ticker.C:
+			if err := r.runClusterUpdate(ctx, instance, logger); err != nil {
+				log.Println("Error during periodic update:", err)
+			}
+		case <-ctx.Done():
+			log.Println("Ticker stopped:", ctx.Err())
+			return
+		}
+	}
+}
+
+// Extracted function for cluster update logic
+func (r *HosstedProjectReconciler) runClusterUpdate(ctx context.Context, instance *hosstedcomv1.Hosstedproject, logger logr.Logger) error {
+	collector, _, _, err := r.collector(ctx, instance)
+	if err != nil {
+		//return err
+	}
+
+	for i := range collector {
+		collector[i].AppAPIInfo.ClusterUUID = instance.Status.ClusterUUID
+		collector[i].AppAPIInfo.HeartBeat = true
+		collectorJson, err := json.Marshal(collector[i])
+		if err != nil {
+			//return err
+		}
+
+		appUUIDRegPath := os.Getenv("HOSSTED_API_URL") + "/apps"
+		resp, err := internalHTTP.HttpRequest(collectorJson, appUUIDRegPath)
+		if err != nil {
+			//return err
+		}
+
+		logger.Info(fmt.Sprintf("Sending heartbeat req no [%d] to hossted API", i), "appUUID", collector[i].AppAPIInfo.AppUUID, "resp", resp.ResponseBody, "statuscode", resp.StatusCode)
+	}
+
+	log.Println("Periodic cluster update successful")
+	return nil
+}

controllers/hosstedproject_controller.go

@@ -92,6 +92,7 @@ func (r *HosstedProjectReconciler) Reconcile(ctx context.Context, req ctrl.Reque
 		if err != nil {
 			return ctrl.Result{}, err
 		} else {
+			r.StartPeriodicUpdate(ctx, instance, logger)
 			return ctrl.Result{RequeueAfter: r.ReconcileDuration}, nil
 		}
 	} else {
@@ -597,19 +598,6 @@ func (r *HosstedProjectReconciler) handleVulnReports(ctx context.Context, namesp
 	return nil
 }
 
-// // handleExistingCluster handles reconciliation for an existing cluster.
-// func (r *HosstedProjectReconciler) registerDns(ctx context.Context, instance *hosstedcomv1.Hosstedproject) {
-// 	dnsrequest, _ := r.getDns(ctx, instance)
-// 	body, _ := json.Marshal(dnsrequest)
-// 	dnsURL := os.Getenv("HOSSTED_API_URL") + "/clusters/dns"
-// 	resp, _ := internalHTTP.HttpRequest(body, dnsURL)
-// 	instance.Status.DnsResponse = resp.StatusCode
-// 	if instance.Status.DnsResponse != 200 || instance.Status.DnsResponse == 0 {
-// 		_ = r.Status().Update(ctx, instance)
-// 	}
-
-// }
-
 func generateConfigMap(uuid, lokiURL, lokiUser, lokiPass, mimirURL, mimirUser, mimirPass string) string {
 	configMapTemplate := `
 discovery.kubernetes "metrics_integrations_kubernetes_nodes_cadvisor" {