From df611a3ce36321c7a505aeaaf1128cac1ccafef5 Mon Sep 17 00:00:00 2001
From: Boki <boki@stare.gg>
Date: Tue, 10 Jun 2025 21:06:01 -0400
Subject: [PATCH] cleaned up index

---
 apps/data-service/src/index.ts | 48 ++++++++++++++--------------------
 1 file changed, 19 insertions(+), 29 deletions(-)

diff --git a/apps/data-service/src/index.ts b/apps/data-service/src/index.ts
index 00a0311..dd3fde2 100644
--- a/apps/data-service/src/index.ts
+++ b/apps/data-service/src/index.ts
@@ -19,8 +19,8 @@ loadEnvVariables();
 
 const app = new Hono();
 const logger = getLogger('data-service');
-
 const PORT = parseInt(process.env.DATA_SERVICE_PORT || '3002');
+let server: any = null;
 
 // Register all routes
 app.route('', healthRoutes);
@@ -47,47 +47,37 @@ async function initializeServices() {
 }
 
 // Start server
-let server: any = null;
-
 async function startServer() {
   await initializeServices();
-  
   // Start the HTTP server using Bun's native serve
   server = Bun.serve({
     port: PORT,
     fetch: app.fetch,
     development: process.env.NODE_ENV === 'development',
   });
-  
   logger.info(`Data Service started on port ${PORT}`);
-  
-  // Register shutdown callbacks
-  setupShutdownHandlers();
 }
 
-// Setup shutdown handlers using the shutdown library
-function setupShutdownHandlers() {
-  // Set shutdown timeout to 15 seconds
-  setShutdownTimeout(15000);
-  
-  // Register cleanup for HTTP server
-  onShutdown(async () => {
-    if (server) {
-      logger.info('Stopping HTTP server...');
-      server.stop();
-    }
-  });
-  
-  // Register cleanup for queue manager
-  onShutdown(async () => {
-    logger.info('Shutting down queue manager...');
-    await queueManager.shutdown();
-  });
-  
-  logger.info('Shutdown handlers registered');
-}
+// Setup shutdown handling
+setShutdownTimeout(15000);
+
+// Register cleanup for HTTP server
+onShutdown(async () => {
+  if (server) {
+    logger.info('Stopping HTTP server...');
+    server.stop();
+  }
+});
+
+// Register cleanup for queue manager
+onShutdown(async () => {
+  logger.info('Shutting down queue manager...');
+  await queueManager.shutdown();
+});
 
 startServer().catch(error => {
   logger.error('Failed to start server', { error });
   process.exit(1);
 });
+
+logger.info('Shutdown handlers registered');
\ No newline at end of file