1
0
mirror of https://github.com/oceanprotocol/ocean.js.git synced 2024-11-26 20:39:05 +01:00

Split coupled tests to fix timeout issues (#1827)

* split coupled tests
This commit is contained in:
Bogdan Fazakas 2024-06-25 16:34:55 +02:00 committed by GitHub
parent 865891c961
commit e257a64053
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -197,7 +197,7 @@ describe('Publish consume test', async () => {
) )
}) })
it('Should publish the assets', async () => { it('Should publish url asset', async () => {
urlAssetId = await createAsset( urlAssetId = await createAsset(
'UrlDatatoken', 'UrlDatatoken',
'URLDT', 'URLDT',
@ -209,19 +209,9 @@ describe('Publish consume test', async () => {
aquarius aquarius
) )
assert(urlAssetId, 'Failed to publish url DDO') assert(urlAssetId, 'Failed to publish url DDO')
})
arweaveAssetId = await createAsset( it('Should publish ipfs asset', async () => {
'ArwaveDatatoken',
'ARWAVEDT',
publisherAccount,
arweaveFile,
assetDdo,
providerUrl,
addresses.ERC721Factory,
aquarius
)
assert(urlAssetId, 'Failed to arwave publish DDO')
ipfsAssetId = await createAsset( ipfsAssetId = await createAsset(
'IpfsDatatoken', 'IpfsDatatoken',
'IPFSDT', 'IPFSDT',
@ -233,7 +223,23 @@ describe('Publish consume test', async () => {
aquarius aquarius
) )
assert(urlAssetId, 'Failed to publish ipfs DDO') assert(urlAssetId, '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 = { const chainFile: Smartcontract = {
type: 'smartcontract', type: 'smartcontract',
address: addresses.Router, address: addresses.Router,
@ -246,11 +252,10 @@ describe('Publish consume test', async () => {
}, },
chainId: 8996 chainId: 8996
} }
onchainFile.files[0] = chainFile onchainFile.files[0] = chainFile
onchainAssetId = await createAsset( onchainAssetId = await createAsset(
'IpfsDatatoken', 'ChainDatatoken',
'IPFSDT', 'CHAINDT',
publisherAccount, publisherAccount,
onchainFile, onchainFile,
assetDdo, assetDdo,
@ -259,10 +264,12 @@ describe('Publish consume test', async () => {
aquarius aquarius
) )
assert(onchainAssetId, 'Failed to publish onchain DDO') assert(onchainAssetId, 'Failed to publish onchain DDO')
})
it('Should publish graphql asset', async () => {
grapqlAssetId = await createAsset( grapqlAssetId = await createAsset(
'IpfsDatatoken', 'GraphDatatoken',
'IPFSDT', 'GRAPHDT',
publisherAccount, publisherAccount,
grapqlFile, grapqlFile,
assetDdo, assetDdo,
@ -335,9 +342,8 @@ describe('Publish consume test', async () => {
assert(graphqlMintTx, 'Failed minting graphql datatoken to consumer.') assert(graphqlMintTx, 'Failed minting graphql datatoken to consumer.')
}) })
it('Should order the datasets', async () => { it('Should order url dataset', async () => {
datatoken = new Datatoken(consumerAccount, config.chainId) datatoken = new Datatoken(consumerAccount, config.chainId)
urlOrderTx = await orderAsset( urlOrderTx = await orderAsset(
resolvedUrlAssetDdo.id, resolvedUrlAssetDdo.id,
resolvedUrlAssetDdo.services[0].datatokenAddress, resolvedUrlAssetDdo.services[0].datatokenAddress,
@ -348,7 +354,9 @@ describe('Publish consume test', async () => {
providerUrl providerUrl
) )
assert(urlOrderTx, 'Ordering url dataset failed.') assert(urlOrderTx, 'Ordering url dataset failed.')
}).timeout(40000)
it('Should order arweave dataset', async () => {
arwaveOrderTx = await orderAsset( arwaveOrderTx = await orderAsset(
resolvedArweaveAssetDdo.id, resolvedArweaveAssetDdo.id,
resolvedArweaveAssetDdo.services[0].datatokenAddress, resolvedArweaveAssetDdo.services[0].datatokenAddress,
@ -359,18 +367,9 @@ describe('Publish consume test', async () => {
providerUrl providerUrl
) )
assert(arwaveOrderTx, 'Ordering arwave dataset failed.') assert(arwaveOrderTx, 'Ordering arwave dataset failed.')
}).timeout(40000)
onchainOrderTx = await orderAsset( it('Should order ipfs dataset', async () => {
resolvedOnchainAssetDdo.id,
resolvedOnchainAssetDdo.services[0].datatokenAddress,
await consumerAccount.getAddress(),
resolvedOnchainAssetDdo.services[0].id,
0,
datatoken,
providerUrl
)
assert(onchainOrderTx, 'Ordering onchain dataset failed.')
ipfsOrderTx = await orderAsset( ipfsOrderTx = await orderAsset(
resolvedIpfsAssetDdo.id, resolvedIpfsAssetDdo.id,
resolvedIpfsAssetDdo.services[0].datatokenAddress, resolvedIpfsAssetDdo.services[0].datatokenAddress,
@ -381,7 +380,22 @@ describe('Publish consume test', async () => {
providerUrl providerUrl
) )
assert(ipfsOrderTx, 'Ordering ipfs dataset failed.') 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( grapqlOrderTx = await orderAsset(
resolvedGraphqlAssetDdo.id, resolvedGraphqlAssetDdo.id,
resolvedGraphqlAssetDdo.services[0].datatokenAddress, resolvedGraphqlAssetDdo.services[0].datatokenAddress,
@ -392,7 +406,7 @@ describe('Publish consume test', async () => {
providerUrl providerUrl
) )
assert(grapqlOrderTx, 'Ordering graphql dataset failed.') assert(grapqlOrderTx, 'Ordering graphql dataset failed.')
}).timeout(40000) })
it('Should download the datasets files', async () => { it('Should download the datasets files', async () => {
const urlDownloadUrl = await ProviderInstance.getDownloadUrl( const urlDownloadUrl = await ProviderInstance.getDownloadUrl(
@ -467,7 +481,7 @@ describe('Publish consume test', async () => {
} }
}) })
it('Should update datasets metadata', async () => { it('Should update url dataset', async () => {
resolvedUrlAssetDdo.metadata.name = 'updated url asset name' resolvedUrlAssetDdo.metadata.name = 'updated url asset name'
const updateUrlTx = await updateAssetMetadata( const updateUrlTx = await updateAssetMetadata(
publisherAccount, publisherAccount,
@ -476,7 +490,9 @@ describe('Publish consume test', async () => {
aquarius aquarius
) )
assert(updateUrlTx, 'Failed to update url asset metadata') assert(updateUrlTx, 'Failed to update url asset metadata')
})
it('Should update arweave dataset', async () => {
resolvedArweaveAssetDdo.metadata.name = 'updated arwave asset name' resolvedArweaveAssetDdo.metadata.name = 'updated arwave asset name'
const updateArwaveTx = await updateAssetMetadata( const updateArwaveTx = await updateAssetMetadata(
publisherAccount, publisherAccount,
@ -485,7 +501,9 @@ describe('Publish consume test', async () => {
aquarius aquarius
) )
assert(updateArwaveTx, 'Failed to update arwave asset metadata') assert(updateArwaveTx, 'Failed to update arwave asset metadata')
})
it('Should update ipfs dataset', async () => {
resolvedIpfsAssetDdo.metadata.name = 'updated ipfs asset name' resolvedIpfsAssetDdo.metadata.name = 'updated ipfs asset name'
const updateIpfsTx = await updateAssetMetadata( const updateIpfsTx = await updateAssetMetadata(
publisherAccount, publisherAccount,
@ -494,7 +512,9 @@ describe('Publish consume test', async () => {
aquarius aquarius
) )
assert(updateIpfsTx, 'Failed to update ipfs asset metadata') assert(updateIpfsTx, 'Failed to update ipfs asset metadata')
})
it('Should update onchain dataset', async () => {
resolvedOnchainAssetDdo.metadata.name = 'updated onchain asset name' resolvedOnchainAssetDdo.metadata.name = 'updated onchain asset name'
const updateOnchainTx = await updateAssetMetadata( const updateOnchainTx = await updateAssetMetadata(
publisherAccount, publisherAccount,
@ -503,7 +523,9 @@ describe('Publish consume test', async () => {
aquarius aquarius
) )
assert(updateOnchainTx, 'Failed to update ipfs asset metadata') assert(updateOnchainTx, 'Failed to update ipfs asset metadata')
})
it('Should update graphql dataset', async () => {
resolvedGraphqlAssetDdo.metadata.name = 'updated graphql asset name' resolvedGraphqlAssetDdo.metadata.name = 'updated graphql asset name'
const updateGraphqlTx = await updateAssetMetadata( const updateGraphqlTx = await updateAssetMetadata(
publisherAccount, publisherAccount,