Merge pull request #9 from cryptomkt/feat/update-january-2025

Feat/update january 2025

Author: ppbustamante

.ruby-version

@@ -0,0 +1 @@
+3.1.6

lib/cryptomarket/client.rb

@@ -33,16 +33,16 @@ class HttpManager
 
     def initialize(api_key:, api_secret:, window: nil)
       @credential_factory = Cryptomarket::CredentialsFactory.new(
-        api_version: @@API_VERSION, api_key: api_key, api_secret: api_secret, window: window
+        api_version: @@API_VERSION, api_key:, api_secret:, window:
       )
     end
 
     def change_credentials(api_key:, api_secret:)
-      @credential_factory.change_credentials(api_key: api_key, api_secret: api_secret)
+      @credential_factory.change_credentials(api_key:, api_secret:)
     end
 
     def change_window(window:)
-      @credential_factory.change_window(window: window)
+      @credential_factory.change_window(window:)
     end
 
     def make_request(method:, endpoint:, params: nil, public: false)
@@ -77,7 +77,7 @@ def build_payload(params)
     end
 
     def do_request(method, uri, payload, headers)
-      args = { method: method.downcase.to_sym, url: uri.to_s, headers: headers }
+      args = { method: method.downcase.to_sym, url: uri.to_s, headers: }
       if post?(method) || patch?(method)
         args[:payload] = post?(method) ? payload.to_json : payload
       end

lib/cryptomarket/http_manager.rb

@@ -12,7 +12,7 @@ def initialize(url:, api_key:, api_secret:, subscription_keys:, window: nil)
         @api_key = api_key
         @api_secret = api_secret
         @window = window
-        super url: url, subscription_keys: subscription_keys
+        super(url:, subscription_keys:)
         @authed = false
       end
 

lib/cryptomarket/websocket/auth_client.rb

@@ -11,7 +11,7 @@ class ClientBase
       def initialize(url:, subscription_keys:, on_connect: -> {}, on_error: ->(error) {}, on_close: -> {})
         @subscription_keys = subscription_keys
         @callback_cache = CallbackCache.new
-        @ws_manager = WSManager.new self, url: url
+        @ws_manager = WSManager.new(self, url:)
         @on_connect = on_connect
         @on_error = on_error
         @on_close = on_close

lib/cryptomarket/websocket/client_base.rb

@@ -291,7 +291,7 @@ def subscribe_to_top_of_book_in_batches(callback:, speed:, symbols: ['*'], resul
 
       def subscribe_to_price_rates(callback:, speed:, target_currency:, currencies: ['*'], result_callback: nil)
         params = {
-          speed: speed, target_currency: target_currency, currencies: currencies
+          speed:, target_currency:, currencies:
         }
         send_channel_subscription("price/rate/#{speed}", callback, intercept_result_callback(result_callback), params)
       end
@@ -314,7 +314,7 @@ def subscribe_to_price_rates(callback:, speed:, target_currency:, currencies: ['
       def subscribe_to_price_rates_in_batches(callback:, speed:, target_currency:, currencies: ['*'],
                                               result_callback: nil)
         params = {
-          speed: speed, target_currency: target_currency, currencies: currencies
+          speed:, target_currency:, currencies:
         }
         send_channel_subscription("price/rate/#{speed}/batch", callback,
                                   intercept_result_callback(result_callback), params)

lib/cryptomarket/websocket/market_data_client.rb

@@ -17,9 +17,9 @@ class TradingClient < AuthClient
       def initialize(api_key:, api_secret:, window: nil)
         super(
           url: 'wss://api.exchange.cryptomkt.com/api/3/ws/trading',
-          api_key: api_key,
-          api_secret: api_secret,
-          window: window,
+          api_key:,
+          api_secret:,
+          window:,
           subscription_keys: build_subscription_hash)
       end
 
@@ -76,7 +76,7 @@ def subscribe_to_spot_balance(callback:, mode: nil, result_callback: nil)
         interceptor = lambda { |notification, _type|
           callback.call(notification)
         }
-        send_subscription('spot_balance_subscribe', interceptor, { mode: mode }, result_callback)
+        send_subscription('spot_balance_subscribe', interceptor, { mode: }, result_callback)
       end
 
       # stop recieving the feed of balances changes
@@ -129,9 +129,9 @@ def create_spot_order( # rubocop:disable Metrics/ParameterLists
         expire_time: nil, strict_validate: nil, post_only: nil, take_rate: nil, make_rate: nil, callback: nil
       )
         request('spot_new_order', callback,
-                { client_order_id: client_order_id, symbol: symbol, side: side, quantity: quantity, type: type,
-                  time_in_force: time_in_force, price: price, stop_price: stop_price, expire_time: expire_time,
-                  strict_validate: strict_validate, post_only: post_only, take_rate: take_rate, make_rate: make_rate })
+                { client_order_id:, symbol:, side:, quantity:, type:,
+                  time_in_force:, price:, stop_price:, expire_time:,
+                  strict_validate:, post_only:, take_rate:, make_rate: })
       end
 
       # creates a list of spot orders
@@ -174,7 +174,7 @@ def create_spot_order_list(
         orders:, contingency_type:, order_list_id: nil, callback: nil
       )
         request('spot_new_order_list', callback, {
-                  orders: orders, contingency_type: contingency_type, order_list_id: order_list_id
+                  orders:, contingency_type:, order_list_id:
                 },
                 orders.count)
       end
@@ -187,7 +187,7 @@ def create_spot_order_list(
       # +String+ +client_order_id+:: the client order id of the order to cancel
       # +Proc+ +callback+:: Optional. A +Proc+ of two arguments, An exception and a result, called either with the exception or with the result, a list of reports of the canceled orders
       def cancel_spot_order(client_order_id:, callback: nil)
-        request('spot_cancel_order', callback, { client_order_id: client_order_id })
+        request('spot_cancel_order', callback, { client_order_id: })
       end
 
       # cancel all active spot orders and returns the ones that could not be canceled
@@ -222,7 +222,7 @@ def get_spot_trading_balances(callback:)
       # +String+ +currency+:: The currency code to query the balance
       # +Proc+ +callback+:: A +Proc+ of two arguments, An exception and a result, called either with the exception or with the result, a trading balance
       def get_spot_trading_balance(currency:, callback:)
-        request('spot_balance', callback, { currency: currency })
+        request('spot_balance', callback, { currency: })
       end
 
       # changes the parameters of an existing order, quantity or price
@@ -234,14 +234,15 @@ def get_spot_trading_balance(currency:, callback:)
       # +String+ +new_client_order_id+:: the new client order id for the modified order. must be unique within the trading day
       # +String+ +quantity+:: new order quantity
       # +String+ +price+:: new order price
+      # +String+ +stop_price+:: Required if order type is 'stopLimit', 'stopMarket', 'takeProfitLimit', or 'takeProfitMarket'. Order stop price
       # +Bool+ +strict_validate+::  price and quantity will be checked for the incrementation with tick size and quantity step. See symbol's tick_size and quantity_increment
       # +Proc+ +callback+:: Optional. A +Proc+ of two arguments, An exception and a result, called either with the exception or with the result, the new version of the order
       def replace_spot_order( # rubocop:disable Metrics/ParameterLists
-        client_order_id:, new_client_order_id:, quantity:, price:, strict_validate: nil, callback: nil
+        client_order_id:, new_client_order_id:, quantity:, price:, stop_price: nil, strict_validate: nil, callback: nil
       )
         request('spot_replace_order', callback, {
-                  client_order_id: client_order_id, new_client_order_id: new_client_order_id, quantity: quantity,
-                  price: price, strict_validate: strict_validate
+                  client_order_id:, new_client_order_id:, quantity:,
+                  price:, stop_price:, strict_validate:
                 })
       end
 
@@ -267,7 +268,7 @@ def get_spot_commissions(callback:)
       # +String+ +symbol+:: The symbol of the commission rate
       # +Proc+ +callback+:: A +Proc+ of two arguments, An exception and a result, called either with the exception or with the result, a commission for a symbol for the user
       def get_spot_commission(symbol:, callback:)
-        request('spot_fee', callback, { symbol: symbol })
+        request('spot_fee', callback, { symbol: })
       end
 
       alias get_spot_trading_balance_of_currency get_spot_trading_balance

lib/cryptomarket/websocket/trading_client.rb

@@ -18,9 +18,9 @@ class WalletClient < AuthClient
       def initialize(api_key:, api_secret:, window: nil)
         super(
           url: 'wss://api.exchange.cryptomkt.com/api/3/ws/wallet',
-          api_key: api_key,
-          api_secret: api_secret,
-          window: window,
+          api_key:,
+          api_secret:,
+          window:,
           subscription_keys: build_subscription_hash)
       end
 
@@ -125,7 +125,7 @@ def get_wallet_balance(currency:, callback:)
           balance['currency'] = currency
           callback.call(err, balance)
         }
-        request('wallet_balance', interceptor, { currency: currency })
+        request('wallet_balance', interceptor, { currency: })
       end
 
       # Get the transaction history of the account
@@ -160,9 +160,9 @@ def get_transactions( # rubocop:disable Metrics/ParameterLists
         id_from: nil, id_till: nil, order_by: nil, sort: nil, limit: nil, offset: nil, group_transactions: nil
       )
         request('get_transactions', callback, {
-                  tx_ids: tx_ids, types: types, subtypes: subtypes, statuses: statuses, currencies: currencies,
-                  from: from, till: till, id_from: id_from, id_till: id_till, order_by: order_by, sort: sort,
-                  limit: limit, offset: offset, group_transactions: group_transactions
+                  tx_ids:, types:, subtypes:, statuses:, currencies:,
+                  from:, till:, id_from:, id_till:, order_by:, sort:,
+                  limit:, offset:, group_transactions:
                 })
       end
 

lib/cryptomarket/websocket/wallet_client.rb

@@ -145,7 +145,9 @@ def self.good_ws_mini_ticker
   end
 
   def self.good_ticker
-    ->(ticker) { good_params(ticker, %w[t o c h l v q p P L]) } # missing a A b B in some responses
+    lambda { |ticker|
+      good_params(ticker, %w[t h l v q L])
+    } # missing a A b B o c p P in some responses
   end
 
   def self.good_orderbook

tests/checks.rb

@@ -130,7 +130,7 @@ def test_get_candles_by_symbol
 
   def test_get_converted_candles
     symbols = %w[EOSETH BTCUSDT]
-    result = @client.get_converted_candles(symbols: symbols, limit: 2, target_currency: 'usdt')
+    result = @client.get_converted_candles(symbols:, limit: 2, target_currency: 'usdt')
     result['data'].each do |symbol, candles|
       assert(symbols.include?(symbol))
       candles.each { |val| assert(Check.good_candle(val)) }