123456789101112131415161718192021222324252627282930313233343536 |
- module.exports = function(io, streams) {
- io.on('connection', function(socket) {
- console.log('-- ' + socket.id + ' joined --');
- socket.emit('id', socket.id);
- socket.on('message', function (details) {
- var othersocket = io.sockets.connected[details.to];
- if (!othersocket) {
- return;
- }
- delete details.to;
- details.from = socket.id;
- othersocket.emit('message', details);
- });
- socket.on('readyToStream', function(options) {
- console.log('-- ' + socket.id + ' is ready to stream --');
-
- streams.addStream(socket.id, options.name);
- });
- socket.on('update', function(options) {
- streams.update(socket.id, options.name);
- });
- function leave() {
- console.log('-- ' + socket.id + ' left --');
- streams.removeStream(socket.id);
- }
- socket.on('disconnect', leave);
- socket.on('leave', leave);
- });
- };
|