feat(logger): wire http/cli

- add http process handlers
- add NODE_ENV=test to config/schemas.ts

Author: clementvidon

backend/src/cli/http.ts

@@ -3,6 +3,7 @@ import { pathToFileURL } from 'node:url';
 import OpenAI from 'openai';
 import type { FetchPort } from '../application/ports/output/FetchPort';
 import type { LlmPort } from '../application/ports/output/LlmPort';
+import type { LoggerPort } from '../application/ports/output/LoggerPort';
 import type { PersistencePort } from '../application/ports/output/PersistencePort';
 import { makeReportingAgentService } from '../application/usecases/agent/makeReportingAgentService';
 import { makeSnapshotQueryService } from '../application/usecases/queries/makeSnapshotQueryService';
@@ -12,13 +13,29 @@ import { NodeFetchAdapter } from '../infrastructure/fetch/NodeFetchAdapter';
 import type { RedditCredentials } from '../infrastructure/items/redditAuth';
 import { RedditItemsAdapter } from '../infrastructure/items/RedditItemsAdapter';
 import { OpenAIAdapter } from '../infrastructure/llm/OpenAIAdapter';
+import { makeLogger } from '../infrastructure/logging/root';
 import { PostgresAdapter } from '../infrastructure/persistence/PostgresAdapter';
 import { makeReportController } from '../interface/web/ReportController';
 
+const rootLogger = makeLogger();
+
+process.on('unhandledRejection', (reason) => {
+  rootLogger.error('Unhandled rejection', { error: reason });
+  process.exit(1);
+});
+
+process.on('uncaughtException', (err) => {
+  rootLogger.error('Uncaught exception', { error: err });
+  process.exit(1);
+});
+
 type Deps = {
+  logger: LoggerPort;
   port: number;
+
   fetcher: FetchPort;
   persistence: PersistencePort;
+
   llm: LlmPort;
   redditUrl: string;
   redditCreds: RedditCredentials;
@@ -33,19 +50,24 @@ export function buildServer(deps: Deps) {
 
   const agent = makeReportingAgentService(provider, deps.llm, deps.persistence);
   const query = makeSnapshotQueryService(deps.persistence);
-  const app = makeReportController(agent, query);
+  const app = makeReportController(
+    deps.logger.child({ module: 'http' }),
+    agent,
+    query,
+  );
   return { app, port: deps.port };
 }
 
-export function depsFromConfig(config: ReportingAgentConfig): Deps {
+export function buildDeps(config: ReportingAgentConfig): Deps {
   const { port, databaseUrl, openaiApiKey, reddit } = config;
 
   return {
-    redditUrl: reddit.url,
+    logger: rootLogger,
     port,
     fetcher: new NodeFetchAdapter(globalThis.fetch),
     persistence: new PostgresAdapter(databaseUrl),
     llm: new OpenAIAdapter(new OpenAI({ apiKey: openaiApiKey })),
+    redditUrl: reddit.url,
     redditCreds: {
       clientId: reddit.clientId,
       clientSecret: reddit.clientSecret,
@@ -57,11 +79,11 @@ export function depsFromConfig(config: ReportingAgentConfig): Deps {
 
 export function runHttpServer() {
   const config = loadReportingAgentConfig();
-  const { app, port } = buildServer(depsFromConfig(config));
+  const deps = buildDeps(config);
+  const { app, port } = buildServer(deps);
 
-  return app.listen(port, () => {
-    console.log(`→ http://localhost:${port}`);
-  });
+  const httpLogger = rootLogger.child({ module: 'http' });
+  return app.listen(port, () => httpLogger.info('Server listening', { port }));
 }
 
 const entryUrl = process.argv[1]
@@ -72,7 +94,7 @@ if (import.meta.url === entryUrl) {
   try {
     runHttpServer();
   } catch (err) {
-    console.error('ReportingAgentService run failed:', err);
+    rootLogger.error('ReportingAgentService run failed:', { error: err });
     process.exit(1);
   }
 }

backend/src/infrastructure/config/schemas.ts

@@ -3,7 +3,9 @@ import { z } from 'zod';
 export const GlobalEnvSchema = z.object({
   APP_NAME: z.string().optional().default('app'),
   APP_VERSION: z.string().optional().default('0.0.0'),
-  NODE_ENV: z.enum(['development', 'production']).default('development'),
+  NODE_ENV: z
+    .enum(['development', 'production', 'test'])
+    .default('development'),
 });
 
 export const CoreEnvSchema = z.object({

backend/src/interface/web/ReportController.ts

@@ -1,26 +1,54 @@
 import express, { type Express } from 'express';
 import type { ReportingAgentPort } from '../../application/ports/input/ReportingAgentPort';
 import type { SnapshotQueryPort } from '../../application/ports/input/SnapshotQueryPort';
+import type { LoggerPort } from '../../application/ports/output/LoggerPort';
+
+declare module 'express-serve-static-core' {
+  interface Request {
+    logger?: LoggerPort;
+  }
+}
 
 export function makeReportController(
+  logger: LoggerPort,
   agent: ReportingAgentPort,
   query: SnapshotQueryPort,
 ): Express {
   const app = express();
   app.use(express.json());
 
-  app.get('/report', async (_, res) => {
-    const report = await query.getLastReport();
-    if (!report) return res.status(404).json({ error: 'No report found' });
-    res.json(report);
+  app.use((req, _res, next) => {
+    const requestId =
+      globalThis.crypto?.randomUUID?.() ?? Math.random().toString(36).slice(2);
+    req.logger = logger.child({ requestId });
+    next();
+  });
+
+  app.get('/report', async (req, res) => {
+    const reqLogger = req.logger ?? logger;
+    try {
+      const report = await query.getLastReport();
+      if (!report) {
+        reqLogger.warn('No report found');
+        return res.status(404).json({ error: 'No report found' });
+      }
+      res.json(report);
+    } catch (err) {
+      const error = err instanceof Error ? err : new Error(String(err));
+      reqLogger.error('Failed to load report', { error });
+      res.status(500).json({ error: 'Failed to load report' });
+    }
   });
 
-  app.post('/report', async (_, res) => {
+  app.post('/report', async (req, res) => {
+    const reqLogger = req.logger ?? logger;
     try {
       await agent.captureSnapshot();
+      reqLogger.info('Report snapshot captured');
       res.json({ ok: true });
     } catch (err) {
-      console.error(err);
+      const error = err instanceof Error ? err : new Error(String(err));
+      reqLogger.error('Failed to update report', { error });
       res.status(500).json({ error: 'Failed to update report' });
     }
   });

backend/src/interface/web/express.d.ts

@@ -0,0 +1,7 @@
+import type { LoggerPort } from '../../application/ports/output/LoggerPort';
+
+declare module 'express-serve-static-core' {
+  interface Request {
+    logger?: LoggerPort;
+  }
+}