codex-storage
/
nim-codex
mirror of https://github.com/codex-storage/nim-codex.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

market: use `pending` blocktag when querying onchain state

This commit is contained in:
Mark Spanbroek 2024-02-22 06:58:50 +01:00
parent 3a6db45e14
commit ed47edfe69
No known key found for this signature in database
GPG Key ID: FBE3E9548D427C00
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
codex/contracts/market.nim
View File

@ -60,7 +60,8 @@ method proofDowntime*(market: OnChainMarket): Future[uint8] {.async.} =
return config.proofs.downtime return config.proofs.downtime
method getPointer*(market: OnChainMarket, slotId: SlotId): Future[uint8] {.async.} = method getPointer*(market: OnChainMarket, slotId: SlotId): Future[uint8] {.async.} =
return await market.contract.getPointer(slotId) let overrides = CallOverrides(blockTag: some BlockTag.pending)
return await market.contract.getPointer(slotId, overrides)
method myRequests*(market: OnChainMarket): Future[seq[RequestId]] {.async.} = method myRequests*(market: OnChainMarket): Future[seq[RequestId]] {.async.} =
return await market.contract.myRequests return await market.contract.myRequests
@ -88,7 +89,8 @@ method getRequest(market: OnChainMarket,
method requestState*(market: OnChainMarket, method requestState*(market: OnChainMarket,
requestId: RequestId): Future[?RequestState] {.async.} = requestId: RequestId): Future[?RequestState] {.async.} =
try: try:
return some await market.contract.requestState(requestId) let overrides = CallOverrides(blockTag: some BlockTag.pending)
return some await market.contract.requestState(requestId, overrides)
except ProviderError as e: except ProviderError as e:
if e.revertReason.contains("Unknown request"): if e.revertReason.contains("Unknown request"):
return none RequestState return none RequestState
@ -96,7 +98,8 @@ method requestState*(market: OnChainMarket,
method slotState*(market: OnChainMarket, method slotState*(market: OnChainMarket,
slotId: SlotId): Future[SlotState] {.async.} = slotId: SlotId): Future[SlotState] {.async.} =
return await market.contract.slotState(slotId) let overrides = CallOverrides(blockTag: some BlockTag.pending)
return await market.contract.slotState(slotId, overrides)
method getRequestEnd*(market: OnChainMarket, method getRequestEnd*(market: OnChainMarket,
id: RequestId): Future[SecondsSince1970] {.async.} = id: RequestId): Future[SecondsSince1970] {.async.} =
@ -140,7 +143,8 @@ method withdrawFunds(market: OnChainMarket,
method isProofRequired*(market: OnChainMarket, method isProofRequired*(market: OnChainMarket,
id: SlotId): Future[bool] {.async.} = id: SlotId): Future[bool] {.async.} =
try: try:
return await market.contract.isProofRequired(id) let overrides = CallOverrides(blockTag: some BlockTag.pending)
return await market.contract.isProofRequired(id, overrides)
except ProviderError as e: except ProviderError as e:
if e.revertReason.contains("Slot is free"): if e.revertReason.contains("Slot is free"):
return false return false
@ -149,14 +153,16 @@ method isProofRequired*(market: OnChainMarket,
method willProofBeRequired*(market: OnChainMarket, method willProofBeRequired*(market: OnChainMarket,
id: SlotId): Future[bool] {.async.} = id: SlotId): Future[bool] {.async.} =
try: try:
return await market.contract.willProofBeRequired(id) let overrides = CallOverrides(blockTag: some BlockTag.pending)
return await market.contract.willProofBeRequired(id, overrides)
except ProviderError as e: except ProviderError as e:
if e.revertReason.contains("Slot is free"): if e.revertReason.contains("Slot is free"):
return false return false
raise e raise e
method getChallenge*(market: OnChainMarket, id: SlotId): Future[ProofChallenge] {.async.} = method getChallenge*(market: OnChainMarket, id: SlotId): Future[ProofChallenge] {.async.} =
return await market.contract.getChallenge(id) let overrides = CallOverrides(blockTag: some BlockTag.pending)
return await market.contract.getChallenge(id, overrides)
method submitProof*(market: OnChainMarket, method submitProof*(market: OnChainMarket,
id: SlotId, id: SlotId,