LumeWeb
/
libhyperproxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

*Update dist

This commit is contained in:
Derrick Hammer 2023-04-16 03:17:02 -04:00
parent 13ff64002d
commit 8b678e81e8
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
dist/proxies/multiSocket.js vendored
View File

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