Merge branch 'main' into forestgeo-app-acacia

frontend/components/processors/processormacros.tsx

@@ -243,3 +243,35 @@ export function buildPaginatedQuery(config: QueryConfig): {
 
   return { query, params: queryParams };
 }
+
+// Function to close all active connections
+async function closeConnections() {
+  console.log('Closing all active connections...');
+  await poolMonitor.closeAllConnections();
+  console.log('All connections closed.');
+}
+
+// Function to handle graceful shutdown
+async function gracefulShutdown() {
+  console.log('Initiating graceful shutdown...');
+  try {
+    await closeConnections();
+    console.log('Graceful shutdown complete.');
+    process.exit(0);
+  } catch (error) {
+    console.error('Error during graceful shutdown:', error);
+    process.exit(1);
+  }
+}
+
+// Capture SIGINT signal (triggered by ctrl+c)
+process.on('SIGINT', async () => {
+  console.log('SIGINT signal received.');
+  await gracefulShutdown();
+});
+
+// Capture SIGTERM signal (triggered by process kill)
+process.on('SIGTERM', async () => {
+  console.log('SIGTERM signal received.');
+  await gracefulShutdown();
+});

frontend/config/poolmonitor.ts

@@ -52,11 +52,10 @@ export class PoolMonitor {
       this.logPoolStatus();
       this.resetInactivityTimer();
     });
-
+    
     // Initialize inactivity timer
     this.resetInactivityTimer();
   }
-
   async getConnection(): Promise<PoolConnection> {
     if (this.poolClosed) {
       throw new Error('Connection pool is closed');