webrtc-fullmesh-signaling-server
v1.0.6
Published
A full-mesh signaling server for WebRTC connections.
Downloads
13
Maintainers
Readme
webrtc-fullmesh-signaling-server
A signaling server for a full-mesh WebRTC network - runs in Node.js
Install
npm i -S webrtc-fullmesh-signaling-server
Usage
Just require it in your node server entry file (the default port is 2013):
require( 'webrtc-fullmesh-signaling-server' )
Client Code
The following is an example using the npm package simple-peer:
import SimplePeer from 'simple-peer';
const peers = {};
const uuid = /*myCoolUUIDGeneratorFunction()*/
var socket;
function startup() {
socket = io.connect( /*SIGNALING_SERVER_ADDRESS*/, {
transports: ['websocket'],
reconnection: true,
reconnectionDelay: 1000,
reconnectionDelayMax : 5000,
reconnectionAttempts: 99999
});
socket.on( 'connected', (data)=>{
console.log( 'got "connected" message from signaling server - data:' );
console.log( data ); // should contain all the uuid's of extant clients
for( var i = 0; i < data.allClientIds.length; ++i ) {
var clientId = data.allClientIds[ i ];
if( clientId===uuid ) {
// don't store my own uuid as a peer
continue;
}
var p = peers[clientId] = new SimplePeer({
initiator: true,
channelName: 'my_cool_channel_name'
});
addPeerListeners( p, clientId );
}
// send my uuid to the signaling server
socket.emit( 'uuid', {uuid} );
});
socket.on( 'new_peer', (data)=>{
if( data.newPeerId === uuid ) {
// don't do anything if i got my own uuid
return;
}
var p = peers[data.newPeerId] = new SimplePeer({
initiator: false,
channelName: 'my_cool_channel_name'
});
addPeerListeners( p, data.newPeerId );
});
socket.on( 'signal', (data)=>{
console.log( 'got signal from signaling server:' );
console.log( data );
if( peers[data.senderId] ) {
peers[data.senderId].signal( JSON.stringify(data) );
}
});
}
function addPeerListeners( p, peerId ) {
p.on('error', function (err) { console.error(err); });
p.on('signal', function (data) {
data.senderId = uuid;
data.receiverId = peerId;
console.log('SIGNAL', JSON.stringify(data));
socket.emit( 'signal', data );
});
p.on('connect', function () {
console.log('WebRTC connection!');
});
p.on('data', function (data) {
data = JSON.parse( data );
console.log( 'data: ' );
console.log( data );
// do whatever you want with the data now
});
p.on( 'close', ()=>{
delete peers[ peerId ];
});
}
function sendDataToPeers( data ) {
// will send the data to every single peer in the network
for( var peerId in peers ) {
try {
peers[peerId].send( JSON.stringify(data) );
} catch( error ) {
console.warn( error );
}
}
}