fix(node): fixing the repair script so we can repair while a node is …

…syncing
nitsujlangston · Jan 28, 2019 · b1b1e17 · b1b1e17
1 parent bd46b05
commit b1b1e17
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/packages/bitcore-node/src/services/p2p.ts b/packages/bitcore-node/src/services/p2p.ts
@@ -208,6 +208,7 @@ export class P2pWorker {
   }
 
   async connect() {
+    this.setupListeners();
     this.pool.connect();
     this.connectInterval = setInterval(this.pool.connect.bind(this.pool), 5000);
     return new Promise<void>(resolve => {
@@ -446,7 +447,6 @@ export class P2pWorker {
 
   async start() {
     logger.debug(`Started worker for chain ${this.chain}`);
-    this.setupListeners();
     await this.connect();
     this.registerSyncingNode();
   }

diff --git a/packages/bitcore-node/test/verification/db-repair.ts b/packages/bitcore-node/test/verification/db-repair.ts
@@ -18,7 +18,8 @@ import { BlockStorage } from '../../src/models/block';
   await Storage.start();
   const chainConfig = Config.chainConfig({ chain, network });
   const worker = new P2pWorker({ chain, network, chainConfig });
-  await worker.start();
+  await worker.connect();
+
   const handleRepair = async data => {
     switch (data.type) {
       case 'DUPE_COIN':