feat: added more logs

mbret · Mar 17, 2024 · ca7b9d3 · ca7b9d3
1 parent 1243afc
commit ca7b9d3
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 6 deletions.
diff --git 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
@@ -54,5 +54,9 @@ export const lock = async (
     return { alreadyLocked: false }
   }
 
+  if (response.error) {
+    throw response.error
+  }
+
   return { alreadyLocked: true }
 }