Skip to content

Commit

Permalink
Merge pull request #3966 from rubyforgood/inventory-aggregate-method
Browse files Browse the repository at this point in the history
Add event_time in inventory method
  • Loading branch information
awwaiid authored Dec 17, 2023
2 parents 3f7ffec + 28c96b0 commit 8610d17
Showing 1 changed file with 4 additions and 8 deletions.
12 changes: 4 additions & 8 deletions app/events/inventory_aggregate.rb
Original file line number Diff line number Diff line change
Expand Up @@ -9,17 +9,13 @@ def on(*event_types, &block)
end

# @param organization_id [Integer]
# @param first_event [Integer]
# @param last_event [Integer]
# @param event_time [DateTime]
# @param validate [Boolean]
# @return [EventTypes::Inventory]
def inventory_for(organization_id, first_event: nil, last_event: nil, validate: false)
def inventory_for(organization_id, event_time: nil, validate: false)
events = Event.for_organization(organization_id)
if first_event
events = events.where("id >= ?", first_event)
end
if last_event
events = events.where("id <= ?", last_event)
if event_time
events = events.where("event_time <= ?", event_time)
end
inventory = EventTypes::Inventory.from(organization_id)
events.group_by { |e| [e.eventable_type, e.eventable_id] }.each do |_, event_batch|
Expand Down

0 comments on commit 8610d17

Please sign in to comment.