[FEATURE]: refactor codes and add logger

package.json

@@ -26,7 +26,7 @@
   "homepage": "https://github.com/Behzad-rabiei/tc-discordBot#readme",
   "dependencies": {
     "@sentry/node": "^7.51.2",
-    "@togethercrew.dev/db": "^2.4.95",
+    "@togethercrew.dev/db": "^2.4.96",
     "@togethercrew.dev/tc-messagebroker": "^0.0.40",
     "babel-jest": "^29.5.0",
     "bullmq": "^3.14.0",
@@ -36,6 +36,7 @@
     "mongodb": "^5.4.0",
     "mongoose": "^6.11.1",
     "node-fetch": "^2.6.7",
+    "pino": "^8.15.0",
     "redis": "^4.6.6"
   },
   "devDependencies": {

src/config/index.ts

@@ -20,6 +20,7 @@ const envVarsSchema = Joi.object()
     REDIS_HOST: Joi.string().required().description('Reids host'),
     REDIS_PORT: Joi.string().required().description('Reids port'),
     REDIS_PASSWORD: Joi.string().required().description('Reids password').allow(''),
+    LOG_LEVEL: Joi.string().required().description('Min allowed log level'),
   })
   .unknown();
 
@@ -51,4 +52,7 @@ export default {
     dsn: envVars.SENTRY_DSN,
     env: envVars.SENTRY_ENV,
   },
+  logger: {
+    level: envVars.LOG_LEVEL,
+  },
 };

src/config/logger.ts

@@ -0,0 +1,18 @@
+import pino, { Bindings } from 'pino';
+import config from './index';
+
+export default pino({
+  level: config.logger.level,
+  formatters: {
+    level: label => {
+      return { level: label.toUpperCase() };
+    },
+  },
+  timestamp: () => `,"timestamp":"${new Date(Date.now()).toISOString()}"`,
+  bindings: (bindings: Bindings) => {
+    return {
+      pid: bindings.pid,
+      host: bindings.hostname,
+    };
+  },
+});

src/database/connection.ts

@@ -1,4 +1,8 @@
 import { Connection } from 'mongoose';
+import parentLogger from '../config/logger';
+
+const logger = parentLogger.child({ module: 'Connection' });
+
 /**
  * Closes a given Mongoose connection.
  * @param {Connection} connection - The Mongoose connection object to be closed.
@@ -8,8 +12,8 @@ import { Connection } from 'mongoose';
 export async function closeConnection(connection: Connection) {
   try {
     await connection.close();
-    console.log('The connection to the database has been successfully closed.');
-  } catch (err) {
-    console.log('Error closing connection to the database:', err);
+    logger.info({ database: connection.name }, 'The connection to database has been successfully closed');
+  } catch (error) {
+    logger.fatal({ database: connection.name, error }, 'Failed to close the connection to the database');
   }
 }