Advertisement
Guest User

Untitled

a guest
Jul 29th, 2016
62
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.88 KB | None | 0 0
  1. app.set('port', httpPort);
  2. let server = http.createServer(app);
  3. let io = require('./socketServer')(server);
  4. io.adapter(redis({host: host, port: port}));
  5. app.set('io', io);
  6.  
  7. io.sockets.on('connection', (socket) =>{
  8. var socketID = socket.handshake.user.sid;
  9. io.clients[socketID] = socket;
  10. io.clients[socketID].broadcast.emit('loggedIn',socket.handshake.user.data);
  11.  
  12. socket.on('disconnect', () =>{
  13. delete io.clients[socketID];
  14. });
  15. });
  16.  
  17. this.redis.getByMask(`sid_clients:*`,(err,rdbData) =>{
  18. Async.each(clients,(client,next)=>{
  19. let sid = `sid_clients:${client}`;
  20. let currentClient = rdbData[sid];
  21. if(!currentClient || !this.io.clients[currentClient]) return next();
  22. this.io.clients[currentClient].emit(event,data);
  23. return next();
  24. });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement