Add wait_for_tx function to DashTestFramework

dashpay · Dec 5, 2019 · 253ba29 · 253ba29
1 parent e7cc24c
commit 253ba29
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/test/functional/test_framework/test_framework.py b/test/functional/test_framework/test_framework.py
@@ -699,6 +699,15 @@ def create_raw_tx(self, node_from, node_to, amount, min_inputs, max_inputs):
         ret = {**decoded, **ret}
         return ret
 
+    def wait_for_tx(self, txid, node, expected=True, timeout=10):
+        def check_tx():
+            try:
+                return node.getrawtransaction(txid)
+            except:
+                return False
+        if wait_until(check_tx, timeout=timeout, sleep=0.5, do_assert=expected) and not expected:
+            raise AssertionError("waiting unexpectedly succeeded")
+
     def wait_for_instantlock(self, txid, node, expected=True, timeout=10):
         def check_instantlock():
             try: