Class: Harpy::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/harpy/client.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opts = nil) ⇒ Client

Returns a new instance of Client.



8
9
10
 
# File 'lib/harpy/client.rb', line 8

def initialize(opts=nil)
  self.options = (opts || {})
end

Instance Attribute Details

#options ⇒ Object

Returns the value of attribute options.



6
7
8
 
# File 'lib/harpy/client.rb', line 6

def options
  @options
end

Instance Method Details

#delete(url_or_urls, opts = nil) ⇒ Object 



32
33
34
 
# File 'lib/harpy/client.rb', line 32

def delete(url_or_urls, opts=nil)
  request :delete, url_or_urls, opts
end

#get(url_or_urls, opts = nil) ⇒ Object 



12
13
14
 
# File 'lib/harpy/client.rb', line 12

def get(url_or_urls, opts=nil)
  request :get, url_or_urls, opts
end

#head(url_or_urls, opts = nil) ⇒ Object 



16
17
18
 
# File 'lib/harpy/client.rb', line 16

def head(url_or_urls, opts=nil)
  request :head, url_or_urls, opts
end

#invalid_code(response) ⇒ Object 



42
43
44
45
46
47
48
49
50
 
# File 'lib/harpy/client.rb', line 42

def invalid_code(response)
  if response.timed_out?
    raise ClientTimeout
  elsif response.code.zero?
    raise ClientError, response.return_message
  else
    raise InvalidResponseCode, response.code.to_s
  end
end

#patch(url_or_urls, opts = nil) ⇒ Object 



28
29
30
 
# File 'lib/harpy/client.rb', line 28

def patch(url_or_urls, opts=nil)
  request :patch, url_or_urls, opts
end

#post(url_or_urls, opts = nil) ⇒ Object 



20
21
22
 
# File 'lib/harpy/client.rb', line 20

def post(url_or_urls, opts=nil)
  request :post, url_or_urls, opts
end

#put(url_or_urls, opts = nil) ⇒ Object 



24
25
26
 
# File 'lib/harpy/client.rb', line 24

def put(url_or_urls, opts=nil)
  request :put, url_or_urls, opts
end

#run(requests) ⇒ Object 



36
37
38
39
40
 
# File 'lib/harpy/client.rb', line 36

def run(requests)
  requests.each{|request| Typhoeus::Hydra.hydra.queue request}
  Typhoeus::Hydra.hydra.run
  requests.collect(&:response)
end