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

Compare commits

base: LumeWeb:f3e5cebe45981c344f2bf1fbf95448f90d9c8a52
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1
..
compare: LumeWeb:3a1ea39a799f073431fcfea698b6c67a46de8c9a
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1

No commits in common. "f3e5cebe45981c344f2bf1fbf95448f90d9c8a52" and "3a1ea39a799f073431fcfea698b6c67a46de8c9a" have entirely different histories.
f3e5cebe45 ... 3a1ea39a79

2 changed files with 20 additions and 24 deletions
Show Stats Expand all files Collapse all files

4
dist/proxies/multiSocket.js vendored
View File

@ -164,7 +164,6 @@ class MultiSocketProxy extends proxy_js_1.default {
decode: this._server ? compact_encoding_1.json.decode : socketEncoding.decode,
},
async onmessage(m) {
if (self._server) {
if (self._allowedPorts.length &&
!self._allowedPorts.includes(m.port)) {
self.get(await self._getPublicKey(peer)).messages.errorSocket.send({
@ -173,10 +172,9 @@ class MultiSocketProxy extends proxy_js_1.default {
});
return;
}
}
m = m;
if (self._server) {
new self.socketClass(nextSocketId(), m.id, self, self.get(await self._getPublicKey(peer)), m).connect();
new self.socketClass(nextSocketId(), m, self, self.get(await self._getPublicKey(peer)), m).connect();
return;
}
const socket = self._sockets.get(m.id);

4
src/proxies/multiSocket.ts
View File

@ -204,7 +204,6 @@ export default class MultiSocketProxy extends Proxy {
decode: this._server ? json.decode : socketEncoding.decode,
},
async onmessage(m: SocketRequest | TcpSocketConnectOpts) {
if (self._server) {
if (
self._allowedPorts.length &&
!self._allowedPorts.includes((m as TcpSocketConnectOpts).port)
@ -217,14 +216,13 @@ export default class MultiSocketProxy extends Proxy {
});
return;
}
}
m = m as SocketRequest;
if (self._server) {
new self.socketClass(
nextSocketId(),
m.id,
m,
self,
self.get(await self._getPublicKey(peer)) as PeerEntity,
m