From dcd4bd497e245b6a67eac0b88233c9ae9e0c972a Mon Sep 17 00:00:00 2001 From: mr Date: Mon, 23 Feb 2026 18:11:55 +0100 Subject: [PATCH] correct Search --- go.mod | 2 +- go.sum | 2 ++ infrastructure/nats.go | 6 +++++- 3 files changed, 8 insertions(+), 2 deletions(-) diff --git a/go.mod b/go.mod index 2432968..9047ad4 100755 --- a/go.mod +++ b/go.mod @@ -3,7 +3,7 @@ module oc-catalog go 1.24.6 require ( - cloud.o-forge.io/core/oc-lib v0.0.0-20260218132556-0b41e2505e2f + cloud.o-forge.io/core/oc-lib v0.0.0-20260223083003-28713536358b github.com/beego/beego/v2 v2.3.4 github.com/smartystreets/goconvey v1.7.2 ) diff --git a/go.sum b/go.sum index 4317cf3..4dc4ee4 100755 --- a/go.sum +++ b/go.sum @@ -18,6 +18,8 @@ cloud.o-forge.io/core/oc-lib v0.0.0-20260212123952-403913d8cf13 h1:DNIPQ7C+7wjbj cloud.o-forge.io/core/oc-lib v0.0.0-20260212123952-403913d8cf13/go.mod h1:jmyBwmsac/4V7XPL347qawF60JsBCDmNAMfn/ySXKYo= cloud.o-forge.io/core/oc-lib v0.0.0-20260218132556-0b41e2505e2f h1:OFuJhi23D/UNwn8Jo30HDt/Sm2Ea1ljUk6IVicYSuAQ= cloud.o-forge.io/core/oc-lib v0.0.0-20260218132556-0b41e2505e2f/go.mod h1:jmyBwmsac/4V7XPL347qawF60JsBCDmNAMfn/ySXKYo= +cloud.o-forge.io/core/oc-lib v0.0.0-20260223083003-28713536358b h1:Tx8hvmJJvt8BYNQsKGYuyCVnQHG59dfyYGP0+NDNxVs= +cloud.o-forge.io/core/oc-lib v0.0.0-20260223083003-28713536358b/go.mod h1:jmyBwmsac/4V7XPL347qawF60JsBCDmNAMfn/ySXKYo= github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= github.com/beego/beego/v2 v2.3.4 h1:HurQEOGIEhLlPFCTR6ZDuQkybrUl2Ag2i6CdVD2rGiI= github.com/beego/beego/v2 v2.3.4/go.mod h1:5cqHsOHJIxkq44tBpRvtDe59GuVRVv/9/tyVDxd5ce4= diff --git a/infrastructure/nats.go b/infrastructure/nats.go index 64ae161..58c9e8b 100644 --- a/infrastructure/nats.go +++ b/infrastructure/nats.go @@ -2,6 +2,7 @@ package infrastructure import ( "encoding/json" + "slices" oclib "cloud.o-forge.io/core/oc-lib" "cloud.o-forge.io/core/oc-lib/models/resources" @@ -51,7 +52,10 @@ func EmitNATS(user string, message tools.PropalgationMessage) { func ListenNATS() { tools.NewNATSCaller().ListenNats(map[tools.NATSMethod]func(tools.NATSResponse){ - tools.CATALOG_SEARCH_EVENT: func(resp tools.NATSResponse) { + tools.SEARCH_EVENT: func(resp tools.NATSResponse) { + if !slices.Contains(ressourceCols, oclib.LibDataEnum(resp.Datatype)) { + return + } p, err := resources.ToResource(int(resp.Datatype), resp.Payload) if err == nil { SearchStream[resp.User] <- p // TODO when do we update it in our catalog ?