66 lines
2.2 KiB
Nim
66 lines
2.2 KiB
Nim
import pkg/ethers
|
|
import pkg/ethers/testing
|
|
import ../storageproofs/timing/proofs
|
|
import ./storage
|
|
|
|
export proofs
|
|
|
|
type
|
|
OnChainProofs* = ref object of Proofs
|
|
storage: Storage
|
|
pollInterval*: Duration
|
|
ProofsSubscription = proofs.Subscription
|
|
EventSubscription = ethers.Subscription
|
|
OnChainProofsSubscription = ref object of ProofsSubscription
|
|
eventSubscription: EventSubscription
|
|
|
|
const DefaultPollInterval = 3.seconds
|
|
|
|
proc new*(_: type OnChainProofs, storage: Storage): OnChainProofs =
|
|
OnChainProofs(storage: storage, pollInterval: DefaultPollInterval)
|
|
|
|
method periodicity*(proofs: OnChainProofs): Future[Periodicity] {.async.} =
|
|
let period = await proofs.storage.proofPeriod()
|
|
return Periodicity(seconds: period)
|
|
|
|
method isProofRequired*(proofs: OnChainProofs,
|
|
id: SlotId): Future[bool] {.async.} =
|
|
try:
|
|
return await proofs.storage.isProofRequired(id)
|
|
except JsonRpcProviderError as e:
|
|
if e.revertReason == "Slot empty":
|
|
return false
|
|
raise e
|
|
|
|
method willProofBeRequired*(proofs: OnChainProofs,
|
|
id: SlotId): Future[bool] {.async.} =
|
|
try:
|
|
return await proofs.storage.willProofBeRequired(id)
|
|
except JsonRpcProviderError as e:
|
|
if e.revertReason == "Slot empty":
|
|
return false
|
|
raise e
|
|
|
|
method getProofEnd*(proofs: OnChainProofs,
|
|
id: SlotId): Future[UInt256] {.async.} =
|
|
try:
|
|
return await proofs.storage.proofEnd(id)
|
|
except ValueError:
|
|
return 0.u256
|
|
|
|
method submitProof*(proofs: OnChainProofs,
|
|
id: SlotId,
|
|
proof: seq[byte]) {.async.} =
|
|
await proofs.storage.submitProof(id, proof)
|
|
|
|
method subscribeProofSubmission*(proofs: OnChainProofs,
|
|
callback: OnProofSubmitted):
|
|
Future[ProofsSubscription] {.async.} =
|
|
proc onEvent(event: ProofSubmitted) {.upraises: [].} =
|
|
callback(event.id, event.proof)
|
|
let subscription = await proofs.storage.subscribe(ProofSubmitted, onEvent)
|
|
return OnChainProofsSubscription(eventSubscription: subscription)
|
|
|
|
method unsubscribe*(subscription: OnChainProofsSubscription) {.async, upraises:[].} =
|
|
await subscription.eventSubscription.unsubscribe()
|