add groups

This commit is contained in:
mr
2026-03-12 09:06:33 +01:00
parent d8e3ca4c47
commit ad29297377
9 changed files with 25 additions and 21 deletions

View File

@@ -20,7 +20,7 @@ var ressourceCols = []oclib.LibDataEnum{
var SearchStream = map[string]chan resources.ResourceInterface{}
func EmitNATS(user string, message tools.PropalgationMessage) {
func EmitNATS(user string, groups []string, message tools.PropalgationMessage) {
b, _ := json.Marshal(message)
if message.Action == tools.PB_SEARCH {
SearchStream[user] = make(chan resources.ResourceInterface, 128)
@@ -28,6 +28,8 @@ func EmitNATS(user string, message tools.PropalgationMessage) {
tools.NewNATSCaller().SetNATSPub(tools.PROPALGATION_EVENT, tools.NATSResponse{
FromApp: "oc-catalog",
Datatype: -1,
User: user,
Groups: groups,
Method: int(tools.PROPALGATION_EVENT),
Payload: b,
})