Sha256: 5b20dd9a84a46362046f43c61ca0b74a66a1a6a09a8ef09fa84c2f1ead5d1ade

Contents?: true

Size: 1.92 KB

Versions: 1

Compression:

Stored size: 1.92 KB

Contents

module Workarea
  module Insights
    class TrendingSearches < Base
      class << self
        def dashboards
          %w(search)
        end

        def generate_monthly!
          results = generate_results.map do |result|
            result.merge(
              query_id: result['_id'],
              query_string: result['query_string'].presence || result['_id']
            )
          end

          create!(results: results) if results.present?
        end

        def generate_results
          Metrics::SearchByWeek
            .collection
            .aggregate([filter_date_range, group_by_query, add_improving_weeks, sort, limit])
            .to_a
        end

        def filter_date_range
          {
            '$match' => {
              'reporting_on' => {
                '$gte' => beginning_of_last_month,
                '$lte' => end_of_last_month
              }
            }
          }
        end

        def group_by_query
          {
            '$group' => {
              '_id' => '$query_id',
              'query_string' => { '$first' => '$query_string' },
              'improving_weeks' => { '$sum' => 1 },
              'revenue_changes' => { '$push' => '$revenue_change' },
              'orders' => { '$sum' => '$orders' }
            }
          }
        end

        def add_improving_weeks
          {
            '$addFields' => {
              'improving_weeks' => {
                '$size' => {
                  '$filter' => {
                    'input' => '$revenue_changes',
                    'as' => 'revenue_change',
                    'cond' => { '$gt' => ['$$revenue_change', 0] }
                  }
                }
              }
            }
          }
        end

        def sort
          { '$sort' => { 'improving_weeks' => -1, 'orders' => -1 } }
        end

        def limit
          { '$limit' => Workarea.config.insights_searches_list_max_results }
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
workarea-core-3.5.0 app/models/workarea/insights/trending_searches.rb