Class: Sr::Jimson::ClientHelper
Constant Summary collapse
- JSON_RPC_VERSION =
'2.0'
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(url, opts = {}, namespace = nil) ⇒ ClientHelper
constructor
A new instance of ClientHelper.
- #process_batch_response(responses) ⇒ Object
- #process_call(sym, args) ⇒ Object
- #process_single_response(data) ⇒ Object
- #push_batch_request(request) ⇒ Object
- #send_batch ⇒ Object
- #send_batch_request(batch) ⇒ Object
- #send_single_request(method, args) ⇒ Object
- #valid_response?(data) ⇒ Boolean
Constructor Details
#initialize(url, opts = {}, namespace = nil) ⇒ ClientHelper
Returns a new instance of ClientHelper.
15 16 17 18 19 20 21 22 |
# File 'lib/sr/jimson/client.rb', line 15 def initialize(url, opts = {}, namespace = nil) @url = url URI.parse(@url) # for the sake of validating the url @batch = [] @opts = opts @namespace = namespace @opts[:content_type] = 'application/json' end |
Class Method Details
.make_id ⇒ Object
11 12 13 |
# File 'lib/sr/jimson/client.rb', line 11 def self.make_id rand(10**12) end |
Instance Method Details
#process_batch_response(responses) ⇒ Object
66 67 68 69 70 71 72 |
# File 'lib/sr/jimson/client.rb', line 66 def process_batch_response(responses) responses.each do |resp| saved_response = @batch.map { |r| r[1] }.select { |r| r.id == resp['id'] }.first raise Client::Error::InvalidResponse.new if saved_response.nil? saved_response.populate!(resp) end end |
#process_call(sym, args) ⇒ Object
24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/sr/jimson/client.rb', line 24 def process_call(sym, args) resp = send_single_request(sym.to_s, args) begin data = MultiJson.load(resp, :symbolize_keys => true) rescue raise Client::Error::InvalidJSON.new(resp) end return process_single_response(data) rescue Exception, StandardError => e e.extend(Client::Error) unless e.is_a?(Client::Error) raise e end |
#process_single_response(data) ⇒ Object
74 75 76 77 78 79 80 81 82 83 84 |
# File 'lib/sr/jimson/client.rb', line 74 def process_single_response(data) raise Client::Error::InvalidResponse.new if !valid_response?(data) if !!data[:error] code = data[:error][:code] msg = data[:error][:message] raise Client::Error::ServerError.new(code, msg) end return data[:result] end |
#push_batch_request(request) ⇒ Object
111 112 113 114 115 116 |
# File 'lib/sr/jimson/client.rb', line 111 def push_batch_request(request) request.id = self.class.make_id response = Response.new(request.id) @batch << [request, response] return response end |
#send_batch ⇒ Object
118 119 120 121 122 123 124 125 126 127 128 129 130 |
# File 'lib/sr/jimson/client.rb', line 118 def send_batch batch = @batch.map(&:first) # get the requests response = send_batch_request(batch) begin responses = MultiJson.load(response, :symbolize_keys) rescue raise Client::Error::InvalidJSON.new(json) end process_batch_response(responses) @batch = [] end |
#send_batch_request(batch) ⇒ Object
56 57 58 59 60 61 62 63 64 |
# File 'lib/sr/jimson/client.rb', line 56 def send_batch_request(batch) post_data = MultiJson.dump(batch) resp = RestClient.post(@url, post_data, @opts) if resp.nil? || resp.body.nil? || resp.body.empty? raise Client::Error::InvalidResponse.new end return resp.body end |
#send_single_request(method, args) ⇒ Object
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
# File 'lib/sr/jimson/client.rb', line 40 def send_single_request(method, args) namespaced_method = @namespace.nil? ? method : "#@namespace#{method}" post_data = MultiJson.dump({ 'jsonrpc' => JSON_RPC_VERSION, 'method' => namespaced_method, 'params' => args, 'id' => self.class.make_id }) resp = RestClient.post(@url, post_data, @opts) if resp.nil? || resp.body.nil? || resp.body.empty? raise Client::Error::InvalidResponse.new end return resp.body end |
#valid_response?(data) ⇒ Boolean
86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 |
# File 'lib/sr/jimson/client.rb', line 86 def valid_response?(data) return false if !data.is_a?(Hash) return false if data[:jsonrpc] != JSON_RPC_VERSION return false if !data.has_key?(:id) return false if data.has_key?(:error) && data.has_key?(:result) if data.has_key?(:error) if !data[:error].is_a?(Hash) || !data[:error].has_key?(:code) || !data[:error].has_key?(:message) return false end if !data[:error][:code].is_a?(Fixnum) || !data[:error][:message].is_a?(String) return false end end return true rescue return false end |