From b7ecea25ebf049fe0a931dd5fa1fa14690d18f6c Mon Sep 17 00:00:00 2001
From: mr <mr>
Date: Wed, 21 Aug 2024 10:21:17 +0200
Subject: [PATCH] NATS is an OCLIB tool

---
 models/workflow/workflow_mongo_accessor.go |  2 +-
 tools/nats_caller.go                       | 18 +++++++-----------
 2 files changed, 8 insertions(+), 12 deletions(-)

diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go
index a85a7a3..ca64c41 100644
--- a/models/workflow/workflow_mongo_accessor.go
+++ b/models/workflow/workflow_mongo_accessor.go
@@ -139,7 +139,7 @@ func (wfa *workflowMongoAccessor) book(id string, realData *Workflow, execs []*w
 
 func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delete bool) (int, error) {
 	var err error
-	nats := tools.NATSCaller{}
+	nats := tools.NewNATSCaller()
 	res, code, _ := wfa.LoadOne(id)
 	if code != 200 {
 		return 404, errors.New("could not load workflow")
diff --git a/tools/nats_caller.go b/tools/nats_caller.go
index c7693bc..be32e8d 100644
--- a/tools/nats_caller.go
+++ b/tools/nats_caller.go
@@ -31,21 +31,17 @@ func (d NATSMethod) String() string {
 	return [...]string{"remove", "create"}[d]
 }
 
-type NATSCaller struct {
-	natsUrl string
+type natsCaller struct{}
+
+func NewNATSCaller() *natsCaller {
+	return &natsCaller{}
 }
 
-func NewNATSCaller(url string) *NATSCaller {
-	return &NATSCaller{
-		natsUrl: url,
-	}
-}
-
-func (o *NATSCaller) SetNATSPub(dataName string, method NATSMethod, data interface{}) string {
-	if o.natsUrl == "" {
+func (o *natsCaller) SetNATSPub(dataName string, method NATSMethod, data interface{}) string {
+	if GetConfig().NATSUrl == "" {
 		return " -> NATS_SERVER is not set"
 	}
-	nc, err := nats.Connect(o.natsUrl)
+	nc, err := nats.Connect(GetConfig().NATSUrl)
 	if err != nil {
 		return " -> Could not reach NATS server : " + err.Error()
 	}