diff --git a/app/modules/crawler/lib/sync/RemoteSynchronizer.ts b/app/modules/crawler/lib/sync/RemoteSynchronizer.ts index f173627cc4a47fedbb42f6dfac25892c8236706e..e9a759fc33eccab8435289f0e27aa26a7b2d890f 100644 --- a/app/modules/crawler/lib/sync/RemoteSynchronizer.ts +++ b/app/modules/crawler/lib/sync/RemoteSynchronizer.ts @@ -382,16 +382,23 @@ export class RemoteSynchronizer extends AbstractSynchronizer { } async syncPeers(fullSync: boolean, to?: number): Promise<void> { + if (!this.node) { + await this.init(); + } const peers = await this.node.getPeers(); for (let i = 0; i < peers.length; i++) { const peer = PeerDTO.fromJSONObject(peers[i]); - this.watcher.writeStatus("Peer " + peer.pubkey); - this.watcher.peersPercent(Math.ceil((i / peers.length) * 100)); + if (this.watcher) { + this.watcher.writeStatus("Peer " + peer.pubkey); + this.watcher.peersPercent(Math.ceil((i / peers.length) * 100)); + } try { await this.PeeringService.submitP(DBPeer.fromPeerDTO(peer)); } catch (e) {} } - this.watcher.peersPercent(100); + if (this.watcher) { + this.watcher.peersPercent(100); + } } async syncSandbox(): Promise<void> {