From 9af8d156724682e7d8b525f57c7a5155a195caee Mon Sep 17 00:00:00 2001 From: mr Date: Tue, 27 Jan 2026 12:49:51 +0100 Subject: [PATCH] DISCOVERY --- models/resources/workflow.go | 2 ++ tools/api.go | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/models/resources/workflow.go b/models/resources/workflow.go index a78e814..baa4f5a 100755 --- a/models/resources/workflow.go +++ b/models/resources/workflow.go @@ -51,3 +51,5 @@ func (w *WorkflowResource) ConvertToPricedResource(t tools.DataType, selectedIns CreatorID: w.CreatorID, }, nil // TODO ??? } + +// TODO : as instanciated resource ! diff --git a/tools/api.go b/tools/api.go index 3d0bff1..7bffe81 100644 --- a/tools/api.go +++ b/tools/api.go @@ -92,7 +92,7 @@ func (a *API) GetState() (State, int, error) { } func (a *API) ListenRouter(exec func(msg map[string]string)) { - go NewNATSCaller().ListenNats(DISCOVERY.GenerateKey(), map[NATSMethod]func(msg map[string]string){ + go NewNATSCaller().ListenNats(map[NATSMethod]func(msg map[string]string){ DISCOVERY: exec, }) } @@ -113,7 +113,7 @@ func (a *API) SubscribeRouter(infos []*beego.ControllerInfo) { } } } - go nats.SetNATSPub("api", DISCOVERY, discovery) + go nats.SetNATSPub(DISCOVERY, discovery) } // CheckRemotePeer checks the state of a remote peer