Merge branch 'main' of https://gitea.tecamino.com/paadi/pubSub

models/data.go

@@ -1,7 +1,14 @@
 package models
 
+import "encoding/json"
+
 type Data struct {
-	Action string `json:"action"`
+	Action string `json:"action,omitempty"`
 	Topic  string `json:"topic"`
 	Data   any    `json:"data"`
 }
+
+func (*Data) ReadData(data []byte) (request Data, err error) {
+	err = json.Unmarshal(data, &request)
+	return
+}

pubSub.go

@@ -53,7 +53,7 @@ func (ps *Pubsub) worker() {
 			func(c func(any), d any) {
 				defer func() { recover() }()
 				c(d)
-			}(cb, job.Data)
+			}(cb, job)
 		}
 	}
 }