Merge pull request #1016 from m2nsp/issue-877-test-queue-msg-wrapping-in-cfworkers

Test queue message wrapping in @fedify/cfworkers

Author: dahlia

packages/cfworkers/src/mod.test.ts

@@ -351,4 +351,26 @@ describe("WorkersMessageQueue", () => {
     expect(second.shouldProcess).toBe(true);
     expect(second.message).toEqual({ id: "second" });
   });
+
+  it("enqueue() sends __fedify_ordering_key__ and __fedify_payload__ to the queue binding", async () => {
+    let sentMessage: unknown;
+
+    const queueBinding = {
+      send: (message: unknown) => {
+        sentMessage = message;
+      },
+    } as unknown as Queue;
+
+    const queue = new WorkersMessageQueue(queueBinding);
+
+    await queue.enqueue(
+      { id: "test-message" },
+      { orderingKey: "actor-1" },
+    );
+
+    expect(sentMessage).toEqual({
+      __fedify_ordering_key__: "actor-1",
+      __fedify_payload__: { id: "test-message" },
+    });
+  });
 });