class Jimson::ClientHelper

Constants

JSON_RPC_VERSION

Public Class Methods

make_id() click to toggle source
# File lib/jimson/client.rb, line 11
def self.make_id
  rand(10**12)
end
new(url, opts = {}, namespace = nil, client_opts = {}) click to toggle source
# File lib/jimson/client.rb, line 15
def initialize(url, opts = {}, namespace = nil, client_opts = {})
  @url = url
  URI.parse(@url) # for the sake of validating the url
  @batch = []
  @opts = opts
  @namespace = namespace
  @opts[:content_type] ||= 'application/json'
  @client_opts = client_opts
end

Public Instance Methods

process_batch_response(responses) click to toggle source
# File lib/jimson/client.rb, line 67
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) click to toggle source
# File lib/jimson/client.rb, line 25
def process_call(sym, args)
  resp = send_single_request(sym.to_s, args)

  begin
    data = MultiJson.decode(resp)
  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) click to toggle source
# File lib/jimson/client.rb, line 75
def process_single_response(data)
  raise Client::Error::InvalidResponse.new(data) 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) click to toggle source
# File lib/jimson/client.rb, line 112
def push_batch_request(request)
  request.id = self.class.make_id
  response = Response.new(request.id)
  @batch << [request, response]
  return response
end
send_batch() click to toggle source
# File lib/jimson/client.rb, line 119
def send_batch
  batch = @batch.map(&:first) # get the requests
  response = send_batch_request(batch)

  begin
    responses = MultiJson.decode(response)
  rescue
    raise Client::Error::InvalidJSON.new(response)
  end

  process_batch_response(responses)
  @batch = []
end
send_batch_request(batch) click to toggle source
# File lib/jimson/client.rb, line 57
def send_batch_request(batch)
  post_data = MultiJson.encode(batch)
  resp = RestClient::Request.execute(@client_opts.merge(:method => :post, :url => @url, :payload => post_data, :headers => @opts))
  if resp.nil? || resp.body.nil? || resp.body.empty?
    raise Client::Error::InvalidResponse.new(resp)
  end

  return resp.body
end
send_single_request(method, args) click to toggle source
# File lib/jimson/client.rb, line 41
def send_single_request(method, args)
  namespaced_method = @namespace.nil? ? method : "#@namespace#{method}"
  post_data = MultiJson.encode({
    'jsonrpc' => JSON_RPC_VERSION,
    'method'  => namespaced_method,
    'params'  => args,
    'id'      => self.class.make_id
  })
  resp = RestClient::Request.execute(@client_opts.merge(:method => :post, :url => @url, :payload => post_data, :headers => @opts))
  if resp.nil? || resp.body.nil? || resp.body.empty?
    raise Client::Error::InvalidResponse.new(resp)
  end

  return resp.body
end
valid_response?(data) click to toggle source
# File lib/jimson/client.rb, line 87
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?(Integer) || !data['error']['message'].is_a?(String)
      return false
    end
  end

  return true

  rescue
    return false
end