Feat Add additional params to the queue override (#773)

* add additional info on the queue message

* add .js so that test doesn't fail in cloudflare

* changeset

* fix test

* review fix

Author: conico974

.changeset/sour-boxes-jump.md

@@ -0,0 +1,5 @@
+---
+"@opennextjs/aws": patch
+---
+
+Add additional params to the queue override

packages/open-next/src/adapters/logger.ts

@@ -1,4 +1,4 @@
-import { isOpenNextError } from "utils/error";
+import { isOpenNextError } from "utils/error.js";
 
 export function debug(...args: any[]) {
   if (globalThis.openNextDebug) {

packages/open-next/src/core/routing/cacheInterceptor.ts

@@ -63,7 +63,12 @@ async function computeCacheControl(
         url = `${NextConfig.basePath}${url}`;
       }
       await globalThis.queue.send({
-        MessageBody: { host, url },
+        MessageBody: {
+          host,
+          url,
+          eTag: etag,
+          lastModified: lastModified ?? Date.now(),
+        },
         MessageDeduplicationId: hash(`${path}-${lastModified}-${etag}`),
         MessageGroupId: generateMessageGroupId(path),
       });

packages/open-next/src/core/routing/util.ts

@@ -324,11 +324,11 @@ export async function revalidateIfRequired(
 
       // For some weird cases, lastModified is not set, haven't been able to figure out yet why
       // For those cases we add the etag to the deduplication id, it might help
-      const etag = headers.etag ?? headers.ETag ?? "";
+      const eTag = `${headers.etag ?? headers.ETag ?? ""}`;
 
       await globalThis.queue.send({
-        MessageBody: { host, url: revalidateUrl },
-        MessageDeduplicationId: hash(`${rawPath}-${lastModified}-${etag}`),
+        MessageBody: { host, url: revalidateUrl, eTag, lastModified },
+        MessageDeduplicationId: hash(`${rawPath}-${lastModified}-${eTag}`),
         MessageGroupId: generateMessageGroupId(rawPath),
       });
     } catch (e) {

packages/open-next/src/types/overrides.ts

@@ -20,6 +20,8 @@ export interface QueueMessage {
   MessageBody: {
     host: string;
     url: string;
+    lastModified: number;
+    eTag: string;
   };
   MessageGroupId: string;
 }

packages/tests-unit/tests/core/routing/util.test.ts

@@ -668,7 +668,12 @@ describe("revalidateIfRequired", () => {
     await revalidateIfRequired("localhost", "/path", headers);
 
     expect(sendMock).toHaveBeenCalledWith({
-      MessageBody: { host: "localhost", url: "/path" },
+      MessageBody: {
+        host: "localhost",
+        url: "/path",
+        eTag: expect.any(String),
+        lastModified: expect.any(Number),
+      },
       MessageDeduplicationId: expect.any(String),
       MessageGroupId: expect.any(String),
     });
@@ -682,7 +687,12 @@ describe("revalidateIfRequired", () => {
     await revalidateIfRequired("localhost", "/path", headers);
 
     expect(sendMock).toHaveBeenCalledWith({
-      MessageBody: { host: "localhost", url: "/path" },
+      MessageBody: {
+        host: "localhost",
+        url: "/path",
+        eTag: expect.any(String),
+        lastModified: expect.any(Number),
+      },
       MessageDeduplicationId: expect.any(String),
       MessageGroupId: expect.any(String),
     });