Sha256: 41a7155c7d556387194c33ab5f538dde580fe86fff40507b5fdfc453dbf484e2
Contents?: true
Size: 1.63 KB
Versions: 12
Compression:
Stored size: 1.63 KB
Contents
# See Pagy API documentation: https://ddnexus.github.io/pagy/docs/api/keyset
# frozen_string_literal: true
class Pagy
class Keyset
# Keyset adapter for sequel
class Sequel < Keyset
protected
# Get the keyset attributes of the latest record
def latest_from(latest_record) = latest_record.to_hash.slice(*@keyset.keys)
# Extract the keyset from the set
def extract_keyset
return {} unless @set.opts[:order]
@set.opts[:order].each_with_object({}) do |item, keyset|
case item
when Symbol
keyset[item] = :asc
when ::Sequel::SQL::OrderedExpression
keyset[item.expression] = item.descending ? :desc : :asc
else
raise TypeError, "#{item.class.inspect} is not a supported Sequel::SQL::OrderedExpression"
end
end
end
# Filter out the already retrieved records
def after_latest = @set.where(::Sequel.lit(after_latest_query, **@latest))
# Append the missing keyset keys if the set is restricted by select
def apply_select
selected = @set.opts[:select]
@set.select_append(*@keyset.keys.reject { |c| selected.include?(c) })
end
# Set with selected columns?
def select? = !@set.opts[:select].nil?
# Typecast the latest attributes
def typecast_latest(latest)
model = @set.opts[:model]
model.unrestrict_primary_key if (restricted_pk = model.restrict_primary_key?)
latest = model.new(latest).to_hash.slice(*latest.keys.map(&:to_sym))
model.restrict_primary_key if restricted_pk
latest
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems