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

Compare commits

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

No commits in common. "37cbac3435d2dd2f3579b26fd5154e7b7040bc7c" and "a8dd1d2c20283b380b52ba1e1c3404e8e86b9e70" have entirely different histories.
37cbac3435 ... a8dd1d2c20

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

3
dist/index.js vendored
View File

@ -28,9 +28,10 @@ class HandshakeProxy extends libhyperproxy_1.Proxy {
return { connect: false }; return { connect: false };
} }
self._node.pool.bindPeer(peer); self._node.pool.bindPeer(peer);
peer.tryOpen(); const open = 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,9 +49,10 @@ export default class HandshakeProxy extends Proxy {
} }
self._node.pool.bindPeer(peer); self._node.pool.bindPeer(peer);
peer.tryOpen(); const open = 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);