Contents

# frozen_string_literal: true

require "memoist"
require "faraday"
require "better-faraday"

module Peatio
  module Ndc
    class Client
      Error = Class.new(StandardError)
      ConnectionError = Class.new(Error)

      class ResponseError < Error
        def initialize(code, msg)
          @code = code
          @msg = msg
        end

        def message
          "#{@msg} (#{@code})"
        end
      end

      extend Memoist

      def initialize(endpoint)
        @json_rpc_endpoint = URI.parse(endpoint)
      end

      def json_rpc(method, params=[])
        response = post(method, params)

        response.assert_2xx!
        response = JSON.parse(response.body)

        response["error"].tap do |e|
          raise ResponseError.new(e["code"], e["message"]) if e
        end

        response.fetch("result")
      rescue Faraday::Error => e
        raise ConnectionError, e
      end

      private

      def post(method, params)
        connection.post("/", {jsonrpc: "1.0", method: method, params: params}.to_json,
                        "Accept" => "application/json", "Content-Type" => "application/json")
      end

      def connection
        @connection ||= Faraday.new(@json_rpc_endpoint) do |f|
          f.adapter :net_http_persistent, pool_size: 5
        end.tap do |connection|
          unless @json_rpc_endpoint.user.blank?
            connection.basic_auth(@json_rpc_endpoint.user,
                                  @json_rpc_endpoint.password)
          end
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
peatio-ndc-0.2.2	lib/peatio/ndc/client.rb