feat: marshal raw data to JSON

Signed-off-by: Valery Piashchynski <[email protected]>
roadrunner-server · Aug 7, 2022 · 69e41d1 · 69e41d1
1 parent e938443
commit 69e41d1
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/beanstalkjobs/item.go b/beanstalkjobs/item.go
@@ -152,6 +152,13 @@ func (c *Consumer) unpack(id uint64, data []byte, out *Item) error {
 			uid := uuid.NewString()
 			c.log.Debug("get raw payload", zap.String("assigned ID", uid))
 
+			if isJSONEncoded(data) != nil {
+				data, err = json.Marshal(data)
+				if err != nil {
+					return err
+				}
+			}
+
 			*out = Item{
 				Job:     auto,
 				Ident:   uid,
@@ -182,3 +189,8 @@ func (c *Consumer) unpack(id uint64, data []byte, out *Item) error {
 
 	return nil
 }
+
+func isJSONEncoded(data []byte) error {
+	var a any
+	return json.Unmarshal(data, &a)
+}