Skip to content
Bitcoin Roots

v31.1-roots.1 · Commit 3: [PATCH 03/17] feat(policy): preserve cluster accounting and repair dynamic dust

test/functional/mempool_graph_policy.py

Before: /dev/null · After: test/functional/mempool_graph_policy.py

File metadata
new file mode 100755
index 0000000000000000000000000000000000000000..2ceeeaf485c311cab009a6ab3ab7c2de094024a4

Download original patch · Release notes

Diff rows 1–112 of 112. Line numbers refer to the original before/after files.

+ Added− RemovedUnmarked lines are context.

Scroll the code area horizontally to read long lines. Before is on the left; after is on the right. Unified view fits narrow screens more easily.

test/functional/mempool_graph_policy.py ADDED
@@ -0,0 +1,112 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ #!/usr/bin/env python3
2
+ # Copyright (c) 2026 The Bitcoin Roots developers
3
+ # Distributed under the MIT software license, see the accompanying
4
+ # file COPYING or http://www.opensource.org/licenses/mit-license.php.
5
+ """Native cluster policy controls, script claims and reorg exceptions."""
6
+
7
+ from decimal import Decimal
8
+
9
+ from test_framework.messages import CTxOut
10
+ from test_framework.test_framework import BitcoinTestFramework
11
+ from test_framework.util import assert_equal, assert_raises_rpc_error
12
+ from test_framework.wallet import MiniWallet
13
+
14
+
15
+ class GraphPolicyTest(BitcoinTestFramework):
16
+ def set_test_params(self):
17
+ self.num_nodes = 1
18
+ self.extra_args = [["-checkmempool=1"]]
19
+
20
+ def make_tx(self, wallet, destination, fee_rate=Decimal("0.001")):
21
+ result = wallet.create_self_transfer(fee_rate=fee_rate)
22
+ result["tx"].vout[0].scriptPubKey = destination.get_output_script()
23
+ wallet.sign_tx(result["tx"])
24
+ return result["tx"]
25
+
26
+ def run_test(self):
27
+ node = self.nodes[0]
28
+ funding = MiniWallet(node)
29
+ other = MiniWallet(node, tag_name="graph-other")
30
+ destination = MiniWallet(node, tag_name="graph-destination")
31
+ self.generate(other, 101)
32
+ funding.rescan_utxos()
33
+ other.rescan_utxos()
34
+
35
+ for mode in ["reject", "accept", "enforce"]:
36
+ for replacement_mode in ["0", "optin", "fee,-optin"]:
37
+ self.restart_node(0, extra_args=[f"-mempooltruc={mode}", f"-mempoolreplacement={replacement_mode}", "-checkmempool=1"])
38
+ tx = funding.create_self_transfer(version=3, sequence=0xffffffff)
39
+ if mode == "reject":
40
+ assert_equal(node.testmempoolaccept([tx["hex"]])[0]["reject-reason"], "version")
41
+ # Local version rejection cannot reject a valid block.
42
+ self.generateblock(node, output=funding.get_address(), transactions=[tx["hex"]])
43
+ block_hash = node.getbestblockhash()
44
+ node.invalidateblock(block_hash)
45
+ assert_equal(node.getrawmempool(), [])
46
+ node.reconsiderblock(block_hash)
47
+ else:
48
+ node.sendrawtransaction(tx["hex"])
49
+ # A direct non-signaling v3 conflict is replaceable in OptIn.
50
+ replacement = tx["tx"]
51
+ replacement.vout[0].nValue -= 10000
52
+ funding.sign_tx(replacement)
53
+ if replacement_mode == "0":
54
+ assert_raises_rpc_error(-26, "txn-mempool-conflict", node.sendrawtransaction, replacement.serialize().hex())
55
+ else:
56
+ node.sendrawtransaction(replacement.serialize().hex())
57
+ self.generate(funding, 1)
58
+ funding.rescan_utxos()
59
+
60
+ # Accept mode permits a non-TRUC parent; Enforce mode checks inheritance.
61
+ if mode != "reject":
62
+ parent = funding.create_self_transfer(version=2)
63
+ node.sendrawtransaction(parent["hex"])
64
+ child = funding.create_self_transfer(utxo_to_spend=parent["new_utxo"], version=3)
65
+ result = node.testmempoolaccept([child["hex"]])[0]
66
+ assert_equal(result["allowed"], mode == "accept")
67
+ if mode == "enforce":
68
+ assert_equal(result["reject-reason"], "TRUC-violation")
69
+ self.generate(funding, 1)
70
+ funding.rescan_utxos()
71
+
72
+ self.restart_node(0, extra_args=["-spkreuse=conflict", "-checkmempool=1"])
73
+ change = funding.create_self_transfer()
74
+ assert_equal(node.testmempoolaccept([change["hex"]])[0]["reject-reason"], "txn-spk-reused-change")
75
+ twin = self.make_tx(funding, destination)
76
+ twin.vout.append(CTxOut(1000, destination.get_output_script()))
77
+ twin.vout[0].nValue -= 1000
78
+ funding.sign_tx(twin)
79
+ assert_equal(node.testmempoolaccept([twin.serialize().hex()])[0]["reject-reason"], "txn-spk-reused-twinoutputs")
80
+
81
+ original = self.make_tx(funding, destination)
82
+ original_id = node.sendrawtransaction(original.serialize().hex())
83
+ # Same output script, independent input, fee-based policy replacement.
84
+ replacement = self.make_tx(other, destination, Decimal("0.01"))
85
+ replacement_id = node.sendrawtransaction(replacement.serialize().hex())
86
+ assert_equal(node.getrawmempool(), [replacement_id])
87
+ assert original_id != replacement_id
88
+ assert_raises_rpc_error(-26, "insufficient fee", node.sendrawtransaction, original.serialize().hex())
89
+ self.generate(funding, 1)
90
+
91
+ # Reorg admission retains local reuse checks. A consensus-valid block
92
+ # with conflicting output scripts is accepted; only the first original
93
+ # returns because the second cannot pay for policy replacement.
94
+ funding.rescan_utxos()
95
+ other.rescan_utxos()
96
+ first = self.make_tx(funding, destination)
97
+ second = self.make_tx(other, destination)
98
+ block = self.generateblock(node, output=funding.get_address(), transactions=[first.serialize().hex(), second.serialize().hex()])
99
+ node.invalidateblock(block["hash"])
100
+ assert_equal(node.getrawmempool(), [first.txid_hex])
101
+ other.rescan_utxos()
102
+ probe = self.make_tx(other, destination)
103
+ assert_equal(node.testmempoolaccept([probe.serialize().hex()])[0]["allowed"], False)
104
+ self.generateblock(node, output=funding.get_address(), transactions=[first.txid_hex])
105
+ assert_equal(node.testmempoolaccept([probe.serialize().hex()])[0]["allowed"], True)
106
+
107
+ self.restart_node(0, extra_args=["-spkreuse=allow", "-checkmempool=1"])
108
+ assert_equal(node.testmempoolaccept([twin.serialize().hex()])[0]["allowed"], True)
109
+
110
+
111
+ if __name__ == '__main__':
112
+ GraphPolicyTest(__file__).main()