From c8a137785133cccf14a9a81cc517448f64bee3bd Mon Sep 17 00:00:00 2001
From: mr <mr>
Date: Thu, 22 Aug 2024 14:56:32 +0200
Subject: [PATCH] Discovery Nats automate

---
 entrypoint.go | 35 ++++++++++++++++++-----------------
 1 file changed, 18 insertions(+), 17 deletions(-)

diff --git a/entrypoint.go b/entrypoint.go
index fc22408..4a2c682 100644
--- a/entrypoint.go
+++ b/entrypoint.go
@@ -91,28 +91,12 @@ func Init(appName string, hostname string, port string) {
 	defer func() {
 		if r := recover(); r != nil {
 			tools.UncatchedError = append(tools.UncatchedError, errors.New("Panic recovered in Init : "+fmt.Sprintf("%v", r)+" - "+string(debug.Stack())))
+			fmt.Printf("Panic recovered in Init : %v - %v\n", r, string(debug.Stack()))
 		}
 	}()
 	logs.SetAppName(appName)
 	logs.SetLogger(logs.CreateLogger("main", ""))
 	logger := logs.GetLogger()
-	discoveryAccess := (&discovery.Discovery{}).GetAccessor(nil)
-	res, code, _ := discoveryAccess.Search(nil, appName)
-	initial := &discovery.Discovery{
-		AbstractObject: utils.AbstractObject{
-			Name: appName,
-		},
-		Host:  hostname,
-		Port:  port,
-		State: 1,
-	}
-	if code == 200 && len(res) == 0 {
-		discoveryAccess.StoreOne(initial)
-	}
-	err := tools.NewNATSCaller().DiscoveryNATS(appName, initial)
-	if err != nil {
-		logger.Error().Msg(err.Error())
-	}
 	mongo.MONGOService.Init(models.GetModelsNames(), tools.GetConfig())
 	accessor := (&resource_model.ResourceModel{}).GetAccessor(nil)
 	for _, model := range []string{utils.DATA_RESOURCE.String(), utils.PROCESSING_RESOURCE.String(), utils.STORAGE_RESOURCE.String(), utils.DATACENTER_RESOURCE.String(), utils.WORKFLOW_RESOURCE.String()} {
@@ -139,6 +123,23 @@ func Init(appName string, hostname string, port string) {
 			})
 		}
 	}
+	discoveryAccess := (&discovery.Discovery{}).GetAccessor(nil)
+	res, code, _ := discoveryAccess.Search(nil, appName)
+	initial := &discovery.Discovery{
+		AbstractObject: utils.AbstractObject{
+			Name: appName,
+		},
+		Host:  hostname,
+		Port:  port,
+		State: 1,
+	}
+	if code == 200 && len(res) == 0 {
+		discoveryAccess.StoreOne(initial)
+	}
+	err := tools.NewNATSCaller().DiscoveryNATS(appName, initial)
+	if err != nil {
+		logger.Error().Msg(err.Error())
+	}
 }
 
 func GetLogger() zerolog.Logger {