# frozen_string_literal: true

namespace :decidim do
  namespace :metrics do
    # All ------
    #
    # Get all metrics entities and execute his own rake task.
    # It admits a date-string parameter, in a 'YYYY-MM-DD' format from
    # today to all past dates
    desc "Execute all metrics calculation methods"
    task :all, [:day] => :environment do |_task, args|
      Decidim::Organization.find_each do |organization|
        Decidim.metrics_registry.all.each do |metric_manifest|
          call_metric_job(metric_manifest, organization, args.day)
        end
      end
    end

    # One ------
    #
    # Execute metric calculations for just one metric
    # It need a metric name and permits a date-string parameter, in a 'YYYY-MM-DD' format from
    # today to all past dates
    desc "Execute one metric calculation method"
    task :one, [:metric, :day] => :environment do |_task, args|
      next if args.metric.blank?
      Decidim::Organization.find_each do |organization|
        metric_manifest = Decidim.metrics_registry.for(args.metric)
        call_metric_job(metric_manifest, organization, args.day)
      end
    end

    desc "Rebuild calculations from specific day"
    task :rebuild, [:metric, :day] => :environment do |_task, args|
      metric = args.metric
      day = args.day
      if args.day.blank?
        day = args.metric
        metric = nil
      end
      begin
        raise ArgumentError if day.blank?
        (Date.parse(day)..Time.zone.today).each do |d|
          Decidim::Organization.find_each do |organization|
            if metric
              m_manifest = Decidim.metrics_registry.for(metric)
              puts "[#{organization.name}]: rebuilding metric [#{metric}] for day [#{d}]"
              call_metric_job(m_manifest, organization, day)
            else
              puts "[#{organization.name}]: rebuilding all metrics for day [#{d}]"
              Decidim.metrics_registry.all.each do |metric_manifest|
                call_metric_job(metric_manifest, organization, day)
              end
            end
          end
        end
      rescue ArgumentError
        puts "ERROR: Please specify since which date should the metrics be rebuild"
        puts "ie: rails decidim:metrics:rebuild[2019-01-01]"
      end
    end

    desc "Show available metrics"
    task list: :environment do
      puts Decidim.metrics_registry.all.pluck :metric_name
    end

    def call_metric_job(metric_manifest, organization, day = nil)
      Decidim::MetricJob.perform_later(
        metric_manifest.manager_class,
        organization.id,
        day
      )
    end
  end
end