Additional logging to see why this app sometimes crashes in dev

Author: jmgasper

app.js

@@ -11,6 +11,45 @@ const bodyParser = require("body-parser");
 const cors = require("cors");
 const HttpStatus = require("http-status-codes");
 const logger = require("./src/common/logger");
+
+// Global error and signal handlers to improve crash visibility.
+// Note: SIGSEGV cannot be handled in userland, but these cover other fatal cases.
+process.on("uncaughtException", (err) => {
+  try {
+    logger.error("Uncaught exception:", err);
+    if (process.report && typeof process.report.writeReport === "function") {
+      const reportPath = process.report.writeReport();
+      if (reportPath) logger.error(`Diagnostic report written: ${reportPath}`);
+    }
+  } finally {
+    // Exit to avoid undefined state after an unhandled exception
+    process.exit(1);
+  }
+});
+
+process.on("unhandledRejection", (reason, promise) => {
+  logger.error("Unhandled rejection:", { reason, promise });
+  try {
+    if (process.report && typeof process.report.writeReport === "function") {
+      const reportPath = process.report.writeReport();
+      if (reportPath) logger.error(`Diagnostic report written: ${reportPath}`);
+    }
+  } catch (_) {}
+});
+
+// Allow on-demand diagnostic reports (e.g., docker/ecs kill -s SIGUSR2 <container>)
+process.on("SIGUSR2", () => {
+  try {
+    if (process.report && typeof process.report.writeReport === "function") {
+      const reportPath = process.report.writeReport();
+      if (reportPath) logger.warn(`SIGUSR2 received. Diagnostic report: ${reportPath}`);
+    } else {
+      logger.warn("SIGUSR2 received, but process.report is not available.");
+    }
+  } catch (err) {
+    logger.error("Error generating diagnostic report on SIGUSR2:", err);
+  }
+});
 const interceptor = require("express-interceptor");
 const fileUpload = require("express-fileupload");
 const YAML = require("yamljs");

docker/Dockerfile

@@ -11,4 +11,12 @@ WORKDIR /challenge-api
 RUN npm i -g pnpm
 RUN pnpm install
 
-CMD node /challenge-api/app.js
+# Enable Node diagnostic reports and Prisma backtraces for deeper crash insights
+ENV NODE_OPTIONS="--report-on-fatalerror --report-uncaught-exception --report-signal=SIGUSR2 --report-directory=/challenge-api/reports --report-filename=report.%p.%t.json --enable-source-maps"
+ENV RUST_BACKTRACE=1
+# Optional: raise Prisma log level from the engine; keep it modest by default
+ENV PRISMA_LOG_LEVEL=info
+
+RUN mkdir -p /challenge-api/reports
+
+CMD ["node","/challenge-api/app.js"]

src/common/prisma.js

@@ -7,6 +7,7 @@ const {
   PrizeSetTypeEnum,
   ReviewOpportunityTypeEnum,
 } = require("@prisma/client");
+const logger = require("./logger");
 
 const prismaClient = new PrismaClient({
   log: [
@@ -24,6 +25,35 @@ const prismaClient = new PrismaClient({
   },
 });
 
+// Forward Prisma engine logs to the application logger. This helps diagnose
+// native engine panics or crashes that may lead to exit code 139.
+prismaClient.$on("error", (e) => {
+  try {
+    logger.error(`[prisma:error] ${e.message || e}`);
+  } catch (_) {}
+});
+prismaClient.$on("warn", (e) => {
+  try {
+    logger.warn(`[prisma:warn] ${e.message || e}`);
+  } catch (_) {}
+});
+prismaClient.$on("info", (e) => {
+  try {
+    logger.info(`[prisma:info] ${e.message || e}`);
+  } catch (_) {}
+});
+
+// Optional verbose query logging: enable by setting PRISMA_LOG_QUERIES=true
+if (process.env.PRISMA_LOG_QUERIES === "true") {
+  prismaClient.$on("query", (e) => {
+    try {
+      logger.info(
+        `[prisma:query] ${e.query} params=${e.params} duration=${e.duration}ms`
+      );
+    } catch (_) {}
+  });
+}
+
 // By running the first query, prisma calls $connect() under the hood
 module.exports.prismaConnect = () => {
   prismaClient.$connect();

src/common/review-prisma.js

@@ -1,5 +1,6 @@
 const { PrismaClient } = require("@prisma/client");
 const config = require("config");
+const logger = require("./logger");
 
 let reviewPrismaClient;
 
@@ -28,6 +29,31 @@ const getReviewClient = () => {
   }
   if (!reviewPrismaClient) {
     reviewPrismaClient = createClient();
+    // Forward Prisma engine logs for the review DB
+    reviewPrismaClient.$on("error", (e) => {
+      try {
+        logger.error(`[prisma:review:error] ${e.message || e}`);
+      } catch (_) {}
+    });
+    reviewPrismaClient.$on("warn", (e) => {
+      try {
+        logger.warn(`[prisma:review:warn] ${e.message || e}`);
+      } catch (_) {}
+    });
+    reviewPrismaClient.$on("info", (e) => {
+      try {
+        logger.info(`[prisma:review:info] ${e.message || e}`);
+      } catch (_) {}
+    });
+    if (process.env.PRISMA_LOG_QUERIES === "true") {
+      reviewPrismaClient.$on("query", (e) => {
+        try {
+          logger.info(
+            `[prisma:review:query] ${e.query} params=${e.params} duration=${e.duration}ms`
+          );
+        } catch (_) {}
+      });
+    }
   }
   return reviewPrismaClient;
 };