diff --git a/test/integration/PublishEditConsume.test.ts b/test/integration/PublishEditConsume.test.ts index 1397b23bf..631f0bafb 100644 --- a/test/integration/PublishEditConsume.test.ts +++ b/test/integration/PublishEditConsume.test.ts @@ -13,7 +13,7 @@ import { } from '../../src' import { Files, Smartcontract } from '../../src/@types' import { createAsset, orderAsset, updateAssetMetadata } from './helpers' -import * as axios from 'axios' +import axios from 'axios' let config: Config @@ -225,368 +225,367 @@ describe('Publish consume test', async () => { assert(urlAssetId, 'Failed to publish url DDO') }) - arweaveAssetId = await createAsset( - 'ArwaveDatatoken', - 'ARWAVEDT', - publisherAccount, - arweaveFile, - assetDdo, - providerUrl, - addresses.ERC721Factory, - aquarius - ) - assert(urlAssetId, 'Failed to arwave publish DDO') - const ipfsCID = await uploadToIpfs(JSON.stringify(assetDdo)) - const ipfsFile: Files = { - datatokenAddress: '0x0', - nftAddress: '0x0', - files: [ - { - type: 'ipfs', - hash: ipfsCID - } - ] - } - ipfsAssetId = await createAsset( - 'IpfsDatatoken', - 'IPFSDT', - publisherAccount, - ipfsFile, - assetDdo, - providerUrl, - addresses.ERC721Factory, - aquarius - ) - assert(ipfsAssetId, 'Failed to publish ipfs DDO') - }) - - it('Should publish arwave asset', async () => { - arweaveAssetId = await createAsset( - 'ArweaveDatatoken', - 'ARWEAVEDT', - publisherAccount, - arweaveFile, - assetDdo, - providerUrl, - addresses.ERC721Factory, - aquarius - ) - assert(arweaveAssetId, 'Failed to publish ipfs DDO') - }) - - it('Should publish onchain asset', async () => { - const chainFile: Smartcontract = { - type: 'smartcontract', - address: addresses.Router, - abi: { - inputs: [], - name: 'swapOceanFee', - outputs: [{ internalType: 'uint256', name: '', type: 'uint256' }], - stateMutability: 'view', - type: 'function' - }, - chainId: 8996 - } - onchainFile.files[0] = chainFile - onchainAssetId = await createAsset( - 'ChainDatatoken', - 'CHAINDT', - publisherAccount, - onchainFile, - assetDdo, - providerUrl, - addresses.ERC721Factory, - aquarius - ) - assert(onchainAssetId, 'Failed to publish onchain DDO') - }) - - it('Should publish graphql asset', async () => { - grapqlAssetId = await createAsset( - 'GraphDatatoken', - 'GRAPHDT', - publisherAccount, - grapqlFile, - assetDdo, - providerUrl, - addresses.ERC721Factory, - aquarius - ) - assert(grapqlAssetId, 'Failed to publish graphql DDO') - }) - - delay(10000) // let's wait for aquarius to index the assets - - it('Resolve published assets', async () => { - resolvedUrlAssetDdo = await aquarius.waitForAqua(urlAssetId) - assert(resolvedUrlAssetDdo, 'Cannot fetch url DDO from Aquarius') - - resolvedArweaveAssetDdo = await aquarius.waitForAqua(arweaveAssetId) - assert(resolvedArweaveAssetDdo, 'Cannot fetch arwave DDO from Aquarius') + arweaveAssetId = await createAsset( + 'ArwaveDatatoken', + 'ARWAVEDT', + publisherAccount, + arweaveFile, + assetDdo, + providerUrl, + addresses.ERC721Factory, + aquarius + ) + assert(urlAssetId, 'Failed to arwave publish DDO') + const ipfsCID = await uploadToIpfs(JSON.stringify(assetDdo)) + const ipfsFile: Files = { + datatokenAddress: '0x0', + nftAddress: '0x0', + files: [ + { + type: 'ipfs', + hash: ipfsCID + } + ] + } + ipfsAssetId = await createAsset( + 'IpfsDatatoken', + 'IPFSDT', + publisherAccount, + ipfsFile, + assetDdo, + providerUrl, + addresses.ERC721Factory, + aquarius + ) + assert(ipfsAssetId, 'Failed to publish ipfs DDO') +}) - resolvedIpfsAssetDdo = await aquarius.waitForAqua(ipfsAssetId) - assert(resolvedIpfsAssetDdo, 'Cannot fetch ipfs DDO from Aquarius') +it('Should publish arwave asset', async () => { + arweaveAssetId = await createAsset( + 'ArweaveDatatoken', + 'ARWEAVEDT', + publisherAccount, + arweaveFile, + assetDdo, + providerUrl, + addresses.ERC721Factory, + aquarius + ) + assert(arweaveAssetId, 'Failed to publish ipfs DDO') +}) - resolvedOnchainAssetDdo = await aquarius.waitForAqua(onchainAssetId) - assert(resolvedOnchainAssetDdo, 'Cannot fetch onchain DDO from Aquarius') +it('Should publish onchain asset', async () => { + const chainFile: Smartcontract = { + type: 'smartcontract', + address: addresses.Router, + abi: { + inputs: [], + name: 'swapOceanFee', + outputs: [{ internalType: 'uint256', name: '', type: 'uint256' }], + stateMutability: 'view', + type: 'function' + }, + chainId: 8996 + } + onchainFile.files[0] = chainFile + onchainAssetId = await createAsset( + 'ChainDatatoken', + 'CHAINDT', + publisherAccount, + onchainFile, + assetDdo, + providerUrl, + addresses.ERC721Factory, + aquarius + ) + assert(onchainAssetId, 'Failed to publish onchain DDO') +}) - resolvedGraphqlAssetDdo = await aquarius.waitForAqua(grapqlAssetId) - assert(resolvedGraphqlAssetDdo, 'Cannot fetch graphql DDO from Aquarius') - }) +it('Should publish graphql asset', async () => { + grapqlAssetId = await createAsset( + 'GraphDatatoken', + 'GRAPHDT', + publisherAccount, + grapqlFile, + assetDdo, + providerUrl, + addresses.ERC721Factory, + aquarius + ) + assert(grapqlAssetId, 'Failed to publish graphql DDO') +}) - it('Mint datasets datatokens to publisher', async () => { - datatoken = new Datatoken(publisherAccount, config.chainId) - const urlMintTx = await datatoken.mint( - resolvedUrlAssetDdo.services[0].datatokenAddress, - await publisherAccount.getAddress(), - '10', - await consumerAccount.getAddress() - ) - assert(urlMintTx, 'Failed minting url datatoken to consumer.') +delay(10000) // let's wait for aquarius to index the assets - const arwaveMintTx = await datatoken.mint( - resolvedArweaveAssetDdo.services[0].datatokenAddress, - await publisherAccount.getAddress(), - '10', - await consumerAccount.getAddress() - ) - assert(arwaveMintTx, 'Failed minting arwave datatoken to consumer.') +it('Resolve published assets', async () => { + resolvedUrlAssetDdo = await aquarius.waitForAqua(urlAssetId) + assert(resolvedUrlAssetDdo, 'Cannot fetch url DDO from Aquarius') - const ipfsMintTx = await datatoken.mint( - resolvedIpfsAssetDdo.services[0].datatokenAddress, - await publisherAccount.getAddress(), - '10', - await consumerAccount.getAddress() - ) - assert(ipfsMintTx, 'Failed minting ipfs datatoken to consumer.') + resolvedArweaveAssetDdo = await aquarius.waitForAqua(arweaveAssetId) + assert(resolvedArweaveAssetDdo, 'Cannot fetch arwave DDO from Aquarius') - const onchainMintTx = await datatoken.mint( - resolvedOnchainAssetDdo.services[0].datatokenAddress, - await publisherAccount.getAddress(), - '10', - await consumerAccount.getAddress() - ) - assert(onchainMintTx, 'Failed minting onchain datatoken to consumer.') + resolvedIpfsAssetDdo = await aquarius.waitForAqua(ipfsAssetId) + assert(resolvedIpfsAssetDdo, 'Cannot fetch ipfs DDO from Aquarius') - const graphqlMintTx = await datatoken.mint( - resolvedGraphqlAssetDdo.services[0].datatokenAddress, - await publisherAccount.getAddress(), - '10', - await consumerAccount.getAddress() - ) - assert(graphqlMintTx, 'Failed minting graphql datatoken to consumer.') - }) + resolvedOnchainAssetDdo = await aquarius.waitForAqua(onchainAssetId) + assert(resolvedOnchainAssetDdo, 'Cannot fetch onchain DDO from Aquarius') - it('Should order url dataset', async () => { - datatoken = new Datatoken(consumerAccount, config.chainId) - urlOrderTx = await orderAsset( - resolvedUrlAssetDdo.id, - resolvedUrlAssetDdo.services[0].datatokenAddress, - await consumerAccount.getAddress(), - resolvedUrlAssetDdo.services[0].id, - 0, - datatoken, - providerUrl - ) - assert(urlOrderTx, 'Ordering url dataset failed.') - }).timeout(40000) - - it('Should order arweave dataset', async () => { - arwaveOrderTx = await orderAsset( - resolvedArweaveAssetDdo.id, - resolvedArweaveAssetDdo.services[0].datatokenAddress, - await consumerAccount.getAddress(), - resolvedArweaveAssetDdo.services[0].id, - 0, - datatoken, - providerUrl - ) - assert(arwaveOrderTx, 'Ordering arwave dataset failed.') - }).timeout(40000) - - it('Should order ipfs dataset', async () => { - ipfsOrderTx = await orderAsset( - resolvedIpfsAssetDdo.id, - resolvedIpfsAssetDdo.services[0].datatokenAddress, - await consumerAccount.getAddress(), - resolvedIpfsAssetDdo.services[0].id, - 0, - datatoken, - providerUrl - ) - assert(ipfsOrderTx, 'Ordering ipfs dataset failed.') - }).timeout(40000) + resolvedGraphqlAssetDdo = await aquarius.waitForAqua(grapqlAssetId) + assert(resolvedGraphqlAssetDdo, 'Cannot fetch graphql DDO from Aquarius') +}) - it('Should order onchain dataset', async () => { - onchainOrderTx = await orderAsset( - resolvedOnchainAssetDdo.id, - resolvedOnchainAssetDdo.services[0].datatokenAddress, - await consumerAccount.getAddress(), - resolvedOnchainAssetDdo.services[0].id, - 0, - datatoken, - providerUrl - ) - assert(onchainOrderTx, 'Ordering onchain dataset failed.') - }).timeout(40000) +it('Mint datasets datatokens to publisher', async () => { + datatoken = new Datatoken(publisherAccount, config.chainId) + const urlMintTx = await datatoken.mint( + resolvedUrlAssetDdo.services[0].datatokenAddress, + await publisherAccount.getAddress(), + '10', + await consumerAccount.getAddress() + ) + assert(urlMintTx, 'Failed minting url datatoken to consumer.') + + const arwaveMintTx = await datatoken.mint( + resolvedArweaveAssetDdo.services[0].datatokenAddress, + await publisherAccount.getAddress(), + '10', + await consumerAccount.getAddress() + ) + assert(arwaveMintTx, 'Failed minting arwave datatoken to consumer.') + + const ipfsMintTx = await datatoken.mint( + resolvedIpfsAssetDdo.services[0].datatokenAddress, + await publisherAccount.getAddress(), + '10', + await consumerAccount.getAddress() + ) + assert(ipfsMintTx, 'Failed minting ipfs datatoken to consumer.') + + const onchainMintTx = await datatoken.mint( + resolvedOnchainAssetDdo.services[0].datatokenAddress, + await publisherAccount.getAddress(), + '10', + await consumerAccount.getAddress() + ) + assert(onchainMintTx, 'Failed minting onchain datatoken to consumer.') + + const graphqlMintTx = await datatoken.mint( + resolvedGraphqlAssetDdo.services[0].datatokenAddress, + await publisherAccount.getAddress(), + '10', + await consumerAccount.getAddress() + ) + assert(graphqlMintTx, 'Failed minting graphql datatoken to consumer.') +}) - it('Should order graphQl dataset', async () => { - grapqlOrderTx = await orderAsset( - resolvedGraphqlAssetDdo.id, - resolvedGraphqlAssetDdo.services[0].datatokenAddress, - await consumerAccount.getAddress(), - resolvedGraphqlAssetDdo.services[0].id, - 0, - datatoken, - providerUrl - ) - assert(grapqlOrderTx, 'Ordering graphql dataset failed.') - }) +it('Should order url dataset', async () => { + datatoken = new Datatoken(consumerAccount, config.chainId) + urlOrderTx = await orderAsset( + resolvedUrlAssetDdo.id, + resolvedUrlAssetDdo.services[0].datatokenAddress, + await consumerAccount.getAddress(), + resolvedUrlAssetDdo.services[0].id, + 0, + datatoken, + providerUrl + ) + assert(urlOrderTx, 'Ordering url dataset failed.') +}).timeout(40000) + +it('Should order arweave dataset', async () => { + arwaveOrderTx = await orderAsset( + resolvedArweaveAssetDdo.id, + resolvedArweaveAssetDdo.services[0].datatokenAddress, + await consumerAccount.getAddress(), + resolvedArweaveAssetDdo.services[0].id, + 0, + datatoken, + providerUrl + ) + assert(arwaveOrderTx, 'Ordering arwave dataset failed.') +}).timeout(40000) + +it('Should order ipfs dataset', async () => { + ipfsOrderTx = await orderAsset( + resolvedIpfsAssetDdo.id, + resolvedIpfsAssetDdo.services[0].datatokenAddress, + await consumerAccount.getAddress(), + resolvedIpfsAssetDdo.services[0].id, + 0, + datatoken, + providerUrl + ) + assert(ipfsOrderTx, 'Ordering ipfs dataset failed.') +}).timeout(40000) + +it('Should order onchain dataset', async () => { + onchainOrderTx = await orderAsset( + resolvedOnchainAssetDdo.id, + resolvedOnchainAssetDdo.services[0].datatokenAddress, + await consumerAccount.getAddress(), + resolvedOnchainAssetDdo.services[0].id, + 0, + datatoken, + providerUrl + ) + assert(onchainOrderTx, 'Ordering onchain dataset failed.') +}).timeout(40000) + +it('Should order graphQl dataset', async () => { + grapqlOrderTx = await orderAsset( + resolvedGraphqlAssetDdo.id, + resolvedGraphqlAssetDdo.services[0].datatokenAddress, + await consumerAccount.getAddress(), + resolvedGraphqlAssetDdo.services[0].id, + 0, + datatoken, + providerUrl + ) + assert(grapqlOrderTx, 'Ordering graphql dataset failed.') +}) - it('Should download the datasets files', async () => { - const urlDownloadUrl = await ProviderInstance.getDownloadUrl( - resolvedUrlAssetDdo.id, - resolvedUrlAssetDdo.services[0].id, - 0, - urlOrderTx.transactionHash, - providerUrl, - consumerAccount - ) - assert(urlDownloadUrl, 'Provider getDownloadUrl failed for url dataset') - try { - await downloadFile(urlDownloadUrl) - } catch (e) { - assert.fail(`Download url dataset failed: ${e}`) - } - const arwaveDownloadURL = await ProviderInstance.getDownloadUrl( - resolvedArweaveAssetDdo.id, - resolvedArweaveAssetDdo.services[0].id, - 0, - arwaveOrderTx.transactionHash, - providerUrl, - consumerAccount - ) - assert(arwaveDownloadURL, 'Provider getDownloadUrl failed for arwave dataset') - try { - await downloadFile(arwaveDownloadURL) - } catch (e) { - assert.fail(`Download arwave dataset failed: ${e}`) - } - const ipfsDownloadURL = await ProviderInstance.getDownloadUrl( - resolvedIpfsAssetDdo.id, - resolvedIpfsAssetDdo.services[0].id, - 0, - ipfsOrderTx.transactionHash, - providerUrl, - consumerAccount - ) - assert(ipfsDownloadURL, 'Provider getDownloadUrl failed for ipfs dataset') - try { - await downloadFile(ipfsDownloadURL) - } catch (e) { - assert.fail(`Download ipfs dataset failed ${e}`) - } - const onchainDownloadURL = await ProviderInstance.getDownloadUrl( - resolvedOnchainAssetDdo.id, - resolvedOnchainAssetDdo.services[0].id, - 0, - onchainOrderTx.transactionHash, - providerUrl, - consumerAccount - ) - assert(onchainDownloadURL, 'Provider getDownloadUrl failed for onchain dataset') - try { - await downloadFile(onchainDownloadURL) - } catch (e) { - assert.fail(`Download onchain dataset failed ${e}`) - } - const graphqlDownloadURL = await ProviderInstance.getDownloadUrl( - resolvedGraphqlAssetDdo.id, - resolvedGraphqlAssetDdo.services[0].id, - 0, - grapqlOrderTx.transactionHash, - providerUrl, - consumerAccount - ) - assert(graphqlDownloadURL, 'Provider getDownloadUrl failed for graphql dataset') - try { - await downloadFile(graphqlDownloadURL) - } catch (e) { - assert.fail(`Download graphql dataset failed ${e}`) - } - }) +it('Should download the datasets files', async () => { + const urlDownloadUrl = await ProviderInstance.getDownloadUrl( + resolvedUrlAssetDdo.id, + resolvedUrlAssetDdo.services[0].id, + 0, + urlOrderTx.transactionHash, + providerUrl, + consumerAccount + ) + assert(urlDownloadUrl, 'Provider getDownloadUrl failed for url dataset') + try { + await downloadFile(urlDownloadUrl) + } catch (e) { + assert.fail(`Download url dataset failed: ${e}`) + } + const arwaveDownloadURL = await ProviderInstance.getDownloadUrl( + resolvedArweaveAssetDdo.id, + resolvedArweaveAssetDdo.services[0].id, + 0, + arwaveOrderTx.transactionHash, + providerUrl, + consumerAccount + ) + assert(arwaveDownloadURL, 'Provider getDownloadUrl failed for arwave dataset') + try { + await downloadFile(arwaveDownloadURL) + } catch (e) { + assert.fail(`Download arwave dataset failed: ${e}`) + } + const ipfsDownloadURL = await ProviderInstance.getDownloadUrl( + resolvedIpfsAssetDdo.id, + resolvedIpfsAssetDdo.services[0].id, + 0, + ipfsOrderTx.transactionHash, + providerUrl, + consumerAccount + ) + assert(ipfsDownloadURL, 'Provider getDownloadUrl failed for ipfs dataset') + try { + await downloadFile(ipfsDownloadURL) + } catch (e) { + assert.fail(`Download ipfs dataset failed ${e}`) + } + const onchainDownloadURL = await ProviderInstance.getDownloadUrl( + resolvedOnchainAssetDdo.id, + resolvedOnchainAssetDdo.services[0].id, + 0, + onchainOrderTx.transactionHash, + providerUrl, + consumerAccount + ) + assert(onchainDownloadURL, 'Provider getDownloadUrl failed for onchain dataset') + try { + await downloadFile(onchainDownloadURL) + } catch (e) { + assert.fail(`Download onchain dataset failed ${e}`) + } + const graphqlDownloadURL = await ProviderInstance.getDownloadUrl( + resolvedGraphqlAssetDdo.id, + resolvedGraphqlAssetDdo.services[0].id, + 0, + grapqlOrderTx.transactionHash, + providerUrl, + consumerAccount + ) + assert(graphqlDownloadURL, 'Provider getDownloadUrl failed for graphql dataset') + try { + await downloadFile(graphqlDownloadURL) + } catch (e) { + assert.fail(`Download graphql dataset failed ${e}`) + } +}) - it('Should update url dataset', async () => { - resolvedUrlAssetDdo.metadata.name = 'updated url asset name' - const updateUrlTx = await updateAssetMetadata( - publisherAccount, - resolvedUrlAssetDdo, - providerUrl, - aquarius - ) - assert(updateUrlTx, 'Failed to update url asset metadata') - }) +it('Should update url dataset', async () => { + resolvedUrlAssetDdo.metadata.name = 'updated url asset name' + const updateUrlTx = await updateAssetMetadata( + publisherAccount, + resolvedUrlAssetDdo, + providerUrl, + aquarius + ) + assert(updateUrlTx, 'Failed to update url asset metadata') +}) - it('Should update arweave dataset', async () => { - resolvedArweaveAssetDdo.metadata.name = 'updated arwave asset name' - const updateArwaveTx = await updateAssetMetadata( - publisherAccount, - resolvedArweaveAssetDdo, - providerUrl, - aquarius - ) - assert(updateArwaveTx, 'Failed to update arwave asset metadata') - }) +it('Should update arweave dataset', async () => { + resolvedArweaveAssetDdo.metadata.name = 'updated arwave asset name' + const updateArwaveTx = await updateAssetMetadata( + publisherAccount, + resolvedArweaveAssetDdo, + providerUrl, + aquarius + ) + assert(updateArwaveTx, 'Failed to update arwave asset metadata') +}) - it('Should update ipfs dataset', async () => { - resolvedIpfsAssetDdo.metadata.name = 'updated ipfs asset name' - const updateIpfsTx = await updateAssetMetadata( - publisherAccount, - resolvedIpfsAssetDdo, - providerUrl, - aquarius - ) - assert(updateIpfsTx, 'Failed to update ipfs asset metadata') - }) +it('Should update ipfs dataset', async () => { + resolvedIpfsAssetDdo.metadata.name = 'updated ipfs asset name' + const updateIpfsTx = await updateAssetMetadata( + publisherAccount, + resolvedIpfsAssetDdo, + providerUrl, + aquarius + ) + assert(updateIpfsTx, 'Failed to update ipfs asset metadata') +}) - it('Should update onchain dataset', async () => { - resolvedOnchainAssetDdo.metadata.name = 'updated onchain asset name' - const updateOnchainTx = await updateAssetMetadata( - publisherAccount, - resolvedOnchainAssetDdo, - providerUrl, - aquarius - ) - assert(updateOnchainTx, 'Failed to update ipfs asset metadata') - }) +it('Should update onchain dataset', async () => { + resolvedOnchainAssetDdo.metadata.name = 'updated onchain asset name' + const updateOnchainTx = await updateAssetMetadata( + publisherAccount, + resolvedOnchainAssetDdo, + providerUrl, + aquarius + ) + assert(updateOnchainTx, 'Failed to update ipfs asset metadata') +}) - it('Should update graphql dataset', async () => { - resolvedGraphqlAssetDdo.metadata.name = 'updated graphql asset name' - const updateGraphqlTx = await updateAssetMetadata( - publisherAccount, - resolvedGraphqlAssetDdo, - providerUrl, - aquarius - ) - assert(updateGraphqlTx, 'Failed to update graphql asset metadata') - }) +it('Should update graphql dataset', async () => { + resolvedGraphqlAssetDdo.metadata.name = 'updated graphql asset name' + const updateGraphqlTx = await updateAssetMetadata( + publisherAccount, + resolvedGraphqlAssetDdo, + providerUrl, + aquarius + ) + assert(updateGraphqlTx, 'Failed to update graphql asset metadata') +}) - delay(10000) // let's wait for aquarius to index the updated ddo's +delay(10000) // let's wait for aquarius to index the updated ddo's - it('Should resolve updated datasets', async () => { - resolvedUrlAssetDdoAfterUpdate = await aquarius.waitForAqua(urlAssetId) - assert(resolvedUrlAssetDdoAfterUpdate, 'Cannot fetch url DDO from Aquarius') +it('Should resolve updated datasets', async () => { + resolvedUrlAssetDdoAfterUpdate = await aquarius.waitForAqua(urlAssetId) + assert(resolvedUrlAssetDdoAfterUpdate, 'Cannot fetch url DDO from Aquarius') - resolvedArweaveAssetDdoAfterUpdate = await aquarius.waitForAqua(arweaveAssetId) - assert(resolvedArweaveAssetDdoAfterUpdate, 'Cannot fetch arwave DDO from Aquarius') + resolvedArweaveAssetDdoAfterUpdate = await aquarius.waitForAqua(arweaveAssetId) + assert(resolvedArweaveAssetDdoAfterUpdate, 'Cannot fetch arwave DDO from Aquarius') - resolvedIpfsAssetDdoAfterUpdate = await aquarius.waitForAqua(ipfsAssetId) - assert(resolvedIpfsAssetDdoAfterUpdate, 'Cannot fetch ipfs DDO from Aquarius') + resolvedIpfsAssetDdoAfterUpdate = await aquarius.waitForAqua(ipfsAssetId) + assert(resolvedIpfsAssetDdoAfterUpdate, 'Cannot fetch ipfs DDO from Aquarius') - resolvedOnchainAssetDdoAfterUpdate = await aquarius.waitForAqua(onchainAssetId) - assert(resolvedOnchainAssetDdoAfterUpdate, 'Cannot fetch onchain DDO from Aquarius') + resolvedOnchainAssetDdoAfterUpdate = await aquarius.waitForAqua(onchainAssetId) + assert(resolvedOnchainAssetDdoAfterUpdate, 'Cannot fetch onchain DDO from Aquarius') - resolvedGraphqlAssetDdoAfterUpdate = await aquarius.waitForAqua(grapqlAssetId) - assert(resolvedGraphqlAssetDdoAfterUpdate, 'Cannot fetch onchain DDO from Aquarius') - }) + resolvedGraphqlAssetDdoAfterUpdate = await aquarius.waitForAqua(grapqlAssetId) + assert(resolvedGraphqlAssetDdoAfterUpdate, 'Cannot fetch onchain DDO from Aquarius') })