(ml5717) Set to full mesh mode and only send once connection established

liowebrtc @ afa8666f

-Subproject commit 14adace866d4c71c5a9e5e39129f770670d78427
+Subproject commit afa8666f796bdd40cc263354917632ea671dfee2

src/y-webrtc/index.js

@@ -21,10 +21,10 @@ function extend(Y) {
       const webrtc = new LioWebRTC({
         url: this.webrtcOptions.url,
         dataOnly: true,
-        network: {
+        /*network: {
           minPeers: 4,
           maxPeers: 8,
-        },
+        },*/
       })
 
       this.webrtc = webrtc
@@ -32,6 +32,10 @@ function extend(Y) {
 
       webrtc.on("ready", () => {
         webrtc.joinRoom(self.webrtcOptions.room)
+
+        webrtc.connection.on("message", (data) =>
+          console.log("socket.io", data),
+        )
       })
 
       webrtc.on("joinedRoom", () => {
@@ -46,14 +50,31 @@ function extend(Y) {
 
       // Cannot use createdPeer here as y-js will then try to send data before the channel is open
       webrtc.on("channelOpen", (dataChannel, peer) => {
+        console.log(
+          "createdPeer",
+          peer.id,
+          this.webrtc.getPeers().map((peer) => peer.id),
+        )
         self.userJoined(peer.id, "master")
       })
 
       webrtc.on("receivedPeerData", (type, message, peer) => {
+        if (message.type !== "update")
+          console.log(
+            "receivedData",
+            peer.id,
+            message,
+            this.webrtc.getPeers().map((peer) => peer.id),
+          )
         self.receiveMessage(peer.id, message)
       })
 
-      webrtc.on("removedPeer", (peer) => {
+      webrtc.on("channelClose", (dataChannel, peer) => {
+        console.log(
+          "removedPeer",
+          peer.id,
+          this.webrtc.getPeers().map((peer) => peer.id),
+        )
         self.userLeft(peer.id)
       })
     }
@@ -75,10 +96,22 @@ function extend(Y) {
     }
 
     send(uid, message) {
+      console.log(
+        "send",
+        uid,
+        message,
+        this.webrtc.getPeers().map((peer) => peer.id),
+      )
       this.webrtc.whisper(this.webrtc.getPeerById(uid), "y-js", message)
     }
 
     broadcast(message) {
+      if (message.type !== "update")
+        console.log(
+          "broadcast",
+          message,
+          this.webrtc.getPeers().map((peer) => peer.id),
+        )
       this.webrtc.shout("y-js", message)
     }