Class: Peatio::Infura::Client
- Inherits:
-
Object
- Object
- Peatio::Infura::Client
- Extended by:
- Memoist
- Defined in:
- lib/peatio/infura/client.rb
Defined Under Namespace
Classes: ConnectionError, ResponseError
Constant Summary collapse
- Error =
Class.new(StandardError)
Instance Method Summary collapse
-
#initialize(endpoint, sign_uri, idle_timeout: 5) ⇒ Client
constructor
A new instance of Client.
- #json_rpc(method, params = [], conn_type = nil) ⇒ Object
Constructor Details
#initialize(endpoint, sign_uri, idle_timeout: 5) ⇒ Client
Returns a new instance of Client.
20 21 22 23 24 25 |
# File 'lib/peatio/infura/client.rb', line 20 def initialize(endpoint, sign_uri, idle_timeout: 5) @json_rpc_endpoint = URI.parse(endpoint) @sign_rpc_endpoint = URI.parse(sign_uri) @json_rpc_call_id = 0 @idle_timeout = idle_timeout end |
Instance Method Details
#json_rpc(method, params = [], conn_type = nil) ⇒ Object
27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/peatio/infura/client.rb', line 27 def json_rpc(method, params = [], conn_type=nil) current_conn = connection unless conn_type.nil? current_conn = sign_connection end response = current_conn.post \ '/', {jsonrpc: '2.0', id: rpc_call_id, method: method, params: params}.to_json, {'Accept' => 'application/json', 'Content-Type' => 'application/json'} response.assert_success! response = JSON.parse(response.body) response['error'].tap { |error| raise ResponseError.new(error['code'], error['message']) if error } response.fetch('result') rescue Faraday::Error => e raise ConnectionError, e rescue StandardError => e raise Error, e end |