From 6e66c5ed7fa06c5bd1b76d6a4e70d7428df33f01 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arwid=20Thornstr=C3=B6m?= <arwid.thornstrom@photowall.se>
Date: Wed, 30 Oct 2024 14:13:10 +0100
Subject: [PATCH] added delay for sqs message (#168)

---
 src/aws/sqs.ts                     | 4 ++++
 src/resolvers/products-resolver.ts | 1 +
 2 files changed, 5 insertions(+)

diff --git a/src/aws/sqs.ts b/src/aws/sqs.ts
index b7f11f7..db94cc3 100644
--- a/src/aws/sqs.ts
+++ b/src/aws/sqs.ts
@@ -8,6 +8,7 @@ import {
 export async function sendMessage(
   body: string,
   queueUrl: string,
+  delaySeconds?: number,
 ): Promise<SendMessageCommandOutput | undefined> {
   const client = new SQSClient({ region: 'eu-west-1' });
 
@@ -15,6 +16,9 @@ export async function sendMessage(
     MessageBody: body,
     QueueUrl: queueUrl,
   };
+  if (delaySeconds) {
+    params.DelaySeconds = delaySeconds;
+  }
   const sendMessageCommand = new SendMessageCommand(params);
 
   return client.send(sendMessageCommand);
diff --git a/src/resolvers/products-resolver.ts b/src/resolvers/products-resolver.ts
index 4a4da96..3677a13 100644
--- a/src/resolvers/products-resolver.ts
+++ b/src/resolvers/products-resolver.ts
@@ -231,6 +231,7 @@ export const productMutationTypeDefs = {
     await sendMessage(
       JSON.stringify({ productId: id, artNo: product.fields.artNo }),
       process.env.SAMPLE_SQS_QUEUE_URL,
+      60 * 10,
     );
 
     return product;