From af28d889cd8f61b8f1ef3833900a0787e9d1cbbb Mon Sep 17 00:00:00 2001
From: "Miquel A. Cabot" <miquel.cabot@gmail.com>
Date: Wed, 27 Apr 2022 10:52:33 +0200
Subject: [PATCH] add aquarius.waitForAqua()

---
 test/integration/MarketplaceFlow.test.ts | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/test/integration/MarketplaceFlow.test.ts b/test/integration/MarketplaceFlow.test.ts
index 5f4f6e52..f6f8e909 100644
--- a/test/integration/MarketplaceFlow.test.ts
+++ b/test/integration/MarketplaceFlow.test.ts
@@ -240,10 +240,13 @@ describe('Marketplace flow tests', async () => {
     consumerDTBalance = await balance(web3, datatokenAddress, publisherAccount)
     console.log(`Consumer ${NFT_SYMBOL} balance after swap: ${consumerDTBalance}`)
 
+    const resolvedDDO = await aquarius.waitForAqua(DDO.id)
+    assert(resolvedDDO, 'Cannot fetch DDO from Aquarius')
+
     // initialize provider
     const initializeData = await ProviderInstance.initialize(
-      DDO.id,
-      DDO.services[0].id,
+      resolvedDDO.id,
+      resolvedDDO.services[0].id,
       0,
       consumerAccount,
       providerUrl