module ROM
  module HTTP
    class Dataset
      include Enumerable
      include Equalizer.new(:config, :options)

      attr_reader :config, :options

      def initialize(config, options = {})
        @config = config
        @options = {
          request_method: :get,
          path: '',
          params: {}
        }.merge(options)
      end

      def uri
        config[:uri]
      end

      def headers
        config.fetch(:headers, {}).merge(options.fetch(:headers, {}))
      end

      def name
        config[:name].to_s
      end

      def path
        options[:path].to_s.sub(%r{\A/}, '')
      end

      def absolute_path
        '/' + path
      end

      def request_method
        options[:request_method]
      end

      def params
        options[:params]
      end

      def with_headers(headers)
        self.class.new(config, options.merge(headers: headers))
      end

      def add_header(header, value)
        with_headers(headers.merge(header => value))
      end

      def with_options(opts)
        self.class.new(config, options.merge(opts))
      end

      def with_path(path)
        with_options(path: path)
      end

      def append_path(path)
        with_options(path: options[:path] + '/' + path)
      end

      def with_request_method(request_method)
        with_options(request_method: request_method)
      end

      def with_params(params)
        with_options(params: params)
      end

      def each(&block)
        return to_enum unless block_given?
        response.each(&block)
      end

      def insert(params)
        with_options(
          request_method: :post,
          params: params
        ).response
      end

      def update(params)
        with_options(
          request_method: :put,
          params: params
        ).response
      end

      def delete
        with_options(
          request_method: :delete
        ).response
      end

      def response
        response_handler.call(request_handler.call(self), self)
      end

      private

      def response_handler
        config[:response_handler]
      end

      def request_handler
        config[:request_handler]
      end
    end
  end
end