# -*- coding: utf-8 -*-
module Dynflow
  # Class for configuring and preparing the Dynflow runtime environment.
  class Rails
    require File.expand_path('../rails/configuration', __FILE__)
    require File.expand_path('../rails/daemon', __FILE__)

    attr_reader :config

    def initialize(config = Rails::Configuration.new)
      @required = false
      @config = config
    end

    # call this method if your engine uses Dynflow
    def require!
      @required = true
    end

    def required?
      @required
    end

    def initialized?
      !@world.nil?
    end

    def initialize!
      return unless @required
      return @world if @world

      if config.lazy_initialization && defined?(::PhusionPassenger)
        config.dynflow_logger.
          warn('Dynflow: lazy loading with PhusionPassenger might lead to unexpected results')
      end
      config.initialize_world.tap do |world|
        @world = world

        unless config.remote?
          config.run_on_init_hooks(world)
          # leave this just for long-running executors
          unless config.rake_task_with_executor?
            world.auto_execute
          end
        end
      end
    end

    # Mark that the process is executor. This prevents the remote setting from
    # applying. Needs to be set up before the world is being initialized
    def executor!
      @executor = true
    end

    def executor?
      @executor
    end

    def reinitialize!
      @world = nil
      initialize!
    end

    def world
      return @world if @world

      initialize! if config.lazy_initialization
      unless @world
        raise 'The Dynflow world was not initialized yet. '\
          'If your plugin uses it, make sure to call Rails.application.dynflow.require! '\
              'in some initializer'
      end

      @world
    end

    attr_writer :world

    def eager_load_actions!
      config.eager_load_paths.each do |load_path|
        Dir.glob("#{load_path}/**/*.rb").sort.each do |file|
          unless loaded_paths.include?(file)
            require_dependency file
            loaded_paths << file
          end
        end
      end
      @world.reload! if @world
    end

    def loaded_paths
      @loaded_paths ||= Set.new
    end
  end
end