Inside Bitcoin

501
502        # Without walletrejectlongchains, we will still generate a txid
503        # The tx will be stored in the wallet but not accepted to the mempool
504        extra_txid = self.nodes[0].sendtoaddress(sending_addr, Decimal('0.0001'))
505        assert extra_txid not in self.nodes[0].getrawmempool()
506        assert extra_txid in [tx["txid"] for tx in self.nodes[0].listtransactions()]
507        self.nodes[0].abandontransaction(extra_txid)
508        total_txs = len(self.nodes[0].listtransactions("*", 99999))
509
510        # Try with walletrejectlongchains
511        # Double chain limit but require combining inputs, so we pass AttemptSelection
512        self.stop_node(0)
513        extra_args = ["-walletrejectlongchains", "-limitclustercount=" + str(2 * chainlimit), "-limitancestorcount=" + str(2*chainlimit)]
514        self.start_node(0, extra_args=extra_args)
515
516        # wait until the wallet has submitted all transactions to the mempool
517        self.wait_until(lambda: len(self.nodes[0].getrawmempool()) == chainlimit * 2)
518
519        # Prevent potential race condition when calling wallet RPCs right after restart
520        self.nodes[0].syncwithvalidationinterfacequeue()
521
522        node0_balance = self.nodes[0].getbalance()
523        # With walletrejectlongchains we will not create the tx and store it in our wallet.
524        assert_raises_rpc_error(-6, "too many unconfirmed transactions in cluster", self.nodes[0].sendtoaddress, sending_addr, node0_balance - Decimal('0.01'))
525
526        # Verify nothing new in wallet
527        assert_equal(total_txs, len(self.nodes[0].listtransactions("*", 99999)))
528
529        # Test getaddressinfo on external address. Note that these addresses are taken from disablewallet.py
530        assert_raises_rpc_error(-5, "Invalid or unsupported Base58-encoded address.", self.nodes[0].getaddressinfo, "3J98t1WpEZ73CNmQviecrnyiWrnqRhWNLy")
531        address_info = self.nodes[0].getaddressinfo("mneYUmWYsuk7kySiURxCi3AGxrAqZxLgPZ")
532        assert_equal(address_info['address'], "mneYUmWYsuk7kySiURxCi3AGxrAqZxLgPZ")
533        assert_equal(address_info["scriptPubKey"], "76a9144e3854046c7bd1594ac904e4793b6a45b36dea0988ac")
534        assert not address_info["ismine"]
535        assert not address_info["isscript"]
536        assert not address_info["ischange"]
537
538        # Test getaddressinfo 'ischange' field on change address.
539        self.generate(self.nodes[0], 1, sync_fun=self.no_op)
540        destination = self.nodes[1].getnewaddress()
541        txid = self.nodes[0].sendtoaddress(destination, 0.123)
542        tx = self.nodes[0].gettransaction(txid=txid, verbose=True)['decoded']
543        assert len(tx["vout"]) > 1
544        for vout in tx["vout"]:
545            address = vout['scriptPubKey']['address']
546            ischange = self.nodes[0].getaddressinfo(address)['ischange']
547            assert_equal(ischange, address != destination)
548            if ischange:
549                change = address
550                assert vout["ischange"]
551            else:
552                assert "ischange" not in vout
553        self.nodes[0].setlabel(change, 'foobar')
554        assert_equal(self.nodes[0].getaddressinfo(change)['ischange'], False)
555
556        # Test gettransaction response with different arguments.
557        self.log.info("Testing gettransaction response with different arguments...")
558        self.nodes[0].setlabel(change, 'baz')
559        baz = self.nodes[0].listtransactions(label="baz", count=1)[0]
560        expected_receive_vout = {"label":    "baz",
561                                 "address":  baz["address"],
562                                 "amount":   baz["amount"],
563                                 "category": baz["category"],
564                                 "vout":     baz["vout"]}
565        expected_fields = frozenset({'amount', 'confirmations', 'details', 'fee',
566                                     'hex', 'lastprocessedblock', 'time', 'timereceived', 'trusted', 'txid', 'wtxid', 'walletconflicts', 'mempoolconflicts',
567                                     'alternate_wtxids'})
568        verbose_field = "decoded"
569        expected_verbose_fields = expected_fields | {verbose_field}
570
571        self.log.debug("Testing gettransaction response without verbose")
572        tx = self.nodes[0].gettransaction(txid=txid)
573        assert_equal(set([*tx]), expected_fields)
574        assert_array_result(tx["details"], {"category": "receive"}, expected_receive_vout)
575
576        self.log.debug("Testing gettransaction response with verbose set to False")
577        tx = self.nodes[0].gettransaction(txid=txid, verbose=False)
578        assert_equal(set([*tx]), expected_fields)
579        assert_array_result(tx["details"], {"category": "receive"}, expected_receive_vout)
580
581        self.log.debug("Testing gettransaction response with verbose set to True")
582        tx = self.nodes[0].gettransaction(txid=txid, verbose=True)
583        assert_equal(set([*tx]), expected_verbose_fields)
584        assert_array_result(tx["details"], {"category": "receive"}, expected_receive_vout)
585        assert_equal(tx[verbose_field], self.nodes[0].decoderawtransaction(tx["hex"]))
586
587        self.log.info("Test send* RPCs with verbose=True")
588        address = self.nodes[0].getnewaddress("test")
589        txid_feeReason_one = self.nodes[2].sendtoaddress(address=address, amount=5, verbose=True)
590        assert_equal(txid_feeReason_one["fee_reason"], "Fallback fee")
591        txid_feeReason_two = self.nodes[2].sendmany(dummy='', amounts={address: 5}, verbose=True)
592        assert_equal(txid_feeReason_two["fee_reason"], "Fallback fee")
593        self.log.info("Test send* RPCs with verbose=False")
594        txid_feeReason_three = self.nodes[2].sendtoaddress(address=address, amount=5, verbose=False)
595        assert_equal(self.nodes[2].gettransaction(txid_feeReason_three)['txid'], txid_feeReason_three)
596        txid_feeReason_four = self.nodes[2].sendmany(dummy='', amounts={address: 5}, verbose=False)
597        assert_equal(self.nodes[2].gettransaction(txid_feeReason_four)['txid'], txid_feeReason_four)
598
599        self.log.info("Testing 'listunspent' outputs the parent descriptor(s) of coins")
600        # Create two multisig descriptors, and send a UTxO each.
601        multi_a = descsum_create("wsh(multi(1,tpubD6NzVbkrYhZ4YBNjUo96Jxd1u4XKWgnoc7LsA1jz3Yc2NiDbhtfBhaBtemB73n9V5vtJHwU6FVXwggTbeoJWQ1rzdz8ysDuQkpnaHyvnvzR/*,tpubD6NzVbkrYhZ4YHdDGMAYGaWxMSC1B6tPRTHuU5t3BcfcS3nrF523iFm5waFd1pP3ZvJt4Jr8XmCmsTBNx5suhcSgtzpGjGMASR3tau1hJz4/*))")
602        multi_b = descsum_create("wsh(multi(1,tpubD6NzVbkrYhZ4YHdDGMAYGaWxMSC1B6tPRTHuU5t3BcfcS3nrF523iFm5waFd1pP3ZvJt4Jr8XmCmsTBNx5suhcSgtzpGjGMASR3tau1hJz4/*,tpubD6NzVbkrYhZ4Y2RLiuEzNQkntjmsLpPYDm3LTRBYynUQtDtpzeUKAcb9sYthSFL3YR74cdFgF5mW8yKxv2W2CWuZDFR2dUpE5PF9kbrVXNZ/*))")
603        addr_a = self.nodes[0].deriveaddresses(multi_a, 0)[0]
604        addr_b = self.nodes[0].deriveaddresses(multi_b, 0)[0]
605        txid_a = self.nodes[0].sendtoaddress(addr_a, 0.01)
606        txid_b = self.nodes[0].sendtoaddress(addr_b, 0.01)
607        self.generate(self.nodes[0], 1, sync_fun=self.no_op)
608        # Prevent race of listunspent with outstanding TxAddedToMempool notifications
609        self.nodes[0].syncwithvalidationinterfacequeue()
610        # Now import the descriptors, make sure we can identify on which descriptor each coin was received.
611        self.nodes[0].createwallet(wallet_name="wo", disable_private_keys=True)
612        wo_wallet = self.nodes[0].get_wallet_rpc("wo")
613        wo_wallet.importdescriptors([
614            {
615                "desc": multi_a,
616                "active": False,
617                "timestamp": "now",
618            },
619            {
620                "desc": multi_b,
621                "active": False,
622                "timestamp": "now",
623            },
624        ])
625        coins = wo_wallet.listunspent(minconf=0)
626        assert_equal(len(coins), 2)
627        coin_a = next(c for c in coins if c["txid"] == txid_a)
628        assert_equal(coin_a["parent_descs"][0], multi_a)
629        coin_b = next(c for c in coins if c["txid"] == txid_b)
630        assert_equal(coin_b["parent_descs"][0], multi_b)
631        self.nodes[0].unloadwallet("wo")
632
633        self.log.info("Test -spendzeroconfchange")
634        self.restart_node(0, ["-spendzeroconfchange=0"])
635
636        # create new wallet and fund it with a confirmed UTXO
637        self.nodes[0].createwallet(wallet_name="zeroconf", load_on_startup=True)
638        zeroconf_wallet = self.nodes[0].get_wallet_rpc("zeroconf")
639        default_wallet = self.nodes[0].get_wallet_rpc(self.default_wallet_name)
640        default_wallet.sendtoaddress(zeroconf_wallet.getnewaddress(), Decimal('1.0'))
641        self.generate(self.nodes[0], 1, sync_fun=self.no_op)
642        utxos = zeroconf_wallet.listunspent(minconf=0)
643        assert_equal(len(utxos), 1)
644        assert_equal(utxos[0]['confirmations'], 1)
645
646        # spend confirmed UTXO to ourselves
647        zeroconf_wallet.sendall(recipients=[zeroconf_wallet.getnewaddress()])
648        utxos = zeroconf_wallet.listunspent(minconf=0)
649        assert_equal(len(utxos), 1)
650        assert_equal(utxos[0]['confirmations'], 0)
651        # accounts for untrusted pending balance
652        bal = zeroconf_wallet.getbalances()
653        assert_equal(bal['mine']['trusted'], 0)
654        assert_equal(bal['mine']['untrusted_pending'], utxos[0]['amount'])
655
656        # spending an unconfirmed UTXO sent to ourselves should fail
657        assert_raises_rpc_error(-6, "Insufficient funds", zeroconf_wallet.sendtoaddress, zeroconf_wallet.getnewaddress(), Decimal('0.5'))
658
659        # check that it works again with -spendzeroconfchange set (=default)
660        self.restart_node(0, ["-spendzeroconfchange=1"])
661        # Make sure the wallet knows the tx in the mempool
662        self.nodes[0].syncwithvalidationinterfacequeue()
663
664        zeroconf_wallet = self.nodes[0].get_wallet_rpc("zeroconf")
665        utxos = zeroconf_wallet.listunspent(minconf=0)
666        assert_equal(len(utxos), 1)
667        assert_equal(utxos[0]['confirmations'], 0)
668        # accounts for trusted balance
669        bal = zeroconf_wallet.getbalances()
670        assert_equal(bal['mine']['trusted'], utxos[0]['amount'])
671        assert_equal(bal['mine']['untrusted_pending'], 0)
672
673        zeroconf_wallet.sendtoaddress(zeroconf_wallet.getnewaddress(), Decimal('0.5'))
674
675        self.test_chain_listunspent()
676
677    def test_chain_listunspent(self):
678        self.wallet = MiniWallet(self.nodes[0])
679        self.nodes[0].get_wallet_rpc(self.default_wallet_name).sendtoaddress(self.wallet.get_address(), "5")
680        self.generate(self.wallet, 1, sync_fun=self.no_op)
681        self.nodes[0].createwallet("watch_wallet", disable_private_keys=True)
682        watch_wallet = self.nodes[0].get_wallet_rpc("watch_wallet")
683        import_res = watch_wallet.importdescriptors([{"desc": self.wallet.get_descriptor(), "timestamp": "now"}])
684        assert_equal(import_res[0]["success"], True)
685
686        # DEFAULT_ANCESTOR_LIMIT transactions off a confirmed tx should be fine
687        chain = self.wallet.create_self_transfer_chain(chain_length=DEFAULT_ANCESTOR_LIMIT)
688        ancestor_vsize = 0
689        ancestor_fees = Decimal(0)
690
691        for i, t in enumerate(chain):
692            ancestor_vsize += t["tx"].get_vsize()
693            ancestor_fees += t["fee"]
694            self.wallet.sendrawtransaction(from_node=self.nodes[0], tx_hex=t["hex"])
695            # Check that listunspent ancestor{count, size, fees} yield the correct results
696            wallet_unspent = watch_wallet.listunspent(minconf=0)
697            this_unspent = next(utxo_info for utxo_info in wallet_unspent if utxo_info["txid"] == t["txid"])
698            assert_equal(this_unspent['ancestorcount'], i + 1)
699            assert_equal(this_unspent['ancestorsize'], ancestor_vsize)
700            assert_equal(this_unspent['ancestorfees'], ancestor_fees * COIN)
701
702
703if __name__ == '__main__':
704    WalletTest(__file__).main()
705