From 56d621bab8d446ed6111037282f04d569da07b47 Mon Sep 17 00:00:00 2001
From: Davidson Gomes <davidsongviolao@gmail.com>
Date: Wed, 2 Aug 2023 21:14:21 -0300
Subject: [PATCH] feat: Added rabbitmq to send events

---
 src/libs/amqp.server.ts   | 2 +-
 src/libs/socket.server.ts | 7 ++++---
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/libs/amqp.server.ts b/src/libs/amqp.server.ts
index 9b3e7f7c..86819c80 100644
--- a/src/libs/amqp.server.ts
+++ b/src/libs/amqp.server.ts
@@ -27,7 +27,7 @@ export const initAMQP = () => {
         channel.assertExchange(exchangeName, 'topic', { durable: false });
         amqpChannel = channel;
 
-        logger.log('AMQP initialized');
+        logger.info('AMQP initialized');
         resolve();
       });
     });
diff --git a/src/libs/socket.server.ts b/src/libs/socket.server.ts
index 4be23d01..367a3933 100644
--- a/src/libs/socket.server.ts
+++ b/src/libs/socket.server.ts
@@ -11,7 +11,6 @@ let io: SocketIO;
 const cors = configService.get<Cors>('CORS').ORIGIN;
 
 export const initIO = (httpServer: Server) => {
-  logger.verbose('Initializing Socket.io');
   io = new SocketIO(httpServer, {
     cors: {
       origin: cors,
@@ -19,12 +18,14 @@ export const initIO = (httpServer: Server) => {
   });
 
   io.on('connection', (socket) => {
-    logger.verbose('Client connected');
+    logger.info('User connected');
+
     socket.on('disconnect', () => {
-      logger.verbose('Client disconnected');
+      logger.info('User disconnected');
     });
   });
 
+  logger.info('Socket.io initialized');
   return io;
 };