Test that the coordinator broadcasts spend txs

Author: danielabrozzoni

tests/test_framework/coordinatord.py

@@ -13,6 +13,8 @@ def __init__(
         stakeholders_keys,
         watchtowers_keys,
         listen_port,
+        bitcoind_rpc_port,
+        bitcoind_cookie_path,
         postgres_user,
         postgres_pass,
         postgres_host="localhost",
@@ -69,7 +71,12 @@ def __init__(
                 f.write(f'"{k.hex()}", ')
             f.write("]\n")
 
-            f.write(f'listen = "127.0.0.1:{listen_port}"')
+            f.write(f'listen = "127.0.0.1:{listen_port}"\n')
+
+            f.write("[bitcoind_config]\n")
+            f.write(f"cookie_path = '{bitcoind_cookie_path}'\n")
+            f.write(f"addr = '127.0.0.1:{bitcoind_rpc_port}'\n")
+            f.write("broadcast_interval = 5\n")
 
     def postgres_exec(self, sql):
         conn = psycopg2.connect(

tests/test_framework/revault_network.py

@@ -210,6 +210,8 @@ def deploy(
             stkonly_noisepubs + stkman_noisepubs,
             stkonly_wt_noisepubs + stkman_wt_noisepubs,
             self.coordinator_port,
+            bitcoind_rpcport,
+            bitcoind_cookie,
             self.postgres_user,
             self.postgres_pass,
             self.postgres_host,

tests/test_spend.py

@@ -694,3 +694,30 @@ def test_revaulted_spend(revault_network, bitcoind, executor):
             lambda: len(w.rpc.listvaults(["unvaulted"], deposits)["vaults"])
             == len(deposits)
         )
+
+
+# Test that the coordinator will broadcast our spends
+@pytest.mark.skipif(not POSTGRES_IS_SETUP, reason="Needs Postgres for servers db")
+def test_coordinator_broadcast(revault_network, bitcoind, executor):
+    """
+    Test that the coordinator broadcasts spend transactions when they become valid
+    """
+    CSV = 12
+    revault_network.deploy(2, 2, n_stkmanagers=1, csv=CSV)
+
+    vault = revault_network.fund(0.05)
+    revault_network.secure_vault(vault)
+    revault_network.activate_vault(vault)
+    revault_network.unvault_vaults_anyhow([vault])
+
+    revault_network.stop_wallets()
+
+    bitcoind.generate_block(CSV - 1)
+    bitcoind.generate_block(1, wait_for_mempool=1)
+
+    revault_network.start_wallets()
+
+    for w in revault_network.participants():
+        wait_for(
+            lambda: len(w.rpc.listvaults(["spent"])["vaults"]) == 1,
+        )