require 'http/options'
require 'http/redirector'
require 'uri'

module HTTP
  # Clients make requests and receive responses
  class Client
    include Chainable

    BUFFER_SIZE = 4096 # Input buffer size

    attr_reader :default_options

    def initialize(default_options = {})
      @default_options = HTTP::Options.new(default_options)
    end

    def body(opts, headers)
      if opts.body
        body = opts.body
      elsif opts.form
        headers['Content-Type'] ||= 'application/x-www-form-urlencoded'
        body = URI.encode_www_form(opts.form)
      end
    end

    # Make an HTTP request
    def request(method, uri, options = {})
      opts = @default_options.merge(options)
      host = URI.parse(uri).host
      opts.headers["Host"] = host
      headers = opts.headers
      proxy = opts.proxy

      method_body = body(opts, headers)
      if opts.params && !opts.params.empty?
        uri="#{uri}?#{URI.encode_www_form(opts.params)}"
      end

      request = HTTP::Request.new method, uri, headers, proxy, method_body
      opts.callbacks[:request].each { |c| c.call(request) }

      response = perform request, opts

      if opts.follow
        response = Redirector.new(opts.follow).perform request, response do |req|
          perform req, opts
        end
      end

      opts.callbacks[:response].each { |c| c.call(response) }
      format_response method, response, opts.response
    end

    def perform(request, options)
      parser = HTTP::Response::Parser.new
      uri = request.uri
      socket = options[:socket_class].open(uri.host, uri.port) # TODO: proxy support

      if uri.is_a?(URI::HTTPS)
        if options[:ssl_context] == nil
          context = OpenSSL::SSL::SSLContext.new
        else
          context = options[:ssl_context]
        end
        socket = options[:ssl_socket_class].new(socket, context)
        socket.connect
      end

      request.stream socket

      begin
        parser << socket.readpartial(BUFFER_SIZE) until parser.headers
      rescue IOError, Errno::ECONNRESET, Errno::EPIPE => ex
        raise IOError, "problem making HTTP request: #{ex}"
      end

      response = HTTP::Response.new(parser.status_code, parser.http_version, parser.headers) do
        if !parser.finished? || (@body_remaining && @body_remaining > 0)
          chunk = parser.chunk || begin
            parser << socket.readpartial(BUFFER_SIZE)
            parser.chunk || ""
          end

          @body_remaining -= chunk.length if @body_remaining
          @body_remaining = nil if @body_remaining && @body_remaining < 1

          chunk
        end
      end

      @body_remaining = Integer(response['Content-Length']) if response['Content-Length']
      response
    end

    def format_response(method, response, option)
      case option
      when :auto, NilClass
        if method == :head
          response
        else
          HTTP::Response::BodyDelegator.new(response, response.parse_body)
        end
      when :object
        response
      when :parsed_body
        HTTP::Response::BodyDelegator.new(response, response.parse_body)
      when :body
        HTTP::Response::BodyDelegator.new(response)
      else raise ArgumentError, "invalid response type: #{option}"
      end
    end
  end
end