core/oc-workflow
6
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

update oc-workflow lib version

Browse Source
This commit is contained in:
mr
2024-08-21 08:40:46 +02:00
parent 6f0b1ffcf4
commit 1be4d79c75
7 changed files with 31 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
controllers/workflow.go
View File

@@ -3,6 +3,7 @@ package controllers
import (
"encoding/json"
"errors"
"fmt"
"time"
oclib "cloud.o-forge.io/core/oc-lib"
@@ -54,14 +55,17 @@ func (o *WorkflowController) Put() {
o.ServeJSON()
}
var NATS_SERVER = "nats://localhost:4222"
func (o *WorkflowController) SetNATSPub(res map[string]interface{}, data oclib.LibData) string {
if sched, ok := res["schedule"]; ok && sched != nil && data.Code == 200 {
workflow := data.ToWorkflow()
if workflow != nil && workflow.Schedule != nil {
// HERE NATS
nc, err := nats.Connect(nats.DefaultURL)
fmt.Println("NATS_SERVER", NATS_SERVER)
nc, err := nats.Connect(NATS_SERVER)
if err != nil {
return " -> Could not reach NATS server"
return " -> Could not reach NATS server : " + err.Error()
}
start := ""
if workflow.Schedule.Start != nil {