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 | |||||