Inside Bitcoin

751            CAddress.NET_IPV4: [
752                "20.0.0.1",
753                "30.0.0.1",
754                "40.0.0.1",
755                "50.0.0.1",
756                "60.0.0.1",
757                "70.0.0.1",
758                "80.0.0.1",
759                "90.0.0.1",
760                "100.0.0.1",
761                "110.0.0.1",
762                "120.0.0.1",
763                "130.0.0.1",
764                "140.0.0.1",
765                "150.0.0.1",
766                "160.0.0.1",
767                "170.0.0.1",
768                "180.0.0.1",
769                "190.0.0.1",
770                "200.0.0.1",
771                "210.0.0.1",
772            ],
773            CAddress.NET_IPV6: [
774                "[20::1]",
775                "[30::1]",
776                "[40::1]",
777                "[50::1]",
778                "[60::1]",
779                "[70::1]",
780                "[80::1]",
781                "[90::1]",
782                "[100::1]",
783                "[110::1]",
784                "[120::1]",
785                "[130::1]",
786                "[140::1]",
787                "[150::1]",
788                "[160::1]",
789                "[170::1]",
790                "[180::1]",
791                "[190::1]",
792                "[200::1]",
793                "[210::1]",
794            ],
795            CAddress.NET_TORV3: [
796                "testonlyad777777777777777777777777777777777777777775b6qd.onion",
797                "testonlyah77777777777777777777777777777777777777777z7ayd.onion",
798                "testonlyal77777777777777777777777777777777777777777vp6qd.onion",
799                "testonlyap77777777777777777777777777777777777777777r5qad.onion",
800                "testonlyat77777777777777777777777777777777777777777udsid.onion",
801                "testonlyax77777777777777777777777777777777777777777yciid.onion",
802                "testonlya777777777777777777777777777777777777777777rhgyd.onion",
803                "testonlybd77777777777777777777777777777777777777777rs4ad.onion",
804                "testonlybp77777777777777777777777777777777777777777zs2ad.onion",
805                "testonlybt777777777777777777777777777777777777777777x6id.onion",
806                "testonlybx777777777777777777777777777777777777777775styd.onion",
807                "testonlyb3777777777777777777777777777777777777777774ckid.onion",
808                "testonlycd77777777777777777777777777777777777777777733id.onion",
809                "testonlych77777777777777777777777777777777777777777t6kid.onion",
810                "testonlycl77777777777777777777777777777777777777777tt3ad.onion",
811                "testonlyct77777777777777777777777777777777777777777wvhyd.onion",
812                "testonlycx7777777777777777777777777777777777777777774bad.onion",
813                "testonlyc377777777777777777777777777777777777777777u6aid.onion",
814                "testonlydd777777777777777777777777777777777777777777u5ad.onion",
815                "testonlydh77777777777777777777777777777777777777777wgnyd.onion",
816            ],
817            CAddress.NET_I2P: [
818                "testonlyad77777777777777777777777777777777777777777q.b32.i2p",
819                "testonlyah77777777777777777777777777777777777777777q.b32.i2p",
820                "testonlyap77777777777777777777777777777777777777777q.b32.i2p",
821                "testonlyat77777777777777777777777777777777777777777q.b32.i2p",
822                "testonlyax77777777777777777777777777777777777777777q.b32.i2p",
823                "testonlya377777777777777777777777777777777777777777q.b32.i2p",
824                "testonlya777777777777777777777777777777777777777777q.b32.i2p",
825                "testonlybd77777777777777777777777777777777777777777q.b32.i2p",
826                "testonlybh77777777777777777777777777777777777777777q.b32.i2p",
827                "testonlybl77777777777777777777777777777777777777777q.b32.i2p",
828                "testonlybp77777777777777777777777777777777777777777q.b32.i2p",
829                "testonlybt77777777777777777777777777777777777777777q.b32.i2p",
830                "testonlybx77777777777777777777777777777777777777777q.b32.i2p",
831                "testonlyb777777777777777777777777777777777777777777q.b32.i2p",
832                "testonlych77777777777777777777777777777777777777777q.b32.i2p",
833                "testonlycp77777777777777777777777777777777777777777q.b32.i2p",
834                "testonlyct77777777777777777777777777777777777777777q.b32.i2p",
835                "testonlycx77777777777777777777777777777777777777777q.b32.i2p",
836                "testonlyc377777777777777777777777777777777777777777q.b32.i2p",
837                "testonlyc777777777777777777777777777777777777777777q.b32.i2p",
838            ],
839            CAddress.NET_CJDNS: [
840                "[fc00::1]",
841                "[fc00::2]",
842                "[fc00::3]",
843                "[fc00::5]",
844                "[fc00::6]",
845                "[fc00::7]",
846                "[fc00::8]",
847                "[fc00::9]",
848                "[fc00::10]",
849                "[fc00::11]",
850                "[fc00::12]",
851                "[fc00::13]",
852                "[fc00::15]",
853                "[fc00::16]",
854                "[fc00::17]",
855                "[fc00::18]",
856                "[fc00::19]",
857                "[fc00::20]",
858                "[fc00::22]",
859                "[fc00::23]",
860            ],
861        }
862        for addr_type in address_types_to_add:
863            for addr in ADDRESSES[addr_type]:
864                res = self.nodes[node_index].addpeeraddress(address=addr, port=0 if addr.endswith(".i2p") else 8333, tried=False)
865                if not res["success"]:
866                    self.log.debug(f"Could not add {addr} to nodes[{node_index}]'s addrman (collision?)")
867
868    # Private helper methods. These should not be accessed by the subclass test scripts.
869
870    def _start_logging(self):
871        # Add logger and logging handlers
872        self.log = logging.getLogger('TestFramework')
873        self.log.setLevel(logging.DEBUG)
874        # Create file handler to log all messages
875        fh = logging.FileHandler(self.options.tmpdir + '/test_framework.log')
876        fh.setLevel(logging.DEBUG)
877        # Create console handler to log messages to stderr. By default this logs only error messages, but can be configured with --loglevel.
878        ch = logging.StreamHandler(sys.stdout)
879        # User can provide log level as a number or string (eg DEBUG). loglevel was caught as a string, so try to convert it to an int
880        ll = int(self.options.loglevel) if self.options.loglevel.isdigit() else self.options.loglevel.upper()
881        ch.setLevel(ll)
882
883        # Format logs the same as bitcoind's debug.log with microprecision (so log files can be concatenated and sorted)
884        class MicrosecondFormatter(logging.Formatter):
885            def formatTime(self, record, _=None):
886                dt = datetime.fromtimestamp(record.created, timezone.utc)
887                return dt.strftime('%Y-%m-%dT%H:%M:%S.%f')
888
889        formatter = MicrosecondFormatter(
890            fmt='%(asctime)sZ %(name)s (%(levelname)s): %(message)s',
891        )
892        fh.setFormatter(formatter)
893        ch.setFormatter(formatter)
894        # add the handlers to the logger
895        self.log.addHandler(fh)
896        self.log.addHandler(ch)
897
898        if self.options.trace_rpc:
899            rpc_logger = logging.getLogger("BitcoinRPC")
900            rpc_logger.setLevel(logging.DEBUG)
901            rpc_handler = logging.StreamHandler(sys.stdout)
902            rpc_handler.setLevel(logging.DEBUG)
903            rpc_logger.addHandler(rpc_handler)
904
905    def _initialize_chain(self):
906        """Initialize a pre-mined blockchain for use by the test.
907
908        Create a cache of a 199-block-long chain
909        Afterward, create num_nodes copies from the cache."""
910
911        CACHE_NODE_ID = 0  # Use node 0 to create the cache for all other nodes
912        cache_node_dir = get_datadir_path(self.options.cachedir, CACHE_NODE_ID)
913        assert self.num_nodes <= MAX_NODES
914
915        if not os.path.isdir(cache_node_dir):
916            self.log.debug("Creating cache directory {}".format(cache_node_dir))
917
918            initialize_datadir(self.options.cachedir, CACHE_NODE_ID, self.chain, self.disable_autoconnect)
919            self.nodes.append(
920                TestNode(
921                    CACHE_NODE_ID,
922                    cache_node_dir,
923                    chain=self.chain,
924                    extra_conf=["bind=127.0.0.1"],
925                    extra_args=[],
926                    rpchost=None,
927                    timewait=self.rpc_timeout,
928                    timeout_factor=self.options.timeout_factor,
929                    binaries=self.get_binaries(),
930                    coverage_dir=None,
931                    cwd=self.options.tmpdir,
932                    uses_wallet=self.uses_wallet,
933                ))
934            self.start_node(CACHE_NODE_ID)
935            cache_node = self.nodes[CACHE_NODE_ID]
936
937            # Wait for RPC connections to be ready
938            cache_node.wait_for_rpc_connection()
939
940            # Set a time in the past, so that blocks don't end up in the future
941            cache_node.setmocktime(cache_node.getblockheader(cache_node.getbestblockhash())['time'])
942
943            # Create a 199-block-long chain; each of the 3 first nodes
944            # gets 25 mature blocks and 25 immature.
945            # The 4th address gets 25 mature and only 24 immature blocks so that the very last
946            # block in the cache does not age too much (have an old tip age).
947            # This is needed so that we are out of IBD when the test starts,
948            # see the tip age check in IsInitialBlockDownload().
949            gen_addresses = [k.address for k in TestNode.PRIV_KEYS][:3] + [create_deterministic_address_bcrt1_p2tr_op_true()[0]]
950            assert_equal(len(gen_addresses), 4)
951            for i in range(8):
952                self.generatetoaddress(
953                    cache_node,
954                    nblocks=25 if i != 7 else 24,
955                    address=gen_addresses[i % len(gen_addresses)],
956                )
957
958            assert_equal(cache_node.getblockchaininfo()["blocks"], 199)
959
960            # Shut it down, and clean up cache directories:
961            self.stop_nodes()
962            self.nodes = []
963
964            cache_path = cache_node_dir / self.chain
965
966            (cache_path / "wallets").rmdir()  # Do not cache empty wallets dir
967            shutil.rmtree(cache_path / "fees")  # Do not cache fees dat files
968            for entry in cache_path.iterdir():
969                if entry.name not in ["chainstate", "blocks", "indexes"]:  # Only keep indexes, chainstate and blocks folders
970                    entry.unlink()
971
972        for i in range(self.num_nodes):
973            self.log.debug("Copy cache directory {} to node {}".format(cache_node_dir, i))
974            to_dir = get_datadir_path(self.options.tmpdir, i)
975            shutil.copytree(cache_node_dir, to_dir)
976            initialize_datadir(self.options.tmpdir, i, self.chain, self.disable_autoconnect)  # Overwrite port/rpcport in bitcoin.conf
977
978    def _initialize_chain_clean(self):
979        """Initialize empty blockchain for use by the test.
980
981        Create an empty blockchain and num_nodes wallets.
982        Useful if a test case wants complete control over initialization."""
983        for i in range(self.num_nodes):
984            initialize_datadir(self.options.tmpdir, i, self.chain, self.disable_autoconnect)
985
986    def skip_if_no_py3_zmq(self):
987        """Attempt to import the zmq package and skip the test if the import fails."""
988        try:
989            import zmq  # noqa
990        except ImportError:
991            raise SkipTest("python3-zmq module not available.")
992
993    def skip_if_no_py_sqlite3(self):
994        """Attempt to import the sqlite3 package and skip the test if the import fails."""
995        try:
996            import sqlite3  # noqa
997        except ImportError:
998            raise SkipTest("sqlite3 module not available.")
999
1000    def skip_if_no_py_capnp(self):