Contents

module KrakenClient
  module Endpoints
    class Private < Base

      def perform(endpoint_name, args)
        url      = config.base_uri + url_path(endpoint_name)
        response = request_manager.call(url, endpoint_name, args)

        if response.is_a?(Array) && response.first.match(/^E[\w]+:/)
          fail ErrorResponse.new(response.first)
        elsif response == "error"
          fail ErrorResponse.new(response)
        else
          response.with_indifferent_access
        end
      end

      def data
        {
          :Balance       => :balance,
          :TradeBalance  => :trade_balance,
          :OpenOrders    => :open_orders,
          :ClosedOrders  => :closed_orders,
          :QueryOrders   => [:query_orders,  params: [:txid]],
          :TradesHistory => :trades_history,
          :QueryTrades   => [:query_trades,  params: [:txid]],
          :OpenPositions => :open_positions, params: [:txid],
          :Ledgers       => :ledgers,
          :QueryLedgers  => [:query_ledgers, params: [:id]],
          :TradeVolume   => :trade_volume,
          :AddOrder      => [:add_order,     params: [:pair, :type, :ordertype, :volume]],
          :CancelOrder   => [:cancel_order,  params: [:txid]],
          :Withdraw      => [:withdraw,      params: [:asset, :key, :amount]]
        }
      end

      def raise_exception(options, args)
        return unless options.is_a?(Hash)

        leftover = options[:params] - args.keys

        if leftover.length > 0
          fail ::KrakenClient::ArgumentError, "Required options absent. Input must include #{leftover}"
        end
      end

      private

      def url_path(method)
        '/' + config.api_version.to_s + '/private/' + method
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
kraken_client-1.3.0	lib/kraken_client/endpoints/private.rb
kraken_client-1.2.1	lib/kraken_client/endpoints/private.rb
kraken_client-1.2	lib/kraken_client/endpoints/private.rb