ci: run dag connection test

Author: pinheadmz

.github/workflows/test.yml

@@ -33,7 +33,7 @@ jobs:
     strategy:
       matrix:
         # test: [scenarios_test.py, rpc_test.py, graph_test.py, ln_test.py, dag_connection_test.py, logging_test.py]
-        test: [graph_test.py, rpc_test.py, scenarios_test.py, graph_test.py]
+        test: [scenarios_test.py, rpc_test.py, graph_test.py,               dag_connection_test.py, logging_test.py]
     steps:
       - uses: actions/checkout@v4
       - uses: hynek/setup-cached-uv@v1

test/dag_connection_test.py

@@ -14,7 +14,6 @@ def __init__(self):
         )
 
     def run_test(self):
-        self.start_server()
         try:
             self.setup_network()
             self.run_connect_dag_scenario()

test/data/scenario_connect_dag.py

@@ -4,7 +4,8 @@
 from enum import Enum, auto, unique
 from time import sleep
 
-from warnet.test_framework_bridge import WarnetTestFramework
+# The base class exists inside the commander container
+from commander import Commander
 
 
 def cli_help():
@@ -17,7 +18,7 @@ class ConnectionType(Enum):
     DNS = auto()
 
 
-class ConnectDag(WarnetTestFramework):
+class ConnectDag(Commander):
     def set_test_params(self):
         # This is just a minimum
         self.num_nodes = 10

test/test_base.py

@@ -13,7 +13,7 @@
 from warnet import SRC_DIR
 from warnet.cli.network import _status as network_status
 from warnet.cli.network import _connected as network_connected
-
+from warnet.cli.scenarios import _active as scenarios_active
 
 class TestBase:
     def __init__(self):
@@ -128,9 +128,13 @@ def wait_for_all_edges(self, timeout=20 * 60, interval=5):
 
     def wait_for_all_scenarios(self):
         def check_scenarios():
-            scns = self.rpc("scenarios_list_running")
-            return all(not scn["active"] for scn in scns)
-
+            scns = scenarios_active()
+            if len(scns) == 0:
+                return True
+            for s in scns:
+                if s["status"] != "succeeded":
+                    return False
+            return True
         self.wait_for_predicate(check_scenarios)
 
     def get_scenario_return_code(self, scenario_name):