scripts/txradar

   1 #!/usr/bin/env python
   2
   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
   7
   8 try:
   9     tx = sys.argv[1]
  10 except:
  11     print "usage: txradar txid"
  12     sys.exit(1)
  13
  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:
  18     print "not connected"
  19     exit()
  20
  21 # 2. get list of peers
  22 q = Queue.Queue()
  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')
  27
  28 print "Contacting %d servers"%len(peers)
  29 # start interfaces
  30 config = SimpleConfig()
  31 interfaces = map ( lambda server: Interface(server, config), peers )
  32 results_queue = Queue.Queue()
  33 reached_servers = []
  34 for i in interfaces: i.start(q)
  35
  36 t0 = time.time()
  37 while peers:
  38     try:
  39         i = q.get(timeout=1)
  40     except:
  41         if time.time() - t0 > 10:
  42             print "timeout"
  43             break
  44         else:
  45             continue
  46     peers.remove(i.server)
  47     if i.is_connected:
  48         i.send([('blockchain.transaction.get',[tx])], lambda i,x: results_queue.put((i,x)))
  49         reached_servers.append(i.server)
  50     else:
  51         print "Connection failed:", i.server
  52
  53 print "%d servers could be reached"%len(reached_servers)
  54
  55
  56 r1 = []
  57 r2 = []
  58
  59 while reached_servers:
  60     i, r = results_queue.get(timeout=10000)
  61     reached_servers.remove(i.server)
  62
  63     if r.get('result'):
  64         r1.append(i.server)
  65     else:
  66         r2.append(i.server)
  67
  68
  69 if r2:
  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)))
  74 else:
  75     print "transaction propagated everywhere"