logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-01-09 08:53:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Increase timeout and replace eventually by subscription

Browse Source
This commit is contained in:
Arnaud 2025-06-10 11:03:02 +02:00
parent 18bbe61e45
commit 33cb0c484c
No known key found for this signature in database
GPG Key ID: B8FBC178F10CA7AE
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/integration/testmarketplace.nim
View File

@ -294,10 +294,12 @@ marketplacesuite "Marketplace payouts":
let cid = (await clientApi.upload(data)).get
var slotFilledFut = Future[void].Raising([CancelledError]).init()
var slotIdxFilled = none uint64
proc onSlotFilled(eventResult: ?!SlotFilled) =
assert not eventResult.isErr
slotIdxFilled = some (!eventResult).slotIndex
slotFilledFut.complete()
var requestCancelledFut = Future[void].Raising([CancelledError]).init()
proc onRequestCancelled(eventResult: ?!RequestCancelled) {.raises: [].} =
@ -320,12 +322,9 @@ marketplacesuite "Marketplace payouts":
)
# wait until one slot is filled
check eventually(slotIdxFilled.isSome, timeout = expiry.int * 1000)
let slotId = slotId(!(await clientApi.requestId(id)), !slotIdxFilled)
await slotFilledFut.wait(timeout = chronos.seconds(expiry.int + 10))
# check eventually(
# await providerApi.saleStateIs(slotId, "SaleCancelled"), timeout = expiry.int * 1000, pollInterval = 100
# )
let slotId = slotId(!(await clientApi.requestId(id)), !slotIdxFilled)
# wait until sale is cancelled
await ethProvider.advanceTime(expiry.u256)
@ -336,12 +335,12 @@ marketplacesuite "Marketplace payouts":
let pricePerSlotPerSecond = minPricePerBytePerSecond * slotSize
check eventually (
check eventuallySafe (
let endBalanceProvider = (await token.balanceOf(provider.ethAccount))
endBalanceProvider > startBalanceProvider and
endBalanceProvider < startBalanceProvider + expiry.u256 * pricePerSlotPerSecond
)
check eventually(
check eventuallySafe(
(
let endBalanceClient = (await token.balanceOf(client.ethAccount))
let endBalanceProvider = (await token.balanceOf(provider.ethAccount))
@ -441,7 +440,7 @@ marketplacesuite "Marketplace payouts":
availability.totalRemainingCollateral ==
availableSlots * slotSize * minPricePerBytePerSecond,
timeout = 30 * 1000,
timeout = 3 * 60 * 1000,
)
await startedSubscription.unsubscribe()