[feat]: added winston logger

Praashh · Oct 19, 2024 · 99c8a35 · 99c8a35
1 parent 3965940
commit 99c8a35
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 6 deletions.
diff --git a/packages/order-queue/logs/server.log b/packages/order-queue/logs/server.log
@@ -0,0 +1,10 @@
+[ 2024-10-19 19:59:55 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-19 20:00:56 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-19 20:00:56 ] -  [32minfo[39m -  SERVER | REDIS: Connected to Redis
+[ 2024-10-19 20:00:56 ] -  [32minfo[39m -  SERVER | REDIS: Redis connection is ready
+[ 2024-10-19 20:01:12 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-19 20:01:12 ] -  [32minfo[39m -  SERVER | REDIS: Connected to Redis
+[ 2024-10-19 20:01:12 ] -  [32minfo[39m -  SERVER | REDIS: Redis connection is ready
+[ 2024-10-19 20:02:18 ] -  [32minfo[39m -  WORKER | Starting order worker
+[ 2024-10-19 20:02:18 ] -  [32minfo[39m -  SERVER | REDIS: Connected to Redis
+[ 2024-10-19 20:02:18 ] -  [32minfo[39m -  SERVER | REDIS: Redis connection is ready to start execution
diff --git a/packages/order-queue/package.json b/packages/order-queue/package.json
@@ -3,6 +3,7 @@
   "version": "1.0.0",
   "main": "index.js",
   "dependencies": {
+    "@opinix/logger": "*",
     "dotenv": "^16.4.5",
     "nodemon": "^3.1.7",
     "redis": "^4.7.0"

diff --git a/packages/order-queue/src/config/redisClient.ts b/packages/order-queue/src/config/redisClient.ts
@@ -1,5 +1,6 @@
 import IORedis, { Redis } from "ioredis";
 import "dotenv/config";
+import { logger } from "@opinix/logger";
 const redisUri = process.env.REDIS_URI || "redis://localhost:6379";
 let redisParams = {
   maxRetriesPerRequest: null,
@@ -11,23 +12,25 @@ const getRedisClient = () => {
       ...redisParams,
     });
     redisClient.on("connect", () => {
-      console.info("SERVER | REDIS: Connected to Redis");
+      logger.info("SERVER | REDIS: Connected to Redis");
     });
 
     redisClient.on("ready", () => {
-      console.info("SERVER | REDIS: Redis connection is ready");
+      logger.info(
+        "SERVER | REDIS: Redis connection is ready to start execution"
+      );
     });
 
     redisClient.on("error", (err) => {
-      console.error("SERVER: ERROR Connecting to Redis", err);
+      logger.error("SERVER: ERROR Connecting to Redis", err);
     });
 
     redisClient.on("close", () => {
-      console.warn("SERVER | REDIS: Connection closed");
+      logger.warn("SERVER | REDIS: Connection closed");
     });
 
     redisClient.on("reconnecting", () => {
-      console.info("SERVER | REDIS: Reconnecting...");
+      logger.info("SERVER | REDIS: Reconnecting...");
     });
   }
   return redisClient;

diff --git a/packages/order-queue/src/index.ts b/packages/order-queue/src/index.ts
@@ -1,7 +1,8 @@
 import { addToOrderQueue } from "./queues/orderQueue";
 import orderWorker from "./queues/orderProcessor";
+import { logger } from "@opinix/logger";
 const startWorker = async () => {
-  console.log("Starting Order Queue Worker...");
+  logger.info("WORKER | Starting order worker");
   orderWorker;
 };