docbrown/app/labor/article_analytics_fetcher.rb

class ArticleAnalyticsFetcher
  def initialize(context = "default")
    @context = context
  end

  def update_analytics(user_id)
    articles_to_check = Article.where(user_id: user_id, published: true)
    qualified_articles = get_articles_that_qualify(articles_to_check)
    return if qualified_articles.none?

    fetch_and_update_page_views_and_reaction_counts(qualified_articles, user_id)
  end

  private

  def fetch_and_update_page_views_and_reaction_counts(qualified_articles, user_id)
    qualified_articles.each_slice(15).to_a.each do |chunk|
      pageviews = GoogleAnalytics.new(chunk.pluck(:id), user_id).get_pageviews
      page_views_obj = pageviews.to_h
      chunk.each do |article|
        article.update_columns(previous_positive_reactions_count: article.positive_reactions_count)
        Notification.send_milestone_notification(type: "Reaction", article: article)
        next if article.page_views_count > page_views_obj[article.id].to_i

        article.update_columns(page_views_count: page_views_obj[article.id].to_i)
        Notification.send_milestone_notification(type: "View", article: article)
      end
    end
  end

  def get_articles_that_qualify(articles_to_check)
    qualified_articles = []
    articles_to_check.each do |article|
      qualified_articles << article if should_fetch(article)
    end
    qualified_articles
  end

  def should_fetch(article)
    return true if @context == "force"

    article.positive_reactions_count > article.previous_positive_reactions_count || occasionally_force_fetch?
  end

  def occasionally_force_fetch?
    rand(25) == 1
  end
end