mirror of
https://github.com/status-im/nim-dagger.git
synced 2025-02-27 13:50:47 +00:00
0107eb06fe
* Change cid format from string to bytes for the marketplace * refactor: marketplace custom errors handling * chore: update contracts repo * chore: update contracts submodule * Update contracts submodule * Initialize the Cid using init function * Restorage serialize pragma * Use Cid object instead of buffer * Simplify cid usage * Simplify cid usage * bump codex-contracts-eth after PR merge, formatting * fix rebase * collateralPerByte => collateralPerSlot --------- Co-authored-by: Adam Uhlíř <adam@uhlir.dev> Co-authored-by: Eric <5089238+emizzle@users.noreply.github.com>
59 lines
2.2 KiB
Nim
59 lines
2.2 KiB
Nim
from pkg/libp2p import Cid, init
|
|
import ../examples
|
|
import ./marketplacesuite
|
|
import ./nodeconfigs
|
|
import ./hardhatconfig
|
|
|
|
marketplacesuite "Bug #821 - node crashes during erasure coding":
|
|
test "should be able to create storage request and download dataset",
|
|
NodeConfigs(
|
|
clients: CodexConfigs
|
|
.init(nodes = 1)
|
|
# .debug() # uncomment to enable console log output.debug()
|
|
.withLogFile()
|
|
# uncomment to output log file to tests/integration/logs/<start_datetime> <suite_name>/<test_name>/<node_role>_<node_idx>.log
|
|
.withLogTopics("node", "erasure", "marketplace").some,
|
|
providers: CodexConfigs.init(nodes = 0)
|
|
# .debug() # uncomment to enable console log output
|
|
# .withLogFile() # uncomment to output log file to tests/integration/logs/<start_datetime> <suite_name>/<test_name>/<node_role>_<node_idx>.log
|
|
# .withLogTopics("node", "marketplace", "sales", "reservations", "node", "proving", "clock")
|
|
.some,
|
|
):
|
|
let pricePerBytePerSecond = 1.u256
|
|
let duration = 20.periods
|
|
let collateralPerByte = 1.u256
|
|
let expiry = 10.periods
|
|
let data = await RandomChunker.example(blocks = 8)
|
|
let client = clients()[0]
|
|
let clientApi = client.client
|
|
|
|
let cid = clientApi.upload(data).get
|
|
|
|
var requestId = none RequestId
|
|
proc onStorageRequested(eventResult: ?!StorageRequested) =
|
|
assert not eventResult.isErr
|
|
requestId = some (!eventResult).requestId
|
|
|
|
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)
|
|
|
|
let request = await marketplace.getRequest(requestId.get)
|
|
let cidFromRequest = request.content.cid
|
|
let downloaded = await clientApi.downloadBytes(cidFromRequest, local = true)
|
|
check downloaded.isOk
|
|
check downloaded.get.toHex == data.toHex
|
|
|
|
await subscription.unsubscribe()
|