Nulo/y-webrtc
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Reconnect after conn close & always propagate update messages

Browse source
This commit is contained in:
Kevin Jahns 2020-06-29 00:55:47 +02:00
parent fea1e243b8
commit a418fa916f
1 changed files with 10 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/y-webrtc.js
View file

@ -219,9 +219,13 @@ export class WebrtcConn {
this.peer.destroy() this.peer.destroy()
log('closed connection to ', logging.BOLD, remotePeerId) log('closed connection to ', logging.BOLD, remotePeerId)
}) })
this.peer.on('error', err => { this.peer.on('close', () => {
log('Connection to remote peer ', logging.BOLD, remotePeerId, logging.UNBOLD, ' has been closed')
announceSignalingInfo(room)
})
this.peer.on('error', err => {
log('Error in connection to ', logging.BOLD, remotePeerId, ': ', err)
announceSignalingInfo(room) announceSignalingInfo(room)
log('error in connection to ', logging.BOLD, remotePeerId, ': ', err)
}) })
this.peer.on('data', data => { this.peer.on('data', data => {
const answer = readPeerMessage(this, data) const answer = readPeerMessage(this, data)
@ -339,12 +343,10 @@ export class Room {
* @param {any} origin * @param {any} origin
*/ */
this._docUpdateHandler = (update, origin) => { this._docUpdateHandler = (update, origin) => {
if (origin !== this) { const encoder = encoding.createEncoder()
const encoder = encoding.createEncoder() encoding.writeVarUint(encoder, messageSync)
encoding.writeVarUint(encoder, messageSync) syncProtocol.writeUpdate(encoder, update)
syncProtocol.writeUpdate(encoder, update) broadcastRoomMessage(this, encoding.toUint8Array(encoder))
broadcastRoomMessage(this, encoding.toUint8Array(encoder))
}
} }
/** /**
* Listens to Awareness updates and sends them to remote peers * Listens to Awareness updates and sends them to remote peers