bugfix: recreate geoip index on missing

Author: javjodar

CHANGELOG.md

@@ -2,3 +2,4 @@
 ## Bug Fixes
 - Enhanced the Log Explorer UI to improve usability by refining the display of Refresh, Save Query, Load Query, and Add Filter actions for a more intuitive user experience..
 
+- Recreating geoip opensearch index if missing

correlation/aaa/rules/system

@@ -0,0 +1 @@
+Subproject commit 58317e8e2665c7fc7609b7756870ae6f5d60f9aa

correlation/system

@@ -0,0 +1 @@
+Subproject commit 58317e8e2665c7fc7609b7756870ae6f5d60f9aa

installer/cloud.go

@@ -212,7 +212,13 @@ func Cloud(c *types.Config, update bool) error {
 		fmt.Println("Initializing User Auditor database [OK]")
 	}
 
-	if utils.GetLock(7, stack.LocksDir) {
+	indexURL := "http://localhost:9200/.utm-geoip?pretty"
+	indexExists, err := utils.CheckIndexExists(indexURL)
+	if err != nil {
+		return err
+	}
+
+	if !indexExists || utils.GetLock(7, stack.LocksDir) {
 		fmt.Println("Initializing OpenSearch. This may take a while.")
 		if err := InitOpenSearch(); err != nil {
 			return err

installer/master.go

@@ -200,7 +200,13 @@ func Master(c *types.Config) error {
 		fmt.Println("Initializing User Auditor database [OK]")
 	}
 
-	if utils.GetLock(7, stack.LocksDir) {
+	indexURL := "http://localhost:9200/.utm-geoip?pretty"
+	indexExists, err := utils.CheckIndexExists(indexURL)
+	if err != nil {
+		return err
+	}
+
+	if !indexExists || utils.GetLock(7, stack.LocksDir) {
 		fmt.Println("Initializing OpenSearch. This may take a while.")
 		if err := InitOpenSearch(); err != nil {
 			return err

installer/utils/elastic.go

@@ -0,0 +1,28 @@
+package utils
+
+import (
+	"fmt"
+	"net/http"
+)
+
+// CheckIndexExists checks if the given Elasticsearch index exists by sending an HTTP GET
+// request to the provided URL. It returns true if the index exists, false otherwise.
+func CheckIndexExists(url string) (bool, error) {
+	resp, err := http.Get(url)
+	if err != nil {
+		return false, err
+	}
+	defer resp.Body.Close()
+
+	switch resp.StatusCode {
+	case http.StatusOK:
+		// The index exists.
+		return true, nil
+	case http.StatusNotFound:
+		// The index does not exist.
+		return false, nil
+	default:
+		// For any other status code, return an error.
+		return false, fmt.Errorf("unexpected status code: %d", resp.StatusCode)
+	}
+}