thedrummeraki/tanoshimu

module Admin
  class InvokeTask < ApplicationOperation
    property! :task, accepts: String

    def execute
      runnable_task = Admin::FetchRunnableTasks.perform.where(name: task).first
      unless runnable_task.present?
        Rails.logger.error("No task found for #{task}")
        return
      end

      task_name = runnable_task.name

      task = Rake::Task[task_name]
      task.execute

      try_to_find_job(task_name)
    end

    private

    def try_to_find_job(task_name)
      retries = 5
      count = 0

      while count <= retries
        sleep(1)
        found_job = JobEvent.where(task: task_name).last
        return found_job if found_job.present?

        count += 1
      end

      nil
    end
  end
end