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

correct Search

Browse Source
This commit is contained in:
mr
2026-02-23 18:11:55 +01:00
parent 978a2aa7d5
commit dcd4bd497e
3 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
infrastructure/nats.go
View File

@@ -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 ?