Skip to content

chore: use ERC20 subscriptions instead of eventually to check balances #1289

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
wants to merge 12 commits into
base: master
Choose a base branch
from
Draft

chore: use ERC20 subscriptions instead of eventually to check balances #1289

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
d312a07
Use ERC20 subscriptions instead of eventually to check balances
2-towns Jun 24, 2025
bf5ae2e
Enable logs because the test seems to fail occasionally.
2-towns Jun 25, 2025
3d7a4b7
Check exact balances using ERC20 transfer subscription
2-towns Jul 1, 2025
f3311cc
Fail test immediately on first check failure
2-towns Jul 2, 2025
69b0bf3
Add a template to stop the test when a storage request fails
2-towns Jul 2, 2025
ff0de4d
Verify that the provider is hosting the request by checking the slots…
2-towns Jul 2, 2025
8f415be
Check provider precise balance
2-towns Jul 3, 2025
5f8a6a9
Refactor and adjust test timeout durations
2-towns Jul 7, 2025
42422e5
Reduce the colleral for the first availability
2-towns Jul 7, 2025
24f9454
Add more delay to give more time to get the request failed event
2-towns Jul 7, 2025
6a8445d
Restore duration value
2-towns Jul 7, 2025
881a32f
Stop the test when the request fails
2-towns Jul 7, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
37 changes: 11 additions & 26 deletions tests/integration/1_minute/testecbug.nim
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,7 @@ import ../marketplacesuite
import ../nodeconfigs
import ../hardhatconfig

marketplacesuite(
name = "Bug #821 - node crashes during erasure coding", stopOnRequestFail = true
):
marketplacesuite(name = "Bug #821 - node crashes during erasure coding"):
test "should be able to create storage request and download dataset",
NodeConfigs(
clients: CodexConfigs
Expand All @@ -18,42 +16,29 @@ marketplacesuite(
providers: CodexConfigs.init(nodes = 0).some,
):
let
pricePerBytePerSecond = 1.u256
duration = 20.periods
collateralPerByte = 1.u256
expiry = 10.periods
data = await RandomChunker.example(blocks = 8)
client = clients()[0]
clientApi = client.client
data = await RandomChunker.example(blocks = 8)

let (purchaseId, requestId) = await requestStorage(
clientApi, duration = duration, expiry = expiry, data = data.some
)

let cid = (await clientApi.upload(data)).get
let storageRequestedEvent = newAsyncEvent()

var requestId = none RequestId
proc onStorageRequested(eventResult: ?!StorageRequested) =
assert not eventResult.isErr
requestId = some (!eventResult).requestId
storageRequestedEvent.fire()

let subscription = await marketplace.subscribe(StorageRequested, onStorageRequested)

# client requests storage but requires multiple slots to host the content
let id = await clientApi.requestStorage(
cid,
duration = duration,
pricePerBytePerSecond = pricePerBytePerSecond,
expiry = expiry,
collateralPerByte = collateralPerByte,
nodes = 3,
tolerance = 1,
)

check eventually(requestId.isSome, timeout = expiry.int * 1000)
await marketplaceSubscribe(StorageRequested, onStorageRequested)
await storageRequestedEvent.wait().wait(timeout = chronos.seconds(expiry.int64))

let
request = await marketplace.getRequest(requestId.get)
request = await marketplace.getRequest(requestId)
cidFromRequest = request.content.cid
downloaded = await clientApi.downloadBytes(cidFromRequest, local = true)

check downloaded.isOk
check downloaded.get.toHex == data.toHex

await subscription.unsubscribe()
Loading
Loading