Bitcoin Core  27.99.0
P2P Digital Currency
txpackage_tests.cpp
Go to the documentation of this file.
1 // Copyright (c) 2021-2022 The Bitcoin Core developers
2 // Distributed under the MIT software license, see the accompanying
3 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
4 
5 #include <consensus/validation.h>
6 #include <key_io.h>
7 #include <policy/packages.h>
8 #include <policy/policy.h>
9 #include <policy/rbf.h>
10 #include <primitives/transaction.h>
11 #include <script/script.h>
12 #include <serialize.h>
13 #include <streams.h>
14 #include <test/util/random.h>
15 #include <test/util/script.h>
16 #include <test/util/setup_common.h>
17 #include <util/strencodings.h>
18 #include <test/util/txmempool.h>
19 #include <validation.h>
20 
21 #include <boost/test/unit_test.hpp>
22 
23 BOOST_AUTO_TEST_SUITE(txpackage_tests)
24 // A fee amount that is above 1sat/vB but below 5sat/vB for most transactions created within these
25 // unit tests.
26 static const CAmount low_fee_amt{200};
27 
28 // Create placeholder transactions that have no meaning.
29 inline CTransactionRef create_placeholder_tx(size_t num_inputs, size_t num_outputs)
30 {
32  mtx.vin.resize(num_inputs);
33  mtx.vout.resize(num_outputs);
34  auto random_script = CScript() << ToByteVector(InsecureRand256()) << ToByteVector(InsecureRand256());
35  for (size_t i{0}; i < num_inputs; ++i) {
36  mtx.vin[i].prevout.hash = Txid::FromUint256(InsecureRand256());
37  mtx.vin[i].prevout.n = 0;
38  mtx.vin[i].scriptSig = random_script;
39  }
40  for (size_t o{0}; o < num_outputs; ++o) {
41  mtx.vout[o].nValue = 1 * CENT;
42  mtx.vout[o].scriptPubKey = random_script;
43  }
44  return MakeTransactionRef(mtx);
45 }
46 
47 // Create a Wtxid from a hex string
48 inline Wtxid WtxidFromString(std::string_view str)
49 {
50  return Wtxid::FromUint256(uint256S(str));
51 }
52 
54 {
55  // Random real segwit transaction
56  DataStream stream_1{
57  ParseHex("02000000000101964b8aa63509579ca6086e6012eeaa4c2f4dd1e283da29b67c8eea38b3c6fd220000000000fdffffff0294c618000000000017a9145afbbb42f4e83312666d0697f9e66259912ecde38768fa2c0000000000160014897388a0889390fd0e153a22bb2cf9d8f019faf50247304402200547406380719f84d68cf4e96cc3e4a1688309ef475b150be2b471c70ea562aa02206d255f5acc40fd95981874d77201d2eb07883657ce1c796513f32b6079545cdf0121023ae77335cefcb5ab4c1dc1fb0d2acfece184e593727d7d5906c78e564c7c11d125cf0c00"),
58  };
59  CTransaction tx_1(deserialize, TX_WITH_WITNESS, stream_1);
61 
62  // Random real nonsegwit transaction
63  DataStream stream_2{
64  ParseHex("01000000010b26e9b7735eb6aabdf358bab62f9816a21ba9ebdb719d5299e88607d722c190000000008b4830450220070aca44506c5cef3a16ed519d7c3c39f8aab192c4e1c90d065f37b8a4af6141022100a8e160b856c2d43d27d8fba71e5aef6405b8643ac4cb7cb3c462aced7f14711a0141046d11fee51b0e60666d5049a9101a72741df480b96ee26488a4d3466b95c9a40ac5eeef87e10a5cd336c19a84565f80fa6c547957b7700ff4dfbdefe76036c339ffffffff021bff3d11000000001976a91404943fdd508053c75000106d3bc6e2754dbcff1988ac2f15de00000000001976a914a266436d2965547608b9e15d9032a7b9d64fa43188ac00000000"),
65  };
66  CTransaction tx_2(deserialize, TX_WITH_WITNESS, stream_2);
68 
69  // Random real segwit transaction
70  DataStream stream_3{
71  ParseHex("0200000000010177862801f77c2c068a70372b4c435ef8dd621291c36a64eb4dd491f02218f5324600000000fdffffff014a0100000000000022512035ea312034cfac01e956a269f3bf147f569c2fbb00180677421262da042290d803402be713325ff285e66b0380f53f2fae0d0fb4e16f378a440fed51ce835061437566729d4883bc917632f3cff474d6384bc8b989961a1d730d4a87ed38ad28bd337b20f1d658c6c138b1c312e072b4446f50f01ae0da03a42e6274f8788aae53416a7fac0063036f7264010118746578742f706c61696e3b636861727365743d7574662d3800357b2270223a226272632d3230222c226f70223a226d696e74222c227469636b223a224342414c222c22616d74223a2236393639227d6821c1f1d658c6c138b1c312e072b4446f50f01ae0da03a42e6274f8788aae53416a7f00000000"),
72  };
73  CTransaction tx_3(deserialize, TX_WITH_WITNESS, stream_3);
75 
76  // It's easy to see that wtxids are sorted in lexicographical order:
77  Wtxid wtxid_1{WtxidFromString("0x85cd1a31eb38f74ed5742ec9cb546712ab5aaf747de28a9168b53e846cbda17f")};
78  Wtxid wtxid_2{WtxidFromString("0xb4749f017444b051c44dfd2720e88f314ff94f3dd6d56d40ef65854fcd7fff6b")};
79  Wtxid wtxid_3{WtxidFromString("0xe065bac15f62bb4e761d761db928ddee65a47296b2b776785abb912cdec474e3")};
80  BOOST_CHECK_EQUAL(tx_1.GetWitnessHash(), wtxid_1);
81  BOOST_CHECK_EQUAL(tx_2.GetWitnessHash(), wtxid_2);
82  BOOST_CHECK_EQUAL(tx_3.GetWitnessHash(), wtxid_3);
83 
84  BOOST_CHECK(wtxid_1.GetHex() < wtxid_2.GetHex());
85  BOOST_CHECK(wtxid_2.GetHex() < wtxid_3.GetHex());
86 
87  // The txids are not (we want to test that sorting and hashing use wtxid, not txid):
88  Txid txid_1{TxidFromString("0xbd0f71c1d5e50589063e134fad22053cdae5ab2320db5bf5e540198b0b5a4e69")};
89  Txid txid_2{TxidFromString("0xb4749f017444b051c44dfd2720e88f314ff94f3dd6d56d40ef65854fcd7fff6b")};
90  Txid txid_3{TxidFromString("0xee707be5201160e32c4fc715bec227d1aeea5940fb4295605e7373edce3b1a93")};
91  BOOST_CHECK_EQUAL(tx_1.GetHash(), txid_1);
92  BOOST_CHECK_EQUAL(tx_2.GetHash(), txid_2);
93  BOOST_CHECK_EQUAL(tx_3.GetHash(), txid_3);
94 
95  BOOST_CHECK(txid_2.GetHex() < txid_1.GetHex());
96 
97  BOOST_CHECK(txid_1.ToUint256() != wtxid_1.ToUint256());
98  BOOST_CHECK(txid_2.ToUint256() == wtxid_2.ToUint256());
99  BOOST_CHECK(txid_3.ToUint256() != wtxid_3.ToUint256());
100 
101  // We are testing that both functions compare using GetHex() and not uint256.
102  // (in this pair of wtxids, hex string order != uint256 order)
103  BOOST_CHECK(wtxid_2 < wtxid_1);
104  // (in this pair of wtxids, hex string order == uint256 order)
105  BOOST_CHECK(wtxid_2 < wtxid_3);
106 
107  // All permutations of the package containing ptx_1, ptx_2, ptx_3 have the same package hash
108  std::vector<CTransactionRef> package_123{ptx_1, ptx_2, ptx_3};
109  std::vector<CTransactionRef> package_132{ptx_1, ptx_3, ptx_2};
110  std::vector<CTransactionRef> package_231{ptx_2, ptx_3, ptx_1};
111  std::vector<CTransactionRef> package_213{ptx_2, ptx_1, ptx_3};
112  std::vector<CTransactionRef> package_312{ptx_3, ptx_1, ptx_2};
113  std::vector<CTransactionRef> package_321{ptx_3, ptx_2, ptx_1};
114 
115  uint256 calculated_hash_123 = (HashWriter() << wtxid_1 << wtxid_2 << wtxid_3).GetSHA256();
116 
117  uint256 hash_if_by_txid = (HashWriter() << wtxid_2 << wtxid_1 << wtxid_3).GetSHA256();
118  BOOST_CHECK(hash_if_by_txid != calculated_hash_123);
119 
120  uint256 hash_if_use_txid = (HashWriter() << txid_2 << txid_1 << txid_3).GetSHA256();
121  BOOST_CHECK(hash_if_use_txid != calculated_hash_123);
122 
123  uint256 hash_if_use_int_order = (HashWriter() << wtxid_2 << wtxid_1 << wtxid_3).GetSHA256();
124  BOOST_CHECK(hash_if_use_int_order != calculated_hash_123);
125 
126  BOOST_CHECK_EQUAL(calculated_hash_123, GetPackageHash(package_123));
127  BOOST_CHECK_EQUAL(calculated_hash_123, GetPackageHash(package_132));
128  BOOST_CHECK_EQUAL(calculated_hash_123, GetPackageHash(package_231));
129  BOOST_CHECK_EQUAL(calculated_hash_123, GetPackageHash(package_213));
130  BOOST_CHECK_EQUAL(calculated_hash_123, GetPackageHash(package_312));
131  BOOST_CHECK_EQUAL(calculated_hash_123, GetPackageHash(package_321));
132 }
133 
134 BOOST_FIXTURE_TEST_CASE(package_sanitization_tests, TestChain100Setup)
135 {
136  // Packages can't have more than 25 transactions.
137  Package package_too_many;
138  package_too_many.reserve(MAX_PACKAGE_COUNT + 1);
139  for (size_t i{0}; i < MAX_PACKAGE_COUNT + 1; ++i) {
140  package_too_many.emplace_back(create_placeholder_tx(1, 1));
141  }
142  PackageValidationState state_too_many;
143  BOOST_CHECK(!IsWellFormedPackage(package_too_many, state_too_many, /*require_sorted=*/true));
145  BOOST_CHECK_EQUAL(state_too_many.GetRejectReason(), "package-too-many-transactions");
146 
147  // Packages can't have a total weight of more than 404'000WU.
148  CTransactionRef large_ptx = create_placeholder_tx(150, 150);
149  Package package_too_large;
150  auto size_large = GetTransactionWeight(*large_ptx);
151  size_t total_weight{0};
152  while (total_weight <= MAX_PACKAGE_WEIGHT) {
153  package_too_large.push_back(large_ptx);
154  total_weight += size_large;
155  }
156  BOOST_CHECK(package_too_large.size() <= MAX_PACKAGE_COUNT);
157  PackageValidationState state_too_large;
158  BOOST_CHECK(!IsWellFormedPackage(package_too_large, state_too_large, /*require_sorted=*/true));
160  BOOST_CHECK_EQUAL(state_too_large.GetRejectReason(), "package-too-large");
161 
162  // Packages can't contain transactions with the same txid.
163  Package package_duplicate_txids_empty;
164  for (auto i{0}; i < 3; ++i) {
165  CMutableTransaction empty_tx;
166  package_duplicate_txids_empty.emplace_back(MakeTransactionRef(empty_tx));
167  }
168  PackageValidationState state_duplicates;
169  BOOST_CHECK(!IsWellFormedPackage(package_duplicate_txids_empty, state_duplicates, /*require_sorted=*/true));
171  BOOST_CHECK_EQUAL(state_duplicates.GetRejectReason(), "package-contains-duplicates");
172  BOOST_CHECK(!IsConsistentPackage(package_duplicate_txids_empty));
173 
174  // Packages can't have transactions spending the same prevout
175  CMutableTransaction tx_zero_1;
176  CMutableTransaction tx_zero_2;
177  COutPoint same_prevout{Txid::FromUint256(InsecureRand256()), 0};
178  tx_zero_1.vin.emplace_back(same_prevout);
179  tx_zero_2.vin.emplace_back(same_prevout);
180  // Different vouts (not the same tx)
181  tx_zero_1.vout.emplace_back(CENT, P2WSH_OP_TRUE);
182  tx_zero_2.vout.emplace_back(2 * CENT, P2WSH_OP_TRUE);
183  Package package_conflicts{MakeTransactionRef(tx_zero_1), MakeTransactionRef(tx_zero_2)};
184  BOOST_CHECK(!IsConsistentPackage(package_conflicts));
185  // Transactions are considered sorted when they have no dependencies.
186  BOOST_CHECK(IsTopoSortedPackage(package_conflicts));
187  PackageValidationState state_conflicts;
188  BOOST_CHECK(!IsWellFormedPackage(package_conflicts, state_conflicts, /*require_sorted=*/true));
190  BOOST_CHECK_EQUAL(state_conflicts.GetRejectReason(), "conflict-in-package");
191 
192  // IsConsistentPackage only cares about conflicts between transactions, not about a transaction
193  // conflicting with itself (i.e. duplicate prevouts in vin).
194  CMutableTransaction dup_tx;
195  const COutPoint rand_prevout{Txid::FromUint256(InsecureRand256()), 0};
196  dup_tx.vin.emplace_back(rand_prevout);
197  dup_tx.vin.emplace_back(rand_prevout);
198  Package package_with_dup_tx{MakeTransactionRef(dup_tx)};
199  BOOST_CHECK(IsConsistentPackage(package_with_dup_tx));
200  package_with_dup_tx.emplace_back(create_placeholder_tx(1, 1));
201  BOOST_CHECK(IsConsistentPackage(package_with_dup_tx));
202 }
203 
204 BOOST_FIXTURE_TEST_CASE(package_validation_tests, TestChain100Setup)
205 {
206  LOCK(cs_main);
207  unsigned int initialPoolSize = m_node.mempool->size();
208 
209  // Parent and Child Package
210  CKey parent_key = GenerateRandomKey();
211  CScript parent_locking_script = GetScriptForDestination(PKHash(parent_key.GetPubKey()));
212  auto mtx_parent = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[0], /*input_vout=*/0,
213  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
214  /*output_destination=*/parent_locking_script,
215  /*output_amount=*/CAmount(49 * COIN), /*submit=*/false);
216  CTransactionRef tx_parent = MakeTransactionRef(mtx_parent);
217 
218  CKey child_key = GenerateRandomKey();
219  CScript child_locking_script = GetScriptForDestination(PKHash(child_key.GetPubKey()));
220  auto mtx_child = CreateValidMempoolTransaction(/*input_transaction=*/tx_parent, /*input_vout=*/0,
221  /*input_height=*/101, /*input_signing_key=*/parent_key,
222  /*output_destination=*/child_locking_script,
223  /*output_amount=*/CAmount(48 * COIN), /*submit=*/false);
224  CTransactionRef tx_child = MakeTransactionRef(mtx_child);
225  Package package_parent_child{tx_parent, tx_child};
226  const auto result_parent_child = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package_parent_child, /*test_accept=*/true, /*client_maxfeerate=*/{});
227  if (auto err_parent_child{CheckPackageMempoolAcceptResult(package_parent_child, result_parent_child, /*expect_valid=*/true, nullptr)}) {
228  BOOST_ERROR(err_parent_child.value());
229  } else {
230  auto it_parent = result_parent_child.m_tx_results.find(tx_parent->GetWitnessHash());
231  auto it_child = result_parent_child.m_tx_results.find(tx_child->GetWitnessHash());
232 
233  BOOST_CHECK(it_parent->second.m_effective_feerate.value().GetFee(GetVirtualTransactionSize(*tx_parent)) == COIN);
234  BOOST_CHECK_EQUAL(it_parent->second.m_wtxids_fee_calculations.value().size(), 1);
235  BOOST_CHECK_EQUAL(it_parent->second.m_wtxids_fee_calculations.value().front(), tx_parent->GetWitnessHash());
236 
237  BOOST_CHECK(it_child->second.m_effective_feerate.value().GetFee(GetVirtualTransactionSize(*tx_child)) == COIN);
238  BOOST_CHECK_EQUAL(it_child->second.m_wtxids_fee_calculations.value().size(), 1);
239  BOOST_CHECK_EQUAL(it_child->second.m_wtxids_fee_calculations.value().front(), tx_child->GetWitnessHash());
240  }
241  // A single, giant transaction submitted through ProcessNewPackage fails on single tx policy.
242  CTransactionRef giant_ptx = create_placeholder_tx(999, 999);
244  Package package_single_giant{giant_ptx};
245  auto result_single_large = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package_single_giant, /*test_accept=*/true, /*client_maxfeerate=*/{});
246  if (auto err_single_large{CheckPackageMempoolAcceptResult(package_single_giant, result_single_large, /*expect_valid=*/false, nullptr)}) {
247  BOOST_ERROR(err_single_large.value());
248  } else {
249  BOOST_CHECK_EQUAL(result_single_large.m_state.GetResult(), PackageValidationResult::PCKG_TX);
250  BOOST_CHECK_EQUAL(result_single_large.m_state.GetRejectReason(), "transaction failed");
251  auto it_giant_tx = result_single_large.m_tx_results.find(giant_ptx->GetWitnessHash());
252  BOOST_CHECK_EQUAL(it_giant_tx->second.m_state.GetRejectReason(), "tx-size");
253  }
254 
255  // Check that mempool size hasn't changed.
256  BOOST_CHECK_EQUAL(m_node.mempool->size(), initialPoolSize);
257 }
258 
259 BOOST_FIXTURE_TEST_CASE(noncontextual_package_tests, TestChain100Setup)
260 {
261  // The signatures won't be verified so we can just use a placeholder
262  CKey placeholder_key = GenerateRandomKey();
263  CScript spk = GetScriptForDestination(PKHash(placeholder_key.GetPubKey()));
264  CKey placeholder_key_2 = GenerateRandomKey();
265  CScript spk2 = GetScriptForDestination(PKHash(placeholder_key_2.GetPubKey()));
266 
267  // Parent and Child Package
268  {
269  auto mtx_parent = CreateValidMempoolTransaction(m_coinbase_txns[0], 0, 0, coinbaseKey, spk,
270  CAmount(49 * COIN), /*submit=*/false);
271  CTransactionRef tx_parent = MakeTransactionRef(mtx_parent);
272 
273  auto mtx_child = CreateValidMempoolTransaction(tx_parent, 0, 101, placeholder_key, spk2,
274  CAmount(48 * COIN), /*submit=*/false);
275  CTransactionRef tx_child = MakeTransactionRef(mtx_child);
276 
278  BOOST_CHECK(IsWellFormedPackage({tx_parent, tx_child}, state, /*require_sorted=*/true));
279  BOOST_CHECK(!IsWellFormedPackage({tx_child, tx_parent}, state, /*require_sorted=*/true));
281  BOOST_CHECK_EQUAL(state.GetRejectReason(), "package-not-sorted");
282  BOOST_CHECK(IsChildWithParents({tx_parent, tx_child}));
283  BOOST_CHECK(IsChildWithParentsTree({tx_parent, tx_child}));
284  BOOST_CHECK(GetPackageHash({tx_parent}) != GetPackageHash({tx_child}));
285  BOOST_CHECK(GetPackageHash({tx_child, tx_child}) != GetPackageHash({tx_child}));
286  BOOST_CHECK(GetPackageHash({tx_child, tx_parent}) != GetPackageHash({tx_child, tx_child}));
287  }
288 
289  // 24 Parents and 1 Child
290  {
291  Package package;
292  CMutableTransaction child;
293  for (int i{0}; i < 24; ++i) {
294  auto parent = MakeTransactionRef(CreateValidMempoolTransaction(m_coinbase_txns[i + 1],
295  0, 0, coinbaseKey, spk, CAmount(48 * COIN), false));
296  package.emplace_back(parent);
297  child.vin.emplace_back(COutPoint(parent->GetHash(), 0));
298  }
299  child.vout.emplace_back(47 * COIN, spk2);
300 
301  // The child must be in the package.
302  BOOST_CHECK(!IsChildWithParents(package));
303 
304  // The parents can be in any order.
305  FastRandomContext rng;
306  std::shuffle(package.begin(), package.end(), rng);
307  package.push_back(MakeTransactionRef(child));
308 
310  BOOST_CHECK(IsWellFormedPackage(package, state, /*require_sorted=*/true));
313 
314  package.erase(package.begin());
316 
317  // The package cannot have unrelated transactions.
318  package.insert(package.begin(), m_coinbase_txns[0]);
319  BOOST_CHECK(!IsChildWithParents(package));
320  }
321 
322  // 2 Parents and 1 Child where one parent depends on the other.
323  {
324  CMutableTransaction mtx_parent;
325  mtx_parent.vin.emplace_back(COutPoint(m_coinbase_txns[0]->GetHash(), 0));
326  mtx_parent.vout.emplace_back(20 * COIN, spk);
327  mtx_parent.vout.emplace_back(20 * COIN, spk2);
328  CTransactionRef tx_parent = MakeTransactionRef(mtx_parent);
329 
330  CMutableTransaction mtx_parent_also_child;
331  mtx_parent_also_child.vin.emplace_back(COutPoint(tx_parent->GetHash(), 0));
332  mtx_parent_also_child.vout.emplace_back(20 * COIN, spk);
333  CTransactionRef tx_parent_also_child = MakeTransactionRef(mtx_parent_also_child);
334 
335  CMutableTransaction mtx_child;
336  mtx_child.vin.emplace_back(COutPoint(tx_parent->GetHash(), 1));
337  mtx_child.vin.emplace_back(COutPoint(tx_parent_also_child->GetHash(), 0));
338  mtx_child.vout.emplace_back(39 * COIN, spk);
339  CTransactionRef tx_child = MakeTransactionRef(mtx_child);
340 
342  BOOST_CHECK(IsChildWithParents({tx_parent, tx_parent_also_child}));
343  BOOST_CHECK(IsChildWithParents({tx_parent, tx_child}));
344  BOOST_CHECK(IsChildWithParents({tx_parent, tx_parent_also_child, tx_child}));
345  BOOST_CHECK(!IsChildWithParentsTree({tx_parent, tx_parent_also_child, tx_child}));
346  // IsChildWithParents does not detect unsorted parents.
347  BOOST_CHECK(IsChildWithParents({tx_parent_also_child, tx_parent, tx_child}));
348  BOOST_CHECK(IsWellFormedPackage({tx_parent, tx_parent_also_child, tx_child}, state, /*require_sorted=*/true));
349  BOOST_CHECK(!IsWellFormedPackage({tx_parent_also_child, tx_parent, tx_child}, state, /*require_sorted=*/true));
351  BOOST_CHECK_EQUAL(state.GetRejectReason(), "package-not-sorted");
352  }
353 }
354 
355 BOOST_FIXTURE_TEST_CASE(package_submission_tests, TestChain100Setup)
356 {
357  LOCK(cs_main);
358  unsigned int expected_pool_size = m_node.mempool->size();
359  CKey parent_key = GenerateRandomKey();
360  CScript parent_locking_script = GetScriptForDestination(PKHash(parent_key.GetPubKey()));
361 
362  // Unrelated transactions are not allowed in package submission.
363  Package package_unrelated;
364  for (size_t i{0}; i < 10; ++i) {
365  auto mtx = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[i + 25], /*input_vout=*/0,
366  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
367  /*output_destination=*/parent_locking_script,
368  /*output_amount=*/CAmount(49 * COIN), /*submit=*/false);
369  package_unrelated.emplace_back(MakeTransactionRef(mtx));
370  }
371  auto result_unrelated_submit = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
372  package_unrelated, /*test_accept=*/false, /*client_maxfeerate=*/{});
373  // We don't expect m_tx_results for each transaction when basic sanity checks haven't passed.
374  BOOST_CHECK(result_unrelated_submit.m_state.IsInvalid());
375  BOOST_CHECK_EQUAL(result_unrelated_submit.m_state.GetResult(), PackageValidationResult::PCKG_POLICY);
376  BOOST_CHECK_EQUAL(result_unrelated_submit.m_state.GetRejectReason(), "package-not-child-with-parents");
377  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
378 
379  // Parent and Child (and Grandchild) Package
380  Package package_parent_child;
381  Package package_3gen;
382  auto mtx_parent = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[0], /*input_vout=*/0,
383  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
384  /*output_destination=*/parent_locking_script,
385  /*output_amount=*/CAmount(49 * COIN), /*submit=*/false);
386  CTransactionRef tx_parent = MakeTransactionRef(mtx_parent);
387  package_parent_child.push_back(tx_parent);
388  package_3gen.push_back(tx_parent);
389 
390  CKey child_key = GenerateRandomKey();
391  CScript child_locking_script = GetScriptForDestination(PKHash(child_key.GetPubKey()));
392  auto mtx_child = CreateValidMempoolTransaction(/*input_transaction=*/tx_parent, /*input_vout=*/0,
393  /*input_height=*/101, /*input_signing_key=*/parent_key,
394  /*output_destination=*/child_locking_script,
395  /*output_amount=*/CAmount(48 * COIN), /*submit=*/false);
396  CTransactionRef tx_child = MakeTransactionRef(mtx_child);
397  package_parent_child.push_back(tx_child);
398  package_3gen.push_back(tx_child);
399 
400  CKey grandchild_key = GenerateRandomKey();
401  CScript grandchild_locking_script = GetScriptForDestination(PKHash(grandchild_key.GetPubKey()));
402  auto mtx_grandchild = CreateValidMempoolTransaction(/*input_transaction=*/tx_child, /*input_vout=*/0,
403  /*input_height=*/101, /*input_signing_key=*/child_key,
404  /*output_destination=*/grandchild_locking_script,
405  /*output_amount=*/CAmount(47 * COIN), /*submit=*/false);
406  CTransactionRef tx_grandchild = MakeTransactionRef(mtx_grandchild);
407  package_3gen.push_back(tx_grandchild);
408 
409  // 3 Generations is not allowed.
410  {
411  auto result_3gen_submit = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
412  package_3gen, /*test_accept=*/false, /*client_maxfeerate=*/{});
413  BOOST_CHECK(result_3gen_submit.m_state.IsInvalid());
414  BOOST_CHECK_EQUAL(result_3gen_submit.m_state.GetResult(), PackageValidationResult::PCKG_POLICY);
415  BOOST_CHECK_EQUAL(result_3gen_submit.m_state.GetRejectReason(), "package-not-child-with-parents");
416  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
417  }
418 
419  // Parent and child package where transactions are invalid for reasons other than fee and
420  // missing inputs, so the package validation isn't expected to happen.
421  {
422  CScriptWitness bad_witness;
423  bad_witness.stack.emplace_back(1);
424  CMutableTransaction mtx_parent_invalid{mtx_parent};
425  mtx_parent_invalid.vin[0].scriptWitness = bad_witness;
426  CTransactionRef tx_parent_invalid = MakeTransactionRef(mtx_parent_invalid);
427  Package package_invalid_parent{tx_parent_invalid, tx_child};
428  auto result_quit_early = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
429  package_invalid_parent, /*test_accept=*/ false, /*client_maxfeerate=*/{});
430  if (auto err_parent_invalid{CheckPackageMempoolAcceptResult(package_invalid_parent, result_quit_early, /*expect_valid=*/false, m_node.mempool.get())}) {
431  BOOST_ERROR(err_parent_invalid.value());
432  } else {
433  auto it_parent = result_quit_early.m_tx_results.find(tx_parent_invalid->GetWitnessHash());
434  auto it_child = result_quit_early.m_tx_results.find(tx_child->GetWitnessHash());
435  BOOST_CHECK_EQUAL(it_parent->second.m_state.GetResult(), TxValidationResult::TX_WITNESS_MUTATED);
436  BOOST_CHECK_EQUAL(it_parent->second.m_state.GetRejectReason(), "bad-witness-nonstandard");
437  BOOST_CHECK_EQUAL(it_child->second.m_state.GetResult(), TxValidationResult::TX_MISSING_INPUTS);
438  BOOST_CHECK_EQUAL(it_child->second.m_state.GetRejectReason(), "bad-txns-inputs-missingorspent");
439  }
440  BOOST_CHECK_EQUAL(result_quit_early.m_state.GetResult(), PackageValidationResult::PCKG_TX);
441  }
442 
443  // Child with missing parent.
444  mtx_child.vin.emplace_back(COutPoint(package_unrelated[0]->GetHash(), 0));
445  Package package_missing_parent;
446  package_missing_parent.push_back(tx_parent);
447  package_missing_parent.push_back(MakeTransactionRef(mtx_child));
448  {
449  const auto result_missing_parent = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
450  package_missing_parent, /*test_accept=*/false, /*client_maxfeerate=*/{});
451  BOOST_CHECK(result_missing_parent.m_state.IsInvalid());
452  BOOST_CHECK_EQUAL(result_missing_parent.m_state.GetResult(), PackageValidationResult::PCKG_POLICY);
453  BOOST_CHECK_EQUAL(result_missing_parent.m_state.GetRejectReason(), "package-not-child-with-unconfirmed-parents");
454  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
455  }
456 
457  // Submit package with parent + child.
458  {
459  const auto submit_parent_child = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
460  package_parent_child, /*test_accept=*/false, /*client_maxfeerate=*/{});
461  expected_pool_size += 2;
462  BOOST_CHECK_MESSAGE(submit_parent_child.m_state.IsValid(),
463  "Package validation unexpectedly failed: " << submit_parent_child.m_state.GetRejectReason());
464  BOOST_CHECK_EQUAL(submit_parent_child.m_tx_results.size(), package_parent_child.size());
465  auto it_parent = submit_parent_child.m_tx_results.find(tx_parent->GetWitnessHash());
466  auto it_child = submit_parent_child.m_tx_results.find(tx_child->GetWitnessHash());
467  BOOST_CHECK(it_parent != submit_parent_child.m_tx_results.end());
468  BOOST_CHECK(it_parent->second.m_state.IsValid());
469  BOOST_CHECK(it_parent->second.m_effective_feerate == CFeeRate(1 * COIN, GetVirtualTransactionSize(*tx_parent)));
470  BOOST_CHECK_EQUAL(it_parent->second.m_wtxids_fee_calculations.value().size(), 1);
471  BOOST_CHECK_EQUAL(it_parent->second.m_wtxids_fee_calculations.value().front(), tx_parent->GetWitnessHash());
472  BOOST_CHECK(it_child->second.m_effective_feerate == CFeeRate(1 * COIN, GetVirtualTransactionSize(*tx_child)));
473  BOOST_CHECK_EQUAL(it_child->second.m_wtxids_fee_calculations.value().size(), 1);
474  BOOST_CHECK_EQUAL(it_child->second.m_wtxids_fee_calculations.value().front(), tx_child->GetWitnessHash());
475 
476  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
477  }
478 
479  // Already-in-mempool transactions should be detected and de-duplicated.
480  {
481  const auto submit_deduped = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
482  package_parent_child, /*test_accept=*/false, /*client_maxfeerate=*/{});
483  if (auto err_deduped{CheckPackageMempoolAcceptResult(package_parent_child, submit_deduped, /*expect_valid=*/true, m_node.mempool.get())}) {
484  BOOST_ERROR(err_deduped.value());
485  } else {
486  auto it_parent_deduped = submit_deduped.m_tx_results.find(tx_parent->GetWitnessHash());
487  auto it_child_deduped = submit_deduped.m_tx_results.find(tx_child->GetWitnessHash());
488  BOOST_CHECK(it_parent_deduped->second.m_result_type == MempoolAcceptResult::ResultType::MEMPOOL_ENTRY);
489  BOOST_CHECK(it_child_deduped->second.m_result_type == MempoolAcceptResult::ResultType::MEMPOOL_ENTRY);
490  }
491 
492  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
493  }
494 }
495 
496 // Tests for packages containing transactions that have same-txid-different-witness equivalents in
497 // the mempool.
498 BOOST_FIXTURE_TEST_CASE(package_witness_swap_tests, TestChain100Setup)
499 {
500  // Mine blocks to mature coinbases.
501  mineBlocks(5);
502  MockMempoolMinFee(CFeeRate(5000));
503  LOCK(cs_main);
504 
505  // Transactions with a same-txid-different-witness transaction in the mempool should be ignored,
506  // and the mempool entry's wtxid returned.
507  CScript witnessScript = CScript() << OP_DROP << OP_TRUE;
508  CScript scriptPubKey = GetScriptForDestination(WitnessV0ScriptHash(witnessScript));
509  auto mtx_parent = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[0], /*input_vout=*/0,
510  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
511  /*output_destination=*/scriptPubKey,
512  /*output_amount=*/CAmount(49 * COIN), /*submit=*/false);
513  CTransactionRef ptx_parent = MakeTransactionRef(mtx_parent);
514 
515  // Make two children with the same txid but different witnesses.
516  CScriptWitness witness1;
517  witness1.stack.emplace_back(1);
518  witness1.stack.emplace_back(witnessScript.begin(), witnessScript.end());
519 
520  CScriptWitness witness2(witness1);
521  witness2.stack.emplace_back(2);
522  witness2.stack.emplace_back(witnessScript.begin(), witnessScript.end());
523 
524  CKey child_key = GenerateRandomKey();
525  CScript child_locking_script = GetScriptForDestination(WitnessV0KeyHash(child_key.GetPubKey()));
526  CMutableTransaction mtx_child1;
527  mtx_child1.version = 1;
528  mtx_child1.vin.resize(1);
529  mtx_child1.vin[0].prevout.hash = ptx_parent->GetHash();
530  mtx_child1.vin[0].prevout.n = 0;
531  mtx_child1.vin[0].scriptSig = CScript();
532  mtx_child1.vin[0].scriptWitness = witness1;
533  mtx_child1.vout.resize(1);
534  mtx_child1.vout[0].nValue = CAmount(48 * COIN);
535  mtx_child1.vout[0].scriptPubKey = child_locking_script;
536 
537  CMutableTransaction mtx_child2{mtx_child1};
538  mtx_child2.vin[0].scriptWitness = witness2;
539 
540  CTransactionRef ptx_child1 = MakeTransactionRef(mtx_child1);
541  CTransactionRef ptx_child2 = MakeTransactionRef(mtx_child2);
542 
543  // child1 and child2 have the same txid
544  BOOST_CHECK_EQUAL(ptx_child1->GetHash(), ptx_child2->GetHash());
545  // child1 and child2 have different wtxids
546  BOOST_CHECK(ptx_child1->GetWitnessHash() != ptx_child2->GetWitnessHash());
547  // Check that they have different package hashes
548  BOOST_CHECK(GetPackageHash({ptx_parent, ptx_child1}) != GetPackageHash({ptx_parent, ptx_child2}));
549 
550  // Try submitting Package1{parent, child1} and Package2{parent, child2} where the children are
551  // same-txid-different-witness.
552  {
553  Package package_parent_child1{ptx_parent, ptx_child1};
554  const auto submit_witness1 = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
555  package_parent_child1, /*test_accept=*/false, /*client_maxfeerate=*/{});
556  if (auto err_witness1{CheckPackageMempoolAcceptResult(package_parent_child1, submit_witness1, /*expect_valid=*/true, m_node.mempool.get())}) {
557  BOOST_ERROR(err_witness1.value());
558  }
559 
560  // Child2 would have been validated individually.
561  Package package_parent_child2{ptx_parent, ptx_child2};
562  const auto submit_witness2 = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
563  package_parent_child2, /*test_accept=*/false, /*client_maxfeerate=*/{});
564  if (auto err_witness2{CheckPackageMempoolAcceptResult(package_parent_child2, submit_witness2, /*expect_valid=*/true, m_node.mempool.get())}) {
565  BOOST_ERROR(err_witness2.value());
566  } else {
567  auto it_parent2_deduped = submit_witness2.m_tx_results.find(ptx_parent->GetWitnessHash());
568  auto it_child2 = submit_witness2.m_tx_results.find(ptx_child2->GetWitnessHash());
569  BOOST_CHECK(it_parent2_deduped->second.m_result_type == MempoolAcceptResult::ResultType::MEMPOOL_ENTRY);
570  BOOST_CHECK(it_child2->second.m_result_type == MempoolAcceptResult::ResultType::DIFFERENT_WITNESS);
571  BOOST_CHECK_EQUAL(ptx_child1->GetWitnessHash(), it_child2->second.m_other_wtxid.value());
572  }
573 
574  // Deduplication should work when wtxid != txid. Submit package with the already-in-mempool
575  // transactions again, which should not fail.
576  const auto submit_segwit_dedup = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
577  package_parent_child1, /*test_accept=*/false, /*client_maxfeerate=*/{});
578  if (auto err_segwit_dedup{CheckPackageMempoolAcceptResult(package_parent_child1, submit_segwit_dedup, /*expect_valid=*/true, m_node.mempool.get())}) {
579  BOOST_ERROR(err_segwit_dedup.value());
580  } else {
581  auto it_parent_dup = submit_segwit_dedup.m_tx_results.find(ptx_parent->GetWitnessHash());
582  auto it_child_dup = submit_segwit_dedup.m_tx_results.find(ptx_child1->GetWitnessHash());
583  BOOST_CHECK(it_parent_dup->second.m_result_type == MempoolAcceptResult::ResultType::MEMPOOL_ENTRY);
584  BOOST_CHECK(it_child_dup->second.m_result_type == MempoolAcceptResult::ResultType::MEMPOOL_ENTRY);
585  }
586  }
587 
588  // Try submitting Package1{child2, grandchild} where child2 is same-txid-different-witness as
589  // the in-mempool transaction, child1. Since child1 exists in the mempool and its outputs are
590  // available, child2 should be ignored and grandchild should be accepted.
591  //
592  // This tests a potential censorship vector in which an attacker broadcasts a competing package
593  // where a parent's witness is mutated. The honest package should be accepted despite the fact
594  // that we don't allow witness replacement.
595  CKey grandchild_key = GenerateRandomKey();
596  CScript grandchild_locking_script = GetScriptForDestination(WitnessV0KeyHash(grandchild_key.GetPubKey()));
597  auto mtx_grandchild = CreateValidMempoolTransaction(/*input_transaction=*/ptx_child2, /*input_vout=*/0,
598  /*input_height=*/0, /*input_signing_key=*/child_key,
599  /*output_destination=*/grandchild_locking_script,
600  /*output_amount=*/CAmount(47 * COIN), /*submit=*/false);
601  CTransactionRef ptx_grandchild = MakeTransactionRef(mtx_grandchild);
602  // Check that they have different package hashes
603  BOOST_CHECK(GetPackageHash({ptx_child1, ptx_grandchild}) != GetPackageHash({ptx_child2, ptx_grandchild}));
604  // We already submitted child1 above.
605  {
606  Package package_child2_grandchild{ptx_child2, ptx_grandchild};
607  const auto submit_spend_ignored = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
608  package_child2_grandchild, /*test_accept=*/false, /*client_maxfeerate=*/{});
609  if (auto err_spend_ignored{CheckPackageMempoolAcceptResult(package_child2_grandchild, submit_spend_ignored, /*expect_valid=*/true, m_node.mempool.get())}) {
610  BOOST_ERROR(err_spend_ignored.value());
611  } else {
612  auto it_child2_ignored = submit_spend_ignored.m_tx_results.find(ptx_child2->GetWitnessHash());
613  auto it_grandchild = submit_spend_ignored.m_tx_results.find(ptx_grandchild->GetWitnessHash());
614  BOOST_CHECK(it_child2_ignored->second.m_result_type == MempoolAcceptResult::ResultType::DIFFERENT_WITNESS);
615  BOOST_CHECK(it_grandchild->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
616  }
617  }
618 
619  // A package Package{parent1, parent2, parent3, child} where the parents are a mixture of
620  // identical-tx-in-mempool, same-txid-different-witness-in-mempool, and new transactions.
621  Package package_mixed;
622 
623  // Give all the parents anyone-can-spend scripts so we don't have to deal with signing the child.
624  CScript acs_script = CScript() << OP_TRUE;
625  CScript acs_spk = GetScriptForDestination(WitnessV0ScriptHash(acs_script));
626  CScriptWitness acs_witness;
627  acs_witness.stack.emplace_back(acs_script.begin(), acs_script.end());
628 
629  // parent1 will already be in the mempool
630  auto mtx_parent1 = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[1], /*input_vout=*/0,
631  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
632  /*output_destination=*/acs_spk,
633  /*output_amount=*/CAmount(49 * COIN), /*submit=*/true);
634  CTransactionRef ptx_parent1 = MakeTransactionRef(mtx_parent1);
635  package_mixed.push_back(ptx_parent1);
636 
637  // parent2 will have a same-txid-different-witness tx already in the mempool
638  CScript grandparent2_script = CScript() << OP_DROP << OP_TRUE;
639  CScript grandparent2_spk = GetScriptForDestination(WitnessV0ScriptHash(grandparent2_script));
640  CScriptWitness parent2_witness1;
641  parent2_witness1.stack.emplace_back(1);
642  parent2_witness1.stack.emplace_back(grandparent2_script.begin(), grandparent2_script.end());
643  CScriptWitness parent2_witness2;
644  parent2_witness2.stack.emplace_back(2);
645  parent2_witness2.stack.emplace_back(grandparent2_script.begin(), grandparent2_script.end());
646 
647  // Create grandparent2 creating an output with multiple spending paths. Submit to mempool.
648  auto mtx_grandparent2 = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[2], /*input_vout=*/0,
649  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
650  /*output_destination=*/grandparent2_spk,
651  /*output_amount=*/CAmount(49 * COIN), /*submit=*/true);
652  CTransactionRef ptx_grandparent2 = MakeTransactionRef(mtx_grandparent2);
653 
654  CMutableTransaction mtx_parent2_v1;
655  mtx_parent2_v1.version = 1;
656  mtx_parent2_v1.vin.resize(1);
657  mtx_parent2_v1.vin[0].prevout.hash = ptx_grandparent2->GetHash();
658  mtx_parent2_v1.vin[0].prevout.n = 0;
659  mtx_parent2_v1.vin[0].scriptSig = CScript();
660  mtx_parent2_v1.vin[0].scriptWitness = parent2_witness1;
661  mtx_parent2_v1.vout.resize(1);
662  mtx_parent2_v1.vout[0].nValue = CAmount(48 * COIN);
663  mtx_parent2_v1.vout[0].scriptPubKey = acs_spk;
664 
665  CMutableTransaction mtx_parent2_v2{mtx_parent2_v1};
666  mtx_parent2_v2.vin[0].scriptWitness = parent2_witness2;
667 
668  CTransactionRef ptx_parent2_v1 = MakeTransactionRef(mtx_parent2_v1);
669  CTransactionRef ptx_parent2_v2 = MakeTransactionRef(mtx_parent2_v2);
670  // Put parent2_v1 in the package, submit parent2_v2 to the mempool.
671  const MempoolAcceptResult parent2_v2_result = m_node.chainman->ProcessTransaction(ptx_parent2_v2);
673  package_mixed.push_back(ptx_parent2_v1);
674 
675  // parent3 will be a new transaction. Put a low feerate to make it invalid on its own.
676  auto mtx_parent3 = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[3], /*input_vout=*/0,
677  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
678  /*output_destination=*/acs_spk,
679  /*output_amount=*/CAmount(50 * COIN - low_fee_amt), /*submit=*/false);
680  CTransactionRef ptx_parent3 = MakeTransactionRef(mtx_parent3);
681  package_mixed.push_back(ptx_parent3);
682  BOOST_CHECK(m_node.mempool->GetMinFee().GetFee(GetVirtualTransactionSize(*ptx_parent3)) > low_fee_amt);
683  BOOST_CHECK(m_node.mempool->m_opts.min_relay_feerate.GetFee(GetVirtualTransactionSize(*ptx_parent3)) <= low_fee_amt);
684 
685  // child spends parent1, parent2, and parent3
686  CKey mixed_grandchild_key = GenerateRandomKey();
687  CScript mixed_child_spk = GetScriptForDestination(WitnessV0KeyHash(mixed_grandchild_key.GetPubKey()));
688 
689  CMutableTransaction mtx_mixed_child;
690  mtx_mixed_child.vin.emplace_back(COutPoint(ptx_parent1->GetHash(), 0));
691  mtx_mixed_child.vin.emplace_back(COutPoint(ptx_parent2_v1->GetHash(), 0));
692  mtx_mixed_child.vin.emplace_back(COutPoint(ptx_parent3->GetHash(), 0));
693  mtx_mixed_child.vin[0].scriptWitness = acs_witness;
694  mtx_mixed_child.vin[1].scriptWitness = acs_witness;
695  mtx_mixed_child.vin[2].scriptWitness = acs_witness;
696  mtx_mixed_child.vout.emplace_back((48 + 49 + 50 - 1) * COIN, mixed_child_spk);
697  CTransactionRef ptx_mixed_child = MakeTransactionRef(mtx_mixed_child);
698  package_mixed.push_back(ptx_mixed_child);
699 
700  // Submit package:
701  // parent1 should be ignored
702  // parent2_v1 should be ignored (and v2 wtxid returned)
703  // parent3 should be accepted
704  // child should be accepted
705  {
706  const auto mixed_result = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package_mixed, false, /*client_maxfeerate=*/{});
707  if (auto err_mixed{CheckPackageMempoolAcceptResult(package_mixed, mixed_result, /*expect_valid=*/true, m_node.mempool.get())}) {
708  BOOST_ERROR(err_mixed.value());
709  } else {
710  auto it_parent1 = mixed_result.m_tx_results.find(ptx_parent1->GetWitnessHash());
711  auto it_parent2 = mixed_result.m_tx_results.find(ptx_parent2_v1->GetWitnessHash());
712  auto it_parent3 = mixed_result.m_tx_results.find(ptx_parent3->GetWitnessHash());
713  auto it_child = mixed_result.m_tx_results.find(ptx_mixed_child->GetWitnessHash());
714 
715  BOOST_CHECK(it_parent1->second.m_result_type == MempoolAcceptResult::ResultType::MEMPOOL_ENTRY);
716  BOOST_CHECK(it_parent2->second.m_result_type == MempoolAcceptResult::ResultType::DIFFERENT_WITNESS);
717  BOOST_CHECK(it_parent3->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
718  BOOST_CHECK(it_child->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
719  BOOST_CHECK_EQUAL(ptx_parent2_v2->GetWitnessHash(), it_parent2->second.m_other_wtxid.value());
720 
721  // package feerate should include parent3 and child. It should not include parent1 or parent2_v1.
722  const CFeeRate expected_feerate(1 * COIN, GetVirtualTransactionSize(*ptx_parent3) + GetVirtualTransactionSize(*ptx_mixed_child));
723  BOOST_CHECK(it_parent3->second.m_effective_feerate.value() == expected_feerate);
724  BOOST_CHECK(it_child->second.m_effective_feerate.value() == expected_feerate);
725  std::vector<Wtxid> expected_wtxids({ptx_parent3->GetWitnessHash(), ptx_mixed_child->GetWitnessHash()});
726  BOOST_CHECK(it_parent3->second.m_wtxids_fee_calculations.value() == expected_wtxids);
727  BOOST_CHECK(it_child->second.m_wtxids_fee_calculations.value() == expected_wtxids);
728  }
729  }
730 }
731 
733 {
734  mineBlocks(5);
735  MockMempoolMinFee(CFeeRate(5000));
736  LOCK(::cs_main);
737  size_t expected_pool_size = m_node.mempool->size();
738  CKey child_key = GenerateRandomKey();
739  CScript parent_spk = GetScriptForDestination(WitnessV0KeyHash(child_key.GetPubKey()));
740  CKey grandchild_key = GenerateRandomKey();
741  CScript child_spk = GetScriptForDestination(WitnessV0KeyHash(grandchild_key.GetPubKey()));
742 
743  // low-fee parent and high-fee child package
744  const CAmount coinbase_value{50 * COIN};
745  const CAmount parent_value{coinbase_value - low_fee_amt};
746  const CAmount child_value{parent_value - COIN};
747 
748  Package package_cpfp;
749  auto mtx_parent = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[0], /*input_vout=*/0,
750  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
751  /*output_destination=*/parent_spk,
752  /*output_amount=*/parent_value, /*submit=*/false);
753  CTransactionRef tx_parent = MakeTransactionRef(mtx_parent);
754  package_cpfp.push_back(tx_parent);
755 
756  auto mtx_child = CreateValidMempoolTransaction(/*input_transaction=*/tx_parent, /*input_vout=*/0,
757  /*input_height=*/101, /*input_signing_key=*/child_key,
758  /*output_destination=*/child_spk,
759  /*output_amount=*/child_value, /*submit=*/false);
760  CTransactionRef tx_child = MakeTransactionRef(mtx_child);
761  package_cpfp.push_back(tx_child);
762 
763  // Package feerate is calculated using modified fees, and prioritisetransaction accepts negative
764  // fee deltas. This should be taken into account. De-prioritise the parent transaction
765  // to bring the package feerate to 0.
766  m_node.mempool->PrioritiseTransaction(tx_parent->GetHash(), child_value - coinbase_value);
767  {
768  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
769  const auto submit_cpfp_deprio = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
770  package_cpfp, /*test_accept=*/ false, /*client_maxfeerate=*/{});
771  if (auto err_cpfp_deprio{CheckPackageMempoolAcceptResult(package_cpfp, submit_cpfp_deprio, /*expect_valid=*/false, m_node.mempool.get())}) {
772  BOOST_ERROR(err_cpfp_deprio.value());
773  } else {
774  BOOST_CHECK_EQUAL(submit_cpfp_deprio.m_state.GetResult(), PackageValidationResult::PCKG_TX);
775  BOOST_CHECK_EQUAL(submit_cpfp_deprio.m_tx_results.find(tx_parent->GetWitnessHash())->second.m_state.GetResult(),
777  BOOST_CHECK_EQUAL(submit_cpfp_deprio.m_tx_results.find(tx_child->GetWitnessHash())->second.m_state.GetResult(),
779  BOOST_CHECK(submit_cpfp_deprio.m_tx_results.find(tx_parent->GetWitnessHash())->second.m_state.GetRejectReason() == "min relay fee not met");
780  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
781  }
782  }
783 
784  // Clear the prioritisation of the parent transaction.
785  WITH_LOCK(m_node.mempool->cs, m_node.mempool->ClearPrioritisation(tx_parent->GetHash()));
786 
787  // Package CPFP: Even though the parent's feerate is below the mempool minimum feerate, the
788  // child pays enough for the package feerate to meet the threshold.
789  {
790  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
791  const auto submit_cpfp = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
792  package_cpfp, /*test_accept=*/ false, /*client_maxfeerate=*/{});
793  if (auto err_cpfp{CheckPackageMempoolAcceptResult(package_cpfp, submit_cpfp, /*expect_valid=*/true, m_node.mempool.get())}) {
794  BOOST_ERROR(err_cpfp.value());
795  } else {
796  auto it_parent = submit_cpfp.m_tx_results.find(tx_parent->GetWitnessHash());
797  auto it_child = submit_cpfp.m_tx_results.find(tx_child->GetWitnessHash());
798  BOOST_CHECK(it_parent->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
799  BOOST_CHECK(it_parent->second.m_base_fees.value() == coinbase_value - parent_value);
800  BOOST_CHECK(it_child->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
801  BOOST_CHECK(it_child->second.m_base_fees.value() == COIN);
802 
803  const CFeeRate expected_feerate(coinbase_value - child_value,
804  GetVirtualTransactionSize(*tx_parent) + GetVirtualTransactionSize(*tx_child));
805  BOOST_CHECK(it_parent->second.m_effective_feerate.value() == expected_feerate);
806  BOOST_CHECK(it_child->second.m_effective_feerate.value() == expected_feerate);
807  std::vector<Wtxid> expected_wtxids({tx_parent->GetWitnessHash(), tx_child->GetWitnessHash()});
808  BOOST_CHECK(it_parent->second.m_wtxids_fee_calculations.value() == expected_wtxids);
809  BOOST_CHECK(it_child->second.m_wtxids_fee_calculations.value() == expected_wtxids);
810  BOOST_CHECK(expected_feerate.GetFeePerK() > 1000);
811  }
812  expected_pool_size += 2;
813  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
814  }
815 
816  // Just because we allow low-fee parents doesn't mean we allow low-feerate packages.
817  // The mempool minimum feerate is 5sat/vB, but this package just pays 800 satoshis total.
818  // The child fees would be able to pay for itself, but isn't enough for the entire package.
819  Package package_still_too_low;
820  const CAmount parent_fee{200};
821  const CAmount child_fee{600};
822  auto mtx_parent_cheap = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[1], /*input_vout=*/0,
823  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
824  /*output_destination=*/parent_spk,
825  /*output_amount=*/coinbase_value - parent_fee, /*submit=*/false);
826  CTransactionRef tx_parent_cheap = MakeTransactionRef(mtx_parent_cheap);
827  package_still_too_low.push_back(tx_parent_cheap);
828  BOOST_CHECK(m_node.mempool->GetMinFee().GetFee(GetVirtualTransactionSize(*tx_parent_cheap)) > parent_fee);
829  BOOST_CHECK(m_node.mempool->m_opts.min_relay_feerate.GetFee(GetVirtualTransactionSize(*tx_parent_cheap)) <= parent_fee);
830 
831  auto mtx_child_cheap = CreateValidMempoolTransaction(/*input_transaction=*/tx_parent_cheap, /*input_vout=*/0,
832  /*input_height=*/101, /*input_signing_key=*/child_key,
833  /*output_destination=*/child_spk,
834  /*output_amount=*/coinbase_value - parent_fee - child_fee, /*submit=*/false);
835  CTransactionRef tx_child_cheap = MakeTransactionRef(mtx_child_cheap);
836  package_still_too_low.push_back(tx_child_cheap);
837  BOOST_CHECK(m_node.mempool->GetMinFee().GetFee(GetVirtualTransactionSize(*tx_child_cheap)) <= child_fee);
838  BOOST_CHECK(m_node.mempool->GetMinFee().GetFee(GetVirtualTransactionSize(*tx_parent_cheap) + GetVirtualTransactionSize(*tx_child_cheap)) > parent_fee + child_fee);
839  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
840 
841  // Cheap package should fail for being too low fee.
842  {
843  const auto submit_package_too_low = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
844  package_still_too_low, /*test_accept=*/false, /*client_maxfeerate=*/{});
845  if (auto err_package_too_low{CheckPackageMempoolAcceptResult(package_still_too_low, submit_package_too_low, /*expect_valid=*/false, m_node.mempool.get())}) {
846  BOOST_ERROR(err_package_too_low.value());
847  } else {
848  // Individual feerate of parent is too low.
849  BOOST_CHECK_EQUAL(submit_package_too_low.m_tx_results.at(tx_parent_cheap->GetWitnessHash()).m_state.GetResult(),
851  BOOST_CHECK(submit_package_too_low.m_tx_results.at(tx_parent_cheap->GetWitnessHash()).m_effective_feerate.value() ==
852  CFeeRate(parent_fee, GetVirtualTransactionSize(*tx_parent_cheap)));
853  // Package feerate of parent + child is too low.
854  BOOST_CHECK_EQUAL(submit_package_too_low.m_tx_results.at(tx_child_cheap->GetWitnessHash()).m_state.GetResult(),
856  BOOST_CHECK(submit_package_too_low.m_tx_results.at(tx_child_cheap->GetWitnessHash()).m_effective_feerate.value() ==
857  CFeeRate(parent_fee + child_fee, GetVirtualTransactionSize(*tx_parent_cheap) + GetVirtualTransactionSize(*tx_child_cheap)));
858  }
859  BOOST_CHECK_EQUAL(submit_package_too_low.m_state.GetResult(), PackageValidationResult::PCKG_TX);
860  BOOST_CHECK_EQUAL(submit_package_too_low.m_state.GetRejectReason(), "transaction failed");
861  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
862  }
863 
864  // Package feerate includes the modified fees of the transactions.
865  // This means a child with its fee delta from prioritisetransaction can pay for a parent.
866  m_node.mempool->PrioritiseTransaction(tx_child_cheap->GetHash(), 1 * COIN);
867  // Now that the child's fees have "increased" by 1 BTC, the cheap package should succeed.
868  {
869  const auto submit_prioritised_package = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
870  package_still_too_low, /*test_accept=*/false, /*client_maxfeerate=*/{});
871  if (auto err_prioritised{CheckPackageMempoolAcceptResult(package_still_too_low, submit_prioritised_package, /*expect_valid=*/true, m_node.mempool.get())}) {
872  BOOST_ERROR(err_prioritised.value());
873  } else {
874  const CFeeRate expected_feerate(1 * COIN + parent_fee + child_fee,
875  GetVirtualTransactionSize(*tx_parent_cheap) + GetVirtualTransactionSize(*tx_child_cheap));
876  BOOST_CHECK_EQUAL(submit_prioritised_package.m_tx_results.size(), package_still_too_low.size());
877  auto it_parent = submit_prioritised_package.m_tx_results.find(tx_parent_cheap->GetWitnessHash());
878  auto it_child = submit_prioritised_package.m_tx_results.find(tx_child_cheap->GetWitnessHash());
879  BOOST_CHECK(it_parent->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
880  BOOST_CHECK(it_parent->second.m_base_fees.value() == parent_fee);
881  BOOST_CHECK(it_parent->second.m_effective_feerate.value() == expected_feerate);
882  BOOST_CHECK(it_child->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
883  BOOST_CHECK(it_child->second.m_base_fees.value() == child_fee);
884  BOOST_CHECK(it_child->second.m_effective_feerate.value() == expected_feerate);
885  std::vector<Wtxid> expected_wtxids({tx_parent_cheap->GetWitnessHash(), tx_child_cheap->GetWitnessHash()});
886  BOOST_CHECK(it_parent->second.m_wtxids_fee_calculations.value() == expected_wtxids);
887  BOOST_CHECK(it_child->second.m_wtxids_fee_calculations.value() == expected_wtxids);
888  }
889  expected_pool_size += 2;
890  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
891  }
892 
893  // Package feerate is calculated without topology in mind; it's just aggregating fees and sizes.
894  // However, this should not allow parents to pay for children. Each transaction should be
895  // validated individually first, eliminating sufficient-feerate parents before they are unfairly
896  // included in the package feerate. It's also important that the low-fee child doesn't prevent
897  // the parent from being accepted.
898  Package package_rich_parent;
899  const CAmount high_parent_fee{1 * COIN};
900  auto mtx_parent_rich = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[2], /*input_vout=*/0,
901  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
902  /*output_destination=*/parent_spk,
903  /*output_amount=*/coinbase_value - high_parent_fee, /*submit=*/false);
904  CTransactionRef tx_parent_rich = MakeTransactionRef(mtx_parent_rich);
905  package_rich_parent.push_back(tx_parent_rich);
906 
907  auto mtx_child_poor = CreateValidMempoolTransaction(/*input_transaction=*/tx_parent_rich, /*input_vout=*/0,
908  /*input_height=*/101, /*input_signing_key=*/child_key,
909  /*output_destination=*/child_spk,
910  /*output_amount=*/coinbase_value - high_parent_fee, /*submit=*/false);
911  CTransactionRef tx_child_poor = MakeTransactionRef(mtx_child_poor);
912  package_rich_parent.push_back(tx_child_poor);
913 
914  // Parent pays 1 BTC and child pays none. The parent should be accepted without the child.
915  {
916  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
917  const auto submit_rich_parent = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool,
918  package_rich_parent, /*test_accept=*/false, /*client_maxfeerate=*/{});
919  if (auto err_rich_parent{CheckPackageMempoolAcceptResult(package_rich_parent, submit_rich_parent, /*expect_valid=*/false, m_node.mempool.get())}) {
920  BOOST_ERROR(err_rich_parent.value());
921  } else {
922  // The child would have been validated on its own and failed.
923  BOOST_CHECK_EQUAL(submit_rich_parent.m_state.GetResult(), PackageValidationResult::PCKG_TX);
924  BOOST_CHECK_EQUAL(submit_rich_parent.m_state.GetRejectReason(), "transaction failed");
925 
926  auto it_parent = submit_rich_parent.m_tx_results.find(tx_parent_rich->GetWitnessHash());
927  auto it_child = submit_rich_parent.m_tx_results.find(tx_child_poor->GetWitnessHash());
928  BOOST_CHECK(it_parent->second.m_result_type == MempoolAcceptResult::ResultType::VALID);
929  BOOST_CHECK(it_child->second.m_result_type == MempoolAcceptResult::ResultType::INVALID);
930  BOOST_CHECK(it_parent->second.m_state.GetRejectReason() == "");
931  BOOST_CHECK_MESSAGE(it_parent->second.m_base_fees.value() == high_parent_fee,
932  strprintf("rich parent: expected fee %s, got %s", high_parent_fee, it_parent->second.m_base_fees.value()));
933  BOOST_CHECK(it_parent->second.m_effective_feerate == CFeeRate(high_parent_fee, GetVirtualTransactionSize(*tx_parent_rich)));
934  BOOST_CHECK_EQUAL(it_child->second.m_result_type, MempoolAcceptResult::ResultType::INVALID);
935  BOOST_CHECK_EQUAL(it_child->second.m_state.GetResult(), TxValidationResult::TX_MEMPOOL_POLICY);
936  BOOST_CHECK(it_child->second.m_state.GetRejectReason() == "min relay fee not met");
937  }
938  expected_pool_size += 1;
939  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
940  }
941 }
942 
944 {
945  mineBlocks(5);
946  LOCK(::cs_main);
947  size_t expected_pool_size = m_node.mempool->size();
948  CKey child_key{GenerateRandomKey()};
949  CScript parent_spk = GetScriptForDestination(WitnessV0KeyHash(child_key.GetPubKey()));
950  CKey grandchild_key{GenerateRandomKey()};
951  CScript child_spk = GetScriptForDestination(WitnessV0KeyHash(grandchild_key.GetPubKey()));
952 
953  const CAmount coinbase_value{50 * COIN};
954  // Test that de-duplication works. This is not actually package rbf.
955  {
956  // 1 parent paying 200sat, 1 child paying 300sat
957  Package package1;
958  // 1 parent paying 200sat, 1 child paying 500sat
959  Package package2;
960  // Package1 and package2 have the same parent. The children conflict.
961  auto mtx_parent = CreateValidMempoolTransaction(/*input_transaction=*/m_coinbase_txns[0], /*input_vout=*/0,
962  /*input_height=*/0, /*input_signing_key=*/coinbaseKey,
963  /*output_destination=*/parent_spk,
964  /*output_amount=*/coinbase_value - low_fee_amt, /*submit=*/false);
965  CTransactionRef tx_parent = MakeTransactionRef(mtx_parent);
966  package1.push_back(tx_parent);
967  package2.push_back(tx_parent);
968 
969  CTransactionRef tx_child_1 = MakeTransactionRef(CreateValidMempoolTransaction(tx_parent, 0, 101, child_key, child_spk, coinbase_value - low_fee_amt - 300, false));
970  package1.push_back(tx_child_1);
971  CTransactionRef tx_child_2 = MakeTransactionRef(CreateValidMempoolTransaction(tx_parent, 0, 101, child_key, child_spk, coinbase_value - low_fee_amt - 500, false));
972  package2.push_back(tx_child_2);
973 
974  LOCK(m_node.mempool->cs);
975  const auto submit1 = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package1, /*test_accept=*/false, std::nullopt);
976  if (auto err_1{CheckPackageMempoolAcceptResult(package1, submit1, /*expect_valid=*/true, m_node.mempool.get())}) {
977  BOOST_ERROR(err_1.value());
978  }
979 
980  // Check precise ResultTypes and mempool size. We know it_parent_1 and it_child_1 exist from above call
981  auto it_parent_1 = submit1.m_tx_results.find(tx_parent->GetWitnessHash());
982  auto it_child_1 = submit1.m_tx_results.find(tx_child_1->GetWitnessHash());
983  BOOST_CHECK_EQUAL(it_parent_1->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
984  BOOST_CHECK_EQUAL(it_child_1->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
985  expected_pool_size += 2;
986  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
987 
988  const auto submit2 = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package2, /*test_accept=*/false, std::nullopt);
989  if (auto err_2{CheckPackageMempoolAcceptResult(package2, submit2, /*expect_valid=*/true, m_node.mempool.get())}) {
990  BOOST_ERROR(err_2.value());
991  }
992 
993  // Check precise ResultTypes and mempool size. We know it_parent_2 and it_child_2 exist from above call
994  auto it_parent_2 = submit2.m_tx_results.find(tx_parent->GetWitnessHash());
995  auto it_child_2 = submit2.m_tx_results.find(tx_child_2->GetWitnessHash());
996  BOOST_CHECK_EQUAL(it_parent_2->second.m_result_type, MempoolAcceptResult::ResultType::MEMPOOL_ENTRY);
997  BOOST_CHECK_EQUAL(it_child_2->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
998  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
999 
1000  // child1 has been replaced
1001  BOOST_CHECK(!m_node.mempool->exists(GenTxid::Txid(tx_child_1->GetHash())));
1002  }
1003 
1004  // Test package rbf.
1005  {
1006  CTransactionRef tx_parent_1 = MakeTransactionRef(CreateValidMempoolTransaction(
1007  m_coinbase_txns[1], /*input_vout=*/0, /*input_height=*/0,
1008  coinbaseKey, parent_spk, coinbase_value - 200, /*submit=*/false));
1009  CTransactionRef tx_child_1 = MakeTransactionRef(CreateValidMempoolTransaction(
1010  tx_parent_1, /*input_vout=*/0, /*input_height=*/101,
1011  child_key, child_spk, coinbase_value - 400, /*submit=*/false));
1012 
1013  CTransactionRef tx_parent_2 = MakeTransactionRef(CreateValidMempoolTransaction(
1014  m_coinbase_txns[1], /*input_vout=*/0, /*input_height=*/0,
1015  coinbaseKey, parent_spk, coinbase_value - 800, /*submit=*/false));
1016  CTransactionRef tx_child_2 = MakeTransactionRef(CreateValidMempoolTransaction(
1017  tx_parent_2, /*input_vout=*/0, /*input_height=*/101,
1018  child_key, child_spk, coinbase_value - 800 - 200, /*submit=*/false));
1019 
1020  CTransactionRef tx_parent_3 = MakeTransactionRef(CreateValidMempoolTransaction(
1021  m_coinbase_txns[1], /*input_vout=*/0, /*input_height=*/0,
1022  coinbaseKey, parent_spk, coinbase_value - 199, /*submit=*/false));
1023  CTransactionRef tx_child_3 = MakeTransactionRef(CreateValidMempoolTransaction(
1024  tx_parent_3, /*input_vout=*/0, /*input_height=*/101,
1025  child_key, child_spk, coinbase_value - 199 - 1300, /*submit=*/false));
1026 
1027  // In all packages, the parents conflict with each other
1028  BOOST_CHECK(tx_parent_1->GetHash() != tx_parent_2->GetHash() && tx_parent_2->GetHash() != tx_parent_3->GetHash());
1029 
1030  // 1 parent paying 200sat, 1 child paying 200sat.
1031  Package package1{tx_parent_1, tx_child_1};
1032  // 1 parent paying 800sat, 1 child paying 200sat.
1033  Package package2{tx_parent_2, tx_child_2};
1034  // 1 parent paying 199sat, 1 child paying 1300sat.
1035  Package package3{tx_parent_3, tx_child_3};
1036 
1037  const auto submit1 = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package1, false, std::nullopt);
1038  if (auto err_1{CheckPackageMempoolAcceptResult(package1, submit1, /*expect_valid=*/true, m_node.mempool.get())}) {
1039  BOOST_ERROR(err_1.value());
1040  }
1041  auto it_parent_1 = submit1.m_tx_results.find(tx_parent_1->GetWitnessHash());
1042  auto it_child_1 = submit1.m_tx_results.find(tx_child_1->GetWitnessHash());
1043  BOOST_CHECK_EQUAL(it_parent_1->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
1044  BOOST_CHECK_EQUAL(it_child_1->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
1045  expected_pool_size += 2;
1046  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
1047 
1048  // This replacement is actually not package rbf; the parent carries enough fees
1049  // to replace the entire package on its own.
1050  const auto submit2 = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package2, false, std::nullopt);
1051  if (auto err_2{CheckPackageMempoolAcceptResult(package2, submit2, /*expect_valid=*/true, m_node.mempool.get())}) {
1052  BOOST_ERROR(err_2.value());
1053  }
1054  auto it_parent_2 = submit2.m_tx_results.find(tx_parent_2->GetWitnessHash());
1055  auto it_child_2 = submit2.m_tx_results.find(tx_child_2->GetWitnessHash());
1056  BOOST_CHECK_EQUAL(it_parent_2->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
1057  BOOST_CHECK_EQUAL(it_child_2->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
1058  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
1059 
1060  // Package RBF, in which the replacement transaction's child sponsors the fees to meet RBF feerate rules
1061  const auto submit3 = ProcessNewPackage(m_node.chainman->ActiveChainstate(), *m_node.mempool, package3, false, std::nullopt);
1062  if (auto err_3{CheckPackageMempoolAcceptResult(package3, submit3, /*expect_valid=*/true, m_node.mempool.get())}) {
1063  BOOST_ERROR(err_3.value());
1064  }
1065  auto it_parent_3 = submit3.m_tx_results.find(tx_parent_3->GetWitnessHash());
1066  auto it_child_3 = submit3.m_tx_results.find(tx_child_3->GetWitnessHash());
1067  BOOST_CHECK_EQUAL(it_parent_3->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
1068  BOOST_CHECK_EQUAL(it_child_3->second.m_result_type, MempoolAcceptResult::ResultType::VALID);
1069 
1070  // package3 was considered as a package to replace both package2 transactions
1071  BOOST_CHECK(it_parent_3->second.m_replaced_transactions.size() == 2);
1072  BOOST_CHECK(it_child_3->second.m_replaced_transactions.empty());
1073 
1074  std::vector<Wtxid> expected_package3_wtxids({tx_parent_3->GetWitnessHash(), tx_child_3->GetWitnessHash()});
1075  const auto package3_total_vsize{GetVirtualTransactionSize(*tx_parent_3) + GetVirtualTransactionSize(*tx_child_3)};
1076  BOOST_CHECK(it_parent_3->second.m_wtxids_fee_calculations.value() == expected_package3_wtxids);
1077  BOOST_CHECK(it_child_3->second.m_wtxids_fee_calculations.value() == expected_package3_wtxids);
1078  BOOST_CHECK_EQUAL(it_parent_3->second.m_effective_feerate.value().GetFee(package3_total_vsize), 199 + 1300);
1079  BOOST_CHECK_EQUAL(it_child_3->second.m_effective_feerate.value().GetFee(package3_total_vsize), 199 + 1300);
1080 
1081  BOOST_CHECK_EQUAL(m_node.mempool->size(), expected_pool_size);
1082  }
1083 
1084 }
CScript GetScriptForDestination(const CTxDestination &dest)
Generate a Bitcoin scriptPubKey for the given CTxDestination.
int64_t CAmount
Amount in satoshis (Can be negative)
Definition: amount.h:12
static constexpr CAmount COIN
The amount of satoshis in one BTC.
Definition: amount.h:15
node::NodeContext m_node
Definition: bitcoin-gui.cpp:37
Fee rate in satoshis per kilovirtualbyte: CAmount / kvB.
Definition: feerate.h:33
CAmount GetFeePerK() const
Return the fee in satoshis for a vsize of 1000 vbytes.
Definition: feerate.h:65
An encapsulated private key.
Definition: key.h:33
CPubKey GetPubKey() const
Compute the public key from a private key.
Definition: key.cpp:182
An outpoint - a combination of a transaction hash and an index n into its vout.
Definition: transaction.h:29
Serialized script, used inside transaction inputs and outputs.
Definition: script.h:414
The basic transaction that is broadcasted on the network and contained in blocks.
Definition: transaction.h:296
const Txid & GetHash() const LIFETIMEBOUND
Definition: transaction.h:343
const Wtxid & GetWitnessHash() const LIFETIMEBOUND
Definition: transaction.h:344
Double ended buffer combining vector and stream-like interfaces.
Definition: streams.h:147
Fast randomness source.
Definition: random.h:377
static GenTxid Txid(const uint256 &hash)
Definition: transaction.h:434
A writer stream (for serialization) that computes a 256-bit hash.
Definition: hash.h:101
std::string GetRejectReason() const
Definition: validation.h:126
Result GetResult() const
Definition: validation.h:125
iterator begin()
Definition: prevector.h:304
iterator end()
Definition: prevector.h:306
transaction_identifier represents the two canonical transaction identifier types (txid,...
static transaction_identifier FromUint256(const uint256 &id)
256-bit opaque blob.
Definition: uint256.h:127
static int32_t GetTransactionWeight(const CTransaction &tx)
Definition: validation.h:149
@ TX_MISSING_INPUTS
transaction was missing some of its inputs
@ TX_MEMPOOL_POLICY
violated mempool's fee/size/descendant/RBF/etc limits
@ TX_WITNESS_MUTATED
Transaction might have a witness prior to SegWit activation, or witness may have been malleated (whic...
@ TX_RECONSIDERABLE
fails some policy, but might be acceptable if submitted in a (different) package
RecursiveMutex cs_main
Mutex to guard access to validation specific variables, such as reading or changing the chainstate.
Definition: cs_main.cpp:8
BOOST_AUTO_TEST_SUITE(cuckoocache_tests)
Test Suite for CuckooCache.
BOOST_AUTO_TEST_SUITE_END()
CKey GenerateRandomKey(bool compressed) noexcept
Definition: key.cpp:366
#define BOOST_CHECK_EQUAL(v1, v2)
Definition: object.cpp:18
#define BOOST_CHECK(expr)
Definition: object.cpp:17
bool IsChildWithParents(const Package &package)
Context-free check that a package is exactly one child and its parents; not all parents need to be pr...
Definition: packages.cpp:119
bool IsConsistentPackage(const Package &txns)
Checks that these transactions don't conflict, i.e., spend the same prevout.
Definition: packages.cpp:52
bool IsWellFormedPackage(const Package &txns, PackageValidationState &state, bool require_sorted)
Context-free package policy checks:
Definition: packages.cpp:79
bool IsChildWithParentsTree(const Package &package)
Context-free check that a package IsChildWithParents() and none of the parents depend on each other (...
Definition: packages.cpp:136
uint256 GetPackageHash(const std::vector< CTransactionRef > &transactions)
Get the hash of these transactions' wtxids, concatenated in lexicographical order (treating the wtxid...
Definition: packages.cpp:151
bool IsTopoSortedPackage(const Package &txns, std::unordered_set< uint256, SaltedTxidHasher > &later_txids)
IsTopoSortedPackage where a set of txids has been pre-populated.
Definition: packages.cpp:19
std::vector< CTransactionRef > Package
A package is an ordered list of transactions.
Definition: packages.h:50
static constexpr uint32_t MAX_PACKAGE_WEIGHT
Default maximum total weight of transactions in a package in weight to allow for context-less checks.
Definition: packages.h:24
static constexpr uint32_t MAX_PACKAGE_COUNT
Default maximum number of transactions in a package.
Definition: packages.h:19
@ PCKG_POLICY
The package itself is invalid (e.g. too many transactions).
@ PCKG_TX
At least one tx is invalid.
int64_t GetVirtualTransactionSize(int64_t nWeight, int64_t nSigOpCost, unsigned int bytes_per_sigop)
Compute the virtual transaction size (weight reinterpreted as bytes).
Definition: policy.cpp:295
static constexpr unsigned int DEFAULT_ANCESTOR_SIZE_LIMIT_KVB
Default for -limitancestorsize, maximum kilobytes of tx + all in-mempool ancestors.
Definition: policy.h:61
static constexpr TransactionSerParams TX_WITH_WITNESS
Definition: transaction.h:195
static CTransactionRef MakeTransactionRef(Tx &&txIn)
Definition: transaction.h:424
std::shared_ptr< const CTransaction > CTransactionRef
Definition: transaction.h:423
std::vector< unsigned char > ToByteVector(const T &in)
Definition: script.h:66
@ OP_TRUE
Definition: script.h:83
@ OP_DROP
Definition: script.h:123
constexpr deserialize_type deserialize
Definition: serialize.h:49
static constexpr CAmount CENT
Definition: setup_common.h:50
std::vector< Byte > ParseHex(std::string_view hex_str)
Like TryParseHex, but returns an empty vector on invalid input.
Definition: strencodings.h:66
A mutable version of CTransaction.
Definition: transaction.h:378
std::vector< CTxOut > vout
Definition: transaction.h:380
std::vector< CTxIn > vin
Definition: transaction.h:379
std::vector< std::vector< unsigned char > > stack
Definition: script.h:569
Validation result for a transaction evaluated by MemPoolAccept (single or package).
Definition: validation.h:128
const ResultType m_result_type
Result type.
Definition: validation.h:137
@ DIFFERENT_WITNESS
Valid, transaction was already in the mempool.
@ INVALID
Fully validated, valid.
Testing fixture that pre-creates a 100-block REGTEST-mode block chain.
Definition: setup_common.h:113
std::unique_ptr< CTxMemPool > mempool
Definition: context.h:65
std::unique_ptr< ChainstateManager > chainman
Definition: context.h:69
#define LOCK(cs)
Definition: sync.h:257
#define WITH_LOCK(cs, code)
Run code while locking a mutex.
Definition: sync.h:301
static uint256 InsecureRand256()
Definition: random.h:35
static const CScript P2WSH_OP_TRUE
Definition: script.h:12
std::optional< std::string > CheckPackageMempoolAcceptResult(const Package &txns, const PackageMempoolAcceptResult &result, bool expect_valid, const CTxMemPool *mempool)
Check expected properties for every PackageMempoolAcceptResult, regardless of value.
Definition: txmempool.cpp:43
#define strprintf
Format arguments and return the string or write to given std::ostream (see tinyformat::format doc for...
Definition: tinyformat.h:1161
Txid TxidFromString(std::string_view str)
DEPRECATED due to missing length-check and hex-check, please use the safer FromHex,...
static const CAmount low_fee_amt
Wtxid WtxidFromString(std::string_view str)
BOOST_FIXTURE_TEST_CASE(package_hash_tests, TestChain100Setup)
CTransactionRef create_placeholder_tx(size_t num_inputs, size_t num_outputs)
uint256 uint256S(std::string_view str)
Definition: uint256.h:140
PackageMempoolAcceptResult ProcessNewPackage(Chainstate &active_chainstate, CTxMemPool &pool, const Package &package, bool test_accept, const std::optional< CFeeRate > &client_maxfeerate)
Validate (and maybe submit) a package to the mempool.