cleaning up marshaling/serialization (#1)

* cleaning up marshaling/serialization * cleaning up marshaling/serialization
2023-01-18 11:06:59 -05:00
parent c816103774
commit b9d04f1496
5 changed files with 129 additions and 100 deletions
@@ -229,7 +229,15 @@ func (r *Relay) Publish(ctx context.Context, event Event) Status {
 	defer r.okCallbacks.Delete(event.ID)

 	// publish event
-	if err := r.Connection.WriteJSON([]interface{}{"EVENT", event}); err != nil {
+	message := []byte("[\"EVENT\",")
+	if m, e := event.MarshalJSON(); e == nil {
+		message = append(message, m...)
+		message = append(message, ']')
+	} else {
+		return status
+	}
+
+	if err := r.Connection.WriteMessage(websocket.TextMessage, message); err != nil {
 		return status
 	}