123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263 |
- # frozen_string_literal: true
- class Admin::Metrics::Measure::InstanceFollowersMeasure < Admin::Metrics::Measure::BaseMeasure
- include Admin::Metrics::Measure::QueryHelper
- def self.with_params?
- true
- end
- def key
- 'instance_followers'
- end
- def total_in_time_range?
- false
- end
- protected
- def perform_total_query
- domain = params[:domain]
- domain = Instance.by_domain_and_subdomains(params[:domain]).select(:domain) if params[:include_subdomains]
- Follow.joins(:account).merge(Account.where(domain: domain)).count
- end
- def perform_previous_total_query
- nil
- end
- def sql_array
- [sql_query_string, { start_at: @start_at, end_at: @end_at, domain: params[:domain] }]
- end
- def sql_query_string
- <<~SQL.squish
- SELECT axis.*, (
- WITH new_followers AS (
- SELECT follows.id
- FROM follows
- INNER JOIN accounts ON follows.account_id = accounts.id
- WHERE date_trunc('day', follows.created_at)::date = axis.period
- AND #{account_domain_sql(params[:include_subdomains])}
- )
- SELECT count(*) FROM new_followers
- ) AS value
- FROM (
- SELECT generate_series(date_trunc('day', :start_at::timestamp)::date, date_trunc('day', :end_at::timestamp)::date, interval '1 day') AS period
- ) AS axis
- SQL
- end
- def time_period
- (@start_at.to_date..@end_at.to_date)
- end
- def previous_time_period
- ((@start_at.to_date - length_of_period)..(@end_at.to_date - length_of_period))
- end
- def params
- @params.permit(:domain, :include_subdomains)
- end
- end
|