From 63a28b91a7b0b562b56fc709f436c228a4a3e080 Mon Sep 17 00:00:00 2001
From: Eric <5089238+emizzle@users.noreply.github.com>
Date: Fri, 6 Jun 2025 18:33:19 +1000
Subject: [PATCH] fix(integration): add timeouts to waiting for started futures

---
 tests/integration/testmarketplace.nim | 6 +++---
 tests/integration/testproofs.nim      | 2 +-
 tests/integration/testsales.nim       | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/tests/integration/testmarketplace.nim b/tests/integration/testmarketplace.nim
index 86b67c05..407d0c7e 100644
--- a/tests/integration/testmarketplace.nim
+++ b/tests/integration/testmarketplace.nim
@@ -70,7 +70,7 @@ marketplacesuite "Marketplace":
     )
 
     # wait for request to start
-    await requestStartedFut
+    await requestStartedFut.wait(timeout = chronos.seconds((10 * 60) + 10))
 
     let purchase = (await client.getPurchase(id)).get
     check purchase.error == none string
@@ -126,7 +126,7 @@ marketplacesuite "Marketplace":
       tolerance = ecTolerance,
     )
 
-    await requestStartedFut
+    await requestStartedFut.wait(timeout = chronos.seconds((10 * 60) + 10))
 
     let purchase = (await client.getPurchase(id)).get
     check purchase.error == none string
@@ -322,7 +322,7 @@ marketplacesuite "Marketplace payouts":
     # wait until sale is cancelled
     await ethProvider.advanceTime(expiry.u256)
 
-    await requestCancelledFut.wait(timeout = (expiry.uint32 + 10'u32).seconds)
+    await requestCancelledFut.wait(timeout = chronos.seconds(expiry.int + 10))
 
     await advanceToNextPeriod()
 
diff --git a/tests/integration/testproofs.nim b/tests/integration/testproofs.nim
index 6fc42a49..26fe5921 100644
--- a/tests/integration/testproofs.nim
+++ b/tests/integration/testproofs.nim
@@ -71,7 +71,7 @@ marketplacesuite "Hosts submit regular proofs":
 
     let slotSize = slotSize(blocks, ecNodes, ecTolerance)
 
-    await requestStartedFut
+    await requestStartedFut.wait(timeout = chronos.seconds(10.periods.int + 10))
 
     var proofWasSubmitted = false
     proc onProofSubmitted(event: ?!ProofSubmitted) =
diff --git a/tests/integration/testsales.nim b/tests/integration/testsales.nim
index 5e406e81..66287bdb 100644
--- a/tests/integration/testsales.nim
+++ b/tests/integration/testsales.nim
@@ -148,7 +148,7 @@ marketplacesuite "Sales":
       tolerance = 1,
     )
 
-    await requestStartedFut
+    await requestStartedFut.wait(timeout = chronos.seconds((10 * 60) + 10))
 
     let updatedAvailability =
       ((await host.getAvailabilities()).get).findItem(availability).get
@@ -231,7 +231,7 @@ marketplacesuite "Sales":
       )
     ).get
 
-    await requestStartedFut
+    await requestStartedFut.wait(timeout = chronos.seconds((10 * 60) + 10))
 
     let purchase = (await client.getPurchase(id)).get
     check purchase.error == none string