nim-codex/codex/sales/states/filling.nim

import ../../logutils
import ../../market
import ../statemachine
import ../salesagent
import ./errorhandling
import ./filled
import ./cancelled
import ./failed
import ./ignored
import ./errored

logScope:
  topics = "marketplace sales filling"

type
  SaleFilling* = ref object of ErrorHandlingState
    proof*: Groth16Proof

method `$`*(state: SaleFilling): string = "SaleFilling"

method onCancelled*(state: SaleFilling, request: StorageRequest): ?State =
  return some State(SaleCancelled())

method onFailed*(state: SaleFilling, request: StorageRequest): ?State =
  return some State(SaleFailed())

method run(state: SaleFilling, machine: Machine): Future[?State] {.async.} =
  let data = SalesAgent(machine).data
  let market = SalesAgent(machine).context.market
  without (collateral =? data.request.?ask.?collateral):
    raiseAssert "Request not set"

  logScope:
    requestId = data.requestId
    slotIndex = data.slotIndex

  debug "Filling slot"
  try:
    await market.fillSlot(data.requestId, data.slotIndex, state.proof, collateral)
  except MarketError as e:
    if e.msg.contains "Slot is not free":
      debug "Slot is already filled, ignoring slot"
      return some State( SaleIgnored(reprocessSlot: false, returnBytes: true) )
    else:
      return some State( SaleErrored(error: e) )
  # other CatchableErrors are handled "automatically" by the ErrorHandlingState

  return some State(SaleFilled())