dist/proxies/multiSocket.js

@@ -108,7 +108,7 @@ class MultiSocketProxy extends proxy_js_1.default {
                 item[1].end();
             }
         }
-        const pubkey = this._toString(peer.stream.remotePublicKey);
+        const pubkey = this._toString(peer.socket.remotePublicKey);
         if (this._peers.has(pubkey)) {
             this._peers.delete(pubkey);
         }
@@ -153,7 +153,7 @@ class MultiSocketProxy extends proxy_js_1.default {
             async onmessage(m) {
                 if (self._allowedPorts.length &&
                     !self._allowedPorts.includes(m.port)) {
-                    self.get(peer.stream.remotePublicKey).messages.errorSocket.send({
+                    self.get(peer.socket.remotePublicKey).messages.errorSocket.send({
                         id: m.id,
                         err: new Error(`port ${m.port} not allowed`),
                     });
@@ -161,7 +161,7 @@ class MultiSocketProxy extends proxy_js_1.default {
                 }
                 m = m;
                 if (self._server) {
-                    new self.socketClass(nextSocketId(), m, self, self.get(peer.stream.remotePublicKey), m).connect();
+                    new self.socketClass(nextSocketId(), m, self, self.get(peer.socket.remotePublicKey), m).connect();
                     return;
                 }
                 const socket = self._sockets.get(m.id);
@@ -172,7 +172,7 @@ class MultiSocketProxy extends proxy_js_1.default {
                 }
             },
         });
-        this.update(peer.stream.remotePublicKey, {
+        this.update(peer.socket.remotePublicKey, {
             messages: { openSocket: message },
         });
     }
@@ -184,7 +184,7 @@ class MultiSocketProxy extends proxy_js_1.default {
                 self._sockets.get(m.id)?.push(m.data);
             },
         });
-        this.update(peer.stream.remotePublicKey, {
+        this.update(peer.socket.remotePublicKey, {
             messages: { writeSocket: message },
         });
     }
@@ -196,7 +196,7 @@ class MultiSocketProxy extends proxy_js_1.default {
                 self._sockets.get(m.id)?.end();
             },
         });
-        this.update(peer.stream.remotePublicKey, {
+        this.update(peer.socket.remotePublicKey, {
             messages: { closeSocket: message },
         });
     }
@@ -209,7 +209,7 @@ class MultiSocketProxy extends proxy_js_1.default {
                 self._sockets.get(m.id)?.emit("timeout");
             },
         });
-        this.update(peer.stream.remotePublicKey, {
+        this.update(peer.socket.remotePublicKey, {
             messages: { timeoutSocket: message },
         });
     }
@@ -222,7 +222,7 @@ class MultiSocketProxy extends proxy_js_1.default {
                 self._sockets.get(m.id)?.emit("error", m.err);
             },
         });
-        this.update(peer.stream.remotePublicKey, {
+        this.update(peer.socket.remotePublicKey, {
             messages: { errorSocket: message },
         });
     }

src/proxies/multiSocket.ts

@@ -130,7 +130,7 @@ export default class MultiSocketProxy extends Proxy {
       }
     }
 
-    const pubkey = this._toString(peer.stream.remotePublicKey);
+    const pubkey = this._toString(peer.socket.remotePublicKey);
 
     if (this._peers.has(pubkey)) {
       this._peers.delete(pubkey);
@@ -188,7 +188,7 @@ export default class MultiSocketProxy extends Proxy {
           self._allowedPorts.length &&
           !self._allowedPorts.includes((m as TcpSocketConnectOpts).port)
         ) {
-          self.get(peer.stream.remotePublicKey).messages.errorSocket.send({
+          self.get(peer.socket.remotePublicKey).messages.errorSocket.send({
             id: (m as SocketRequest).id,
             err: new Error(
               `port ${(m as TcpSocketConnectOpts).port} not allowed`
@@ -204,7 +204,7 @@ export default class MultiSocketProxy extends Proxy {
             nextSocketId(),
             m,
             self,
-            self.get(peer.stream.remotePublicKey) as PeerEntity,
+            self.get(peer.socket.remotePublicKey) as PeerEntity,
             m
           ).connect();
           return;
@@ -218,7 +218,7 @@ export default class MultiSocketProxy extends Proxy {
         }
       },
     });
-    this.update(peer.stream.remotePublicKey, {
+    this.update(peer.socket.remotePublicKey, {
       messages: { openSocket: message },
     });
   }
@@ -231,7 +231,7 @@ export default class MultiSocketProxy extends Proxy {
         self._sockets.get(m.id)?.push(m.data);
       },
     });
-    this.update(peer.stream.remotePublicKey, {
+    this.update(peer.socket.remotePublicKey, {
       messages: { writeSocket: message },
     });
   }
@@ -244,7 +244,7 @@ export default class MultiSocketProxy extends Proxy {
         self._sockets.get(m.id)?.end();
       },
     });
-    this.update(peer.stream.remotePublicKey, {
+    this.update(peer.socket.remotePublicKey, {
       messages: { closeSocket: message },
     });
   }
@@ -258,7 +258,7 @@ export default class MultiSocketProxy extends Proxy {
         self._sockets.get(m.id)?.emit("timeout");
       },
     });
-    this.update(peer.stream.remotePublicKey, {
+    this.update(peer.socket.remotePublicKey, {
       messages: { timeoutSocket: message },
     });
   }
@@ -272,7 +272,7 @@ export default class MultiSocketProxy extends Proxy {
         self._sockets.get(m.id)?.emit("error", m.err);
       },
     });
-    this.update(peer.stream.remotePublicKey, {
+    this.update(peer.socket.remotePublicKey, {
       messages: { errorSocket: message },
     });
   }