logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-01-23 15:53:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Revert "filter past requests based on availability"

Browse Source 
This reverts commit 0c2362658b523e0de425794b1fa30ebd53bd30ae.
This commit is contained in:
Eric 2023-09-08 14:16:59 +10:00
parent 6270e8ef1f
commit 7b6f137cf4
No known key found for this signature in database
1 changed files with 14 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
codex/sales.nim
View File

@ -231,35 +231,26 @@ proc onAvailabilityAdded(sales: Sales, availability: Availability) {.async.} =
return
let requests = events.map(event =>
(
pricePerSlot: event.ask.pricePerSlot,
slots: SlotQueueItem.init(event.requestId, event.ask, event.expiry)
)
SlotQueueItem.init(event.requestId, event.ask, event.expiry)
)
trace "found past storage requested events to add to queue",
events = events.len
for (pricePerSlot, slots) in requests:
for slots in requests:
for slot in slots:
if availability =? await sales.context.reservations.findAvailability(
slot.slotSize,
slot.duration,
pricePerSlot,
slot.collateral):
if err =? queue.push(slot).errorOption:
# continue on error
if err of QueueNotRunningError:
warn "cannot push items to queue, queue is not running"
elif err of NoMatchingAvailabilityError:
info "slot in queue had no matching availabilities, ignoring"
elif err of SlotsOutOfRangeError:
warn "Too many slots, cannot add to queue"
elif err of SlotQueueItemExistsError:
trace "item already exists, ignoring"
discard
else: raise err
if err =? queue.push(slot).errorOption:
# continue on error
if err of QueueNotRunningError:
warn "cannot push items to queue, queue is not running"
elif err of NoMatchingAvailabilityError:
info "slot in queue had no matching availabilities, ignoring"
elif err of SlotsOutOfRangeError:
warn "Too many slots, cannot add to queue"
elif err of SlotQueueItemExistsError:
trace "item already exists, ignoring"
discard
else: raise err
except CatchableError as e:
warn "Error adding request to SlotQueue", error = e.msg