feat: implement real-time chat application with WebSocket messaging, room support, and typing indicators

Author: sidsri14

be/dist/index.js

@@ -22,13 +22,18 @@ function broadcast(room, payload, exclude) {
     const data = JSON.stringify(payload);
     allSockets.forEach((user) => {
         if (user.room === room && user.socket !== exclude) {
-            user.socket.send(data);
+            try {
+                user.socket.send(data);
+            }
+            catch (err) {
+                console.error(`Failed to send to user ${user.username}:`, err);
+            }
         }
     });
 }
 wss.on('connection', (socket) => {
     socket.on('message', (data) => {
-        var _a, _b, _c;
+        var _a, _b, _c, _d;
         try {
             const parsed = JSON.parse(data.toString());
             if (parsed.type === 'join') {
@@ -70,6 +75,15 @@ wss.on('connection', (socket) => {
                 roomMessages.get(currentUser.room).push(msg);
                 broadcast(currentUser.room, { type: 'chat', payload: msg });
             }
+            if (parsed.type === 'typing') {
+                const currentUser = allSockets.find((x) => x.socket === socket);
+                if (!currentUser)
+                    return;
+                broadcast(currentUser.room, {
+                    type: 'typing',
+                    payload: { username: currentUser.username, isTyping: !!((_d = parsed.payload) === null || _d === void 0 ? void 0 : _d.isTyping) },
+                }, socket);
+            }
         }
         catch (e) {
             console.error('Error processing message:', e);

be/src/index.ts

@@ -34,7 +34,11 @@ function broadcast(room: string, payload: object, exclude?: WebSocket) {
     const data = JSON.stringify(payload);
     allSockets.forEach((user) => {
         if (user.room === room && user.socket !== exclude) {
-            user.socket.send(data);
+            try {
+                user.socket.send(data);
+            } catch (err) {
+                console.error(`Failed to send to user ${user.username}:`, err);
+            }
         }
     });
 }
@@ -88,6 +92,16 @@ wss.on('connection', (socket) => {
 
                 broadcast(currentUser.room, { type: 'chat', payload: msg });
             }
+
+            if (parsed.type === 'typing') {
+                const currentUser = allSockets.find((x) => x.socket === socket);
+                if (!currentUser) return;
+
+                broadcast(currentUser.room, {
+                    type: 'typing',
+                    payload: { username: currentUser.username, isTyping: !!parsed.payload?.isTyping },
+                }, socket);
+            }
         } catch (e) {
             console.error('Error processing message:', e);
         }