3 import time, sys, electrum, Queue
4 from electrum import Interface, SimpleConfig
5 from electrum.network import filter_protocol, parse_servers
6 from collections import defaultdict
11 print "usage: txradar txid"
14 # 1. start interface and wait for connection
15 interface = electrum.Interface('ecdsa.net:50002:s')
16 interface.start(wait = True)
17 if not interface.is_connected:
21 # 2. get list of peers
23 interface.send([('server.peers.subscribe',[])], lambda i,x: q.put(x))
24 r = q.get(timeout=10000)
25 peers = parse_servers(r.get('result'))
26 peers = filter_protocol(peers,'s')
28 print "Contacting %d servers"%len(peers)
30 config = SimpleConfig()
31 interfaces = map ( lambda server: Interface(server, config), peers )
32 results_queue = Queue.Queue()
34 for i in interfaces: i.start(q)
41 if time.time() - t0 > 10:
46 peers.remove(i.server)
48 i.send([('blockchain.transaction.get',[tx])], lambda i,x: results_queue.put((i,x)))
49 reached_servers.append(i.server)
51 print "Connection failed:", i.server
53 print "%d servers could be reached"%len(reached_servers)
59 while reached_servers:
60 i, r = results_queue.get(timeout=10000)
61 reached_servers.remove(i.server)
70 print "----------------"
71 print "servers that have not seen this transaction:\n", '\n'.join(r2)
72 print "----------------"
73 print "propagation rate: %.1f percent" % (len(r1) *100./(len(r1)+ len(r2)))
75 print "transaction propagated everywhere"