apply bin codec for enqueue messages

fogfish · Sep 25, 2024 · 5a2423d · 5a2423d
1 parent c904724
commit 5a2423d
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/queue/bytes/queue.go b/queue/bytes/queue.go
@@ -30,10 +30,15 @@ type queue struct {
 func (q queue) Put(object []byte) error { return q.Enq(q.cat, object) }
 
 func (q queue) Enq(cat string, object []byte) error {
+	obj, err := q.codec.Encode(object)
+	if err != nil {
+		return err
+	}
+
 	ctx := swarm.NewContext(context.Background(), cat, "")
-	bag := swarm.Bag{Ctx: ctx, Object: object}
+	bag := swarm.Bag{Ctx: ctx, Object: obj}
 
-	err := q.emit.Enq(bag)
+	err = q.emit.Enq(bag)
 	if err != nil {
 		return err
 	}