socketEvents.js

Go to the documentation of this file.

// WebSocket event publisher for dashboard realtime updates
const Redis = require('ioredis');
const { Server } = require('socket.io');
 
const redisConfig = require('./config/redis');
const redis = new Redis(redisConfig);
const io = new Server(/* your HTTP server here */);
 
redis.psubscribe('dashboard:events');
 
redis.on('pmessage', (pattern, channel, message) => {
  io.emit(channel, JSON.parse(message));
});
 
console.log('Socket event publisher running: dashboard gets live updates from Redis.');