mirror of
https://github.com/codex-storage/nim-codex.git
synced 2025-02-22 17:48:24 +00:00
6270e8ef1f
Because availability filtering on push was removed, when availability is added and past storage request events are queried, those requests need to be filtered by availability before being added to the queue.
37 lines
959 B
Nim
37 lines
959 B
Nim
import pkg/chronos
|
|
import pkg/chronicles
|
|
import ../statemachine
|
|
import ../salesagent
|
|
import ./errorhandling
|
|
import ./cancelled
|
|
import ./failed
|
|
|
|
logScope:
|
|
topics = "marketplace sales finished"
|
|
|
|
type
|
|
SaleFinished* = ref object of ErrorHandlingState
|
|
|
|
method `$`*(state: SaleFinished): string = "SaleFinished"
|
|
|
|
method onCancelled*(state: SaleFinished, request: StorageRequest): ?State =
|
|
return some State(SaleCancelled())
|
|
|
|
method onFailed*(state: SaleFinished, request: StorageRequest): ?State =
|
|
return some State(SaleFailed())
|
|
|
|
method run*(state: SaleFinished, machine: Machine): Future[?State] {.async.} =
|
|
let agent = SalesAgent(machine)
|
|
let data = agent.data
|
|
|
|
without request =? data.request:
|
|
raiseAssert "no sale request"
|
|
|
|
without slotIndex =? data.slotIndex:
|
|
raiseAssert("no slot index assigned")
|
|
|
|
info "Slot finished and paid out", requestId = $data.requestId, slotIndex
|
|
|
|
if onCleanUp =? agent.onCleanUp:
|
|
await onCleanUp()
|