|
@@ -124,28 +124,15 @@ PeerServer.prototype._configureWS = function(socket, key, id, token) {
|
|
|
try {
|
|
|
var message = JSON.parse(data);
|
|
|
|
|
|
- switch (message.type) {
|
|
|
- case 'LEAVE':
|
|
|
- // Clean up if a Peer sends a LEAVE.
|
|
|
- if (!message.dst) {
|
|
|
- self._removePeer(key, id);
|
|
|
- }
|
|
|
- break;
|
|
|
- // ICE candidates
|
|
|
- case 'CANDIDATE':
|
|
|
- // Offer or answer between peers.
|
|
|
- case 'OFFER':
|
|
|
- case 'ANSWER':
|
|
|
- // Use the ID we know to be correct to prevent spoofing.
|
|
|
- self._handleTransmission(key, {
|
|
|
- type: message.type,
|
|
|
- src: id,
|
|
|
- dst: message.dst,
|
|
|
- payload: message.payload
|
|
|
- });
|
|
|
- break;
|
|
|
- default:
|
|
|
- util.prettyError('Message unrecognized');
|
|
|
+ if (['LEAVE', 'CANDIDATE', 'OFFER', 'ANSWER'].indexOf(message.type) !== -1) {
|
|
|
+ self._handleTransmission(key, {
|
|
|
+ type: message.type,
|
|
|
+ src: id,
|
|
|
+ dst: message.dst,
|
|
|
+ payload: message.payload
|
|
|
+ });
|
|
|
+ } else {
|
|
|
+ util.prettyError('Message unrecognized');
|
|
|
}
|
|
|
} catch(e) {
|
|
|
util.log('Invalid message', data);
|