discourse/app/jobs/regular/run_problem_check.rb

# frozen_string_literal: true

module Jobs
  class RetrySignal < Exception
  end

  # This job runs a singular scheduled admin check. It is scheduled by
  # the ProblemChecks (plural) scheduled job.
  class RunProblemCheck < ::Jobs::Base
    sidekiq_options retry: false

    def execute(args)
      retry_count = args[:retry_count].to_i
      identifier = args[:check_identifier].to_sym

      check = ProblemCheck[identifier]

      problems = check.call
      raise RetrySignal if problems.present? && retry_count < check.max_retries

      if problems.present?
        problems.each { |problem| AdminDashboardData.add_found_scheduled_check_problem(problem) }
        ProblemCheckTracker[identifier].problem!(next_run_at: check.perform_every.from_now)
      else
        ProblemCheckTracker[identifier].no_problem!(next_run_at: check.perform_every.from_now)
      end
    rescue RetrySignal
      Jobs.enqueue_in(
        check.retry_after,
        :run_problem_check,
        args.merge(retry_count: retry_count + 1).stringify_keys,
      )
    rescue StandardError => err
      Discourse.warn_exception(
        err,
        message: "A scheduled admin dashboard problem check (#{identifier}) errored.",
      )
    end
  end
end