Class: PgEventstore::Web::Paginator::MarkersCollection

Inherits:
BaseCollection
  • Object
show all
Defined in:
lib/pg_eventstore/web/paginator/markers_collection.rb,
sig/pg_eventstore/web/paginator/markers_collection.rbs

Constant Summary collapse

PER_PAGE =

Returns:

  • (Integer) 
10

Constants inherited from BaseCollection

BaseCollection::MIN_QUERY_SIZE_FOR_ADVANCE_SEARCH

Instance Attribute Summary

Attributes inherited from BaseCollection

#config_name, #options, #order, #per_page, #starting_id

Instance Method Summary collapse

Methods inherited from BaseCollection

#connection, #count, #initialize, #prev_page_starting_id, #total_count

Constructor Details

This class inherits a constructor from PgEventstore::Web::Paginator::BaseCollection

Instance Method Details

#collection ⇒ Array<Hash<String => String>>

Returns:

  • (Array<Hash<String => String>>) 


11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/pg_eventstore/web/paginator/markers_collection.rb', line 11

def collection
  @collection ||=
    begin
      sql_builder = SQLBuilder.new.select('name').from('event_markers')
      sql_builder.where("name #{direction_operator} ?", starting_id) if starting_id
      sql_builder.where('name like ?', "#{options[:query]}%")
      sql_builder.order("name #{order}").limit(per_page)
      connection.with do |conn|
        conn.exec_params(*sql_builder.to_exec_params)
      end.to_a
    end
end

#direction_operator ⇒ String

Returns:

  • (String) 


42
43
44
 
# File 'lib/pg_eventstore/web/paginator/markers_collection.rb', line 42

def direction_operator
  order == :asc ? '>=' : '<='
end

#next_page_starting_id ⇒ String?

Returns:

  • (String, nil) 


25
26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/pg_eventstore/web/paginator/markers_collection.rb', line 25

def next_page_starting_id
  return unless collection.size == per_page

  starting_id = collection.first['name']
  sql_builder = SQLBuilder.new.select('name').from('event_markers')
  sql_builder.where("name #{direction_operator} ?", starting_id)
  sql_builder.where('name like ?', "#{options[:query]}%")
  sql_builder.order("name #{order}").limit(1).offset(per_page)

  connection.with do |conn|
    conn.exec_params(*sql_builder.to_exec_params)
  end.to_a.dig(0, 'name')
end