nim-codex/codex/sales/states/errored.nim

import pkg/questionable
import pkg/questionable/results
import pkg/upraises

import ../statemachine
import ../salesagent
import ../../logutils
import ../../utils/exceptions

logScope:
  topics = "marketplace sales errored"

type SaleErrored* = ref object of SaleState
  error*: ref CatchableError
  reprocessSlot*: bool

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

method onError*(state: SaleState, err: ref CatchableError): ?State {.upraises:[].} =
  error "error during SaleErrored run", error = err.msg

method run*(state: SaleErrored, machine: Machine): Future[?State] {.async.} =
  let agent = SalesAgent(machine)
  let data = agent.data
  let context = agent.context

  error "Sale error", error=state.error.msgDetail, requestId = data.requestId, slotIndex = data.slotIndex

  if onClear =? context.onClear and
      request =? data.request:
    onClear(request, data.slotIndex)

  if onCleanUp =? agent.onCleanUp:
    await onCleanUp(returnBytes = true, reprocessSlot = state.reprocessSlot)