From d50e5d56f788c13ad90353ca34e20c347bc256ca Mon Sep 17 00:00:00 2001 From: mr Date: Wed, 28 Jan 2026 17:31:34 +0100 Subject: [PATCH] Update NATS --- daemons/pubsub/nats.go | 4 ++-- go.mod | 2 +- go.sum | 2 ++ 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/daemons/pubsub/nats.go b/daemons/pubsub/nats.go index 63a28e9..a18b9de 100644 --- a/daemons/pubsub/nats.go +++ b/daemons/pubsub/nats.go @@ -27,7 +27,7 @@ func ListenNATS() { GetPubSubService().ToPartnerPublishEvent( context.Background(), propalgation.Action, - dt, propalgation.User, + dt, resp.User, propalgation.Payload, ) case tools.PB_SEARCH: @@ -37,7 +37,7 @@ func ListenNATS() { context.Background(), dt, fmt.Sprintf("%v", m["type"]), - propalgation.User, + resp.User, fmt.Sprintf("%v", m["search"]), ) } diff --git a/go.mod b/go.mod index 616a276..5d0bc51 100644 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module oc-discovery go 1.24.6 require ( - cloud.o-forge.io/core/oc-lib v0.0.0-20260128160440-c0d89ea9e1e8 + cloud.o-forge.io/core/oc-lib v0.0.0-20260128162702-97cf629e27ec github.com/beego/beego v1.12.13 github.com/beego/beego/v2 v2.3.8 github.com/go-redis/redis v6.15.9+incompatible diff --git a/go.sum b/go.sum index 3d257b2..a927c23 100644 --- a/go.sum +++ b/go.sum @@ -22,6 +22,8 @@ cloud.o-forge.io/core/oc-lib v0.0.0-20260128154447-d26789d64e33 h1:WdmHeRtEWV3Rs cloud.o-forge.io/core/oc-lib v0.0.0-20260128154447-d26789d64e33/go.mod h1:vHWauJsS6ryf7UDqq8hRXoYD5RsONxcFTxeZPOztEuI= cloud.o-forge.io/core/oc-lib v0.0.0-20260128160440-c0d89ea9e1e8 h1:h7VHJktaTT8TxO4ld3Xjw3LzMsivr3m7mzbNxb44zes= cloud.o-forge.io/core/oc-lib v0.0.0-20260128160440-c0d89ea9e1e8/go.mod h1:vHWauJsS6ryf7UDqq8hRXoYD5RsONxcFTxeZPOztEuI= +cloud.o-forge.io/core/oc-lib v0.0.0-20260128162702-97cf629e27ec h1:/uvrtEt7A5rwqFPHH8yjujlC33HMjQHhWDIK6I08DrA= +cloud.o-forge.io/core/oc-lib v0.0.0-20260128162702-97cf629e27ec/go.mod h1:vHWauJsS6ryf7UDqq8hRXoYD5RsONxcFTxeZPOztEuI= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= github.com/Knetic/govaluate v3.0.0+incompatible/go.mod h1:r7JcOSlj0wfOMncg0iLm8Leh48TZaKVeNIfJntJ2wa0= github.com/alecthomas/template v0.0.0-20160405071501-a0175ee3bccc/go.mod h1:LOuyumcjzFXgccqObfd/Ljyb9UuFJ6TxHnclSeseNhc=