2022-02-24 18:34:14 -05:00
# frozen_string_literal: true
class Trends :: Query
include Redisable
include Enumerable
attr_reader :prefix , :klass , :loaded
alias loaded? loaded
def initialize ( prefix , klass )
@prefix = prefix
@klass = klass
@records = [ ]
@loaded = false
@allowed = false
2022-04-08 11:10:53 -04:00
@limit = nil
@offset = nil
2022-02-24 18:34:14 -05:00
end
def allowed!
@allowed = true
self
end
def allowed
clone . allowed!
end
def in_locale! ( value )
@locale = value
self
end
def in_locale ( value )
clone . in_locale! ( value )
end
def offset! ( value )
2022-03-25 19:26:50 -04:00
@offset = value . to_i
2022-02-24 18:34:14 -05:00
self
end
def offset ( value )
clone . offset! ( value )
end
def limit! ( value )
2022-03-25 19:26:50 -04:00
@limit = value . to_i
2022-02-24 18:34:14 -05:00
self
end
def limit ( value )
clone . limit! ( value )
end
def records
load
@records
end
2022-04-07 12:06:15 -04:00
delegate :each , :empty? , :first , :last , :size , to : :records
2022-02-24 18:34:14 -05:00
def to_ary
records . dup
end
alias to_a to_ary
def to_arel
tmp_ids = ids
if tmp_ids . empty?
klass . none
else
2022-04-08 11:10:53 -04:00
scope = klass . joins ( " join unnest(array[ #{ tmp_ids . join ( ',' ) } ]) with ordinality as x (id, ordering) on #{ klass . table_name } .id = x.id " ) . reorder ( 'x.ordering' )
scope = scope . offset ( @offset ) if @offset . present?
scope = scope . limit ( @limit ) if @limit . present?
scope
2022-02-24 18:34:14 -05:00
end
end
private
def key
[ @prefix , @allowed ? 'allowed' : 'all' , @locale ] . compact . join ( ':' )
end
def load
unless loaded?
@records = perform_queries
@loaded = true
end
self
end
def ids
2022-04-08 11:10:53 -04:00
redis . zrevrange ( key , 0 , - 1 ) . map ( & :to_i )
2022-02-24 18:34:14 -05:00
end
def perform_queries
apply_scopes ( to_arel ) . to_a
end
def apply_scopes ( scope )
scope
end
end