module Switchman
  class Engine < ::Rails::Engine
    isolate_namespace Switchman

    config.autoload_once_paths << File.expand_path(File.join(__FILE__, "../../../app/models"))

    def self.lookup_stores(cache_store_config)
      result = {}
      cache_store_config.each do |key, value|
        next if value.is_a?(String)
        result[key] = ::ActiveSupport::Cache.lookup_store(value)
      end

      cache_store_config.each do |key, value|
        next unless value.is_a?(String)
        result[key] = result[value]
      end
      result
    end

    initializer 'switchman.initialize_cache', :before => 'initialize_cache' do
      require "switchman/active_support/cache"
      ::ActiveSupport::Cache.singleton_class.prepend(ActiveSupport::Cache::ClassMethods)

      # if we haven't already setup our cache map out-of-band, set it up from
      # config.cache_store now. behaves similarly to Rails' default
      # initialize_cache initializer, but for each value in the map, rather
      # than just Rails.cache. if config.cache_store is a flat value, uses it
      # to fill just the Rails.env entry in the cache map.
      unless Switchman.config[:cache_map].present?
        cache_store_config = ::Rails.configuration.cache_store
        unless cache_store_config.is_a?(Hash)
          cache_store_config = {::Rails.env => cache_store_config}
        end

        Switchman.config[:cache_map] = Engine.lookup_stores(cache_store_config)
      end

      # if the configured cache map (either from before, or as populated from
      # config.cache_store) didn't have an entry for Rails.env, add one using
      # lookup_store(nil); matches the behavior of Rails' default
      # initialize_cache initializer when config.cache_store is nil.
      unless Switchman.config[:cache_map].has_key?(::Rails.env)
        value = ::ActiveSupport::Cache.lookup_store(nil)
        Switchman.config[:cache_map][::Rails.env] = value
      end

      middlewares = Switchman.config[:cache_map].values.map do |store|
        store.middleware if store.respond_to?(:middleware)
      end.compact.uniq
      middlewares.each do |middleware|
        config.middleware.insert_before("Rack::Runtime", middleware)
      end

      # prevent :initialize_cache from trying to (or needing to) set
      # Rails.cache. once our switchman.extend_ar initializer (below) runs
      # Rails.cache will be overridden to pull appropriate values from the
      # cache map, but between now and then, Rails.cache should return the
      # Rails.env entry in the cache map.
      ::Rails.cache = Switchman.config[:cache_map][::Rails.env]
    end

    initializer 'switchman.extend_ar', :before => "active_record.initialize_database" do
      ::ActiveSupport.on_load(:active_record) do
        require "switchman/active_record/abstract_adapter"
        require "switchman/active_record/association"
        require "switchman/active_record/attribute_methods"
        require "switchman/active_record/base"
        require "switchman/active_record/calculations"
        require "switchman/active_record/connection_handler"
        require "switchman/active_record/connection_pool"
        require "switchman/active_record/finder_methods"
        require "switchman/active_record/log_subscriber"
        require "switchman/active_record/model_schema"
        require "switchman/active_record/persistence"
        require "switchman/active_record/predicate_builder"
        require "switchman/active_record/query_cache"
        require "switchman/active_record/query_methods"
        require "switchman/active_record/reflection"
        require "switchman/active_record/relation"
        require "switchman/active_record/spawn_methods"
        require "switchman/active_record/where_clause_factory"
        require "switchman/active_record/type_caster"
        require "switchman/arel"
        require "switchman/rails"
        require "switchman/shackles/relation"
        require "switchman/shard_internal"

        include ActiveRecord::Base
        include ActiveRecord::AttributeMethods
        include ActiveRecord::Persistence
        singleton_class.prepend ActiveRecord::ModelSchema::ClassMethods

        if ::Rails.version > '4.2'
          require "switchman/active_record/statement_cache"
          ::ActiveRecord::StatementCache.prepend(ActiveRecord::StatementCache)
          ::ActiveRecord::StatementCache::BindMap.prepend(ActiveRecord::StatementCache::BindMap)
          ::ActiveRecord::StatementCache::Substitute.send(:attr_accessor, :primary, :sharded)

          ::ActiveRecord::Associations::CollectionAssociation.prepend(ActiveRecord::CollectionAssociation)
        end

        if ::Rails.version >= '4.1.15'
          ::ActiveRecord::PredicateBuilder.singleton_class.prepend(ActiveRecord::PredicateBuilder)
        end

        if ::Rails.version > '4.1'
          prepend(ActiveRecord::AutosaveAssociation)
        end

        ::ActiveRecord::Associations::Association.prepend(ActiveRecord::Association)
        ::ActiveRecord::Associations::BelongsToAssociation.prepend(ActiveRecord::BelongsToAssociation)
        ::ActiveRecord::Associations::CollectionProxy.include(ActiveRecord::CollectionProxy)
        if ::Rails.version < '5'
          ::ActiveRecord::Associations::Builder::CollectionAssociation.include(ActiveRecord::Builder::CollectionAssociation)
        end

        ::ActiveRecord::Associations::Preloader::Association.prepend(ActiveRecord::Preloader::Association)
        ::ActiveRecord::ConnectionAdapters::AbstractAdapter.prepend(ActiveRecord::AbstractAdapter)
        ::ActiveRecord::ConnectionAdapters::ConnectionHandler.prepend(ActiveRecord::ConnectionHandler)
        ::ActiveRecord::ConnectionAdapters::ConnectionPool.prepend(ActiveRecord::ConnectionPool)
        ::ActiveRecord::ConnectionAdapters::AbstractAdapter.prepend(ActiveRecord::QueryCache)
        # when we call super in Switchman::ActiveRecord::QueryCache#select_all,
        # we want it to find the definition from
        # ActiveRecord::ConnectionAdapters::DatabaseStatements, not
        # ActiveRecord::ConnectionAdapters::QueryCache
        ::ActiveRecord::ConnectionAdapters::QueryCache.send(:remove_method, :select_all)

        ::ActiveRecord::LogSubscriber.prepend(ActiveRecord::LogSubscriber)
        ::ActiveRecord::Reflection::AssociationReflection.prepend(ActiveRecord::Reflection::AssociationReflection)
        ::ActiveRecord::Relation.prepend(ActiveRecord::Calculations)
        ::ActiveRecord::Relation.include(ActiveRecord::FinderMethods)
        ::ActiveRecord::Relation.include(ActiveRecord::QueryMethods)
        ::ActiveRecord::Relation.prepend(ActiveRecord::Relation)
        ::ActiveRecord::Relation.include(ActiveRecord::SpawnMethods)
        ::ActiveRecord::Relation.prepend(Shackles::Relation)

        if ::Rails.version >= '5'
          ::ActiveRecord::Relation::WhereClauseFactory.prepend(ActiveRecord::WhereClauseFactory)
          ::ActiveRecord::PredicateBuilder::AssociationQueryValue.prepend(ActiveRecord::PredicateBuilder::AssociationQueryValue)
          ::ActiveRecord::TypeCaster::Map.include(ActiveRecord::TypeCaster::Map)
          ::ActiveRecord::TypeCaster::Connection.include(ActiveRecord::TypeCaster::Connection)
        end

        ::Rails.singleton_class.prepend(Rails::ClassMethods)

        ::Arel::Table.prepend(Arel::Table)
        ::Arel::Visitors::ToSql.prepend(Arel::Visitors::ToSql)
        ::Arel::Visitors::PostgreSQL.include(Arel::Visitors::PostgreSQL) if ::Rails.version < '4.2'
      end
    end

    def self.foreign_key_check(name, type, options)
      if name.to_s =~ /_id\z/ && type.to_s == 'integer' && options[:limit].to_i < 8
        puts "WARNING: All foreign keys need to be 8-byte integers. #{name} looks like a foreign key. If so, please add the option: `:limit => 8`"
      end
    end

    initializer 'switchman.extend_connection_adapters', :after => "active_record.initialize_database" do
      ::ActiveSupport.on_load(:active_record) do
        ::ActiveRecord::ConnectionAdapters::AbstractAdapter.descendants.each do |klass|
          klass.prepend(ActiveRecord::AbstractAdapter::ForeignKeyCheck)
        end

        require 'switchman/active_record/table_definition'
        ::ActiveRecord::ConnectionAdapters::TableDefinition.prepend(ActiveRecord::TableDefinition)

        if defined?(::ActiveRecord::ConnectionAdapters::PostgreSQLAdapter)
          require "switchman/active_record/postgresql_adapter"
          ::ActiveRecord::ConnectionAdapters::PostgreSQLAdapter.prepend(ActiveRecord::PostgreSQLAdapter)
        end
      end
    end

    initializer 'switchman.eager_load' do
      ::ActiveSupport.on_load(:before_eager_load) do
        # This needs to be loaded before Switchman::Shard, otherwise it won't autoload it correctly
        require 'active_record/base'
      end
    end

    initializer 'switchman.extend_shackles', :before => "switchman.extend_ar" do
      ::ActiveSupport.on_load(:active_record) do
        require "switchman/shackles"

        ::Shackles.singleton_class.prepend(Shackles::ClassMethods)
      end
    end

    initializer 'switchman.extend_controller', :after => "shackles.extend_ar" do
      ::ActiveSupport.on_load(:action_controller) do
        require "switchman/action_controller/caching"

        ::ActionController::Base.include(ActionController::Caching)
      end
    end

  end
end