feat(satellite): add logger support to event handler functions

Author: Lasim

services/backend/src/events/satellite/index.ts

@@ -39,7 +39,7 @@ addFormats(ajv);
 /**
  * Build event handler registry by loading all handler modules
  */
-async function buildEventRegistry(): Promise<EventHandlerRegistry> {
+async function buildEventRegistry(logger?: FastifyBaseLogger): Promise<EventHandlerRegistry> {
   const registry: EventHandlerRegistry = {};
 
   for (const loadHandler of handlerModules) {
@@ -48,7 +48,12 @@ async function buildEventRegistry(): Promise<EventHandlerRegistry> {
 
       // Validate handler exports required fields
       if (!handler.EVENT_TYPE || !handler.SCHEMA || !handler.handle) {
-        console.error('Invalid event handler - missing required exports:', handler);
+        if (logger) {
+          logger.error({
+            operation: 'build_event_registry',
+            handler: handler?.EVENT_TYPE || 'unknown'
+          }, 'Invalid event handler - missing required exports');
+        }
         continue;
       }
 
@@ -58,7 +63,12 @@ async function buildEventRegistry(): Promise<EventHandlerRegistry> {
         handle: handler.handle
       };
     } catch (error) {
-      console.error('Failed to load event handler:', error);
+      if (logger) {
+        logger.error({
+          operation: 'build_event_registry',
+          error: error instanceof Error ? error.message : 'Unknown error'
+        }, 'Failed to load event handler');
+      }
     }
   }
 
@@ -71,9 +81,9 @@ let eventRegistry: EventHandlerRegistry | null = null;
 /**
  * Get or initialize event handler registry
  */
-async function getEventRegistry(): Promise<EventHandlerRegistry> {
+async function getEventRegistry(logger?: FastifyBaseLogger): Promise<EventHandlerRegistry> {
   if (!eventRegistry) {
-    eventRegistry = await buildEventRegistry();
+    eventRegistry = await buildEventRegistry(logger);
   }
   return eventRegistry;
 }
@@ -88,7 +98,7 @@ async function processEvent(
   logger: FastifyBaseLogger
 ): Promise<EventProcessingResult> {
   try {
-    const registry = await getEventRegistry();
+    const registry = await getEventRegistry(logger);
 
     // Check if event type is registered
     const handler = registry[event.type];
@@ -126,7 +136,7 @@ async function processEvent(
     }
 
     // Execute handler
-    await handler.handle(satelliteId, event.data, db, eventTimestamp);
+    await handler.handle(satelliteId, event.data, db, eventTimestamp, logger);
 
     logger.info({ 
       satelliteId, 

services/backend/src/events/satellite/mcp-client-activity.ts

@@ -1,4 +1,5 @@
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 import { mcpClientActivity, mcpClientActivityMetrics } from '../../db/schema.sqlite';
 import { eq, and, sql } from 'drizzle-orm';
 import { nanoid } from 'nanoid';
@@ -192,7 +193,8 @@ export async function handle(
   satelliteId: string,
   eventData: Record<string, unknown>,
   db: LibSQLDatabase,
-  eventTimestamp: Date
+  eventTimestamp: Date,
+  logger: FastifyBaseLogger
 ): Promise<void> {
   const data = eventData as unknown as McpClientActivityData;
   const authIdentifier = `oauth:${data.oauth_client_id}`;
@@ -217,13 +219,14 @@ export async function handle(
       eventTimestamp
     );
   } catch (error) {
-    console.error('Failed to write time-series metrics (non-fatal):', {
+    logger.error({
+      operation: 'write_time_series_metrics',
       error: error instanceof Error ? error.message : 'Unknown error',
       satelliteId,
       userId: data.user_id,
       teamId: data.team_id,
       requestCount: data.request_count,
       toolCallCount: data.tool_call_count
-    });
+    }, 'Failed to write time-series metrics (non-fatal)');
   }
 }

services/backend/src/events/satellite/mcp-server-crashed.ts

@@ -5,6 +5,7 @@
  */
 
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 import { satelliteProcesses } from '../../db/schema.sqlite';
 import { eq } from 'drizzle-orm';
 
@@ -84,7 +85,8 @@ export async function handle(
   satelliteId: string,
   eventData: Record<string, unknown>,
   db: LibSQLDatabase,
-  eventTimestamp: Date
+  eventTimestamp: Date,
+  _logger: FastifyBaseLogger
 ): Promise<void> {
   const data = eventData as unknown as ServerCrashedData;
 

services/backend/src/events/satellite/mcp-server-dormant.ts

@@ -5,6 +5,7 @@
  */
 
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 import { satelliteProcesses } from '../../db/schema.sqlite';
 import { eq } from 'drizzle-orm';
 
@@ -69,7 +70,8 @@ export async function handle(
   satelliteId: string,
   eventData: Record<string, unknown>,
   db: LibSQLDatabase,
-  eventTimestamp: Date
+  eventTimestamp: Date,
+  _logger: FastifyBaseLogger
 ): Promise<void> {
   const data = eventData as unknown as ServerDormantData;
 

services/backend/src/events/satellite/mcp-server-respawned.ts

@@ -5,6 +5,7 @@
  */
 
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 import { satelliteProcesses } from '../../db/schema.sqlite';
 import { eq } from 'drizzle-orm';
 
@@ -69,7 +70,8 @@ export async function handle(
   satelliteId: string,
   eventData: Record<string, unknown>,
   db: LibSQLDatabase,
-  eventTimestamp: Date
+  eventTimestamp: Date,
+  _logger: FastifyBaseLogger
 ): Promise<void> {
   const data = eventData as unknown as ServerRespawnedData;
 

services/backend/src/events/satellite/mcp-server-restarted.ts

@@ -5,6 +5,7 @@
  */
 
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 import { satelliteProcesses } from '../../db/schema.sqlite';
 import { eq } from 'drizzle-orm';
 
@@ -75,7 +76,8 @@ export async function handle(
   satelliteId: string,
   eventData: Record<string, unknown>,
   db: LibSQLDatabase,
-  eventTimestamp: Date
+  eventTimestamp: Date,
+  _logger: FastifyBaseLogger
 ): Promise<void> {
   const data = eventData as unknown as ServerRestartedData;
 

services/backend/src/events/satellite/mcp-server-started.ts

@@ -5,6 +5,7 @@
  */
 
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 import { satelliteProcesses } from '../../db/schema.sqlite';
 import { eq } from 'drizzle-orm';
 
@@ -75,7 +76,8 @@ export async function handle(
   satelliteId: string,
   eventData: Record<string, unknown>,
   db: LibSQLDatabase,
-  eventTimestamp: Date
+  eventTimestamp: Date,
+  _logger: FastifyBaseLogger
 ): Promise<void> {
   const data = eventData as unknown as ServerStartedData;
 

services/backend/src/events/satellite/mcp-tool-executed.ts

@@ -5,6 +5,7 @@
  */
 
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 import { satelliteUsageLogs } from '../../db/schema.sqlite';
 import { nanoid } from 'nanoid';
 
@@ -68,7 +69,8 @@ export async function handle(
   satelliteId: string,
   eventData: Record<string, unknown>,
   db: LibSQLDatabase,
-  eventTimestamp: Date
+  eventTimestamp: Date,
+  _logger: FastifyBaseLogger
 ): Promise<void> {
   const data = eventData as unknown as ToolExecutedData;
 

services/backend/src/events/satellite/types.ts

@@ -3,6 +3,7 @@
  */
 
 import type { LibSQLDatabase } from 'drizzle-orm/libsql';
+import type { FastifyBaseLogger } from 'fastify';
 
 /**
  * Base event structure that all events must conform to
@@ -54,7 +55,8 @@ export interface EventHandler {
     satelliteId: string,
     eventData: Record<string, unknown>,
     db: LibSQLDatabase,
-    eventTimestamp: Date
+    eventTimestamp: Date,
+    logger: FastifyBaseLogger
   ) => Promise<void>;
 }