# -*- 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 import math from ccxt.base.errors import ExchangeError from ccxt.base.errors import AuthenticationError from ccxt.base.errors import ArgumentsRequired from ccxt.base.errors import InsufficientFunds from ccxt.base.errors import InvalidOrder from ccxt.base.errors import OrderNotFound from ccxt.base.decimal_to_precision import ROUND class rightbtc(Exchange): def describe(self): return self.deep_extend(super(rightbtc, self).describe(), { 'id': 'rightbtc', 'name': 'RightBTC', 'countries': ['AE'], 'has': { 'cancelOrder': True, 'createOrder': True, 'privateAPI': False, 'fetchBalance': True, 'fetchClosedOrders': False, 'fetchMarkets': True, 'fetchMyTrades': True, 'fetchOHLCV': True, 'fetchOpenOrders': True, 'fetchOrder': 'emulated', 'fetchOrderBook': True, 'fetchOrders': True, 'fetchTicker': True, 'fetchTickers': True, 'fetchTrades': True, }, 'timeframes': { '1m': 'min1', '5m': 'min5', '15m': 'min15', '30m': 'min30', '1h': 'hr1', '1d': 'day1', '1w': 'week', }, 'urls': { 'logo': 'https://user-images.githubusercontent.com/51840849/87182092-1f372700-c2ec-11ea-8f9e-01b4d3ff8941.jpg', 'api': 'https://www.rightbtc.com/api', 'www': 'https://www.rightbtc.com', 'doc': [ 'https://docs.rightbtc.com/api/', ], # eslint-disable-next-line no-useless-escape # 'fees': 'https://www.rightbtc.com/\#\not /support/fee', }, 'api': { 'public': { 'get': [ # 'getAssetsTradingPairs/zh', # 404 'trading_pairs', 'ticker/{trading_pair}', 'tickers', 'depth/{trading_pair}', 'depth/{trading_pair}/{count}', 'trades/{trading_pair}', 'trades/{trading_pair}/{count}', 'candlestick/latest/{trading_pair}', 'candlestick/{timeSymbol}/{trading_pair}', 'candlestick/{timeSymbol}/{trading_pair}/{count}', ], }, 'trader': { 'get': [ 'balance/{symbol}', 'balances', 'deposits/{asset}/{page}', 'withdrawals/{asset}/{page}', 'orderpage/{trading_pair}/{cursor}', 'orders/{trading_pair}/{ids}', # ids are a slash-separated list of {id}/{id}/{id}/... 'history/{trading_pair}/{ids}', 'historys/{trading_pair}/{page}', 'trading_pairs', ], 'post': [ 'order', ], 'delete': [ 'order/{trading_pair}/{ids}', ], }, }, # HARDCODING IS DEPRECATED, THE FEES BELOW SHOULD BE REWRITTEN 'fees': { 'trading': { # min trading fees # 0.0001 BTC # 0.01 ETP # 0.001 ETH # 0.1 BITCNY 'maker': 0.1 / 100, 'taker': 0.2 / 100, }, 'funding': { 'withdraw': { # 'BTM': n => 3 + n * (1 / 100), # 'ZDC': n => 1 + n * (0.5 / 100), # 'ZGC': n => 0.5 + n * (0.5 / 100), # 'BTS': n => 1 + n * (1 / 100), # 'DLT': n => 3 + n * (1 / 100), # 'SNT': n => 10 + n * (1 / 100), # 'XNC': n => 1 + n * (1 / 100), # 'ICO': n => 3 + n * (1 / 100), # 'CMC': n => 1 + n * (0.5 / 100), # 'GXS': n => 0.2 + n * (1 / 100), # 'OBITS': n => 0.3 + n * (1 / 100), # 'ICS': n => 2 + n * (1 / 100), # 'TIC': n => 2 + n * (1 / 100), # 'IND': n => 20 + n * (1 / 100), # 'MVC': n => 20 + n * (1 / 100), # 'BitCNY': n => 0.1 + n * (1 / 100), # 'MTX': n => 1 + n * (1 / 100), 'ETP': 0.01, 'BTC': 0.0005, 'ETH': 0.005, 'ETC': 0.01, 'STORJ': 3, 'LTC': 0.01, 'ZEC': 0.001, 'BCC': 0.001, 'XRB': 0, 'NXS': 0.1, }, }, }, 'commonCurrencies': { 'XRB': 'NANO', }, 'exceptions': { 'ERR_USERTOKEN_NOT_FOUND': AuthenticationError, 'ERR_ASSET_NOT_EXISTS': ExchangeError, 'ERR_ASSET_NOT_AVAILABLE': ExchangeError, 'ERR_BALANCE_NOT_ENOUGH': InsufficientFunds, 'ERR_CREATE_ORDER': InvalidOrder, 'ERR_CANDLESTICK_DATA': ExchangeError, }, }) def fetch_markets(self, params={}): # zh = self.publicGetGetAssetsTradingPairsZh() markets = self.publicGetTradingPairs(params) marketIds = list(markets.keys()) result = [] for i in range(0, len(marketIds)): id = marketIds[i] market = markets[id] baseId = self.safe_string(market, 'bid_asset_symbol') quoteId = self.safe_string(market, 'ask_asset_symbol') base = self.safe_currency_code(baseId) quote = self.safe_currency_code(quoteId) symbol = base + '/' + quote precision = { 'amount': self.safe_integer(market, 'bid_asset_decimals'), 'price': self.safe_integer(market, 'ask_asset_decimals'), } result.append({ 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'baseId': baseId, 'quoteId': quoteId, 'active': True, 'precision': precision, 'limits': { 'amount': { 'min': math.pow(10, -precision['amount']), 'max': math.pow(10, precision['price']), }, 'price': { 'min': math.pow(10, -precision['price']), 'max': math.pow(10, precision['price']), }, 'cost': { 'min': None, 'max': None, }, }, 'info': market, }) return result def divide_safe_float(self, x, key, divisor): value = self.safe_float(x, key) if value is not None: return value / divisor return value def parse_ticker(self, ticker, market=None): symbol = market['symbol'] timestamp = self.safe_integer(ticker, 'date') last = self.divide_safe_float(ticker, 'last', 1e8) high = self.divide_safe_float(ticker, 'high', 1e8) low = self.divide_safe_float(ticker, 'low', 1e8) bid = self.divide_safe_float(ticker, 'buy', 1e8) ask = self.divide_safe_float(ticker, 'sell', 1e8) baseVolume = self.divide_safe_float(ticker, 'vol24h', 1e8) return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': high, 'low': low, 'bid': bid, 'bidVolume': None, 'ask': ask, 'askVolume': None, 'vwap': None, 'open': None, 'close': last, 'last': last, 'previousClose': None, 'change': None, 'percentage': None, 'average': None, 'baseVolume': baseVolume, 'quoteVolume': None, 'info': ticker, } def fetch_ticker(self, symbol, params={}): self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], } response = self.publicGetTickerTradingPair(self.extend(request, params)) result = self.safe_value(response, 'result') if result is None: raise ExchangeError(self.id + ' fetchTicker returned an empty response for symbol ' + symbol) return self.parse_ticker(result, market) def fetch_tickers(self, symbols=None, params={}): self.load_markets() response = self.publicGetTickers(params) tickers = response['result'] result = {} for i in range(0, len(tickers)): ticker = tickers[i] id = ticker['market'] if not (id in self.marketsById): continue market = self.marketsById[id] symbol = market['symbol'] result[symbol] = self.parse_ticker(ticker, market) return self.filter_by_array(result, 'symbol', symbols) def fetch_order_book(self, symbol, limit=None, params={}): self.load_markets() request = { 'trading_pair': self.market_id(symbol), } method = 'publicGetDepthTradingPair' if limit is not None: method += 'Count' request['count'] = limit response = getattr(self, method)(self.extend(request, params)) bidsasks = {} types = ['bid', 'ask'] for ti in range(0, len(types)): type = types[ti] bidsasks[type] = [] for i in range(0, len(response['result'][type])): price, amount, total = response['result'][type][i] bidsasks[type].append([ price / 1e8, amount / 1e8, total / 1e8, ]) return self.parse_order_book(bidsasks, None, 'bid', 'ask') def parse_trade(self, trade, market=None): # # { # "order_id": 118735, # "trade_id": 7, # "trading_pair": "BTCCNY", # "side": "B", # "quantity": 1000000000, # "price": 900000000, # "created_at": "2017-06-06T20:45:27.000Z" # } # timestamp = self.safe_integer(trade, 'date') if timestamp is None: timestamp = self.parse8601(self.safe_string(trade, 'created_at')) id = self.safe_string(trade, 'tid') id = self.safe_string(trade, 'trade_id', id) orderId = self.safe_string(trade, 'order_id') price = self.divide_safe_float(trade, 'price', 1e8) amount = self.safe_float(trade, 'amount') amount = self.safe_float(trade, 'quantity', amount) if amount is not None: amount = amount / 1e8 marketId = self.safe_string(trade, 'trading_pair') symbol = self.safe_symbol(marketId, market) cost = self.cost_to_precision(symbol, price * amount) cost = float(cost) side = self.safe_string_lower(trade, 'side') if side == 'b': side = 'buy' elif side == 's': side = 'sell' return { 'id': id, 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': symbol, 'order': orderId, 'type': 'limit', 'side': side, 'takerOrMaker': None, 'price': price, 'amount': amount, 'cost': cost, 'fee': None, } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], } response = self.publicGetTradesTradingPair(self.extend(request, params)) return self.parse_trades(response['result'], market, since, limit) def parse_ohlcv(self, ohlcv, market=None): return [ self.safe_integer(ohlcv, 0), float(ohlcv[2]) / 1e8, float(ohlcv[3]) / 1e8, float(ohlcv[4]) / 1e8, float(ohlcv[5]) / 1e8, float(ohlcv[1]) / 1e8, ] def fetch_ohlcv(self, symbol, timeframe='5m', since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], 'timeSymbol': self.timeframes[timeframe], } response = self.publicGetCandlestickTimeSymbolTradingPair(self.extend(request, params)) result = self.safe_value(response, 'result', []) return self.parse_ohlcvs(result, market, timeframe, since, limit) def fetch_balance(self, params={}): self.load_markets() response = self.traderGetBalances(params) # # { # "status": { # "success": 1, # "message": "GET_BALANCES" # }, # "result": [ # { # "asset": "ETP", # "balance": "5000000000000", # "frozen": "0", # "state": "1" # }, # { # "asset": "CNY", # "balance": "10000000000000", # "frozen": "240790000", # "state": "1" # } # ] # } # result = {'info': response} balances = self.safe_value(response, 'result', []) for i in range(0, len(balances)): balance = balances[i] currencyId = self.safe_string(balance, 'asset') code = self.safe_currency_code(currencyId) account = self.account() # https://github.com/ccxt/ccxt/issues/3873 account['free'] = self.divide_safe_float(balance, 'balance', 1e8) account['used'] = self.divide_safe_float(balance, 'frozen', 1e8) result[code] = account return self.parse_balance(result) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() market = self.market(symbol) order = { 'trading_pair': market['id'], # We need to use decimalToPrecision here, since # 0.036*1e8 == 3599999.9999999995 # which would get truncated to 3599999 after int// which would then be rejected by rightBtc because it's too precise 'quantity': int(self.decimal_to_precision(amount * 1e8, ROUND, 0, self.precisionMode)), 'limit': int(self.decimal_to_precision(price * 1e8, ROUND, 0, self.precisionMode)), 'type': type.upper(), 'side': side.upper(), } response = self.traderPostOrder(self.extend(order, params)) return self.parse_order(response) def cancel_order(self, id, symbol=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' cancelOrder() requires a symbol argument') self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], 'ids': id, } response = self.traderDeleteOrderTradingPairIds(self.extend(request, params)) return response def parse_order_status(self, status): statuses = { 'NEW': 'open', 'TRADE': 'closed', # TRADE means filled or partially filled orders 'CANCEL': 'canceled', } return self.safe_string(statuses, status, status) def parse_order(self, order, market=None): # # fetchOrder / fetchOpenOrders # # { # "id": 4180528, # "quantity": 20000000, # "rest": 20000000, # "limit": 1000000, # "price": null, # "side": "BUY", # "created": 1496005693738 # } # # fetchOrders # # { # "trading_pair": "ETPCNY", # "status": "TRADE", # "fee": 0.23, # "min_fee": 10000000, # "created_at": "2017-05-25T00:12:27.000Z", # "cost": 1152468000000, # "limit": 3600000000, # "id": 11060, # "quantity": 32013000000, # "filled_quantity": 32013000000 # } # id = self.safe_string(order, 'id') status = self.parse_order_status(self.safe_string(order, 'status')) marketId = self.safe_string(order, 'trading_pair') symbol = self.safe_symbol(marketId, market) timestamp = self.safe_integer(order, 'created') if timestamp is None: timestamp = self.parse8601(self.safe_string(order, 'created_at')) if 'time' in order: timestamp = order['time'] elif 'transactTime' in order: timestamp = order['transactTime'] price = self.safe_float_2(order, 'limit', 'price') if price is not None: price = price / 1e8 amount = self.divide_safe_float(order, 'quantity', 1e8) filled = self.divide_safe_float(order, 'filled_quantity', 1e8) remaining = self.divide_safe_float(order, 'rest', 1e8) cost = self.divide_safe_float(order, 'cost', 1e8) # lines 483-494 should be generalized into a base class method if amount is not None: if remaining is None: if filled is not None: remaining = max(0, amount - filled) if filled is None: if remaining is not None: filled = max(0, amount - remaining) type = 'limit' side = self.safe_string_lower(order, 'side') feeCost = self.divide_safe_float(order, 'min_fee', 1e8) fee = None if feeCost is not None: feeCurrency = None if market is not None: feeCurrency = market['quote'] fee = { 'rate': self.safe_float(order, 'fee'), 'cost': feeCost, 'currency': feeCurrency, } trades = None return { 'info': order, 'id': id, 'clientOrderId': None, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'lastTradeTimestamp': None, 'symbol': symbol, 'type': type, 'timeInForce': None, 'postOnly': None, 'side': side, 'price': price, 'stopPrice': None, 'amount': amount, 'cost': cost, 'filled': filled, 'remaining': remaining, 'status': status, 'fee': fee, 'trades': trades, 'average': None, } def fetch_order(self, id, symbol=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchOrder() requires a symbol argument') self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], 'ids': id, } response = self.traderGetOrdersTradingPairIds(self.extend(request, params)) # # response = { # "status": { # "success": 1, # "message": "SUC_LIST_AVTICE_ORDERS" # }, # "result": [ # { # "id": 4180528, # "quantity": 20000000, # "rest": 20000000, # "limit": 1000000, # "price": null, # "side": "BUY", # "created": 1496005693738 # } # ] # } # orders = self.parse_orders(response['result'], market) ordersById = self.index_by(orders, 'id') if not (id in ordersById): raise OrderNotFound(self.id + ' fetchOrder could not find order ' + str(id) + ' in open orders.') return ordersById[id] def fetch_open_orders(self, symbol=None, since=None, limit=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchOpenOrders() requires a symbol argument') self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], 'cursor': 0, } response = self.traderGetOrderpageTradingPairCursor(self.extend(request, params)) # # response = { # "status": { # "success": 1, # "message": "SUC_LIST_AVTICE_ORDERS_PAGE" # }, # "result": { # "cursor": "0", # "orders": [ # { # "id": 4180528, # "quantity": 20000000, # "rest": 20000000, # "limit": 1000000, # "price": null, # "side": "BUY", # "created": 1496005693738 # } # ] # } # } # return self.parse_orders(response['result']['orders'], market, since, limit) def fetch_orders(self, symbol=None, since=None, limit=None, params={}): ids = self.safe_string(params, 'ids') if (symbol is None) or (ids is None): raise ArgumentsRequired(self.id + " fetchOrders() requires a 'symbol' argument and an extra 'ids' parameter. The 'ids' should be an array or a string of one or more order ids separated with slashes.") # eslint-disable-line quotes if isinstance(ids, list): ids = '/'.join(ids) self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], 'ids': ids, } response = self.traderGetHistoryTradingPairIds(self.extend(request, params)) # # response = { # "status": { # "success": 1, # "message": null # }, # "result": [ # { # "trading_pair": "ETPCNY", # "status": "TRADE", # "fee": 0.23, # "min_fee": 10000000, # "created_at": "2017-05-25T00:12:27.000Z", # "cost": 1152468000000, # "limit": 3600000000, # "id": 11060, # "quantity": 32013000000, # "filled_quantity": 32013000000 # } # ] # } # return self.parse_orders(response['result'], None, since, limit) def fetch_my_trades(self, symbol=None, since=None, limit=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchMyTrades() requires a symbol argument') self.load_markets() market = self.market(symbol) request = { 'trading_pair': market['id'], 'page': 0, } response = self.traderGetHistorysTradingPairPage(self.extend(request, params)) # # response = { # "status": { # "success": 1, # "message": null # }, # "result": [ # { # "order_id": 118735, # "trade_id": 7, # "trading_pair": "BTCCNY", # "side": "B", # "quantity": 1000000000, # "price": 900000000, # "created_at": "2017-06-06T20:45:27.000Z" # }, # { # "order_id": 118734, # "trade_id": 7, # "trading_pair": "BTCCNY", # "side": "S", # "quantity": 1000000000, # "price": 900000000, # "created_at": "2017-06-06T20:45:27.000Z" # } # ] # } # return self.parse_trades(response['result'], None, since, limit) def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): query = self.omit(params, self.extract_params(path)) url = self.urls['api'] + '/' + api + '/' + self.implode_params(path, params) if api == 'public': if query: url += '?' + self.urlencode(query) else: self.check_required_credentials() headers = { 'apikey': self.apiKey, 'signature': self.secret, } if method == 'GET': if query: url += '?' + self.urlencode(query) else: body = self.json(query) headers['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 status = self.safe_value(response, 'status') if status is not None: # # {"status":{"success":0,"message":"ERR_USERTOKEN_NOT_FOUND"}} # success = self.safe_string(status, 'success') if success != '1': message = self.safe_string(status, 'message') feedback = self.id + ' ' + body self.throw_exactly_matched_exception(self.exceptions, message, feedback) raise ExchangeError(feedback)