RailsEventStore/cqrs-es-sample-with-res

module ClientOrders
  class ChangeProductName < Infra::EventHandler
    def call(event)
      ApplicationRecord.with_advisory_lock(event.data.fetch(:product_id)) do
        Product.find_or_create_by(uid: event.data.fetch(:product_id)).update(
          name: event.data.fetch(:name)
        )
      end
    end
  end
end