ministryofjustice/Claim-for-Crown-Court-Defence

# frozen_string_literal: true

# Management information statistics
#
# Counts of records from the management information (V2)
# report filtered by various values, including a date. That
# date is specified as a range here.
#

Dir.glob(File.join(__dir__, 'concerns', '**', '*.rb')).each { |f| require_dependency f }
Dir.glob(File.join(__dir__, 'queries', '**', '*.rb')).each { |f| require_dependency f }

module Stats
  module ManagementInformation
    class DailyReportCountQuery
      def self.call(...)
        new(...).call
      end

      def initialize(**kwargs)
        @query_set = kwargs[:query_set]
        @date_range = kwargs[:date_range]
        raise ArgumentError, 'query set must be provided' if @query_set.blank?
        raise ArgumentError, 'date range must be provided' if @date_range.blank?
      end

      def call
        submission_queries + completion_queries
      end

      private

      def submission_queries
        filter_by(:originally_submitted_at)
      end

      def completion_queries
        filter_by(:completed_at)
      end

      def filter_by(date_column_filter)
        @query_set.each_with_object([]) do |(name, query), results|
          result = { name: name.to_s.humanize, filter: date_column_filter.to_s.humanize }

          query_results = query.call(date_range: @date_range,
                                     date_column_filter:).to_a

          counts_by_day = query_results.map { |rec| { rec['day'].to_date.iso8601 => rec['count'] } }.reduce(:merge)

          result.merge!(counts_by_day)
          results.append(result)
        end
      end
    end
  end
end