#!/usr/bin/env python
-from electrum import Interface, SimpleConfig, set_verbosity
-from electrum.network import DEFAULT_SERVERS, filter_protocol
+from electrum_nvc import Interface, SimpleConfig, set_verbosity
+from electrum_nvc.network import DEFAULT_SERVERS, filter_protocol
import time, Queue
from collections import defaultdict
i = q.get(timeout=1000)
servers.remove(i.server)
if i.is_connected:
- i.send([('blockchain.numblocks.subscribe',[])], lambda i,x: results_queue.put((i,x)))
+ i.send([('blockchain.headers.subscribe',[])], lambda i,x: results_queue.put((i,x)))
reached_servers.append(i.server)
i.status = "ok"
else:
while reached_servers:
i, r = results_queue.get(timeout=1000)
- i.blocks = r.get('result')
+ i.blocks = r.get('result').get('block_height')
d[i.blocks] += 1
reached_servers.remove(i.server)