hash MessageDeduplicationId to avoid invalid values (#139)

* hash MessageDeduplicationId to avoid invalid values * Sync --------- Co-authored-by: Frank <[email protected]>
sst · Jun 22, 2023 · bbd31b3 · bbd31b3 · vercel · Jun 22, 2023
1 parent 45d6731
commit bbd31b3
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/.changeset/tame-papayas-change.md b/.changeset/tame-papayas-change.md
@@ -0,0 +1,5 @@
+---
+"open-next": patch
+---
+
+server: hash message dedup id
diff --git a/packages/open-next/src/adapters/server-adapter.ts b/packages/open-next/src/adapters/server-adapter.ts
@@ -1,4 +1,5 @@
 import path from "node:path";
+import crypto from "node:crypto";
 import type {
   APIGatewayProxyEventV2,
   APIGatewayProxyEvent,
@@ -271,10 +272,12 @@ async function revalidateIfRequired(
   // your page will need to have a different etag to bypass the deduplication window.
   // If data has the same etag during these 5 min dedup window, it will be deduplicated and not revalidated.
   try {
+    const hash = (str: string) => crypto.createHash('md5').update(str).digest('hex')
+
     await sqsClient.send(
       new SendMessageCommand({
         QueueUrl: REVALIDATION_QUEUE_URL,
-        MessageDeduplicationId: `${rawPath}-${headers.etag}`,
+        MessageDeduplicationId: hash(`${rawPath}-${headers.etag}`),
         MessageBody: JSON.stringify({ host, url: rawPath }),
         MessageGroupId: "revalidate",
       })