X-Git-Url: https://git.r.bdr.sh/rbdr/junction/blobdiff_plain/a69b770cb379354226a8c05be5cbea3e8703803f..d4fb48eb3793a93a8726652692b68592333dd778:/server/index.js?ds=sidebyside diff --git a/server/index.js b/server/index.js index 0cfef25..de05616 100644 --- a/server/index.js +++ b/server/index.js @@ -20,9 +20,14 @@ io.sockets.on('connection', (socket) => { 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}`); });