release

package.json

@@ -67,6 +67,7 @@
     "@emotion/cache": "^11.11.0",
     "@mui/material-nextjs": "^5.15.11",
     "arg": "^5.0.2",
+    "pino": "^8.19.0",
     "react-markdown": "^9.0.1",
     "reactjrx": "^1.79.1",
     "remark-gfm": "^4.0.0",

packages/api/serverless.ts

@@ -72,6 +72,9 @@ const serverlessConfiguration: AWS & any = {
       shouldStartNameWithService: true,
       binaryMediaTypes: [`*/*`]
     },
+    logs: {
+      restApi: true
+    },
     // Do this if you want to load env vars into the Serverless environment AND
     // automatically configure all your functions with them.
     // This is usually not recommended to avoid loading secrets by accident (e.g. AWS_SECRET_ACCESS_KEY)

packages/api/src/functions/refreshMetadata/index.ts

@@ -3,14 +3,6 @@ import { handlerPath } from "@libs/handler-resolver"
 export default {
   handler: `${handlerPath(__dirname)}/handler.main`,
   role: "lambdaDefault",
-  /**
-   * Because this lambda check and lock the process
-   * we need to avoid concurrent access. This way we ensure
-   * the lock is always checked in sync.
-   *
-   * This lambda should stay simple and fast (check/lock)
-   */
-  reservedConcurrency: 1,
   events: [
     {
       http: {

packages/api/src/functions/refreshMetadataCollection/index.ts

@@ -3,14 +3,6 @@ import { handlerPath } from "@libs/handler-resolver"
 export default {
   handler: `${handlerPath(__dirname)}/handler.main`,
   role: "lambdaDefault",
-  /**
-   * Because this lambda check and lock the process
-   * we need to avoid concurrent access. This way we ensure
-   * the lock is always checked in sync.
-   *
-   * This lambda should stay simple and fast (check/lock)
-   */
-  reservedConcurrency: 1,
   events: [
     {
       http: {

packages/api/src/functions/refreshMetadataCollectionLongProcess/handler.ts

@@ -73,7 +73,7 @@ const lambda: ValidatedEventAPIGatewayProxyEvent<typeof schema> = async (
 
   await deleteLock(supabase, lockId)
 
-  Logger.log(`lambda executed with success for ${collection._id}`)
+  Logger.info(`lambda executed with success for ${collection._id}`)
 
   return {
     statusCode: 200,

packages/api/src/functions/refreshMetadataCollectionLongProcess/index.ts

@@ -3,13 +3,5 @@ import { handlerPath } from "@libs/handler-resolver"
 export default {
   handler: `${handlerPath(__dirname)}/handler.main`,
   role: "lambdaDefault",
-  /**
-   * This lambda can be heavy on local development.
-   * To avoid memory issues and CPU overuse we lock
-   * it at 1 concurrency
-   */
-  ...(process.env.OFFLINE === "true" && {
-    reservedConcurrency: 1
-  }),
   timeout: 60 * 15 // 15mn
 }

packages/api/src/functions/refreshMetadataLongProcess/handler.ts

@@ -114,7 +114,7 @@ const lambda: ValidatedEventAPIGatewayProxyEvent<typeof schema> = async (
     deleteLock(supabase, lockId)
   ])
 
-  Logger.log(`lambda executed with success for ${book._id}`)
+  Logger.info(`lambda executed with success for ${book._id}`)
 
   return {
     statusCode: 200,

packages/api/src/functions/refreshMetadataLongProcess/index.ts

@@ -3,13 +3,5 @@ import { handlerPath } from "@libs/handler-resolver"
 export default {
   handler: `${handlerPath(__dirname)}/handler.main`,
   role: "lambdaDefault",
-  /**
-   * This lambda can be heavy on local development.
-   * To avoid memory issues and CPU overuse we lock
-   * it at 1 concurrency
-   */
-  ...(process.env.OFFLINE === "true" && {
-    reservedConcurrency: 1
-  }),
   timeout: 60 * 15 // 15mn
 }

packages/api/src/functions/syncDataSource/index.ts

@@ -3,14 +3,6 @@ import { handlerPath } from "@libs/handler-resolver"
 export default {
   handler: `${handlerPath(__dirname)}/handler.main`,
   role: "lambdaDefault",
-  /**
-   * Because this lambda check and lock the process
-   * we need to avoid concurrent access. This way we ensure
-   * the lock is always checked in sync.
-   *
-   * This lambda should stay simple and fast (check/lock)
-   */
-  reservedConcurrency: 1,
   events: [
     {
       http: {

packages/api/src/functions/syncDataSourceLongProcess/handler.ts

@@ -90,9 +90,9 @@ const lambda: ValidatedEventAPIGatewayProxyEvent<typeof schema> = async (
       authorization
     })
 
-    deleteLock(supabase, lockId)
+    await deleteLock(supabase, lockId)
   } catch (e) {
-    deleteLock(supabase, lockId)
+    await deleteLock(supabase, lockId)
 
     throw e
   }

packages/api/src/libs/books/retrieveMetadataAndSaveCover.ts

@@ -23,7 +23,7 @@ import { isBookProtected } from "@libs/couch/isBookProtected"
 import nano from "nano"
 import { atomicUpdate } from "@libs/couch/dbHelpers"
 
-const logger = Logger.namespace("retrieveMetadataAndSaveCover")
+const logger = Logger.child({module: "retrieveMetadataAndSaveCover"})
 
 export type RetrieveMetadataAndSaveCoverContext = {
   userName: string
@@ -39,7 +39,7 @@ export const retrieveMetadataAndSaveCover = async (
     db: nano.DocumentScope<unknown>
   }
 ) => {
-  logger.log(
+  logger.info(
     `syncMetadata run for user ${ctx.userName} with book ${ctx.book._id}`
   )
   let bookNameForDebug = ""
@@ -49,7 +49,7 @@ export const retrieveMetadataAndSaveCover = async (
   try {
     bookNameForDebug = reduceMetadata(ctx.book.metadata).title || ""
 
-    logger.log(
+    logger.info(
       `syncMetadata processing ${ctx.book._id} with resource id ${ctx.link.resourceId}`
     )
 
@@ -189,8 +189,8 @@ export const retrieveMetadataAndSaveCover = async (
               )
               .sort()[0]
 
-        Logger.log(`coverRelativePath`, coverRelativePath)
-        Logger.log(`opfBasePath`, opfBasePath)
+              logger.info(`coverRelativePath`, coverRelativePath)
+              logger.info(`opfBasePath`, opfBasePath)
 
         metadataList.push({
           type: "file",
@@ -210,7 +210,7 @@ export const retrieveMetadataAndSaveCover = async (
           console.log(`No cover path found for ${tmpFilePath}`)
         }
       } else {
-        logger.log(
+        logger.info(
           `${contentType} cannot be extracted to retrieve information (cover, etc)`
         )
       }