module CurbFu
  class Request
    module Base
      include Common
      
      def build(url_params, query_params = {}, &block)
        curb = Curl::Easy.new(build_url(url_params, query_params))

        headers = global_headers
        
        unless url_params.is_a?(String)
          curb.userpwd = "#{url_params[:username]}:#{url_params[:password]}" if url_params[:username]
          if url_params[:authtype]
            curb.http_auth_types = url_params[:authtype]
          elsif url_params[:username]
            curb.http_auth_types = CurbFu::Authentication::BASIC
          end

          headers = headers.merge(url_params[:headers]) unless url_params[:headers].nil?
          headers["Expect"] = '' unless url_params[:headers] && url_params[:headers]["Expect"]
        end
        
        curb.headers = headers
        curb.timeout = @timeout

        yield curb if block_given?

        curb
      end
      
      # Set headers to be used for every request
      # * headers: hash of header names and values
      def global_headers=(headers)
        @global_headers = headers
      end
      
      # Headers to be used for every request
      # Returns: hash of header names and values
      def global_headers
        @global_headers ||= {}
      end
      
      def get(url, params = {}, &block)
        curb = self.build(url, params, &block)
        curb.http_get
        CurbFu::Response::Base.from_curb_response(curb)
      end

      def put(url, params = {}, &block)
        curb = self.build(url, params, &block)
        curb.http_put("")
        CurbFu::Response::Base.from_curb_response(curb)
      end

      def post(url, params = {}, &block)
        fields = create_post_fields(params)
        fields = [fields] if fields.is_a?(String)

        curb = self.build(url, &block)
        curb.http_post(*fields)
        response = CurbFu::Response::Base.from_curb_response(curb)
        if CurbFu.debug?
          puts "Response from server was"
          puts "Status: #{response.status}"
          puts "Headers: #{response.headers.inspect}"
          puts "Body: #{response.body.inspect}"
        end
        response
      end

      def post_file(url, params = {}, filez = {}, &block)
        fields = create_post_fields(params)
        fields += create_file_fields(filez)

        curb = self.build(url, &block)
        curb.multipart_form_post = true
        
        begin
          curb.http_post(*fields)
        rescue Curl::Err::InvalidPostFieldError => e
          field_list = (params.merge(filez)).inject([]) { |list, (name, value)| list << "#{name} => #{value.to_s[0..49].inspect}"; list }
          raise e, "There was an attempt to post invalid fields.  The fields were:\n#{field_list.join("\n")}"
        end
        CurbFu::Response::Base.from_curb_response(curb)
      end

      def delete(url, &block)
        curb = self.build(url, &block)
        curb.http_delete
        CurbFu::Response::Base.from_curb_response(curb)
      end

    private
      def create_post_fields(params)
        return params if params.is_a? String
        
        fields = []
        params.each do |name, value|
          value_string = value if value.is_a?(String)
          value_string = value.join(',') if value.is_a?(Array)
          value_string ||= value.to_s

          fields << Curl::PostField.content(name.to_s,value_string)
        end
        return fields
      end
      
      def create_put_fields(params)
        return params if params.is_a? String
        
        params.inject([]) do |list, (k,v)|
          v = v.is_a?(Array) ? v.join(',') : v
          list << "#{k}=#{v}"
          list
        end.join('&')
      end

      def create_file_fields(filez)
        fields = []
        filez.each do |name, path|
          fields << Curl::PostField.file(name, path)
        end
        fields
      end
    end
  end
end