Module: ChargeBee::Rest

Defined in:
lib/chargebee/rest.rb

Class Method Summary collapse

Class Method Details

.handle_for_error(e, rcode = nil, rbody = nil) ⇒ Object 



74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/chargebee/rest.rb', line 74

def self.handle_for_error(e, rcode=nil, rbody=nil)
  if(rcode == 204)
    raise Error.new("No response returned by the chargebee api. The http status code is #{rcode}")
  end
  begin
    error_obj = JSON.parse(rbody)
    error_obj = Util.symbolize_keys(error_obj)
  rescue Exception => e
    raise Error.new("Error response not in JSON format. The http status code is #{rcode} \n #{rbody.inspect}",e)
  end
  type = error_obj[:type]
  if("payment" == type)
    raise PaymentError.new(rcode, error_obj)
  elsif("operation_failed" == type)
    raise OperationFailedError.new(rcode, error_obj)
  elsif("invalid_request" == type)
    raise InvalidRequestError.new(rcode, error_obj)
  else
    raise APIError.new(rcode, error_obj)
  end
  
end

.request(method, url, env, params = nil, headers = {}) ⇒ Object

Raises:



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/chargebee/rest.rb', line 7

def self.request(method, url, env, params=nil, headers={})
  raise Error.new('No environment configured.') unless env
  api_key = env.api_key
  
  if(ChargeBee.verify_ca_certs?)
    ssl_opts = {
      :verify_ssl => OpenSSL::SSL::VERIFY_PEER,
      :ssl_ca_file => ChargeBee.ca_cert_path
    }
  else
    ssl_opts = {
      :verify_ssl => false
    }
  end
  case method.to_s.downcase.to_sym
  when :get, :head, :delete
    headers = { :params => params }.merge(headers)
    payload = nil
  else
    payload = params
  end
    
  user_agent = ChargeBee.user_agent 
  headers = { 
    "User-Agent" => user_agent,
    :accept => :json,
    "Lang-Version" => RUBY_VERSION,
    "OS-Version" => RUBY_PLATFORM 
    }.merge(headers)      
  opts = {
    :method => method,
    :url => env.api_url(url),
    :user => api_key,
    :headers => headers,
    :payload => payload,
    :open_timeout => env.connect_timeout,
    :timeout => env.read_timeout
    }.merge(ssl_opts)

  begin
    response = RestClient::Request.execute(opts)
  rescue RestClient::ExceptionWithResponse => e
    if rcode = e.http_code and rbody = e.http_body
        raise handle_for_error(e, rcode, rbody)
    else
        raise IOError.new("IO Exception when trying to connect to chargebee with url #{opts[:url]} . Reason #{e}",e)
    end
  rescue Exception => e
        raise IOError.new("IO Exception when trying to connect to chargebee with url #{opts[:url]} . Reason #{e}",e)        
  end
  rbody = response.body
  rcode = response.code
  begin
    resp = JSON.parse(rbody)
  rescue Exception => e
    if rbody.include? "503"
        raise Error.new("Sorry, the server is currently unable to handle the request due to a temporary overload or scheduled maintenance. Please retry after sometime. \n type: internal_temporary_error, \n http_status_code: 503, \n error_code: internal_temporary_error,\n content: #{rbody.inspect}",e)
    elsif rbody.include? "504"
        raise Error.new("The server did not receive a timely response from an upstream server, request aborted. If this problem persists, contact us at [email protected]. \n type: gateway_timeout, \n http_status_code: 504, \n error_code: gateway_timeout,\n content:  #{rbody.inspect}",e)
    else
        raise Error.new("Sorry, something went wrong when trying to process the request. If this problem persists, contact us at [email protected]. \n type: internal_error, \n http_status_code: 500, \n error_code: internal_error,\n content:  #{rbody.inspect}",e)
    end
  end
  resp = Util.symbolize_keys(resp)
  resp
end