fix: added custom marshaler for subscribe over HTTP

tigrisdata-archive · Sep 7, 2022 · b52fdb3 · b52fdb3
1 parent ebd7d73
commit b52fdb3
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/api/server/v1/marshaler.go b/api/server/v1/marshaler.go
@@ -643,6 +643,15 @@ func (x *PublishRequest) UnmarshalJSON(data []byte) error {
 	return nil
 }
 
+func (x *SubscribeResponse) MarshalJSON() ([]byte, error) {
+	resp := struct {
+		Message json.RawMessage `json:"message"`
+	}{
+		Message: x.Message,
+	}
+	return json.Marshal(resp)
+}
+
 // Proper marshal timestamp in metadata
 type dmlResponse struct {
 	Metadata      Metadata          `json:"metadata,omitempty"`