# -*- coding: utf-8 -*- # PLEASE DO NOT EDIT THIS FILE, IT IS GENERATED AND WILL BE OVERWRITTEN: # https://github.com/ccxt/ccxt/blob/master/CONTRIBUTING.md#how-to-contribute-code from ccxt.base.exchange import Exchange # ----------------------------------------------------------------------------- try: basestring # Python 3 except NameError: basestring = str # Python 2 from ccxt.base.errors import ExchangeError from ccxt.base.errors import AuthenticationError from ccxt.base.errors import OrderNotFound from ccxt.base.errors import InvalidNonce from ccxt.base.decimal_to_precision import ROUND from ccxt.base.decimal_to_precision import TICK_SIZE class bitso(Exchange): def describe(self): return self.deep_extend(super(bitso, self).describe(), { 'id': 'bitso', 'name': 'Bitso', 'countries': ['MX'], # Mexico 'rateLimit': 2000, # 30 requests per minute 'version': 'v3', 'has': { 'cancelOrder': True, 'CORS': False, 'createOrder': True, 'fetchBalance': True, 'fetchDepositAddress': True, 'fetchMarkets': True, 'fetchMyTrades': True, 'fetchOpenOrders': True, 'fetchOrder': True, 'fetchOrderBook': True, 'fetchOrderTrades': True, 'fetchTicker': True, 'fetchTrades': True, 'withdraw': True, }, 'urls': { 'logo': 'https://user-images.githubusercontent.com/51840849/87295554-11f98280-c50e-11ea-80d6-15b3bafa8cbf.jpg', 'api': 'https://api.bitso.com', 'www': 'https://bitso.com', 'doc': 'https://bitso.com/api_info', 'fees': 'https://bitso.com/fees', 'referral': 'https://bitso.com/?ref=itej', }, 'precisionMode': TICK_SIZE, 'options': { 'precision': { 'XRP': 0.000001, 'MXN': 0.01, 'TUSD': 0.01, }, 'defaultPrecision': 0.00000001, }, 'api': { 'public': { 'get': [ 'available_books', 'ticker', 'order_book', 'trades', ], }, 'private': { 'get': [ 'account_status', 'balance', 'fees', 'fundings', 'fundings/{fid}', 'funding_destination', 'kyc_documents', 'ledger', 'ledger/trades', 'ledger/fees', 'ledger/fundings', 'ledger/withdrawals', 'mx_bank_codes', 'open_orders', 'order_trades/{oid}', 'orders/{oid}', 'user_trades', 'user_trades/{tid}', 'withdrawals/', 'withdrawals/{wid}', ], 'post': [ 'bitcoin_withdrawal', 'debit_card_withdrawal', 'ether_withdrawal', 'ripple_withdrawal', 'bcash_withdrawal', 'litecoin_withdrawal', 'orders', 'phone_number', 'phone_verification', 'phone_withdrawal', 'spei_withdrawal', 'ripple_withdrawal', 'bcash_withdrawal', 'litecoin_withdrawal', ], 'delete': [ 'orders/{oid}', 'orders/all', ], }, }, 'exceptions': { '0201': AuthenticationError, # Invalid Nonce or Invalid Credentials '104': InvalidNonce, # Cannot perform request - nonce must be higher than 1520307203724237 }, }) def fetch_markets(self, params={}): response = self.publicGetAvailableBooks(params) # # { # "success":true, # "payload":[ # { # "book":"btc_mxn", # "minimum_price":"500", # "maximum_price":"10000000", # "minimum_amount":"0.00005", # "maximum_amount":"500", # "minimum_value":"5", # "maximum_value":"10000000", # "tick_size":"0.01", # "fees":{ # "flat_rate":{"maker":"0.500","taker":"0.650"}, # "structure":[ # {"volume":"1500000","maker":"0.00500","taker":"0.00650"}, # {"volume":"2000000","maker":"0.00490","taker":"0.00637"}, # {"volume":"5000000","maker":"0.00480","taker":"0.00624"}, # {"volume":"7000000","maker":"0.00440","taker":"0.00572"}, # {"volume":"10000000","maker":"0.00420","taker":"0.00546"}, # {"volume":"15000000","maker":"0.00400","taker":"0.00520"}, # {"volume":"35000000","maker":"0.00370","taker":"0.00481"}, # {"volume":"50000000","maker":"0.00300","taker":"0.00390"}, # {"volume":"150000000","maker":"0.00200","taker":"0.00260"}, # {"volume":"250000000","maker":"0.00100","taker":"0.00130"}, # {"volume":"9999999999","maker":"0.00000","taker":"0.00130"}, # ] # } # }, # ] # } markets = self.safe_value(response, 'payload') result = [] for i in range(0, len(markets)): market = markets[i] id = self.safe_string(market, 'book') baseId, quoteId = id.split('_') base = baseId.upper() quote = quoteId.upper() base = self.safe_currency_code(base) quote = self.safe_currency_code(quote) symbol = base + '/' + quote limits = { 'amount': { 'min': self.safe_float(market, 'minimum_amount'), 'max': self.safe_float(market, 'maximum_amount'), }, 'price': { 'min': self.safe_float(market, 'minimum_price'), 'max': self.safe_float(market, 'maximum_price'), }, 'cost': { 'min': self.safe_float(market, 'minimum_value'), 'max': self.safe_float(market, 'maximum_value'), }, } defaultPricePrecision = self.safe_float(self.options['precision'], quote, self.options['defaultPrecision']) pricePrecision = self.safe_float(market, 'tick_size', defaultPricePrecision) precision = { 'amount': self.safe_float(self.options['precision'], base, self.options['defaultPrecision']), 'price': pricePrecision, } fees = self.safe_value(market, 'fees', {}) flatRate = self.safe_value(fees, 'flat_rate', {}) maker = self.safe_float(flatRate, 'maker') taker = self.safe_float(flatRate, 'taker') feeTiers = self.safe_value(fees, 'structure', []) fee = { 'taker': float(self.decimal_to_precision(taker / 100, ROUND, 0.00000001, TICK_SIZE)), 'maker': float(self.decimal_to_precision(maker / 100, ROUND, 0.00000001, TICK_SIZE)), 'percentage': True, 'tierBased': True, } takerFees = [] makerFees = [] for j in range(0, len(feeTiers)): tier = feeTiers[j] volume = self.safe_float(tier, 'volume') takerFee = self.safe_float(tier, 'taker') makerFee = self.safe_float(tier, 'maker') takerFeeToPrecision = float(self.decimal_to_precision(takerFee / 100, ROUND, 0.00000001, TICK_SIZE)) makerFeeToPrecision = float(self.decimal_to_precision(makerFee / 100, ROUND, 0.00000001, TICK_SIZE)) takerFees.append([volume, takerFeeToPrecision]) makerFees.append([volume, makerFeeToPrecision]) if j == 0: fee['taker'] = float(self.decimal_to_precision(taker / 100, ROUND, 0.00000001, TICK_SIZE)) fee['maker'] = float(self.decimal_to_precision(maker / 100, ROUND, 0.00000001, TICK_SIZE)) tiers = { 'taker': takerFees, 'maker': makerFees, } fee['tiers'] = tiers result.append(self.extend({ 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'baseId': baseId, 'quoteId': quoteId, 'info': market, 'limits': limits, 'precision': precision, 'active': None, }, fee)) return result def fetch_balance(self, params={}): self.load_markets() response = self.privateGetBalance(params) balances = self.safe_value(response['payload'], 'balances') result = {'info': response} for i in range(0, len(balances)): balance = balances[i] currencyId = self.safe_string(balance, 'currency') code = self.safe_currency_code(currencyId) account = { 'free': self.safe_float(balance, 'available'), 'used': self.safe_float(balance, 'locked'), 'total': self.safe_float(balance, 'total'), } result[code] = account return self.parse_balance(result) def fetch_order_book(self, symbol, limit=None, params={}): self.load_markets() request = { 'book': self.market_id(symbol), } response = self.publicGetOrderBook(self.extend(request, params)) orderbook = self.safe_value(response, 'payload') timestamp = self.parse8601(self.safe_string(orderbook, 'updated_at')) return self.parse_order_book(orderbook, timestamp, 'bids', 'asks', 'price', 'amount') def fetch_ticker(self, symbol, params={}): self.load_markets() request = { 'book': self.market_id(symbol), } response = self.publicGetTicker(self.extend(request, params)) ticker = self.safe_value(response, 'payload') timestamp = self.parse8601(self.safe_string(ticker, 'created_at')) vwap = self.safe_float(ticker, 'vwap') baseVolume = self.safe_float(ticker, 'volume') quoteVolume = None if baseVolume is not None and vwap is not None: quoteVolume = baseVolume * vwap last = self.safe_float(ticker, 'last') return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': self.safe_float(ticker, 'high'), 'low': self.safe_float(ticker, 'low'), 'bid': self.safe_float(ticker, 'bid'), 'bidVolume': None, 'ask': self.safe_float(ticker, 'ask'), 'askVolume': None, 'vwap': vwap, 'open': None, 'close': last, 'last': last, 'previousClose': None, 'change': None, 'percentage': None, 'average': None, 'baseVolume': baseVolume, 'quoteVolume': quoteVolume, 'info': ticker, } def parse_trade(self, trade, market=None): timestamp = self.parse8601(self.safe_string(trade, 'created_at')) marketId = self.safe_string(trade, 'book') symbol = self.safe_symbol(marketId, market, '_') side = self.safe_string_2(trade, 'side', 'maker_side') amount = self.safe_float_2(trade, 'amount', 'major') if amount is not None: amount = abs(amount) fee = None feeCost = self.safe_float(trade, 'fees_amount') if feeCost is not None: feeCurrencyId = self.safe_string(trade, 'fees_currency') feeCurrency = self.safe_currency_code(feeCurrencyId) fee = { 'cost': feeCost, 'currency': feeCurrency, } cost = self.safe_float(trade, 'minor') if cost is not None: cost = abs(cost) price = self.safe_float(trade, 'price') orderId = self.safe_string(trade, 'oid') id = self.safe_string(trade, 'tid') return { 'id': id, 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': symbol, 'order': orderId, 'type': None, 'side': side, 'takerOrMaker': None, 'price': price, 'amount': amount, 'cost': cost, 'fee': fee, } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) request = { 'book': market['id'], } response = self.publicGetTrades(self.extend(request, params)) return self.parse_trades(response['payload'], market, since, limit) def fetch_my_trades(self, symbol=None, since=None, limit=25, params={}): self.load_markets() market = self.market(symbol) # the don't support fetching trades starting from a date yet # use the `marker` extra param for that # self is not a typo, the variable name is 'marker'(don't confuse with 'market') markerInParams = ('marker' in params) # warn the user with an exception if the user wants to filter # starting from since timestamp, but does not set the trade id with an extra 'marker' param if (since is not None) and not markerInParams: raise ExchangeError(self.id + ' fetchMyTrades does not support fetching trades starting from a timestamp with the `since` argument, use the `marker` extra param to filter starting from an integer trade id') # convert it to an integer unconditionally if markerInParams: params = self.extend(params, { 'marker': int(params['marker']), }) request = { 'book': market['id'], 'limit': limit, # default = 25, max = 100 # 'sort': 'desc', # default = desc # 'marker': id, # integer id to start from } response = self.privateGetUserTrades(self.extend(request, params)) return self.parse_trades(response['payload'], market, since, limit) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() request = { 'book': self.market_id(symbol), 'side': side, 'type': type, 'major': self.amount_to_precision(symbol, amount), } if type == 'limit': request['price'] = self.price_to_precision(symbol, price) response = self.privatePostOrders(self.extend(request, params)) id = self.safe_string(response['payload'], 'oid') return { 'info': response, 'id': id, } def cancel_order(self, id, symbol=None, params={}): self.load_markets() request = { 'oid': id, } return self.privateDeleteOrdersOid(self.extend(request, params)) def parse_order_status(self, status): statuses = { 'partial-fill': 'open', # self is a common substitution in ccxt 'completed': 'closed', } return self.safe_string(statuses, status, status) def parse_order(self, order, market=None): id = self.safe_string(order, 'oid') side = self.safe_string(order, 'side') status = self.parse_order_status(self.safe_string(order, 'status')) marketId = self.safe_string(order, 'book') symbol = self.safe_symbol(marketId, market, '_') orderType = self.safe_string(order, 'type') timestamp = self.parse8601(self.safe_string(order, 'created_at')) price = self.safe_float(order, 'price') amount = self.safe_float(order, 'original_amount') remaining = self.safe_float(order, 'unfilled_amount') filled = None if amount is not None: if remaining is not None: filled = amount - remaining clientOrderId = self.safe_string(order, 'client_id') return { 'info': order, 'id': id, 'clientOrderId': clientOrderId, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'lastTradeTimestamp': None, 'symbol': symbol, 'type': orderType, 'timeInForce': None, 'postOnly': None, 'side': side, 'price': price, 'stopPrice': None, 'amount': amount, 'cost': None, 'remaining': remaining, 'filled': filled, 'status': status, 'fee': None, 'average': None, 'trades': None, } def fetch_open_orders(self, symbol=None, since=None, limit=25, params={}): self.load_markets() market = self.market(symbol) # the don't support fetching trades starting from a date yet # use the `marker` extra param for that # self is not a typo, the variable name is 'marker'(don't confuse with 'market') markerInParams = ('marker' in params) # warn the user with an exception if the user wants to filter # starting from since timestamp, but does not set the trade id with an extra 'marker' param if (since is not None) and not markerInParams: raise ExchangeError(self.id + ' fetchOpenOrders does not support fetching orders starting from a timestamp with the `since` argument, use the `marker` extra param to filter starting from an integer trade id') # convert it to an integer unconditionally if markerInParams: params = self.extend(params, { 'marker': int(params['marker']), }) request = { 'book': market['id'], 'limit': limit, # default = 25, max = 100 # 'sort': 'desc', # default = desc # 'marker': id, # integer id to start from } response = self.privateGetOpenOrders(self.extend(request, params)) orders = self.parse_orders(response['payload'], market, since, limit) return orders def fetch_order(self, id, symbol=None, params={}): self.load_markets() response = self.privateGetOrdersOid({ 'oid': id, }) payload = self.safe_value(response, 'payload') if isinstance(payload, list): numOrders = len(response['payload']) if numOrders == 1: return self.parse_order(payload[0]) raise OrderNotFound(self.id + ': The order ' + id + ' not found.') def fetch_order_trades(self, id, symbol=None, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) request = { 'oid': id, } response = self.privateGetOrderTradesOid(self.extend(request, params)) return self.parse_trades(response['payload'], market) def fetch_deposit_address(self, code, params={}): self.load_markets() currency = self.currency(code) request = { 'fund_currency': currency['id'], } response = self.privateGetFundingDestination(self.extend(request, params)) address = self.safe_string(response['payload'], 'account_identifier') tag = None if address.find('?dt=') >= 0: parts = address.split('?dt=') address = self.safe_string(parts, 0) tag = self.safe_string(parts, 1) self.check_address(address) return { 'currency': code, 'address': address, 'tag': tag, 'info': response, } def withdraw(self, code, amount, address, tag=None, params={}): self.check_address(address) self.load_markets() methods = { 'BTC': 'Bitcoin', 'ETH': 'Ether', 'XRP': 'Ripple', 'BCH': 'Bcash', 'LTC': 'Litecoin', } method = methods[code] if (code in methods) else None if method is None: raise ExchangeError(self.id + ' not valid withdraw coin: ' + code) request = { 'amount': amount, 'address': address, 'destination_tag': tag, } classMethod = 'privatePost' + method + 'Withdrawal' response = getattr(self, classMethod)(self.extend(request, params)) return { 'info': response, 'id': self.safe_string(response['payload'], 'wid'), } def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): endpoint = '/' + self.version + '/' + self.implode_params(path, params) query = self.omit(params, self.extract_params(path)) if method == 'GET': if query: endpoint += '?' + self.urlencode(query) url = self.urls['api'] + endpoint if api == 'private': self.check_required_credentials() nonce = str(self.nonce()) request = ''.join([nonce, method, endpoint]) if method != 'GET': if query: body = self.json(query) request += body signature = self.hmac(self.encode(request), self.encode(self.secret)) auth = self.apiKey + ':' + nonce + ':' + signature headers = { 'Authorization': 'Bitso ' + auth, 'Content-Type': 'application/json', } return {'url': url, 'method': method, 'body': body, 'headers': headers} def handle_errors(self, httpCode, reason, url, method, headers, body, response, requestHeaders, requestBody): if response is None: return # fallback to default error handler if 'success' in response: # # {"success":false,"error":{"code":104,"message":"Cannot perform request - nonce must be higher than 1520307203724237"}} # success = self.safe_value(response, 'success', False) if isinstance(success, basestring): if (success == 'true') or (success == '1'): success = True else: success = False if not success: feedback = self.id + ' ' + self.json(response) error = self.safe_value(response, 'error') if error is None: raise ExchangeError(feedback) code = self.safe_string(error, 'code') self.throw_exactly_matched_exception(self.exceptions, code, feedback) raise ExchangeError(feedback) def request(self, path, api='public', method='GET', params={}, headers=None, body=None): response = self.fetch2(path, api, method, params, headers, body) if 'success' in response: if response['success']: return response raise ExchangeError(self.id + ' ' + self.json(response))