mirror of
https://github.com/romanz/electrs.git
synced 2024-11-19 18:10:51 +01:00
46 lines
1.2 KiB
Python
46 lines
1.2 KiB
Python
import binascii
|
|
import json
|
|
import socket
|
|
import time
|
|
|
|
s = socket.create_connection(('localhost', 8332))
|
|
r = s.makefile()
|
|
cookie = binascii.b2a_base64(open('/home/roman/.bitcoin/.cookie', 'rb').read())
|
|
cookie = cookie.decode('ascii').strip()
|
|
|
|
def request(method, params_list):
|
|
obj = [{"method": method, "params": params} for params in params_list]
|
|
request = json.dumps(obj)
|
|
|
|
msg = ('POST / HTTP/1.1\nAuthorization: Basic {}\nContent-Length: {}\n\n'
|
|
'{}'.format(cookie, len(request), request))
|
|
s.sendall(msg.encode('ascii'))
|
|
|
|
status = r.readline().strip()
|
|
headers = []
|
|
while True:
|
|
line = r.readline().strip()
|
|
if line:
|
|
headers.append(line)
|
|
else:
|
|
break
|
|
|
|
data = r.readline().strip()
|
|
replies = json.loads(data)
|
|
assert all(r['error'] is None for r in replies), replies
|
|
return [d['result'] for d in replies]
|
|
|
|
|
|
def main():
|
|
t = time.time()
|
|
txids, = request('getrawmempool', [[False]])
|
|
print('{:.3f} {}'.format(time.time() - t, len(txids)))
|
|
t = time.time()
|
|
txids = list(map(lambda a: [a], txids))
|
|
entries = request('getmempoolentry', txids)
|
|
print('{:.3f} {}'.format(time.time() - t, len(entries)))
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main()
|