websocket separation

docker-compose.yaml

@@ -45,6 +45,13 @@ services:
       timeout: 10s
       retries: 10
       start_period: 20s
+   io-server:
+     image:  manik2708/hi-io-server:latest
+     environment:
+      REDIS_URL: redis://client:6379
+     container_name: hi-io-server
+     networks:
+      - hi-services 
 networks:
   hi-services:
     external: true

src/Controllers/RetrieveData/Services/retrieve_data_services.ts

@@ -36,15 +36,17 @@ export class RetrieveDataServices {
               socket_id!,
               ommited_message,
               user_id,
-              this.client
+              this.client,
             );
           switch (message.message_type) {
             case MessageType.CONFESSION_MESSAGE_TYPE:
               await message_sender.sendMessage(EventNames.recieveConfession);
               chnl.ack(msg);
               break;
             case MessageType.UPDATE_CONFESSION_STATUS:
-              await message_sender.sendMessage(EventNames.updateConfssionStatus);
+              await message_sender.sendMessage(
+                EventNames.updateConfssionStatus,
+              );
               chnl.ack(msg);
               break;
             case MessageType.ACCEPT_CONFESSION_TYPE:
@@ -76,25 +78,28 @@ class SendMessageToWebsocketServices {
   private redis: RedisClientType;
   private socket_id: string;
   private message: any;
-  private user_id: string
+  private user_id: string;
 
   constructor(
     socket_id: string,
     message: any,
     user_id: string,
-    redis: RedisClientType
+    redis: RedisClientType,
   ) {
     this.socket_id = socket_id;
     this.message = message;
     this.redis = redis;
-    this.user_id = user_id
+    this.user_id = user_id;
   }
 
   sendMessage = async (name: string) => {
-    await this.redis.PUBLISH(this.user_id, JSON.stringify({
-      id: this.socket_id,
-      name: name,
-      data: this.message
-    }))
+    await this.redis.PUBLISH(
+      this.user_id,
+      JSON.stringify({
+        id: this.socket_id,
+        name: name,
+        data: this.message,
+      }),
+    );
   };
-}
+}

src/Services/send_message_to_user.ts

@@ -40,11 +40,14 @@ export class SendMessageToUserService {
           RedisNames.OnlineUserMap + userId,
           RedisNames.SocketId,
         );
-        await this.client.PUBLISH(userId, JSON.stringify({
-          id: socketid!,
-          name: userIsOnlineEvent,
-          data: messageForOnlineUser,
-        }))
+        await this.client.PUBLISH(
+          userId,
+          JSON.stringify({
+            id: socketid!,
+            name: userIsOnlineEvent,
+            data: messageForOnlineUser,
+          }),
+        );
         if (afterAcknowledgement) {
           await afterAcknowledgement();
         }

test/Controllers/Chats/Services/delete_chat_message_for_me.e2e-spec.ts

@@ -1,10 +1,4 @@
-import {
-  describe,
-  it,
-  expect,
-  beforeAll,
-  afterEach,
-} from '@jest/globals';
+import { describe, it, expect, beforeAll, afterEach } from '@jest/globals';
 import { delay } from '../../../Helpers/get_testing_app';
 import { SendMessageToUserService } from '../../../../src/Services/send_message_to_user';
 import { CassandraDatabaseQueries } from '../../../../src/Database/Cassandra/queries';

test/Controllers/Confession/Services/send_confession.e2e-spec.ts

@@ -25,7 +25,7 @@ describe('Send confession tests', () => {
   let socket: Socket;
   let outputData: any;
   let cassandraClient: Client;
-  let crushId = nanoid().toLowerCase()
+  let crushId = nanoid().toLowerCase();
   beforeAll(async () => {
     redisClient = await TestServiceContainers.getTestingRedisClient().connect();
     const moduleRef = await getTestingGlobalServicesModule();

test/Helpers/create_socket_client.ts

@@ -1,4 +1,3 @@
-import { INestApplication } from '@nestjs/common';
 import { io as IoClient, Socket as ClientSocket } from 'socket.io-client';
 
 export const initClientSocket = async (
@@ -12,8 +11,8 @@ export const initClientSocket = async (
 
     socket.on('connect', () => {
       socket.emit('subscribe', {
-        userId: userId
-      })
+        userId: userId,
+      });
       callback(socket);
       resolve(socket);
     });

test/docker-compose.yaml

@@ -12,6 +12,8 @@ services:
       retries: 3
       start_period: 20s 
     container_name: client-testing
+    networks:
+      - hi-test-services
   rabbitmq-testing:
     image: rabbitmq
     ports:
@@ -23,7 +25,9 @@ services:
       interval: 10s
       timeout: 3s
       retries: 3
-      start_period: 20s  
+      start_period: 20s
+    networks:
+      - hi-test-services  
   cassandra-testing:
     image: cassandra:latest
     ports:
@@ -35,6 +39,8 @@ services:
       timeout: 10s
       retries: 10
       start_period: 20s
+    networks:
+      - hi-test-services
   mongodb-testing:
     image: mongo:latest
     ports: 
@@ -46,4 +52,18 @@ services:
       timeout: 10s
       retries: 10
       start_period: 20s
-
+    networks:
+      - hi-test-services
+  io-server-testing:
+    image:  manik2708/hi-io-server:latest
+    ports:
+      - "3500:3500"
+    environment:
+      REDIS_URL: redis://client-testing:6379
+      PORT: 3500
+    container_name: hi-io-server-testing
+    networks:
+      - hi-test-services 
+networks:
+  hi-test-services:
+    driver: bridge