app.js

const express = require('express');
const http = require('http');
const socketIo = require('socket.io');
const redis = require('redis');

const app = express();
const server = http.createServer(app);
const io = socketIo(server, {
    cors: {
        origin: 'http://127.0.0.1:5500',
        methods: ['GET', 'POST'],
        allowedHeaders: ['Content-Type'],
    }
});

// Crear la conexión con Redis
const redisClient = redis.createClient();

// Objeto para almacenar usuarios conectados
const connectedUsers = {};

// Manejar la conexión de usuarios
io.on('connection', (socket) => {
    console.log('Usuario conectado: ' + socket.id);

    // Agregar usuario a la lista de usuarios conectados
    connectedUsers[socket.id] = socket;

    // Manejar la desconexión de usuarios
    socket.on('disconnect', () => {
        console.log('Usuario desconectado: ' + socket.id);
        // Eliminar usuario de la lista de usuarios conectados
        delete connectedUsers[socket.id];
    });

    // Manejar el envío de notificaciones
    socket.on('enviarNotificacion', (data) => {
        // Verificar si el cliente Redis está disponible y no cerrado
        if (redisClient && redisClient.connected) {
            redisClient.set('notificaciones', JSON.stringify(data), (err) => {
                if (err) {
                    console.error('Error al guardar la notificación en Redis:', err);
                }
            });
        } else {
            console.error('El cliente Redis está cerrado o no conectado.');
        }

        // Enviar la notificación a todos los usuarios conectados
        io.emit('nuevaNotificacion', data);
    });
});

server.listen(3006, () => {
    console.log('Servidor de notificaciones corriendo en el puerto 3006');
});