Changeset View
Changeset View
Standalone View
Standalone View
test/functional/wallet_keypool_topup.py
| Show All 10 Lines | |||||
| - Stop node1, clear the datadir, move wallet file back into the datadir and restart node1. | - Stop node1, clear the datadir, move wallet file back into the datadir and restart node1. | ||||
| - connect node1 to node0. Verify that they sync and node1 receives its funds.""" | - connect node1 to node0. Verify that they sync and node1 receives its funds.""" | ||||
| import os | import os | ||||
| import shutil | import shutil | ||||
| from test_framework.test_framework import BitcoinTestFramework | from test_framework.test_framework import BitcoinTestFramework | ||||
| from test_framework.util import ( | from test_framework.util import ( | ||||
| assert_equal, | assert_equal, | ||||
| connect_nodes_bi, | connect_nodes, | ||||
| ) | ) | ||||
| class KeypoolRestoreTest(BitcoinTestFramework): | class KeypoolRestoreTest(BitcoinTestFramework): | ||||
| def set_test_params(self): | def set_test_params(self): | ||||
| self.setup_clean_chain = True | self.setup_clean_chain = True | ||||
| self.num_nodes = 2 | self.num_nodes = 2 | ||||
| self.extra_args = [[], ['-keypool=100']] | self.extra_args = [[], ['-keypool=100']] | ||||
| def skip_test_if_missing_module(self): | def skip_test_if_missing_module(self): | ||||
| self.skip_if_no_wallet() | self.skip_if_no_wallet() | ||||
| def run_test(self): | def run_test(self): | ||||
| wallet_path = os.path.join( | wallet_path = os.path.join( | ||||
| self.nodes[1].datadir, "regtest", "wallets", "wallet.dat") | self.nodes[1].datadir, "regtest", "wallets", "wallet.dat") | ||||
| wallet_backup_path = os.path.join(self.nodes[1].datadir, "wallet.bak") | wallet_backup_path = os.path.join(self.nodes[1].datadir, "wallet.bak") | ||||
| self.nodes[0].generate(101) | self.nodes[0].generate(101) | ||||
| self.log.info("Make backup of wallet") | self.log.info("Make backup of wallet") | ||||
| self.stop_node(1) | self.stop_node(1) | ||||
| shutil.copyfile(wallet_path, wallet_backup_path) | shutil.copyfile(wallet_path, wallet_backup_path) | ||||
| self.start_node(1, self.extra_args[1]) | self.start_node(1, self.extra_args[1]) | ||||
| connect_nodes_bi(self.nodes[0], self.nodes[1]) | connect_nodes(self.nodes[0], self.nodes[1]) | ||||
| self.log.info("Generate keys for wallet") | self.log.info("Generate keys for wallet") | ||||
| for _ in range(90): | for _ in range(90): | ||||
| addr_oldpool = self.nodes[1].getnewaddress() | addr_oldpool = self.nodes[1].getnewaddress() | ||||
| for _ in range(20): | for _ in range(20): | ||||
| addr_extpool = self.nodes[1].getnewaddress() | addr_extpool = self.nodes[1].getnewaddress() | ||||
| self.log.info("Send funds to wallet") | self.log.info("Send funds to wallet") | ||||
| self.nodes[0].sendtoaddress(addr_oldpool, 10) | self.nodes[0].sendtoaddress(addr_oldpool, 10) | ||||
| self.nodes[0].generate(1) | self.nodes[0].generate(1) | ||||
| self.nodes[0].sendtoaddress(addr_extpool, 5) | self.nodes[0].sendtoaddress(addr_extpool, 5) | ||||
| self.nodes[0].generate(1) | self.nodes[0].generate(1) | ||||
| self.sync_blocks() | self.sync_blocks() | ||||
| self.log.info("Restart node with wallet backup") | self.log.info("Restart node with wallet backup") | ||||
| self.stop_node(1) | self.stop_node(1) | ||||
| shutil.copyfile(wallet_backup_path, wallet_path) | shutil.copyfile(wallet_backup_path, wallet_path) | ||||
| self.start_node(1, self.extra_args[1]) | self.start_node(1, self.extra_args[1]) | ||||
| connect_nodes_bi(self.nodes[0], self.nodes[1]) | connect_nodes(self.nodes[0], self.nodes[1]) | ||||
| self.sync_all() | self.sync_all() | ||||
| self.log.info("Verify keypool is restored and balance is correct") | self.log.info("Verify keypool is restored and balance is correct") | ||||
| assert_equal(self.nodes[1].getbalance(), 15) | assert_equal(self.nodes[1].getbalance(), 15) | ||||
| assert_equal(self.nodes[1].listtransactions() | assert_equal(self.nodes[1].listtransactions() | ||||
| [0]['category'], "receive") | [0]['category'], "receive") | ||||
| # Check that we have marked all keys up to the used keypool key as used | # Check that we have marked all keys up to the used keypool key as used | ||||
| assert_equal(self.nodes[1].getaddressinfo( | assert_equal(self.nodes[1].getaddressinfo( | ||||
| self.nodes[1].getnewaddress())['hdkeypath'], "m/0'/0'/110'") | self.nodes[1].getnewaddress())['hdkeypath'], "m/0'/0'/110'") | ||||
| if __name__ == '__main__': | if __name__ == '__main__': | ||||
| KeypoolRestoreTest().main() | KeypoolRestoreTest().main() | ||||