cleaned up index

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);
+// Setup shutdown handling
+setShutdownTimeout(15000);
 
-  // Register cleanup for HTTP server
-  onShutdown(async () => {
-    if (server) {
-      logger.info('Stopping HTTP server...');
-      server.stop();
-    }
-  });
+// 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');
-}
+// 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');