feat: Integrate Sentry logging and enhance SSE timeout configurations

Author: tacxou

apps/api/src/core/logger/internal.logger.ts

@@ -2,6 +2,7 @@ import { ConsoleLogger, Injectable, LogLevel } from '@nestjs/common';
 import { MongooseModuleOptions } from '@nestjs/mongoose';
 import { Request } from 'express';
 import { Connection, connect } from 'mongoose';
+import * as Sentry from '@sentry/nestjs';
 
 export interface InternalLoggerOptions {
   logLevel: LogLevel[];
@@ -32,11 +33,17 @@ export class InternalLogger extends ConsoleLogger {
   }
 
   public async initialize() {
+    Sentry.logger.info('Initializing logs database connection...', {
+      'module': this.constructor.name,
+    });
     super.log('Initializing logs database connection...', this.constructor.name);
     try {
       const mongoose = await connect(this._options.mongoose.uri, this._options.mongoose.options);
       this.connection = mongoose.connection;
     } catch (e) {
+      Sentry.logger.error('Failed to connect to the logs database', e, {
+        'module': this.constructor.name,
+      });
       super.error('Failed to connect to the logs database', e, this.constructor.name);
       setTimeout(() => this.initialize(), 5000);
     }
@@ -56,6 +63,9 @@ export class InternalLogger extends ConsoleLogger {
       if (!options.target.includes(InternalLogLevel.CONSOLE)) return;
     }
 
+    Sentry.logger.error(message, {
+      'module': typeof lastParam === 'string' ? lastParam : this.constructor.name,
+    });
     super.error(...[message, ...optionalParams]);
   }
 
@@ -72,6 +82,7 @@ export class InternalLogger extends ConsoleLogger {
       if (!options.target.includes(InternalLogLevel.CONSOLE)) return;
     }
 
+    Sentry.logger.warn(message);
     super.warn(...[message, ...optionalParams]);
   }
 
@@ -85,6 +96,7 @@ export class InternalLogger extends ConsoleLogger {
       if (!options.target.includes(InternalLogLevel.CONSOLE)) return;
     }
 
+    Sentry.logger.info(message);
     super.log(...[message, ...optionalParams]);
   }
 
@@ -101,6 +113,7 @@ export class InternalLogger extends ConsoleLogger {
       if (!options.target.includes(InternalLogLevel.CONSOLE)) return;
     }
 
+    Sentry.logger.debug(message);
     super.debug(...[message, ...optionalParams]);
   }
 
@@ -133,6 +146,7 @@ export class InternalLogger extends ConsoleLogger {
       if (!options.target.includes(InternalLogLevel.CONSOLE)) return;
     }
 
+    Sentry.logger.fatal(message);
     super.fatal(...[message, ...optionalParams]);
   }
 

apps/api/src/instrument.ts

@@ -7,17 +7,20 @@ if (!process.env.SESAME_SENTRY_DSN) {
 } else {
   Sentry.init({
     dsn: process.env.SESAME_SENTRY_DSN!,
+    release: process.env.npm_package_name + '@' + process.env.npm_package_version,
     debug: false,
 
     sendDefaultPii: true,
     tracesSampleRate: 1.0,
     profilesSampleRate: 1.0,
     includeLocalVariables: true,
+    profileLifecycle: 'trace',
+
+    enableLogs: true,
 
     integrations: [
       nodeProfilingIntegration(),
 
-
       Sentry.mongooseIntegration(),
       Sentry.consoleIntegration(),
       Sentry.httpIntegration(),
@@ -27,5 +30,10 @@ if (!process.env.SESAME_SENTRY_DSN) {
       Sentry.fsIntegration(),
     ],
   })
+  Sentry.startSpan({
+    name: "My Span",
+  }, () => {
+    // The code executed here will be profiled
+  });
   Logger.log(`Sentry initialized successfully`, 'SentryInit')
 }

apps/api/src/main.ts

@@ -64,11 +64,23 @@ declare const module: any;
 
   const shutdownObserver = app.get(ShutdownObserver);
   const httpServer = http.createServer(server).listen(4000);
+
+  // Set timeout to 0 for SSE connections
+  httpServer.timeout = 0;
+  httpServer.keepAliveTimeout = 0;
+  httpServer.headersTimeout = 0;
+
   shutdownObserver.addHttpServer(httpServer);
   logger.log(`Sesame - Orchestrator is READY on <http://127.0.0.1:4000> !`);
 
   if (cfg.application?.https?.enabled) {
     const httpsServer = https.createServer(extraOptions.httpsOptions!, server).listen(4443);
+
+    // Set timeout to 0 for SSE connections
+    httpsServer.timeout = 0;
+    httpsServer.keepAliveTimeout = 0;
+    httpsServer.headersTimeout = 0;
+
     shutdownObserver.addHttpServer(httpsServer);
     logger.log(`Sesame - Orchestrator is READY on <https://127.0.0.1:4443> !`);
   }

apps/web/nuxt.config.ts

@@ -137,6 +137,15 @@ export default defineNuxtConfig({
         secure: false,
         changeOrigin: true,
         xfwd: true,
+        configure: (proxy, options) => {
+          proxy.on('proxyReq', (proxyReq, req, res) => {
+            // Disable timeout for SSE endpoints
+            if (req.url?.includes('/backends/sse')) {
+              proxyReq.setTimeout(0);
+              res.setTimeout(0);
+            }
+          });
+        },
       }
     },
     cors: false,
@@ -196,6 +205,21 @@ export default defineNuxtConfig({
   future: {
     typescriptBundlerResolution: true,
   },
+  nitro: {
+    experimental: {
+      websocket: false,
+    },
+    routeRules: {
+      '/api/core/backends/sse': {
+        // Disable compression and caching for SSE
+        headers: {
+          'Cache-Control': 'no-cache, no-transform',
+          'Connection': 'keep-alive',
+          'X-Accel-Buffering': 'no', // Disable buffering in nginx
+        },
+      },
+    },
+  },
   experimental: {
     appManifest: false,
   },
@@ -227,7 +251,7 @@ export default defineNuxtConfig({
       console.log('[OpenapiTS] Generating .nuxt/types/service-api.d.ts...')
       try {
         const fileData = await openapiTS(`${SESAME_APP_API_URL}/swagger/json`)
-        writeFileSync('.nuxt/types/service-api.d.ts', fileData)
+        writeFileSync('.nuxt/types/service-api.d.ts', String(fileData))
         console.log('[OpenapiTS] Generated .nuxt/types/service-api.d.ts !')
       } catch (error) {
         console.debug('[OpenapiTS] Error while generating .nuxt/types/service-api.d.ts', error)