module Workarea
  module Configuration
    module Sidekiq
      extend self

      def load
        require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/i18n_client_middleware"
        require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/i18n_server_middleware"
        require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/audit_log_client_middleware"
        require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/audit_log_server_middleware"
        require_dependency "#{Workarea::Core::Engine.root}/app/middleware/workarea/release_server_middleware"

        unless manually_configured?
          ::Sidekiq.options.merge!(
            pidfile: pidfile,
            concurrency: concurrency,
            timeout: timeout,
            queues: queues
          )
        end

        configure_workarea!
      end

      def configure_workarea!
        ::Sidekiq::Logging.logger = Logger.new(
          File.join(Rails.root, 'log', 'sidekiq.log')
        )

        ::Sidekiq.default_worker_options = {
          log_duplicate_payload: true
        }

        ::Sidekiq.configure_server do |config|
          config.server_middleware do |chain|
            chain.add I18nServerMiddleware
            chain.add AuditLogServerMiddleware
            chain.add ReleaseServerMiddleware
          end

          config.client_middleware do |chain|
            chain.add I18nClientMiddleware
            chain.add AuditLogClientMiddleware
          end

          config.redis = {
            url: Configuration::Redis.persistent.to_url,
            size: pool_size,
            pool_timeout: pool_timeout
          }
        end

        ::Sidekiq.configure_client do |config|
          config.client_middleware do |chain|
            chain.add Workarea::I18nClientMiddleware
            chain.add AuditLogClientMiddleware
          end

          config.redis = { url: Configuration::Redis.persistent.to_url }
        end
      end

      def configure_plugins!
        ActiveJob::Base.queue_adapter = :sidekiq

        if ::Sidekiq.const_defined?('Testing') && ::Sidekiq::Testing.inline?
          ::Sidekiq.configure_client do |config|
            config.client_middleware do |chain|
              chain.remove SidekiqUniqueJobs::Client::Middleware
            end
          end
        end

        ::Sidekiq::Callbacks.assert_valid_config!
        ::Sidekiq::Throttled.setup!
      end

      def pidfile
        ENV['WORKAREA_SIDEKIQ_PIDFILE'].presence || './tmp/pids/sidekiq.pid'
      end

      def concurrency
        value = ENV['WORKAREA_SIDEKIQ_CONCURRENCY'].presence ||
          ::Sidekiq::DEFAULTS[:concurrency]

        value.to_i
      end

      def timeout
        value = ENV['WORKAREA_SIDEKIQ_TIMEOUT'].presence ||
          ENV['WORKAREA_SIDEKIQ_DEFAULT_TIMEOUT'].presence || # legacy
          ::Sidekiq::DEFAULTS[:timeout]

        value.to_i
      end

      def queues
        ENV['WORKAREA_SIDEKIQ_QUEUES'].to_s.split(',').presence ||
          %w(high default low mailers)
      end

      def pool_size
        value = ENV['WORKAREA_SIDEKIQ_POOL_SIZE'].presence ||
          ::Sidekiq.options[:concurrency] + 5

        value.to_i
      end

      def pool_timeout
        (ENV['WORKAREA_SIDEKIQ_POOL_TIMEOUT'].presence || 1).to_i
      end

      def manually_configured?
        %w[config/sidekiq.yml config/sidekiq.yml.erb].any? do |filename|
          File.exist?(Rails.root.join(filename))
        end
      end
    end
  end
end