test: Transaction expiry from mempool #18172

   0 | @@ -0,0 +1,100 @@
   1 | +#!/usr/bin/env python3
   2 | +# Copyright (c) 2020 The Bitcoin Core developers
   3 | +# Distributed under the MIT software license, see the accompanying
   4 | +# file COPYING or http://www.opensource.org/licenses/mit-license.php.
   5 | +"""Tests that a mempool transaction expires after a given timeout and that its
   6 | +children are removed as well.
   7 | +
   8 | +Both the default expiry timeout defied by DEFAULT_MEMPOOL_EXPIRY and a user

---

  87 | +                      DEFAULT_MEMPOOL_EXPIRY)
  88 | +        self.test_transaction_expiry(DEFAULT_MEMPOOL_EXPIRY)
  89 | +
  90 | +        self.log.info("----")
  91 | +
  92 | +        CUSTOM_MEMPOOL_EXPIRY = 10

---

  12 | +
  13 | +from datetime import timedelta
  14 | +
  15 | +from test_framework.test_framework import BitcoinTestFramework
  16 | +from test_framework.util import (assert_equal, assert_raises_rpc_error,
  17 | +                                 find_vout_for_address)

---

  53 | +        # Let half of the timeout elapse and broadcast the child transaction.
  54 | +        half_expiry_time = entry_time + int(60 * 60 * timeout/2)
  55 | +        node.setmocktime(half_expiry_time)
  56 | +        child_txid = node.sendrawtransaction(child_signed)
  57 | +        self.log.info("Broadcast child transaction after {} hours.".format(
  58 | +            str(timedelta(seconds=(half_expiry_time-entry_time)))))

---

  89 | +
  90 | +        self.log.info("Test default mempool expiry timeout of %d hours." %
  91 | +                      DEFAULT_MEMPOOL_EXPIRY)
  92 | +        self.test_transaction_expiry(DEFAULT_MEMPOOL_EXPIRY)
  93 | +
  94 | +        self.log.info("----")

---

  17 | +    assert_equal,
  18 | +    assert_raises_rpc_error,
  19 | +    find_vout_for_address,
  20 | +)
  21 | +
  22 | +DEFAULT_MEMPOOL_EXPIRY = 336

---

  38 | +        # Send a parent transaction that will expire.
  39 | +        parent_address = node.getnewaddress()
  40 | +        parent_txid = node.sendtoaddress(parent_address, 1.0)
  41 | +
  42 | +        # Set the mocktime to the arrival time of the parent transaction.
  43 | +        entry_time = node.getmempoolentry(parent_txid)["time"]

---

  62 | +        nearly_expiry_time = entry_time + 60 * 60 * timeout - 5
  63 | +        node.setmocktime(nearly_expiry_time)
  64 | +        # Expiry of mempool transactions is only checked when a new transaction
  65 | +        # is added to the to the mempool.
  66 | +        node.sendtoaddress(node.getnewaddress(), 1.0)
  67 | +        self.log.info("Test parent tx not expired after {} hours.".format(

---

  84 | +        self.log.info("Test child tx is evicted as well.")
  85 | +        assert_raises_rpc_error(-5, "Transaction not in mempool",
  86 | +                                node.getmempoolentry, child_txid)
  87 | +
  88 | +    def run_test(self):
  89 | +

---