LumeWeb
/
hypercore-proxy-handshake
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:a8dd1d2c20283b380b52ba1e1c3404e8e86b9e70
Branches Tags
LumeWeb:master
..
compare: LumeWeb:37cbac3435d2dd2f3579b26fd5154e7b7040bc7c
Branches Tags
LumeWeb:master

2 Commits
a8dd1d2c20 ... 37cbac3435

Author SHA1 Message Date
Derrick Hammer 37cbac3435
*Update dist 2023-02-18 09:49:51 -05:00
Derrick Hammer 3da2a3e8df
*Don't await on tryOpen 2023-02-18 09:49:33 -05:00
2 changed files with 2 additions and 4 deletions
Show Stats Expand all files Collapse all files

3
dist/index.js vendored
View File

@ -28,10 +28,9 @@ class HandshakeProxy extends libhyperproxy_1.Proxy {
return { connect: false }; return { connect: false };
} }
self._node.pool.bindPeer(peer); self._node.pool.bindPeer(peer);
const open = peer.tryOpen(); peer.tryOpen();
// @ts-ignore // @ts-ignore
socket.emit("connect"); socket.emit("connect");
await open;
self._node.pool.peers.add(peer); self._node.pool.peers.add(peer);
self._node.pool.connectedGroups.add(peer.address.getGroup()); self._node.pool.connectedGroups.add(peer.address.getGroup());
self._node.pool.emit("peer", peer); self._node.pool.emit("peer", peer);

3
src/index.ts
View File

@ -49,10 +49,9 @@ export default class HandshakeProxy extends Proxy {
} }
self._node.pool.bindPeer(peer); self._node.pool.bindPeer(peer);
const open = peer.tryOpen(); peer.tryOpen();
// @ts-ignore // @ts-ignore
socket.emit("connect"); socket.emit("connect");
await open;
self._node.pool.peers.add(peer); self._node.pool.peers.add(peer);
self._node.pool.connectedGroups.add(peer.address.getGroup()); self._node.pool.connectedGroups.add(peer.address.getGroup());
self._node.pool.emit("peer", peer); self._node.pool.emit("peer", peer);