require 'rom/configuration'

module Hanami
  module Model
    # Configuration for the framework, models and adapters.
    #
    # Hanami::Model has its own global configuration that can be manipulated
    # via `Hanami::Model.configure`.
    #
    # @since 0.2.0
    class Configuration
      # @since 0.7.0
      # @api private
      attr_reader :mappings

      # @since 0.7.0
      # @api private
      attr_reader :entities

      # @since 1.0.0
      # @api private
      attr_reader :logger

      # @since 1.0.0
      # @api private
      attr_reader :migrations_logger

      # @since 0.2.0
      # @api private
      def initialize(configurator)
        @backend = configurator.backend
        @url = configurator.url
        @migrations        = configurator._migrations
        @schema            = configurator._schema
        @gateway_config    = configurator._gateway
        @logger            = configurator._logger
        @migrations_logger = configurator.migrations_logger
        @mappings          = {}
        @entities          = {}
      end

      # NOTE: This must be changed when we want to support several adapters at the time
      #
      # @since 0.7.0
      # @api private
      attr_reader :url

      # NOTE: This must be changed when we want to support several adapters at the time
      #
      # @since 0.7.0
      # @api private
      def connection
        gateway.connection
      end

      # NOTE: This must be changed when we want to support several adapters at the time
      #
      # @since 0.7.0
      # @api private
      def gateway
        gateways[:default]
      end

      # Root directory
      #
      # @since 0.4.0
      # @api private
      def root
        Hanami.respond_to?(:root) ? Hanami.root : Pathname.pwd
      end

      # Migrations directory
      #
      # @since 0.4.0
      def migrations
        (@migrations.nil? ? root : root.join(@migrations)).realpath
      end

      # Path for schema dump file
      #
      # @since 0.4.0
      def schema
        @schema.nil? ? root : root.join(@schema)
      end

      # @since 0.7.0
      # @api private
      def define_mappings(root, &blk)
        @mappings[root] = Mapping.new(&blk)
      end

      # @since 0.7.0
      # @api private
      def register_entity(plural, singular, klass)
        @entities[plural]   = klass
        @entities[singular] = klass
      end

      # @since 0.7.0
      # @api private
      def define_entities_mappings(container, repositories)
        return unless defined?(Sql::Entity::Schema)

        repositories.each do |r|
          relation = r.relation
          entity   = r.entity

          entity.schema = Sql::Entity::Schema.new(entities, container.relations[relation], mappings.fetch(relation))
        end
      end

      # @since 1.0.0
      # @api private
      def configure_gateway
        @gateway_config&.call(gateway)
      end

      # @since 1.0.0
      # @api private
      def logger=(value)
        return if value.nil?
        gateway.use_logger(@logger = value)
      end

      # @since 1.0.0
      # @api private
      def rom
        @rom ||= ROM::Configuration.new(@backend, @url, infer_relations: false)
      end

      # @since 1.0.0
      # @api private
      def load!(repositories, &blk) # rubocop:disable Metrics/AbcSize
        rom.setup.auto_registration(config.directory.to_s) unless config.directory.nil?
        rom.instance_eval(&blk)                            if     block_given?
        configure_gateway
        repositories.each(&:load!)
        self.logger = logger

        container = ROM.container(rom)
        define_entities_mappings(container, repositories)
        container
      rescue => e
        raise Hanami::Model::Error.for(e)
      end

      # @since 1.0.0
      # @api private
      def method_missing(method_name, *args, &blk)
        if rom.respond_to?(method_name)
          rom.__send__(method_name, *args, &blk)
        else
          super
        end
      end

      # @since 1.1.0
      # @api private
      def respond_to_missing?(method_name, include_all)
        rom.respond_to?(method_name, include_all)
      end
    end
  end
end