better indenting on signal.js
This commit is contained in:
Connor Turland
parent
5921513c79
commit
786ea64480
1 changed files with 99 additions and 131 deletions
|
|
@ -4,148 +4,116 @@ var uuid = require('node-uuid')
|
|||
// since it was updated to socket.io 1.3.7
|
||||
|
||||
function safeCb(cb) {
|
||||
if (typeof cb === 'function') {
|
||||
return cb;
|
||||
} else {
|
||||
return function () {};
|
||||
}
|
||||
if (typeof cb === 'function') {
|
||||
return cb;
|
||||
} else {
|
||||
return function () {};
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = function(io, stunservers, state) {
|
||||
|
||||
io.on('connection', function (socket) {
|
||||
socket.resources = {
|
||||
screen: false,
|
||||
video: true,
|
||||
audio: false
|
||||
}
|
||||
io.on('connection', function (socket) {
|
||||
socket.resources = {
|
||||
screen: false,
|
||||
video: true,
|
||||
audio: false
|
||||
}
|
||||
|
||||
// pass a message to another id
|
||||
socket.on('message', function (details) {
|
||||
if (!details) return
|
||||
// pass a message to another id
|
||||
socket.on('message', function (details) {
|
||||
if (!details) return
|
||||
|
||||
var otherClient = io.to(details.to)
|
||||
if (!otherClient) return
|
||||
var otherClient = io.to(details.to)
|
||||
if (!otherClient) return
|
||||
|
||||
details.from = socket.id
|
||||
otherClient.emit('message', details)
|
||||
})
|
||||
|
||||
socket.on('shareScreen', function () {
|
||||
socket.resources.screen = true
|
||||
})
|
||||
|
||||
socket.on('unshareScreen', function (type) {
|
||||
socket.resources.screen = false
|
||||
removeFeed('screen')
|
||||
})
|
||||
|
||||
socket.on('join', join)
|
||||
|
||||
function removeFeed(type) {
|
||||
if (socket.room) {
|
||||
io.sockets.in(socket.room).emit('remove', {
|
||||
id: socket.id,
|
||||
type: type
|
||||
})
|
||||
if (!type) {
|
||||
socket.leave(socket.room)
|
||||
socket.room = undefined
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function join(name, cb) {
|
||||
// sanity check
|
||||
if (typeof name !== 'string') return
|
||||
/*
|
||||
// check if maximum number of sockets reached
|
||||
if (config.rooms && config.rooms.maxClients > 0 &&
|
||||
socketsInRoom(name) >= config.rooms.maxClients) {
|
||||
safeCb(cb)('full')
|
||||
return
|
||||
}*/
|
||||
// leave any existing rooms
|
||||
removeFeed()
|
||||
safeCb(cb)(null, describeRoom(name))
|
||||
socket.join(name)
|
||||
socket.room = name
|
||||
}
|
||||
|
||||
// we don't want to pass "leave" directly because the
|
||||
// event type string of "socket end" gets passed too.
|
||||
socket.on('disconnect', function () {
|
||||
removeFeed()
|
||||
})
|
||||
socket.on('leave', function () {
|
||||
removeFeed()
|
||||
})
|
||||
|
||||
socket.on('create', function (name, cb) {
|
||||
if (arguments.length == 2) {
|
||||
cb = (typeof cb == 'function') ? cb : function () {}
|
||||
name = name || uuid()
|
||||
} else {
|
||||
cb = name
|
||||
name = uuid()
|
||||
}
|
||||
// check if exists
|
||||
var room = io.nsps['/'].adapter.rooms[name]
|
||||
if (room && room.length) {
|
||||
safeCb(cb)('taken')
|
||||
} else {
|
||||
join(name)
|
||||
safeCb(cb)(null, name)
|
||||
}
|
||||
})
|
||||
|
||||
// support for logging full webrtc traces to stdout
|
||||
// useful for large-scale error monitoring
|
||||
socket.on('trace', function (data) {
|
||||
console.log('trace', JSON.stringify(
|
||||
[data.type, data.session, data.prefix, data.peer, data.time, data.value]
|
||||
))
|
||||
})
|
||||
|
||||
/*
|
||||
// tell socket about stun and turn servers and generate nonces
|
||||
socket.emit('stunservers', config.stunservers || [])
|
||||
|
||||
// create shared secret nonces for TURN authentication
|
||||
// the process is described in draft-uberti-behave-turn-rest
|
||||
var credentials = []
|
||||
// allow selectively vending turn credentials based on origin.
|
||||
var origin = socket.handshake.headers.origin
|
||||
if (!config.turnorigins || config.turnorigins.indexOf(origin) !== -1) {
|
||||
config.turnservers.forEach(function (server) {
|
||||
var hmac = crypto.createHmac('sha1', server.secret)
|
||||
// default to 86400 seconds timeout unless specified
|
||||
var username = Math.floor(new Date().getTime() / 1000) + (server.expiry || 86400) + ""
|
||||
hmac.update(username)
|
||||
credentials.push({
|
||||
username: username,
|
||||
credential: hmac.digest('base64'),
|
||||
urls: server.urls || server.url
|
||||
})
|
||||
})
|
||||
}
|
||||
socket.emit('turnservers', credentials)
|
||||
*/
|
||||
details.from = socket.id
|
||||
otherClient.emit('message', details)
|
||||
})
|
||||
|
||||
function describeRoom(name) {
|
||||
var adapter = io.nsps['/'].adapter
|
||||
var sockets = adapter.rooms[name] || {}
|
||||
var result = {
|
||||
clients: {}
|
||||
}
|
||||
Object.keys(sockets).forEach(function (id) {
|
||||
result.clients[id] = adapter.nsp.connected[id].resources
|
||||
socket.on('shareScreen', function () {
|
||||
socket.resources.screen = true
|
||||
})
|
||||
|
||||
socket.on('unshareScreen', function (type) {
|
||||
socket.resources.screen = false
|
||||
removeFeed('screen')
|
||||
})
|
||||
|
||||
socket.on('join', join)
|
||||
|
||||
function removeFeed(type) {
|
||||
if (socket.room) {
|
||||
io.sockets.in(socket.room).emit('remove', {
|
||||
id: socket.id,
|
||||
type: type
|
||||
})
|
||||
return result
|
||||
if (!type) {
|
||||
socket.leave(socket.room)
|
||||
socket.room = undefined
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function socketsInRoom(name) {
|
||||
return io.sockets.sockets(name).length
|
||||
function join(name, cb) {
|
||||
// sanity check
|
||||
if (typeof name !== 'string') return
|
||||
// leave any existing rooms
|
||||
removeFeed()
|
||||
safeCb(cb)(null, describeRoom(name))
|
||||
socket.join(name)
|
||||
socket.room = name
|
||||
}
|
||||
|
||||
// we don't want to pass "leave" directly because the
|
||||
// event type string of "socket end" gets passed too.
|
||||
socket.on('disconnect', function () {
|
||||
removeFeed()
|
||||
})
|
||||
socket.on('leave', function () {
|
||||
removeFeed()
|
||||
})
|
||||
|
||||
socket.on('create', function (name, cb) {
|
||||
if (arguments.length == 2) {
|
||||
cb = (typeof cb == 'function') ? cb : function () {}
|
||||
name = name || uuid()
|
||||
} else {
|
||||
cb = name
|
||||
name = uuid()
|
||||
}
|
||||
// check if exists
|
||||
var room = io.nsps['/'].adapter.rooms[name]
|
||||
if (room && room.length) {
|
||||
safeCb(cb)('taken')
|
||||
} else {
|
||||
join(name)
|
||||
safeCb(cb)(null, name)
|
||||
}
|
||||
})
|
||||
|
||||
// support for logging full webrtc traces to stdout
|
||||
// useful for large-scale error monitoring
|
||||
socket.on('trace', function (data) {
|
||||
console.log('trace', JSON.stringify(
|
||||
[data.type, data.session, data.prefix, data.peer, data.time, data.value]
|
||||
))
|
||||
})
|
||||
})
|
||||
|
||||
function describeRoom(name) {
|
||||
var adapter = io.nsps['/'].adapter
|
||||
var sockets = adapter.rooms[name] || {}
|
||||
var result = {
|
||||
clients: {}
|
||||
}
|
||||
Object.keys(sockets).forEach(function (id) {
|
||||
result.clients[id] = adapter.nsp.connected[id].resources
|
||||
})
|
||||
return result
|
||||
}
|
||||
|
||||
function socketsInRoom(name) {
|
||||
return io.sockets.sockets(name).length
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue