RailsEventStore/cqrs-es-sample-with-res

module Shipping
  class OnRemoveItemFromShipmentPickingList
    def initialize(event_store)
      @repository = AggregateRoot::Repository.new(event_store)
    end

    def call(command)
      @repository.with_aggregate(
        Shipment.new(command.order_id),
        "Shipping::Shipment$#{command.order_id}"
      ) do |shipment|
        shipment.remove_item(command.product_id)
      end
    end
  end
end