# frozen_string_literal: true
class ActivityTracker
include Redisable
EXPIRE_AFTER = 6.months.seconds
def initialize(prefix, type)
@prefix = prefix
@type = type
end
def add(value = 1, at_time = Time.now.utc)
key = key_at(at_time)
case @type
when :basic
redis.incrby(key, value)
when :unique
redis.pfadd(key, value)
redis.expire(key, EXPIRE_AFTER)
def get(start_at, end_at = Time.now.utc)
(start_at.to_date...end_at.to_date).map do |date|
key = key_at(date.to_time(:utc))
value = begin
redis.get(key).to_i
redis.pfcount(key)
[date, value]
def sum(start_at, end_at = Time.now.utc)
keys = (start_at.to_date...end_at.to_date).flat_map { |date| [key_at(date.to_time(:utc)), legacy_key_at(date)] }.uniq
redis.mget(*keys).map(&:to_i).sum
redis.pfcount(*keys)
class << self
def increment(prefix)
new(prefix, :basic).add
def record(prefix, value)
new(prefix, :unique).add(value)
private
def key_at(at_time)
"#{@prefix}:#{at_time.beginning_of_day.to_i}"
def legacy_key_at(at_time)
"#{@prefix}:#{at_time.to_date.cweek}"