Module: CurbFu::Request::Test::ClassMethods

Defined in:
lib/curb-fu/request/test.rb

Instance Method Summary collapse

Instance Method Details

#build_request_options(url) ⇒ Object 



44
45
46
47
48
49
50
51
 
# File 'lib/curb-fu/request/test.rb', line 44

def build_request_options(url)
  options = {}
  options[:headers] = (url.is_a?(String)) ? nil : url.delete(:headers)
  options[:url] = build_url(url)
  options[:username], options[:password] = get_auth(url)
  options[:interface] = get_interface(url)
  options
end

#delete(url, params = {}) ⇒ Object 



38
39
40
41
42
 
# File 'lib/curb-fu/request/test.rb', line 38

def delete(url, params = {})
  request_options = build_request_options(url)
  respond(request_options[:interface], :delete, request_options[:url],
    params, request_options[:headers], request_options[:username], request_options[:password])
end

#get(url, params = {}) ⇒ Object 



13
14
15
16
17
 
# File 'lib/curb-fu/request/test.rb', line 13

def get(url, params = {})
  request_options = build_request_options(url)
  respond(request_options[:interface], :get, request_options[:url],
    params, request_options[:headers], request_options[:username], request_options[:password])
end

#get_auth(url) ⇒ Object 



98
99
100
101
102
103
104
105
 
# File 'lib/curb-fu/request/test.rb', line 98

def get_auth(url)
  username = password = nil
  if url.is_a?(Hash) && url[:username]
    username = url[:username]
    password = url[:password]
  end
  [username, password]
end

#get_interface(url) ⇒ Object 



77
78
79
80
81
82
83
84
 
# File 'lib/curb-fu/request/test.rb', line 77

def get_interface(url)
  if url.is_a?(Hash)
    host = url[:host]
  else
    host = parse_hostname(url)
  end
  match_host(host)
end

#match_host(host) ⇒ Object 



91
92
93
94
95
96
 
# File 'lib/curb-fu/request/test.rb', line 91

def match_host(host)
  match = CurbFu.stubs.find do |(hostname, interface)|
    hostname == host
  end
  match.last unless match.nil?
end

#parse_hostname(uri) ⇒ Object 



86
87
88
89
 
# File 'lib/curb-fu/request/test.rb', line 86

def parse_hostname(uri)
  parsed_hostname = URI.parse(uri)
  parsed_hostname.host || parsed_hostname.path
end

#post(url, params = {}) ⇒ Object 



19
20
21
22
23
 
# File 'lib/curb-fu/request/test.rb', line 19

def post(url, params = {})
  request_options = build_request_options(url)
  respond(request_options[:interface], :post, request_options[:url],
    params, request_options[:headers], request_options[:username], request_options[:password])
end

#post_file(url, params = {}, filez = {}) ⇒ Object 



25
26
27
28
29
30
 
# File 'lib/curb-fu/request/test.rb', line 25

def post_file(url, params = {}, filez = {})
  request_options = build_request_options(url)
  uploaded_files = filez.inject({}) { |hsh, f| hsh["file_#{hsh.keys.length}"] = Rack::Test::UploadedFile.new(f.last.path); hsh }
  respond(request_options[:interface], :post, request_options[:url], 
    params.merge(uploaded_files), request_options[:headers], request_options[:username], request_options[:password])
end

#process_headers(headers) ⇒ Object 



68
69
70
71
72
73
74
75
 
# File 'lib/curb-fu/request/test.rb', line 68

def process_headers(headers)
  headers.inject({}) do |accum, (header_name, value)|
    key = header_name.gsub("-", "_").upcase
    key = "HTTP_" + key unless key =~ /^HTTP_/
    accum[key] = value
    accum
  end
end

#put(url, params = {}) ⇒ Object 



32
33
34
35
36
 
# File 'lib/curb-fu/request/test.rb', line 32

def put(url, params = {})
  request_options = build_request_options(url)
  respond(request_options[:interface], :put, request_options[:url],
    params, request_options[:headers], request_options[:username], request_options[:password])
end

#respond(interface, operation, url, params, headers, username = nil, password = nil) ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/curb-fu/request/test.rb', line 53

def respond(interface, operation, url, params, headers, username = nil, password = nil)
  if interface.nil?
    raise Curl::Err::ConnectionFailedError
  else
    unless headers.nil?
      process_headers(headers).each do |name, value|
        interface.header(name, value)
      end
    end
    interface.authorize(username, password) unless username.nil?
    response = interface.send(operation, url, params)
    CurbFu::Response::Base.from_rack_response(response)
  end
end