src/index.ts

@@ -20,7 +20,7 @@ let swarm;
 let proxy: HandshakeProxy;
 
 function resolveWithPeers(resolve: Function) {
-  if (!proxy.node.pool.peers.head()) {
+  if (proxy.node.peers.list.size === 0) {
     proxy.node.pool.once("peer", () => {
       resolve(null);
     });
@@ -48,16 +48,14 @@ async function handleReady(aq: ActiveQuery) {
       return resolveWithPeers(resolve);
     }
 
-    proxy.node.pool.once("full", () => {
+    proxy.node.pool.on("full", resolveWithPeers);
-      resolveWithPeers(resolve);
-    });
   });
 
   aq.respond();
 }
 
 async function handleQuery(aq: ActiveQuery) {
-  if (!proxy.node.chain.synced || !proxy.node.pool.peers.head()) {
+  if (!proxy.node.chain.synced || proxy.node.peers.list.size === 0) {
     aq.reject("not ready");
     return;
   }