feat: añadir soporte para rooms (canales tipo room)

- Añadir evento 'unirse' para unirse a rooms
- Añadir destino 'room' en eventos relay y notificar
- Actualizar documentación con ejemplos de uso
- Mantener compatibilidad total con API existente
- Versión 2.1

Closes #2

Author: NeftaliYagua

README.md

@@ -98,6 +98,7 @@ socket.on('relay', (data) => {
 | Evento | Descripción | Payload |
 |--------|-------------|---------|
 | `identificar` | Identificar usuario | `(userId, callback)` |
+| `unirse` | Unirse a un room (v2.1) | `(room, callback)` |
 | `notificar` | Enviar notificación | `{ ...data, destino }` |
 | `relay` | Canal genérico | `{ ...data, destino }` |
 
@@ -108,6 +109,22 @@ socket.on('relay', (data) => {
 | `yo` | Solo al emisor (default) |
 | `ustedes` | A todos menos el emisor |
 | `nosotros` | A todos incluyendo el emisor |
+| `room` | A todos en el room especificado (v2.1) |
+
+### Ejemplo con Rooms
+
+```javascript
+// Unirse a un room
+socket.emit('unirse', 'aulaA');
+
+// Enviar a ese room
+socket.emit('relay', {
+  destino: 'room',
+  room: 'aulaA',
+  tipo: 'mensaje',
+  texto: 'Hola aula A'
+});
+```
 
 ## Configuración
 

docs/docs/api.md

@@ -120,6 +120,7 @@ client.on('mensaje', (data) => {
 | Evento | Descripción | Payload |
 |--------|-------------|---------|
 | `identificar` | Identificar usuario | `(userId, callback)` |
+| `unirse` | Unirse a un room (v2.1) | `(room, callback)` |
 | `notificar` | Enviar notificación | `{ ...data, destino }` |
 | `relay` | Canal genérico | `{ ...data, destino }` |
 
@@ -139,6 +140,65 @@ client.on('mensaje', (data) => {
 | `yo` | Solo al emisor (default) |
 | `ustedes` | A todos menos el emisor |
 | `nosotros` | A todos incluyendo el emisor |
+| `room` | A todos en el room especificado (v2.1) |
+
+## Rooms (v2.1)
+
+Relay soporta rooms para segmentar usuarios en grupos específicos. Un room es simplemente un identificador de string que agrupa conexiones.
+
+### Unirse a un room
+
+```javascript
+socket.emit('unirse', 'aulaA', (ok) => {
+  console.log('Unido a aulaA:', ok);
+});
+```
+
+Puedes unirte a múltiples rooms:
+
+```javascript
+socket.emit('unirse', 'aulaA');
+socket.emit('unirse', 'Ingenieria');
+socket.emit('unirse', 'Directivos');
+```
+
+### Enviar a un room
+
+Usa `destino: 'room'` y especifica el `room`:
+
+```javascript
+socket.emit('relay', {
+  destino: 'room',
+  room: 'aulaA',
+  tipo: 'mensaje',
+  texto: 'Hola aula A'
+});
+```
+
+También funciona con `notificar`:
+
+```javascript
+socket.emit('notificar', {
+  destino: 'room',
+  room: 'Ingenieria',
+  tipo: 'aviso',
+  mensaje: 'Reunión en 5 minutos'
+});
+```
+
+### Casos de Uso
+
+- **Segmentación por departamento**: `'Ingenieria'`, `'Derecho'`, `'Directivos'`
+- **Aulas o grupos**: `'aulaA'`, `'aulaB'`, `'grupo1'`
+- **Proyectos**: `'proyecto-123'`, `'sprint-5'`
+- **Chats grupales**: `'chat-general'`, `'chat-soporte'`
+
+### Notas
+
+- Los rooms son temporales: se eliminan automáticamente cuando no hay usuarios
+- Un socket puede estar en múltiples rooms simultáneamente
+- Al desconectar, el socket sale automáticamente de todos los rooms
+- Los rooms funcionan con múltiples instancias gracias al Redis Adapter
 
 ## Servidor
 

docs/docs/intro.md

@@ -8,8 +8,8 @@ Relay es un **gateway de comunicación en tiempo real** diseñado para ser **inm
 
 El gateway no cambia. Todos los proyectos usan la misma API:
 
-- **3 eventos**: `identificar`, `notificar`, `relay`
-- **3 destinos**: `yo`, `ustedes`, `nosotros`
+- **4 eventos**: `identificar`, `unirse`, `notificar`, `relay`
+- **4 destinos**: `yo`, `ustedes`, `nosotros`, `room`
 - **Sin configuración**: El gateway no necesita saber qué tipo de aplicación estás construyendo
 
 ### 🎯 Agnóstico
@@ -33,8 +33,20 @@ await relay.conectar();
 // 2. Identificar
 await relay.identificar('mi-usuario-123');
 
-// 3. Enviar y recibir
+// 3. Unirse a un room (v2.1)
+socket.emit('unirse', 'aulaA');
+
+// 4. Enviar y recibir
 relay.enviarATodos({ tipo: 'saludo', mensaje: 'Hola!' });
+
+// 5. Enviar a un room específico
+socket.emit('relay', {
+  destino: 'room',
+  room: 'aulaA',
+  tipo: 'mensaje',
+  texto: 'Hola aula A'
+});
+
 relay.on('relay', (data) => console.log(data));
 ```
 

src/Relay.js

@@ -1,16 +1,18 @@
 /**
- * Coderic Relay v2.0
+ * Coderic Relay v2.1
  * Real-time messaging infrastructure - Versión como paquete npm
  * 
  * API de eventos:
  * - identificar: Identificar usuario
+ * - unirse: Unirse a un room
  * - notificar: Enviar notificaciones  
  * - relay: Canal de mensajes genérico
  * 
  * Destinos:
  * - yo: Solo al emisor
  * - ustedes: A todos menos el emisor
  * - nosotros: A todos incluyendo el emisor
+ * - room: A todos en el room especificado
  */
 
 import { createServer } from 'http';
@@ -372,6 +374,12 @@ export class Relay extends EventEmitter {
         self.publishToKafka('user_connected', { usuario, socketId: socket.id });
       });
 
+      // EVENTO: unirse
+      socket.on('unirse', function(room, fn) {
+        socket.join(room);
+        if (typeof fn === 'function') fn(true);
+      });
+      
       // EVENTO: notificar
       socket.on('notificar', function(data) {
         if (self.metricsMessages) {
@@ -391,6 +399,11 @@ export class Relay extends EventEmitter {
           case 'nosotros':
             self.namespace.emit('notificar', data);
             break;
+          case 'room':
+            if (data.room) {
+              self.namespace.to(data.room).emit('notificar', data);
+            }
+            break;
           default: // "yo"
             socket.emit('notificar', data);
             break;
@@ -438,6 +451,11 @@ export class Relay extends EventEmitter {
           case 'nosotros':
             self.namespace.emit('relay', data);
             break;
+          case 'room':
+            if (data.room) {
+              self.namespace.to(data.room).emit('relay', data);
+            }
+            break;
           default: // "yo"
             socket.emit('relay', data);
             break;