Class: PgEventstore::Web::Paginator::StreamIdsCollection

Inherits:
BaseCollection
  • Object
show all
Defined in:
lib/pg_eventstore/web/paginator/stream_ids_collection.rb,
sig/pg_eventstore/web/paginator/stream_ids_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
 
# File 'lib/pg_eventstore/web/paginator/stream_ids_collection.rb', line 11

def collection
  @collection ||=
    begin
      sql_builder = streams_index_sql_builder(from_id: starting_id)
      sql_builder.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) 


54
55
56
 
# File 'lib/pg_eventstore/web/paginator/stream_ids_collection.rb', line 54

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

#next_page_starting_id ⇒ String?

Returns:

  • (String, nil) 


24
25
26
27
28
29
30
31
32
33
 
# File 'lib/pg_eventstore/web/paginator/stream_ids_collection.rb', line 24

def next_page_starting_id
  return unless collection.size == per_page

  sql_builder = streams_index_sql_builder(from_id: collection.first['stream_id'])
  sql_builder.limit(1).offset(per_page)

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