console.log(`[CONNECT] New client connected with ID ${me}`);
socket.on('join', (data) => {
- socket.join(data.url);
- Object.keys(io.in(data.url).sockets).forEach(peer => peer.emit(events.types.ADD_PEER, events.addPeer(me, peer.id === me)));
+ Object.entries(io.in(data.url).sockets).forEach(([peerId, peer]) => {
+ if (peerId !== me) {
+ peer.emit(events.types.ADD_PEER, events.addPeer(me, false));
+ socket.emit(events.types.ADD_PEER, events.addPeer(peerId, true));
+ }
+ });
+ socket.join(data.url);
console.log(`[CONNECT] Client ${me} added to room ${data.url}`);
});