feat: extend Pino logger to critical server modules

- Update k8s-config.ts (6 console calls → logger calls)
- Update log-ingester.ts (3 console calls → logger calls)
- Update anomaly-ai-analyzer.ts (5 console calls → logger calls)
- Remove [ModuleName] prefixes from log messages (handled by logger.name field)
- All 941 tests passing, build ✓

Server logs now include automatic timestamps across all critical paths:
[HH:MM:ss] LEVEL (K8s Config): kubectl (358ms): get pods...
[HH:MM:ss] LEVEL (LogIngester): Tailing logs from: pod-name...
[HH:MM:ss] LEVEL (AnomalyAIAnalyzer): Calling AI provider with N anomalies...

Co-Authored-By: Claude Haiku 4.5 <noreply@anthropic.com>

Author: theo-learner

src/lib/anomaly-ai-analyzer.ts

@@ -9,6 +9,9 @@ import { AISeverity } from '@/types/scaling';
 import { chatCompletion } from './ai-client';
 import { parseAIJSON } from './ai-response-parser';
 import { getChainPlugin } from '@/chains';
+import { createLogger } from '@/lib/logger';
+
+const logger = createLogger('AnomalyAIAnalyzer');
 
 // ============================================================================
 // Configuration
@@ -192,13 +195,13 @@ export async function analyzeAnomalies(
   if (analysisCache &&
       analysisCache.anomalyHash === anomalyHash &&
       now - analysisCache.timestamp < ANALYSIS_CACHE_TTL_MS) {
-    console.info('[AnomalyAIAnalyzer] Returning cached analysis');
+    logger.info('Returning cached analysis');
     return analysisCache.result;
   }
 
   // 2. Rate limiting: return cached result or default response if interval not met
   if (now - lastAICallTime < MIN_AI_CALL_INTERVAL_MS) {
-    console.info('[AnomalyAIAnalyzer] Rate limited, returning cached or default');
+    logger.info('Rate limited, returning cached or default');
     if (analysisCache) {
       return analysisCache.result;
     }
@@ -227,7 +230,7 @@ Analyze these anomalies and provide your assessment.`;
 
   // 4. Call AI Gateway
   try {
-    console.info(`[AnomalyAIAnalyzer] Calling AI provider with ${anomalies.length} anomalies...`);
+    logger.info(`Calling AI provider with ${anomalies.length} anomalies...`);
     lastAICallTime = now;
 
     const aiResult = await chatCompletion({
@@ -248,12 +251,12 @@ Analyze these anomalies and provide your assessment.`;
       timestamp: now,
     };
 
-    console.info(`[AnomalyAIAnalyzer] Analysis complete: severity=${result.severity}, type=${result.anomalyType}`);
+    logger.info(`Analysis complete: severity=${result.severity}, type=${result.anomalyType}`);
     return result;
 
   } catch (error) {
     const errorMessage = error instanceof Error ? error.message : 'Unknown error';
-    console.error('[AnomalyAIAnalyzer] AI provider error:', errorMessage);
+    logger.error('AI provider error: ' + errorMessage);
 
     // Default response on failure
     return {

src/lib/k8s-config.ts

@@ -5,9 +5,11 @@
 
 import { exec, execFile } from 'child_process';
 import { promisify } from 'util';
+import { createLogger } from '@/lib/logger';
 
 const execAsync = promisify(exec);
 const execFileAsync = promisify(execFile);
+const logger = createLogger('K8s Config');
 
 // ============================================================
 // Environment Detection
@@ -26,7 +28,7 @@ function isDevelopmentEnvironment(): boolean {
  */
 function logK8sWarning(message: string): void {
   if (!isDevelopmentEnvironment()) {
-    console.warn(`[K8s Config] ${message}`);
+    logger.warn(message);
   } else if (process.env.DEBUG_K8S === 'true') {
     console.debug(`[K8s Config] ${message}`);
   }
@@ -119,7 +121,7 @@ async function resolveAwsRegion(): Promise<string | undefined> {
     const region = stdout.trim();
     if (region) {
       regionCache = region;
-      console.info(`[K8s Config] Auto-detected AWS region: ${region}`);
+      logger.info(`Auto-detected AWS region: ${region}`);
       return regionCache;
     }
   } catch {
@@ -169,7 +171,7 @@ async function resolveK8sApiUrl(): Promise<string | undefined> {
 
     if (endpoint && endpoint !== 'None') {
       apiUrlCache = endpoint;
-      console.info(`[K8s Config] Auto-detected API URL: ${endpoint} (${Date.now() - startTime}ms)`);
+      logger.info(`Auto-detected API URL: ${endpoint} (${Date.now() - startTime}ms)`);
       return apiUrlCache;
     }
   } catch (e) {
@@ -217,7 +219,7 @@ async function getK8sToken(): Promise<string | undefined> {
 
     const startTime = Date.now();
     const { stdout } = await execFileAsync('aws', args, { timeout: 10000 });
-    console.info(`[K8s Config] Token generated (${Date.now() - startTime}ms)`);
+    logger.info(`Token generated (${Date.now() - startTime}ms)`);
 
     const tokenData = JSON.parse(stdout);
     const token = tokenData.status.token;
@@ -302,12 +304,12 @@ export async function runK8sCommand(
     const result = await execAsync(fullCmd, {
       timeout: options?.timeout ?? 10000,
     });
-    console.info(`[K8s Config] kubectl (${Date.now() - startTime}ms): ${command.substring(0, 40)}...`);
+    logger.info(`kubectl (${Date.now() - startTime}ms): ${command.substring(0, 40)}...`);
     return result;
   } catch (e) {
     // Only log kubectl failures in production/configured environments
     if (!isDevelopmentEnvironment()) {
-      console.info(`[K8s Config] kubectl failed (${Date.now() - startTime}ms): ${command}`);
+      logger.info(`kubectl failed (${Date.now() - startTime}ms): ${command}`);
     }
     throw e;
   }

src/lib/log-ingester.ts

@@ -37,6 +37,9 @@ export function generateMockLogs(mode: 'normal' | 'attack' = 'normal'): Record<s
 import { runK8sCommand, getNamespace, getAppPrefix } from '@/lib/k8s-config';
 import { isDockerMode } from '@/lib/docker-config';
 import { getDockerContainerLogs } from '@/lib/docker-orchestrator';
+import { createLogger } from '@/lib/logger';
+
+const logger = createLogger('LogIngester');
 
 // Fetch logs from ALL components
 export async function getAllLiveLogs(namespace?: string): Promise<Record<string, string>> {
@@ -68,13 +71,13 @@ export async function getLiveLogs(namespace?: string, labelSelector?: string): P
         );
 
         if (!podName || podName.trim() === '') {
-            console.warn(`[LogIngester] No pods found for ${label}`);
+            logger.warn(`No pods found for ${label}`);
             return `WARN [System] No active pods found matching '${label}' in namespace '${ns}'.
             Verify your K8s context and pod labels.`;
         }
 
         const cleanPodName = podName.trim();
-        console.info(`[LogIngester] Tailing logs from: ${cleanPodName}`);
+        logger.info(`Tailing logs from: ${cleanPodName}`);
 
         // 2. Fetch Logs (Tail)
         const { stdout: logs, stderr: logsErr } = await runK8sCommand(
@@ -89,7 +92,7 @@ export async function getLiveLogs(namespace?: string, labelSelector?: string): P
 
     } catch (error) {
         const errorMessage = error instanceof Error ? error.message : 'Unknown error';
-        console.error("[LogIngester] kubectl Error:", errorMessage);
+        logger.error("kubectl Error: " + errorMessage);
 
         if (errorMessage.includes('command not found')) {
             return `ERROR [System] 'kubectl' command not found on server.