Add interface for logger, add logger factories

src/application/commandProcessors/createUser.ts

@@ -1,5 +1,3 @@
-import { Logger } from "pino";
-
 import {
     InvalidUserNameError,
     InvalidEmailError,
@@ -15,6 +13,7 @@ import {
     UserTelegramIsAlreadyTakenError,
     UserGateway,
     TransactionManager,
+    Logger,
 } from "src/application/common";
 import { CreateUserCommand } from "src/application/commands";
 
@@ -114,8 +113,8 @@ class CreateUserLoggingProcessor {
 
     async process(command: CreateUserCommand): Promise<void> {
         this.logger.debug(
-            {command: command},
             "'Create user' command processing started",
+            {command: command},
         )
 
         try {
@@ -154,8 +153,8 @@ class CreateUserLoggingProcessor {
             )
         } else {
             this.logger.error(
-                {"traceback": error.stack},
                 "Unexpected error occurred",
+                {"traceback": error.stack},
             )
         }
         throw error

src/application/common/index.ts

@@ -3,4 +3,5 @@ export * from "./errors";
 export * from "./valueObjects";
 export * from "./commandProcessors";
 
+export { type Logger } from "./logger";
 export { type TransactionManager } from "./transactionManager";

src/application/common/logger.ts

@@ -0,0 +1,6 @@
+export interface Logger {
+    debug(message: string, obj?: object): void;
+    info(message: string, obj?: object): void;
+    warning(message: string, obj?: object): void;
+    error(message: string, obj?: object): void;
+}

src/infrastructure/logging/index.ts

@@ -0,0 +1,3 @@
+export * from "./pino";
+
+export { RealLogger } from "./logger";

src/infrastructure/logging/logger.ts

@@ -0,0 +1,22 @@
+import { Logger as PinoLogger } from "pino";
+
+
+export class RealLogger {
+    constructor(protected readonly pinoLogger: PinoLogger) {}
+
+    debug(message: string, obj?: object): void {
+        this.pinoLogger.debug(obj, message)
+    }
+
+    info(message: string, obj?: object): void {
+        this.pinoLogger.info(obj, message)
+    }
+
+    warning(message: string, obj?: object): void {
+        this.pinoLogger.warn(obj, message)
+    }
+
+    error(message: string, obj?: object): void {
+        this.pinoLogger.error(obj,message)
+    }
+}

src/infrastructure/logging/pino.ts

@@ -0,0 +1,16 @@
+import { Logger as PinoLogger, pino } from "pino";
+
+import { OperationId } from "src/application";
+
+
+export function pinoRootLoggerFactory(): PinoLogger {
+    return pino()
+}
+
+
+export function pinoLoggerFactory(
+    rootPinoLogger: PinoLogger,
+    operationId: OperationId,
+): PinoLogger {
+    return rootPinoLogger.child({"operation_id": operationId})
+}

src/presentation/cli/handlers/createUser.ts

@@ -1,5 +1,5 @@
 import { Command, OptionValues } from "commander";
-import { pino } from "pino";
+import { v7 as uuid7 } from "uuid";
 
 import {
     UserId,
@@ -8,12 +8,20 @@ import {
     TelegramValidator,
     CreateUser,
 } from "src/domain";
-import { createUserFactory } from "src/application";
+import {
+    OperationId,
+    createUserFactory,
+} from "src/application";
 import {
     UserMapper,
     postgresConfigFromEnv,
     kyselyDatabaseFactory,
 } from "src/infrastructure/database";
+import {
+    pinoRootLoggerFactory,
+    pinoLoggerFactory,
+    RealLogger,
+} from "src/infrastructure/logging";
 
 
 export const createUserCommand = new Command("create-user")
@@ -38,11 +46,18 @@ async function createUser(options: OptionValues): Promise<void> {
         telegramValidator: new TelegramValidator(),
     })
 
+    const pinoRootLogger = pinoRootLoggerFactory()
+    const pinoLogger = pinoLoggerFactory(
+        pinoRootLogger,
+        new OperationId(uuid7()),
+    )
+    const realLogger = new RealLogger(pinoLogger)
+
     const commandProcessor = createUserFactory({
         createUser: createUser,
         userGateway: userMapper,
         txManager: {commit: async () => {}},
-        logger: pino(),
+        logger: realLogger,
     })
     await commandProcessor.process({
         id: new UserId(options.id),