update aws dep

Author: conico974

packages/cloudflare/package.json

@@ -73,7 +73,7 @@
   "dependencies": {
     "@ast-grep/napi": "^0.36.1",
     "@dotenvx/dotenvx": "catalog:",
-    "@opennextjs/aws": "https://pkg.pr.new/@opennextjs/aws@7e23eee",
+    "@opennextjs/aws": "https://pkg.pr.new/@opennextjs/aws@773",
     "enquirer": "^2.4.1",
     "glob": "catalog:",
     "yaml": "^2.7.0"

packages/cloudflare/src/api/durable-objects/queue.spec.ts

@@ -52,8 +52,8 @@ const createDurableObjectQueue = ({
   });
 };
 
-const createMessage = (dedupId: string) => ({
-  MessageBody: { host: "test.local", url: "/test" },
+const createMessage = (dedupId: string, lastModified = Date.now()) => ({
+  MessageBody: { host: "test.local", url: "/test", eTag: "test", lastModified },
   MessageGroupId: "test.local/test",
   MessageDeduplicationId: dedupId,
   previewModeId: "test",

packages/cloudflare/src/api/memory-queue.spec.ts

@@ -12,6 +12,13 @@ vi.mock("./cloudflare-context", () => ({
   }),
 }));
 
+const generateMessageBody = ({ host, url }: { host: string; url: string }) => ({
+  host,
+  url,
+  eTag: "etag",
+  lastModified: Date.now(),
+});
+
 describe("MemoryQueue", () => {
   beforeAll(() => {
     vi.useFakeTimers();
@@ -22,7 +29,7 @@ describe("MemoryQueue", () => {
 
   it("should process revalidations for a path", async () => {
     const firstRequest = cache.send({
-      MessageBody: { host: "test.local", url: "/test" },
+      MessageBody: generateMessageBody({ host: "test.local", url: "/test" }),
       MessageGroupId: generateMessageGroupId("/test"),
       MessageDeduplicationId: "",
     });
@@ -31,7 +38,7 @@ describe("MemoryQueue", () => {
     expect(mockServiceWorkerFetch).toHaveBeenCalledTimes(1);
 
     const secondRequest = cache.send({
-      MessageBody: { host: "test.local", url: "/test" },
+      MessageBody: generateMessageBody({ host: "test.local", url: "/test" }),
       MessageGroupId: generateMessageGroupId("/test"),
       MessageDeduplicationId: "",
     });
@@ -42,7 +49,7 @@ describe("MemoryQueue", () => {
 
   it("should process revalidations for multiple paths", async () => {
     const firstRequest = cache.send({
-      MessageBody: { host: "test.local", url: "/test" },
+      MessageBody: generateMessageBody({ host: "test.local", url: "/test" }),
       MessageGroupId: generateMessageGroupId("/test"),
       MessageDeduplicationId: "",
     });
@@ -51,7 +58,7 @@ describe("MemoryQueue", () => {
     expect(mockServiceWorkerFetch).toHaveBeenCalledTimes(1);
 
     const secondRequest = cache.send({
-      MessageBody: { host: "test.local", url: "/test" },
+      MessageBody: generateMessageBody({ host: "test.local", url: "/test" }),
       MessageGroupId: generateMessageGroupId("/other"),
       MessageDeduplicationId: "",
     });
@@ -63,12 +70,12 @@ describe("MemoryQueue", () => {
   it("should de-dupe revalidations", async () => {
     const requests = [
       cache.send({
-        MessageBody: { host: "test.local", url: "/test" },
+        MessageBody: generateMessageBody({ host: "test.local", url: "/test" }),
         MessageGroupId: generateMessageGroupId("/test"),
         MessageDeduplicationId: "",
       }),
       cache.send({
-        MessageBody: { host: "test.local", url: "/test" },
+        MessageBody: generateMessageBody({ host: "test.local", url: "/test" }),
         MessageGroupId: generateMessageGroupId("/test"),
         MessageDeduplicationId: "",
       }),