adding health check for tenzir

backend/go-app/main.go

@@ -5131,7 +5131,6 @@ func initHandlers() {
 	r.HandleFunc("/api/v1/triggers/pipeline", shuffle.HandleNewPipelineRegister).Methods("POST", "OPTIONS")
     //r.HandleFunc("/api/v1/triggers/pipeline/save", shuffle.HandleSavePipelineInfo).Methods("PUT", "OPTIONS")
 	r.HandleFunc("/api/v1/pipelines/{key}", handlePipelineCallback).Methods("POST", "GET", "PATCH", "PUT", "DELETE", "OPTIONS")
-	r.HandleFunc("/api/v1/pipelines/tenzir_node_health", handleTenzirHealthUpdate).Methods("POST","OPTIONS")
 	r.HandleFunc("/api/v1/triggers", shuffle.HandleGetTriggers).Methods("GET", "OPTIONS")
 	//r.HandleFunc("/api/v1/triggers/gmail/routing", handleGmailRouting).Methods("POST", "OPTIONS")
 
@@ -5200,6 +5199,7 @@ func initHandlers() {
 	r.HandleFunc("/api/v1/files/detection/sigma_rules", shuffle.HandleGetSigmaRules).Methods("GET", "OPTIONS")
 	r.HandleFunc("/api/v1/files/detection/{fileId}/{action}", shuffle.HandleToggleRule).Methods("PUT", "OPTIONS")
 	r.HandleFunc("/api/v1/files/detection/{action}", shuffle.HandleFolderToggle).Methods("PUT", "OPTIONS")
+	r.HandleFunc("/api/v1/detection/siem/node_health", handleTenzirHealthUpdate).Methods("POST","OPTIONS")
 
 	// Introduced in 0.9.21 to handle notifications for e.g. failed Workflow
 	r.HandleFunc("/api/v1/notifications", shuffle.HandleCreateNotification).Methods("POST", "OPTIONS")

functions/onprem/orborus/orborus.go

@@ -1913,6 +1913,7 @@ func main() {
 	log.Printf("[INFO] Waiting for executions at %s with Environment %#v", fullUrl, environment)
 	hasStarted := false
 	for {
+		_ = sendTenzirHealthStatus()
 		if req.Method == "POST" {
 			// Should find data to send (memory etc.)
 
@@ -2260,7 +2261,6 @@ func main() {
 			}
 
 		}
-		_ = sendTenzirHealthStatus()
 		time.Sleep(time.Duration(sleepTime) * time.Second)
 	}
 }
@@ -2580,9 +2580,9 @@ func deployTenzirNode() error {
 }
 
 func checkTenzirNode() error {
-	retries := 20
-	retryInterval := 3 * time.Second
-	url := fmt.Sprintf("%s/api/v0/ping", tenzirUrl)
+    retries := 5
+    retryInterval := 3 * time.Second
+	url := fmt.Sprintf("%s/api/v0/ping",tenzirUrl)
 	forwardMethod := "POST"
 
 	client := http.Client{}
@@ -3075,7 +3075,7 @@ func removePath(containerName, path string) error {
 
 func sendTenzirHealthStatus() error {
     var status string
-	url :=  fmt.Sprintf("%s/api/v1/triggers/pipeline/tenzir_node_health", baseUrl)
+	url :=  fmt.Sprintf("%s/api/v1/detection/siem/node_health", baseUrl)
 	err := checkTenzirNode()
 	if err != nil {
 		return err
@@ -3116,7 +3116,7 @@ func sendTenzirHealthStatus() error {
 		log.Printf("[ERROR] Received non-successful HTTP status code: %d", resp.StatusCode)
 		return fmt.Errorf("unexpected HTTP status code: %d", resp.StatusCode)
 	}
-
+   log.Printf("this is send successfully")
 	return nil
 }