Reconnect after conn close & always propagate update messages

yjs · Jun 28, 2020 · a418fa9 · a418fa9
1 parent fea1e24
commit a418fa9
Showing 1 changed file with 9 additions and 7 deletions.
diff --git a/src/y-webrtc.js b/src/y-webrtc.js
@@ -219,9 +219,13 @@ export class WebrtcConn {
       this.peer.destroy()
       log('closed connection to ', logging.BOLD, remotePeerId)
     })
+    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)
-      log('error in connection to ', logging.BOLD, remotePeerId, ': ', err)
     })
     this.peer.on('data', data => {
       const answer = readPeerMessage(this, data)
@@ -339,12 +343,10 @@ export class Room {
      * @param {any} origin
      */
     this._docUpdateHandler = (update, origin) => {
-      if (origin !== this) {
-        const encoder = encoding.createEncoder()
-        encoding.writeVarUint(encoder, messageSync)
-        syncProtocol.writeUpdate(encoder, update)
-        broadcastRoomMessage(this, encoding.toUint8Array(encoder))
-      }
+      const encoder = encoding.createEncoder()
+      encoding.writeVarUint(encoder, messageSync)
+      syncProtocol.writeUpdate(encoder, update)
+      broadcastRoomMessage(this, encoding.toUint8Array(encoder))
     }
     /**
      * Listens to Awareness updates and sends them to remote peers