3 import time, electrum, Queue
4 from electrum import Interface, SimpleConfig
5 from electrum.network import filter_protocol, parse_servers
6 from collections import defaultdict
8 # 1. start interface and wait for connection
9 interface = electrum.Interface('ecdsa.net:50002:s')
10 interface.start(wait = True)
11 if not interface.is_connected:
15 # 2. get list of peers
17 interface.send([('server.peers.subscribe',[])], lambda i,x: q.put(x))
18 r = q.get(timeout=10000)
19 peers = parse_servers(r.get('result'))
20 peers = filter_protocol(peers,'s')
22 print "Contacting %d servers"%len(peers)
24 config = SimpleConfig()
25 interfaces = map ( lambda server: Interface(server, config), peers )
26 results_queue = Queue.Queue()
28 for i in interfaces: i.start(q)
35 if time.time() - t0 > 10:
40 peers.remove(i.server)
42 i.send([('blockchain.headers.subscribe',[])], lambda i,x: results_queue.put((i,x)))
43 reached_servers.append(i.server)
45 print "Connection failed:", i.server
47 print "%d servers could be reached"%len(reached_servers)
52 for k, v in results.items():
53 height = v.get('block_height')
54 merkle = v.get('merkle_root')
55 utxo = v.get('utxo_root')
56 d = dd.get(merkle, defaultdict(int))
61 for merkle, d in dd.items():
64 ref = d.keys()[v.index(m)]
67 for k, v in results.items():
68 height = v.get('block_height')
69 merkle = v.get('merkle_root')
70 utxo = v.get('utxo_root')
71 ref_utxo, num = refs.get(merkle)
73 if ref_utxo != utxo and num > 1:
74 out[k] = height, merkle, utxo
80 while reached_servers:
81 i, r = results_queue.get(timeout=10000)
82 results[i.server] = r.get('result')
83 reached_servers.remove(i.server)
85 errors = analyze(results).keys()
87 for n,v in sorted(results.items(), key=lambda x:x[1]['block_height']):
88 print "%40s"%n, v['block_height'], v['utxo_root'], "error" if n in errors else "ok"