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

Change User

Browse Source
This commit is contained in:
mr
2026-01-28 17:30:39 +01:00
parent e650ad479d
commit c6bbeeecbc
9 changed files with 28 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
infrastructure/nats.go
View File

@@ -11,10 +11,10 @@ import (
var SearchStream = map[string]chan resources.ResourceInterface{}
func EmitNATS(message tools.PropalgationMessage) {
func EmitNATS(user string, message tools.PropalgationMessage) {
b, _ := json.Marshal(message)
if message.Action == tools.PB_SEARCH {
SearchStream[message.User] = make(chan resources.ResourceInterface, 128)
SearchStream[user] = make(chan resources.ResourceInterface, 128)
}
tools.NewNATSCaller().SetNATSPub(tools.PROPALGATION_EVENT, tools.NATSResponse{
FromApp: "oc-catalog",
@@ -27,15 +27,9 @@ func EmitNATS(message tools.PropalgationMessage) {
func ListenNATS() {
tools.NewNATSCaller().ListenNats(map[tools.NATSMethod]func(tools.NATSResponse){
tools.CATALOG_SEARCH_EVENT: func(resp tools.NATSResponse) {
p := map[string]interface{}{}
err := json.Unmarshal(resp.Payload, &p)
p, err := resources.ToResource(int(resp.Datatype), resp.Payload)
if err == nil {
access := oclib.NewRequestAdmin(oclib.LibDataEnum(resp.Datatype), nil)
if data := access.LoadOne(fmt.Sprintf("%v", p["id"])); data.Data != nil {
access.UpdateOne(p, fmt.Sprintf("%v", p["id"]))
} else {
access.StoreOne(p)
}
SearchStream[resp.User] <- p
}
},
tools.CREATE_RESOURCE: func(resp tools.NATSResponse) {