rtcSocketHandler.js 930 B

123456789101112131415161718192021222324252627282930313233343536
  1. module.exports = function(io, streams) {
  2. io.on('connection', function(socket) {
  3. console.log('-- ' + socket.id + ' joined --');
  4. socket.emit('id', socket.id);
  5. socket.on('message', function (details) {
  6. var othersocket = io.sockets.connected[details.to];
  7. if (!othersocket) {
  8. return;
  9. }
  10. delete details.to;
  11. details.from = socket.id;
  12. othersocket.emit('message', details);
  13. });
  14. socket.on('readyToStream', function(options) {
  15. console.log('-- ' + socket.id + ' is ready to stream --');
  16. streams.addStream(socket.id, options.name);
  17. });
  18. socket.on('update', function(options) {
  19. streams.update(socket.id, options.name);
  20. });
  21. function leave() {
  22. console.log('-- ' + socket.id + ' left --');
  23. streams.removeStream(socket.id);
  24. }
  25. socket.on('disconnect', leave);
  26. socket.on('leave', leave);
  27. });
  28. };