require "mission_control/jobs/version"
require "mission_control/jobs/engine"

require "importmap-rails"
require "turbo-rails"
require "stimulus-rails"

module MissionControl
  module Jobs
    class Engine < ::Rails::Engine
      isolate_namespace MissionControl::Jobs

      config.mission_control = ActiveSupport::OrderedOptions.new unless config.try(:mission_control)
      config.mission_control.jobs = ActiveSupport::OrderedOptions.new

      config.before_initialize do
        config.mission_control.jobs.applications = MissionControl::Jobs::Applications.new

        config.mission_control.jobs.each do |key, value|
          MissionControl::Jobs.public_send("#{key}=", value)
        end

        if MissionControl::Jobs.adapters.empty?
          MissionControl::Jobs.adapters << (config.active_job.queue_adapter || :async)
        end
      end

      initializer "mission_control-jobs.active_job.extensions" do
        ActiveSupport.on_load :active_job do
          include ActiveJob::Querying
          include ActiveJob::Executing
          include ActiveJob::Failed
          ActiveJob.extend ActiveJob::Querying::Root
        end
      end

      config.before_initialize do
        if MissionControl::Jobs.adapters.include?(:resque)
          require "resque/thread_safe_redis"
          ActiveJob::QueueAdapters::ResqueAdapter.prepend ActiveJob::QueueAdapters::ResqueExt
          Resque.prepend Resque::ThreadSafeRedis
        end

        if MissionControl::Jobs.adapters.include?(:solid_queue)
          ActiveJob::QueueAdapters::SolidQueueAdapter.prepend ActiveJob::QueueAdapters::SolidQueueExt
        end

        ActiveJob::QueueAdapters::AsyncAdapter.include MissionControl::Jobs::Adapter
      end

      config.after_initialize do |app|
        unless app.config.eager_load
          # When loading classes lazily (development), we want to make sure
          # the base host +ApplicationController+ class is loaded when loading the
          # Engine's +ApplicationController+, or it will fail to load the class.
          MissionControl::Jobs.base_controller_class.constantize
        end

        if MissionControl::Jobs.applications.empty?
          queue_adapters_by_name = MissionControl::Jobs.adapters.each_with_object({}) do |adapter, hsh|
            hsh[adapter] = ActiveJob::QueueAdapters.lookup(adapter).new
          end

          MissionControl::Jobs.applications.add(app.class.module_parent.name, queue_adapters_by_name)
        end
      end

      console do
        require "irb"

        IRB::Command.register :connect_to, Console::ConnectTo
        IRB::Command.register :jobs_help, Console::JobsHelp

        IRB::Context.prepend(MissionControl::Jobs::Console::Context)

        MissionControl::Jobs.delay_between_bulk_operation_batches = 2
        MissionControl::Jobs.logger = ActiveSupport::Logger.new(STDOUT)

        if MissionControl::Jobs.applications.one? && (application = MissionControl::Jobs.applications.first) && application.servers.one?
          MissionControl::Jobs::Current.application = application
          MissionControl::Jobs::Current.server = application.servers.first
        end

        if MissionControl::Jobs.show_console_help
          puts "\n\nType 'jobs_help' to see how to connect to the available job servers to manage jobs\n\n"
        end
      end

      initializer "mission_control-jobs.assets" do |app|
        app.config.assets.paths << root.join("app/javascript")
        app.config.assets.precompile += %w[ mission_control_jobs_manifest ]
      end

      initializer "mission_control-jobs.importmap", before: "importmap" do |app|
        app.config.importmap.paths << root.join("config/importmap.rb")
        app.config.importmap.cache_sweepers << root.join("app/javascript")
      end
    end
  end
end