Contents

# encoding: utf-8
require 'ting_yun/http/abstract_request'

module TingYun
  module Http

      class ExconHTTPResponse

        def initialize(response)
          @response = response
          # Since HTTP headers are case-insensitive, we normalize all of them to
          # upper case here, and then also in our [](key) implementation.
          @normalized_headers = {}
          headers = response.respond_to?(:headers) ? response.headers : response[:headers]
          (headers || {}).each do |key, val|
            @normalized_headers[key.upcase] = val
          end
        end


        def [](key)
          @normalized_headers[key.upcase]
        end

        def to_hash
          @normalized_headers.dup
        end
      end

      class ExconHTTPRequest < AbstractRequest
        attr_reader :method

        EXCON = "Excon".freeze
        LHOST = 'host'.freeze
        UHOST = 'Host'.freeze
        COLON = ':'.freeze

        def initialize(datum)
          @datum = datum

          @method = @datum[:method].to_s.upcase
          @scheme = @datum[:scheme]
          @port   = @datum[:port]
          @path   = @datum[:path]
        end

        def type
          EXCON
        end

        def from
          "excon%2Fhttp"
        end

        def host_from_header
          headers = @datum[:headers]
          if hostname = (headers[LHOST] || headers[UHOST])
            hostname.split(COLON).first
          end
        end

        def host
          host_from_header || @datum[:host]
        end

        def [](key)
          @datum[:headers][key]
        end

        def []=(key, value)
          @datum[:headers] ||= {}
          @datum[:headers][key] = value
        end

        def uri
          URI.parse("#{@scheme}://#{host}:#{@port}#{@path}")
        end
      end
    end

end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
tingyun_rpm-1.6.1	lib/ting_yun/http/excon_wrappers.rb
tingyun_rpm-1.5.0	lib/ting_yun/http/excon_wrappers.rb