Better error logging

Author: ServerlessLife

src/frameworks/cdkFramework.ts

@@ -477,6 +477,14 @@ export class CdkFramework implements IFramework {
         }
       });
 
+      // worker.stdout.on('data', (data: Buffer) => {
+      //   Logger.log(`[CDK]`, data.toString());
+      // });
+
+      // worker.stderr.on('data', (data: Buffer) => {
+      //   Logger.error(`[CDK]`, data.toString());
+      // });
+
       worker.postMessage({
         compileOutput: compileCodeFile,
       });

src/frameworks/cdkFrameworkWorker.mjs

@@ -14,38 +14,43 @@ Logger.setVerbose(workerData.verbose);
 Logger.verbose(`[CDK] [Worker] Started`);
 
 parentPort.on('message', async (data) => {
-  // this is global variable to store the data from the CDK code once it is executed
-  global.lambdas = [];
-
-  Logger.verbose(`[Worker ${workerData.workerId}] Received message`, data);
-
-  // execute code to get the data into global.lambdas
-  await fixCdkPaths(workerData.awsCdkLibPath);
-  await import(data.compileOutput);
-
-  if (!global.lambdas || global.lambdas?.length === 0) {
-    throw new Error('No Lambda functions found in the CDK code');
+  try {
+    // this is global variable to store the data from the CDK code once it is executed
+    global.lambdas = [];
+
+    Logger.verbose(`[Worker ${workerData.workerId}] Received message`, data);
+
+    // execute code to get the data into global.lambdas
+    await fixCdkPaths(workerData.awsCdkLibPath);
+    await import(data.compileOutput);
+
+    if (!global.lambdas || global.lambdas?.length === 0) {
+      throw new Error('No Lambda functions found in the CDK code');
+    }
+
+    const lambdas = global.lambdas.map((lambda) => ({
+      handler: lambda.handler,
+      stackName: lambda.stackName,
+      codePath: lambda.codePath,
+      code: {
+        path: lambda.code?.path,
+      },
+      cdkPath: lambda.node.defaultChild.node.path,
+      bundling: {
+        ...lambda.bundling,
+        commandHooks: undefined, // can not be serialized
+      },
+    }));
+
+    Logger.verbose(
+      `[CDK] [Worker] Sending found lambdas`,
+      JSON.stringify(lambdas, null, 2),
+    );
+    parentPort.postMessage(lambdas);
+  } catch (error) {
+    Logger.error(`[CDK] [Worker] Error`, error);
+    throw error;
   }
-
-  const lambdas = global.lambdas.map((lambda) => ({
-    handler: lambda.handler,
-    stackName: lambda.stackName,
-    codePath: lambda.codePath,
-    code: {
-      path: lambda.code?.path,
-    },
-    cdkPath: lambda.node.defaultChild.node.path,
-    bundling: {
-      ...lambda.bundling,
-      commandHooks: undefined, // can not be serialized
-    },
-  }));
-
-  Logger.verbose(
-    `[CDK] [Worker] Sending found lambdas`,
-    JSON.stringify(lambdas, null, 2),
-  );
-  parentPort.postMessage(lambdas);
 });
 
 /**
@@ -97,3 +102,7 @@ async function fixCdkPaths(awsCdkLibPath) {
     exports: pathProxy,
   };
 }
+
+process.on('unhandledRejection', (error) => {
+  Logger.error(`[CDK] [Worker] Unhandled Rejection`, error);
+});

src/nodeWorker.ts

@@ -110,7 +110,7 @@ function startWorker(input: WorkerRequest) {
     Logger.log(`[Function ${input.functionId}]`, data.toString());
   });
   worker.stderr.on('data', (data: Buffer) => {
-    Logger.log(`[Function ${input.functionId}]`, data.toString());
+    Logger.error(`[Function ${input.functionId}]`, data.toString());
   });
   worker.on('exit', () => {
     Logger.verbose(