Class: Cb::Utils::Api
- Inherits:
-
Object
- Object
- Cb::Utils::Api
- Includes:
- HTTParty, Observable
- Defined in:
- lib/cb/utils/api.rb
Class Method Summary collapse
- .criteria_to_hash(criteria) ⇒ Object
- .instance(headers: {}, use_default_params: true) ⇒ Object
- .is_numeric?(obj) ⇒ Boolean
Instance Method Summary collapse
- #append_api_responses(obj, resp) ⇒ Object
- #cb_delete(path, options = {}, &block) ⇒ Object
- #cb_get(path, options = {}, &block) ⇒ Object
- #cb_post(path, options = {}, &block) ⇒ Object
- #cb_put(path, options = {}, &block) ⇒ Object
- #execute_http_request(http_method, uri, path, options = {}) ⇒ Object
-
#initialize(headers: {}, use_default_params: true) ⇒ Api
constructor
A new instance of Api.
- #timed_http_request(http_method, uri, path, options = {}, &block) ⇒ Object
Constructor Details
#initialize(headers: {}, use_default_params: true) ⇒ Api
Returns a new instance of Api.
32 33 34 35 36 37 38 39 |
# File 'lib/cb/utils/api.rb', line 32 def initialize(headers: {}, use_default_params: true) self.class.default_params add_default_params if use_default_params self.class.default_timeout Cb.configuration.time_out h = { 'developerkey' => Cb.configuration.dev_key } h.merge! ({ 'accept-encoding' => 'deflate, gzip' }) unless Cb.configuration.debug_api h.merge! headers self.class.headers(h) end |
Class Method Details
.criteria_to_hash(criteria) ⇒ Object
107 108 109 110 111 112 113 114 115 116 117 118 |
# File 'lib/cb/utils/api.rb', line 107 def self.criteria_to_hash(criteria) params = {} if criteria.respond_to?(:instance_variables) criteria.instance_variables.each do |var| var_name = var.to_s var_name.slice!(0) var_name_hash_safe = camelize(var_name) params["#{var_name_hash_safe}"] = criteria.instance_variable_get(var) end end params end |
.instance(headers: {}, use_default_params: true) ⇒ Object
21 22 23 24 25 26 27 28 29 30 |
# File 'lib/cb/utils/api.rb', line 21 def self.instance(headers: {}, use_default_params: true) api = Cb::Utils::Api.new(headers: headers, use_default_params: use_default_params) Cb.configuration.observers.each do |class_name| api.add_observer(class_name.new) end if Cb.configuration.debug_api && !Cb.configuration.observers.include?(Cb::Utils::ConsoleObserver) api.add_observer(Cb::Utils::ConsoleObserver.new) end api end |
.is_numeric?(obj) ⇒ Boolean
120 121 122 |
# File 'lib/cb/utils/api.rb', line 120 def self.is_numeric?(obj) true if Float(obj) rescue false end |
Instance Method Details
#append_api_responses(obj, resp) ⇒ Object
75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 |
# File 'lib/cb/utils/api.rb', line 75 def append_api_responses(obj, resp) #As of ruby 2.2 nil is frozen so stop monkey patching it please -jyeary if obj.nil? && obj.frozen? obj = Cb::Utils::NilResponse.new end = (obj) resp.each do |api_key, api_value| = format_hash_key(api_key) unless .empty? if == 'errors' && api_value.is_a?(Hash) api_value = api_value.values elsif == 'error' && api_value.is_a?(String) # this is a horrible hack to get consistent object.cb_response.errors behavior for the client = 'errors' api_value = [api_value] elsif self.class.is_numeric?(api_value) api_value = api_value.to_i end .class.send(:attr_reader, ) .instance_variable_set(:"@#{}", api_value) end end obj.class.send(:attr_reader, 'api_error') obj.instance_variable_set(:@api_error, @api_error) obj.class.send(:attr_reader, 'cb_response') obj.instance_variable_set(:@cb_response, ) obj end |
#cb_delete(path, options = {}, &block) ⇒ Object
53 54 55 |
# File 'lib/cb/utils/api.rb', line 53 def cb_delete(path, = {}, &block) timed_http_request(:delete, nil, path, , &block) end |
#cb_get(path, options = {}, &block) ⇒ Object
41 42 43 |
# File 'lib/cb/utils/api.rb', line 41 def cb_get(path, = {}, &block) timed_http_request(:get, nil, path, , &block) end |
#cb_post(path, options = {}, &block) ⇒ Object
45 46 47 |
# File 'lib/cb/utils/api.rb', line 45 def cb_post(path, = {}, &block) timed_http_request(:post, nil, path, , &block) end |
#cb_put(path, options = {}, &block) ⇒ Object
49 50 51 |
# File 'lib/cb/utils/api.rb', line 49 def cb_put(path, = {}, &block) timed_http_request(:put, nil, path, , &block) end |
#execute_http_request(http_method, uri, path, options = {}) ⇒ Object
70 71 72 73 |
# File 'lib/cb/utils/api.rb', line 70 def execute_http_request(http_method, uri, path, = {}) self.class.base_uri(uri || Cb.configuration.base_uri) self.class.method(http_method).call(path, ) end |
#timed_http_request(http_method, uri, path, options = {}, &block) ⇒ Object
57 58 59 60 61 62 63 64 65 66 67 68 |
# File 'lib/cb/utils/api.rb', line 57 def timed_http_request(http_method, uri, path, = {}, &block) api_caller = find_api_caller(caller) response = nil start_time = Time.now.to_f cb_event(:"cb_#{ http_method }_before", path, , api_caller, response, 0.0, &block) begin response = execute_http_request(http_method, uri, path, ) ensure cb_event(:"cb_#{ http_method }_after", path, , api_caller, response, Time.now.to_f - start_time, &block) end validate_response(response) end |