Module: Sequent::Support::Events

Extended by:

ActiveRecord::ConnectionAdapters::Quoting

Defined in:

lib/sequent/support/view_projection.rb

Constant Summary

ORDERED_BY_STREAM =

lambda do |event_store|
  event_records = quote_table_name(Sequent.configuration.event_record_class.table_name)
  stream_records = quote_table_name(Sequent.configuration.stream_record_class.table_name)
  snapshot_event_type = quote(Sequent.configuration.snapshot_event_class)

  Sequent.configuration.event_record_class
    .select("event_type, event_json")
    .joins("INNER JOIN #{stream_records} ON #{event_records}.stream_record_id = #{stream_records}.id")
    .where("event_type <> #{snapshot_event_type}")
    .order!("#{stream_records}.id, #{event_records}.sequence_number")
end