Changeset View
Changeset View
Standalone View
Standalone View
test/functional/notifications.py
Show First 20 Lines • Show All 54 Lines • ▼ Show 20 Lines | def run_test(self): | ||||
map(lambda t: t['txid'], self.nodes[1].listtransactions("*", block_count))) | map(lambda t: t['txid'], self.nodes[1].listtransactions("*", block_count))) | ||||
with open(self.tx_filename, 'r') as f: | with open(self.tx_filename, 'r') as f: | ||||
assert_equal(sorted(txids_rpc), sorted(f.read().splitlines())) | assert_equal(sorted(txids_rpc), sorted(f.read().splitlines())) | ||||
os.remove(self.tx_filename) | os.remove(self.tx_filename) | ||||
self.log.info("test -walletnotify after rescan") | self.log.info("test -walletnotify after rescan") | ||||
# restart node to rescan to force wallet notifications | # restart node to rescan to force wallet notifications | ||||
self.restart_node(1) | self.restart_node(1) | ||||
connect_nodes_bi(self.nodes, 0, 1) | connect_nodes_bi(self.nodes[0], self.nodes[1]) | ||||
wait_until(lambda: os.path.isfile(self.tx_filename) and os.stat( | wait_until(lambda: os.path.isfile(self.tx_filename) and os.stat( | ||||
self.tx_filename).st_size >= (block_count * 65), timeout=10) | self.tx_filename).st_size >= (block_count * 65), timeout=10) | ||||
# file content should equal the generated transaction hashes | # file content should equal the generated transaction hashes | ||||
txids_rpc = list( | txids_rpc = list( | ||||
map(lambda t: t['txid'], self.nodes[1].listtransactions("*", block_count))) | map(lambda t: t['txid'], self.nodes[1].listtransactions("*", block_count))) | ||||
with open(self.tx_filename, 'r') as f: | with open(self.tx_filename, 'r') as f: | ||||
▲ Show 20 Lines • Show All 47 Lines • Show Last 20 Lines |