Add blocknotify and walletnotify functional tests #10941

  27 | +        self.extra_args = [['-blocknotify=echo %%s >> %s' % path]]
  28 | +
  29 | +    def run_test(self):
  30 | +        # generate 5 blocks
  31 | +        blocks = self.nodes[0].generate(5)
  32 | +        sleep(1)

---

   0 | @@ -0,0 +1,42 @@
   1 | +#!/usr/bin/env python3
   2 | +# Copyright (c) 2017 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 | +"""Test blocknotify.
   6 | +
   7 | +Verify that a bitcoind node calls the given command for each block
   8 | +"""
   9 | +from os import close, remove

---

   7 | +Verify that a bitcoind node calls the given command for each block
   8 | +"""
   9 | +from os import close, remove
  10 | +from tempfile import mkstemp
  11 | +from test_framework.test_framework import BitcoinTestFramework
  12 | +from test_framework.util import assert_equal, assert_raises_jsonrpc

---

  16 | +
  17 | +    def __init__(self):
  18 | +        super().__init__()
  19 | +
  20 | +        # get a temporary file path to store the notified blocks
  21 | +        (fd, path) = mkstemp(text = True)

---

  19 | +
  20 | +    def __init__(self):
  21 | +        super().__init__()
  22 | +
  23 | +        # get a temporary file path to store the notified blocks
  24 | +        fd, path = tempfile.mkstemp(text = True)

---

  34 | +    def run_test(self):
  35 | +        # generate 3 blocks
  36 | +        blocks = self.nodes[0].generate(3)
  37 | +
  38 | +        # wait while the command runs asynchronously
  39 | +        time.sleep(3)

---

  39 | +        time.sleep(3)
  40 | +
  41 | +        # file content should equal the generated blocks hashes
  42 | +        with open(self.path, 'r') as f:
  43 | +            assert_equal(''.join(blocks), f.read())
  44 | +        

---

  22 | +
  23 | +        # get a temporary file path to store the notified blocks
  24 | +        fd, path = tempfile.mkstemp(text = True)
  25 | +        os.close(fd)
  26 | +
  27 | +        self.path = path

---

  31 | +
  32 | +    def run_test(self):
  33 | +        block_count = 10
  34 | +        blocks = self.nodes[0].generate(block_count)
  35 | +
  36 | +        # wait for expected data length

---

  33 | +        block_count = 10
  34 | +        blocks = self.nodes[0].generate(block_count)
  35 | +
  36 | +        # wait at most 10 seconds for expected file size before reading the content
  37 | +        attempts = 0
  38 | +        while os.stat(self.path).st_size < (block_count * 65) and attempts < 100:

---

  24 | +
  25 | +    def setup_network(self):
  26 | +        self.path = os.path.join(self.options.tmpdir, 'blocks.txt')
  27 | +
  28 | +        # the command will append the notified block hash to file
  29 | +        self.extra_args = [['-blocknotify=echo %%s >> %s' % self.path]]

---

  32 | +        # wait at most 10 seconds for expected file size before reading the content
  33 | +        wait_until(lambda: os.stat(self.path).st_size >= (block_count * 65), timeout=10)
  34 | +
  35 | +        # file content should equal the generated blocks hashes
  36 | +        with open(self.path, 'r') as f:
  37 | +            assert_equal(blocks, f.read().splitlines())

---

   0 | @@ -0,0 +1,86 @@
   1 | +#!/usr/bin/env python3
   2 | +# Copyright (c) 2014-2016 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 | +"""Test the -alertnotify and -blocknotify options."""

---

   6 | +import os
   7 | +
   8 | +from test_framework.test_framework import BitcoinTestFramework
   9 | +from test_framework.util import assert_equal, wait_until, connect_nodes_bi
  10 | +
  11 | +class ForkNotifyTest(BitcoinTestFramework):

---