From ca7b9d3c7a1ea3a1bac464b1f389ef696a63f532 Mon Sep 17 00:00:00 2001
From: maxime <bret.maxime@gmail.com>
Date: Sun, 17 Mar 2024 12:51:37 +0100
Subject: [PATCH] feat: added more logs

---
 .../src/functions/refreshMetadata/handler.ts  | 22 ++++++++++++++-----
 packages/api/src/libs/supabase/lock.ts        |  4 ++++
 2 files changed, 20 insertions(+), 6 deletions(-)

diff --git a/packages/api/src/functions/refreshMetadata/handler.ts b/packages/api/src/functions/refreshMetadata/handler.ts
index bf9fdb2b..7b34939f 100644
--- a/packages/api/src/functions/refreshMetadata/handler.ts
+++ b/packages/api/src/functions/refreshMetadata/handler.ts
@@ -28,15 +28,25 @@ const lambda: ValidatedEventAPIGatewayProxyEvent<typeof schema> = async (
     })
   })
 
-  const lockId = `metadata_${event.body.bookId}`
+  logger.info(`invoke for ${event.body.bookId}`)
 
-  const { alreadyLocked } = await lock(lockId, LOCK_MAX_DURATION_MN)
+  try {
+    const lockId = `metadata_${event.body.bookId}`
 
-  if (!alreadyLocked) {
-    const response = await client.send(command)
+    const { alreadyLocked } = await lock(lockId, LOCK_MAX_DURATION_MN)
 
-    logger.info(`${event.body.bookId}: command sent with success`)
-    logger.info(response)
+    if (!alreadyLocked) {
+      const response = await client.send(command)
+
+      logger.info(`${event.body.bookId}: command sent with success`)
+      logger.info(response)
+    } else {
+      logger.info(`${event.body.bookId} is already locked, ignoring!`)
+    }
+  } catch (error) {
+    logger.error(error)
+
+    throw error
   }
 
   return {
diff --git a/packages/api/src/libs/supabase/lock.ts b/packages/api/src/libs/supabase/lock.ts
index 3c7b4b16..d4d4d36f 100644
--- a/packages/api/src/libs/supabase/lock.ts
+++ b/packages/api/src/libs/supabase/lock.ts
@@ -54,5 +54,9 @@ export const lock = async (
     return { alreadyLocked: false }
   }
 
+  if (response.error) {
+    throw response.error
+  }
+
   return { alreadyLocked: true }
 }