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

add some delays before resolving datasets

Browse Source
This commit is contained in:
Bogdan Fazakas 2023-05-22 08:40:42 +03:00
parent a227004d19
commit 09d15b3947
2 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/integration/ComputeFlow.test.ts
View File

@ -345,6 +345,8 @@ describe('Compute flow tests', async () => {
) )
}) })
delay(10000)
it('should resolve published datasets and algorithms', async () => { it('should resolve published datasets and algorithms', async () => {
resolvedDdoWith5mTimeout = await aquarius.waitForAqua(ddoWith5mTimeoutId) resolvedDdoWith5mTimeout = await aquarius.waitForAqua(ddoWith5mTimeoutId)
assert(resolvedDdoWith5mTimeout, 'Cannot fetch DDO from Aquarius') assert(resolvedDdoWith5mTimeout, 'Cannot fetch DDO from Aquarius')

14
test/integration/PublishFlows.test.ts
View File

@ -31,6 +31,8 @@ describe('Publish tests', async () => {
let nft: Nft let nft: Nft
let factory: NftFactory let factory: NftFactory
let publisherAccount: Signer let publisherAccount: Signer
let fixedPricedDID: string
let dispenserDID: string
const assetUrl: Files = { const assetUrl: Files = {
datatokenAddress: '0x0', datatokenAddress: '0x0',
@ -167,6 +169,7 @@ describe('Publish tests', async () => {
'did:op:' + 'did:op:' +
SHA256(ethers.utils.getAddress(nftAddress) + config.chainId.toString(10)) SHA256(ethers.utils.getAddress(nftAddress) + config.chainId.toString(10))
fixedPricedDID = fixedPriceDdo.id
const isAssetValid: ValidateMetadata = await aquarius.validate(fixedPriceDdo) const isAssetValid: ValidateMetadata = await aquarius.validate(fixedPriceDdo)
assert(isAssetValid.valid === true, 'Published asset is not valid') assert(isAssetValid.valid === true, 'Published asset is not valid')
const encryptedResponse = await ProviderInstance.encrypt( const encryptedResponse = await ProviderInstance.encrypt(
@ -186,7 +189,10 @@ describe('Publish tests', async () => {
isAssetValid.hash, isAssetValid.hash,
[] []
) )
const resolvedDDO = await aquarius.waitForAqua(fixedPriceDdo.id) })
it('should resolve the fixed price dataset', async () => {
const resolvedDDO = await aquarius.waitForAqua(fixedPricedDID)
assert(resolvedDDO, 'Cannot fetch DDO from Aquarius') assert(resolvedDDO, 'Cannot fetch DDO from Aquarius')
}) })
@ -252,6 +258,7 @@ describe('Publish tests', async () => {
dispenserDdo.id = dispenserDdo.id =
'did:op:' + 'did:op:' +
SHA256(ethers.utils.getAddress(nftAddress) + config.chainId.toString(10)) SHA256(ethers.utils.getAddress(nftAddress) + config.chainId.toString(10))
dispenserDID = dispenserDdo.id
const isAssetValid: ValidateMetadata = await aquarius.validate(dispenserDdo) const isAssetValid: ValidateMetadata = await aquarius.validate(dispenserDdo)
assert(isAssetValid.valid === true, 'Published asset is not valid') assert(isAssetValid.valid === true, 'Published asset is not valid')
@ -273,7 +280,10 @@ describe('Publish tests', async () => {
encryptedResponse, encryptedResponse,
isAssetValid.hash isAssetValid.hash
) )
const resolvedDDO = await aquarius.waitForAqua(dispenserDdo.id) })
it('should resolve the free dataset', async () => {
const resolvedDDO = await aquarius.waitForAqua(dispenserDID)
assert(resolvedDDO, 'Cannot fetch DDO from Aquarius') assert(resolvedDDO, 'Cannot fetch DDO from Aquarius')
}) })
}) })