test: cover simln service with network export on both backends

Author: pinheadmz

test/data/ln.graphml

@@ -1,5 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?><graphml xmlns="http://graphml.graphdrawing.org/xmlns">
   <key id="version"         attr.name="version"          attr.type="string"   for="node" />
+  <key id="services"        attr.name="services"         attr.type="string"   for="graph" />
   <key id="image"           attr.name="image"            attr.type="string"   for="node" />
   <key id="bitcoin_config"  attr.name="bitcoin_config"   attr.type="string"   for="node" />
   <key id="tc_netem"        attr.name="tc_netem"         attr.type="string"   for="node" />
@@ -14,6 +15,7 @@
   <key id="source_policy"   attr.name="source_policy"    attr.type="string"   for="edge" />
   <key id="target_policy"   attr.name="target_policy"    attr.type="string"   for="edge" />
   <graph edgedefault="directed">
+    <data key="services">simln</data>
     <node id="0">
         <data key="version">26.0</data>
         <data key="bitcoin_config">-uacomment=w0</data>

test/data/services.graphml

@@ -20,6 +20,7 @@
         <data key="version">26.0</data>
         <data key="bitcoin_config">-uacomment=w0 -debug=validation</data>
         <data key="exporter">true</data>
+        <data key="ln">lnd</data>
     </node>
   </graph>
 </graphml>

test/ln_test.py

@@ -25,20 +25,6 @@ def get_cb_forwards(index):
 base.wait_for_all_tanks_status(target="running")
 base.wait_for_all_edges()
 
-if base.backend != "compose":
-    print("\nSkipping network export test, only supported with compose backend")
-else:
-    print("\nTesting warcli network export")
-    path = Path(base.warcli("network export")) / "sim.json"
-    with open(path) as file:
-        data = json.load(file)
-        print(json.dumps(data, indent=4))
-        assert len(data["nodes"]) == 3
-        for node in data["nodes"]:
-            assert os.path.exists(node["macaroon"])
-            assert os.path.exists(node["cert"])
-
-
 print("\nRunning LN Init scenario")
 base.warcli("rpc 0 getblockcount")
 base.warcli("scenarios run ln_init")
@@ -86,17 +72,27 @@ def check_invoices():
 print(base.warcli(f"lncli 2 payinvoice -f {inv}"))
 
 print("Waiting for payment success")
-def check_invoices():
-    invs = json.loads(base.warcli("lncli 0 listinvoices"))["invoices"]
-    if len(invs) > 0 and invs[0]["state"] == "SETTLED":
-        print("\nSettled!")
-        return True
-    else:
-        return False
-base.wait_for_predicate(check_invoices)
+def check_invoices(index):
+    invs = json.loads(base.warcli(f"lncli {index} listinvoices"))["invoices"]
+    settled = 0
+    for inv in invs:
+        if inv["state"] == "SETTLED":
+            settled += 1
+    return settled
+base.wait_for_predicate(lambda: check_invoices(0) == 1)
 
 print("\nEnsuring channel-level channel policy settings: target")
 payment = json.loads(base.warcli("lncli 2 listpayments"))["payments"][0]
 assert payment["fee_msat"] == "2213"
 
+print("\nEngaging simln")
+activity = [{
+  "source": "ln-0",
+  "destination": chan["node1_pub"],
+  "interval_secs": 1,
+  "amount_msat": 2000
+}]
+base.warcli(f"network export --activity={json.dumps(activity).replace(' ', '')}")
+base.wait_for_predicate(lambda: check_invoices(0) > 1 or check_invoices(1) > 1 or check_invoices(2) > 1)
+
 base.stop_server()