Many many more improvements

src/application/logger.ts

@@ -1,68 +1,73 @@
-import fs from 'fs'
-
 import pino from 'pino'
 
 import { getRootPath } from './storage'
 
-// Array of log types
-const LOG_TYPES = ['http', 'game', 'gameMaster', 'app', 'queue', 'command'] as const
-type LogType = (typeof LOG_TYPES)[number]
+export class Logger {
+  private static readonly LOG_TYPES = ['http', 'game', 'gameMaster', 'app', 'queue', 'command', 'repository', 'entity'] as const
+  private readonly logger: ReturnType<typeof pino>
 
-const createLogger = (name: LogType) =>
-  pino({
-    level: process.env.LOG_LEVEL || 'debug',
-    transport: {
-      target: 'pino/file',
-      options: {
-        destination: `./logs/${name}.log`,
-        mkdir: true
-      }
-    },
-    formatters: {
-      level: (label) => {
-        return { level: label.toUpperCase() }
-      }
-    },
-    timestamp: pino.stdTimeFunctions.isoTime,
-    base: null
-  })
-
-// Create logger instances
-const loggers = Object.fromEntries(LOG_TYPES.map((type) => [type, createLogger(type)])) as Record<LogType, ReturnType<typeof createLogger>>
-
-const watchLogs = () => {
-  LOG_TYPES.forEach((type) => {
-    const logFile = getRootPath('logs', `${type}.log`)
-
-    // Get initial file size
-    const stats = fs.statSync(logFile)
-    let lastPosition = stats.size
-
-    fs.watch(logFile, (eventType) => {
-      if (eventType !== 'change') {
-        return
-      }
-
-      fs.stat(logFile, (err, stats) => {
-        if (err) return
-
-        if (stats.size > lastPosition) {
-          const stream = fs.createReadStream(logFile, {
-            start: lastPosition,
-            end: stats.size
-          })
-
-          stream.on('data', (chunk) => {
-            console.log(`[${type}]\n${chunk.toString()}`)
-          })
-
-          lastPosition = stats.size
+  constructor(type: (typeof Logger.LOG_TYPES)[number]) {
+    this.logger = pino({
+      level: process.env.LOG_LEVEL || 'debug',
+      transport: {
+        target: 'pino/file',
+        options: {
+          destination: `./logs/${type}.log`,
+          mkdir: true
         }
+      },
+      formatters: {
+        level: (label) => ({ level: label.toUpperCase() })
+      },
+      timestamp: pino.stdTimeFunctions.isoTime,
+      base: null
+    })
+  }
+
+  info(message: string) {
+    this.logger.info(message)
+  }
+
+  error(message: string) {
+    this.logger.error(message)
+  }
+
+  warn(message: string) {
+    this.logger.warn(message)
+  }
+
+  debug(message: string) {
+    this.logger.debug(message)
+  }
+
+  static watch() {
+    const fs = require('fs')
+
+    this.LOG_TYPES.forEach((type) => {
+      const logFile = getRootPath('logs', `${type}.log`)
+      const stats = fs.statSync(logFile)
+      let lastPosition = stats.size
+
+      fs.watch(logFile, (eventType: string) => {
+        if (eventType !== 'change') return
+
+        fs.stat(logFile, (err: Error, stats: { size: number }) => {
+          if (err) return
+
+          if (stats.size > lastPosition) {
+            const stream = fs.createReadStream(logFile, {
+              start: lastPosition,
+              end: stats.size
+            })
+
+            stream.on('data', (chunk: Buffer) => {
+              console.log(`[${type}]\n${chunk.toString()}`)
+            })
+
+            lastPosition = stats.size
+          }
+        })
       })
     })
-  })
+  }
 }
-
-export const { http: httpLogger, game: gameLogger, gameMaster: gameMasterLogger, app: appLogger, queue: queueLogger, command: commandLogger } = loggers
-
-export { watchLogs }