From beb6aa8d18d3996c098b88dcb18df39296d57bdd Mon Sep 17 00:00:00 2001
From: Philipinho <16838612+Philipinho@users.noreply.github.com>
Date: Thu, 2 May 2024 03:14:38 +0100
Subject: [PATCH] ws/socket.io rooms - WIP

---
 apps/server/src/ws/ws.gateway.ts | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/apps/server/src/ws/ws.gateway.ts b/apps/server/src/ws/ws.gateway.ts
index 70355ce2..00f8a4c1 100644
--- a/apps/server/src/ws/ws.gateway.ts
+++ b/apps/server/src/ws/ws.gateway.ts
@@ -1,4 +1,5 @@
 import {
+  MessageBody,
   OnGatewayConnection,
   SubscribeMessage,
   WebSocketGateway,
@@ -36,6 +37,21 @@ export class WsGateway implements OnGatewayConnection, OnModuleDestroy {
     client.broadcast.emit('message', data);
   }
 
+  @SubscribeMessage('messageToRoom')
+  handleSendMessageToRoom(@MessageBody() message: any) {
+    this.server.to(message?.roomId).emit('messageToRoom', message);
+  }
+
+  @SubscribeMessage('join-room')
+  handleJoinRoom(client: Socket, @MessageBody() roomName: string): void {
+    client.join(roomName);
+  }
+
+  @SubscribeMessage('leave-room')
+  handleLeaveRoom(client: Socket, @MessageBody() roomName: string): void {
+    client.leave(roomName);
+  }
+
   onModuleDestroy() {
     if (this.server) {
       this.server.close();