Added the socket listener and emit for unsubscribe logic

Author: sedanurakcil

src/utils/SocketController.tsx

@@ -3,9 +3,10 @@ import { connect, socket, DataProps, MessageInfoProps } from "./socket";
 import { CommtContext } from "../context/Context";
 import * as types from "./emitTypes";
 import { updateUserOnline } from "../context/actions/usersActions";
-import { addMessage } from "../context/actions/messagesAction";
+import { addMessage, deleteMessages } from "../context/actions/messagesAction";
 import {
   addRoom,
+  deleteRoom,
   updateLastMessage,
   updateReadToken,
 } from "../context/actions/roomsActions";
@@ -211,6 +212,38 @@ const SocketController = () => {
     });
   }, []);
 
+  useEffect(() => {
+    socket.on(types.UNSUBSCRIBE_ROOM, (chatRoomAuthId) => {
+      try {
+        // Send request to server to leave room
+        socket.emit(types.LEAVE_ROOM, chatRoomAuthId, ({ status }) => {
+          // Check if the socket successfully leaves the room
+          if (status === "success") {
+            const roomId = rooms.find(
+              (room) => room.chatRoomAuthId === chatRoomAuthId,
+            )?.roomId;
+
+            // Update the context
+            deleteRoom(chatRoomAuthId)(dispatch);
+            roomId && deleteMessages(roomId)(dispatch);
+          }
+        });
+      } catch (error) {
+        handleLogger({
+          apiKey,
+          subscriptionKey,
+          projectName,
+          chatAuthId: selfUser?.chatAuthId,
+          chatRoomAuthId: chatRoomAuthId,
+          error: {
+            error,
+            event: types.UNSUBSCRIBE_ROOM,
+          },
+        });
+      }
+    });
+  }, [rooms]);
+
   const handleMessage = (data: DataProps) => {
     try {
       const { message: messageData, iv } = data;