lbrycrd/test/functional/zmq_test.py

111 lines
3.8 KiB
Python
Raw Normal View History

2016-03-19 20:58:06 +01:00
#!/usr/bin/env python3
# Copyright (c) 2015-2016 The Bitcoin Core developers
2015-05-05 13:19:19 +02:00
# Distributed under the MIT software license, see the accompanying
# file COPYING or http://www.opensource.org/licenses/mit-license.php.
"""Test the ZMQ API."""
import configparser
import os
import struct
import sys
2015-05-05 13:19:19 +02:00
from test_framework.test_framework import BitcoinTestFramework
from test_framework.util import *
class ZMQTest (BitcoinTestFramework):
def __init__(self):
super().__init__()
self.num_nodes = 4
2015-05-05 13:19:19 +02:00
port = 28332
def setup_nodes(self):
# Try to import python3-zmq. Skip this test if the import fails.
try:
import zmq
except ImportError:
self.log.warning("python3-zmq module not available. Skipping zmq tests!")
sys.exit(self.TEST_EXIT_SKIPPED)
# Check that bitcoin has been built with ZMQ enabled
config = configparser.ConfigParser()
config.read_file(open(os.path.dirname(__file__) + "/config.ini"))
if not config["components"].getboolean("ENABLE_ZMQ"):
self.log.warning("bitcoind has not been built with zmq enabled. Skipping zmq tests!")
sys.exit(self.TEST_EXIT_SKIPPED)
2015-05-05 13:19:19 +02:00
self.zmqContext = zmq.Context()
self.zmqSubSocket = self.zmqContext.socket(zmq.SUB)
self.zmqSubSocket.setsockopt(zmq.SUBSCRIBE, b"hashblock")
self.zmqSubSocket.setsockopt(zmq.SUBSCRIBE, b"hashtx")
2015-05-05 13:19:19 +02:00
self.zmqSubSocket.connect("tcp://127.0.0.1:%i" % self.port)
return start_nodes(self.num_nodes, self.options.tmpdir, extra_args=[
2015-05-05 13:19:19 +02:00
['-zmqpubhashtx=tcp://127.0.0.1:'+str(self.port), '-zmqpubhashblock=tcp://127.0.0.1:'+str(self.port)],
[],
[],
[]
])
def run_test(self):
self.sync_all()
2015-12-02 18:12:23 +01:00
genhashes = self.nodes[0].generate(1)
2015-05-05 13:19:19 +02:00
self.sync_all()
2017-03-08 00:46:17 +01:00
self.log.info("listen...")
2015-05-05 13:19:19 +02:00
msg = self.zmqSubSocket.recv_multipart()
topic = msg[0]
assert_equal(topic, b"hashtx")
2015-05-05 13:19:19 +02:00
body = msg[1]
msgSequence = struct.unpack('<I', msg[-1])[-1]
assert_equal(msgSequence, 0) #must be sequence 0 on hashtx
2015-05-05 13:19:19 +02:00
msg = self.zmqSubSocket.recv_multipart()
topic = msg[0]
2015-05-05 13:19:19 +02:00
body = msg[1]
msgSequence = struct.unpack('<I', msg[-1])[-1]
assert_equal(msgSequence, 0) #must be sequence 0 on hashblock
blkhash = bytes_to_hex_str(body)
2015-05-05 13:19:19 +02:00
assert_equal(genhashes[0], blkhash) #blockhash from generate must be equal to the hash received over zmq
n = 10
2015-12-02 18:12:23 +01:00
genhashes = self.nodes[1].generate(n)
2015-05-05 13:19:19 +02:00
self.sync_all()
zmqHashes = []
blockcount = 0
2015-05-05 13:19:19 +02:00
for x in range(0,n*2):
msg = self.zmqSubSocket.recv_multipart()
topic = msg[0]
2015-05-05 13:19:19 +02:00
body = msg[1]
if topic == b"hashblock":
zmqHashes.append(bytes_to_hex_str(body))
msgSequence = struct.unpack('<I', msg[-1])[-1]
assert_equal(msgSequence, blockcount+1)
blockcount += 1
2015-05-05 13:19:19 +02:00
for x in range(0,n):
assert_equal(genhashes[x], zmqHashes[x]) #blockhash from generate must be equal to the hash received over zmq
#test tx from a second node
hashRPC = self.nodes[1].sendtoaddress(self.nodes[0].getnewaddress(), 1.0)
self.sync_all()
2015-12-02 18:12:23 +01:00
# now we should receive a zmq msg because the tx was broadcast
2015-05-05 13:19:19 +02:00
msg = self.zmqSubSocket.recv_multipart()
topic = msg[0]
2015-05-05 13:19:19 +02:00
body = msg[1]
hashZMQ = ""
if topic == b"hashtx":
hashZMQ = bytes_to_hex_str(body)
msgSequence = struct.unpack('<I', msg[-1])[-1]
assert_equal(msgSequence, blockcount+1)
2015-05-05 13:19:19 +02:00
assert_equal(hashRPC, hashZMQ) #blockhash from generate must be equal to the hash received over zmq
if __name__ == '__main__':
ZMQTest ().main ()