# -*- coding: utf-8 -*- from ccxt.base.exchange import Exchange import hashlib from ccxt.base.errors import ExchangeError class therock (Exchange): def describe(self): return self.deep_extend(super(therock, self).describe(), { 'id': 'therock', 'name': 'TheRockTrading', 'countries': 'MT', 'rateLimit': 1000, 'version': 'v1', 'hasCORS': False, 'hasFetchTickers': True, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/27766869-75057fa2-5ee9-11e7-9a6f-13e641fa4707.jpg', 'api': 'https://api.therocktrading.com', 'www': 'https://therocktrading.com', 'doc': [ 'https://api.therocktrading.com/doc/v1/index.html', 'https://api.therocktrading.com/doc/', ], }, 'api': { 'public': { 'get': [ 'funds/{id}/orderbook', 'funds/{id}/ticker', 'funds/{id}/trades', 'funds/tickers', ], }, 'private': { 'get': [ 'balances', 'balances/{id}', 'discounts', 'discounts/{id}', 'funds', 'funds/{id}', 'funds/{id}/trades', 'funds/{fund_id}/orders', 'funds/{fund_id}/orders/{id}', 'funds/{fund_id}/position_balances', 'funds/{fund_id}/positions', 'funds/{fund_id}/positions/{id}', 'transactions', 'transactions/{id}', 'withdraw_limits/{id}', 'withdraw_limits', ], 'post': [ 'atms/withdraw', 'funds/{fund_id}/orders', ], 'delete': [ 'funds/{fund_id}/orders/{id}', 'funds/{fund_id}/orders/remove_all', ], }, }, 'fees': { 'trading': { 'maker': 0.02 / 100, 'taker': 0.2 / 100, }, 'funding': { 'tierBased': False, 'percentage': False, 'withdraw': { 'BTC': 0.0005, 'BCH': 0.0005, 'PPC': 0.02, 'ETH': 0.001, 'ZEC': 0.001, 'LTC': 0.002, 'EUR': 2.5, # worst-case scenario: https://therocktrading.com/en/pages/fees }, 'deposit': { 'BTC': 0, 'BCH': 0, 'PPC': 0, 'ETH': 0, 'ZEC': 0, 'LTC': 0, 'EUR': 0, }, }, }, }) def fetch_markets(self): markets = self.publicGetFundsTickers() result = [] for p in range(0, len(markets['tickers'])): market = markets['tickers'][p] id = market['fund_id'] base = id[0:3] quote = id[3:6] symbol = base + '/' + quote result.append({ 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'info': market, }) return result def fetch_balance(self, params={}): self.load_markets() response = self.privateGetBalances() balances = response['balances'] result = {'info': response} for b in range(0, len(balances)): balance = balances[b] currency = balance['currency'] free = balance['trading_balance'] total = balance['balance'] used = total - free account = { 'free': free, 'used': used, 'total': total, } result[currency] = account return self.parse_balance(result) def fetch_order_book(self, symbol, params={}): self.load_markets() orderbook = self.publicGetFundsIdOrderbook(self.extend({ 'id': self.market_id(symbol), }, params)) timestamp = self.parse8601(orderbook['date']) return self.parse_order_book(orderbook, timestamp, 'bids', 'asks', 'price', 'amount') def parse_ticker(self, ticker, market=None): timestamp = self.parse8601(ticker['date']) symbol = None if market: symbol = market['symbol'] return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': float(ticker['high']), 'low': float(ticker['low']), 'bid': float(ticker['bid']), 'ask': float(ticker['ask']), 'vwap': None, 'open': float(ticker['open']), 'close': float(ticker['close']), 'first': None, 'last': float(ticker['last']), 'change': None, 'percentage': None, 'average': None, 'baseVolume': float(ticker['volume_traded']), 'quoteVolume': float(ticker['volume']), 'info': ticker, } def fetch_tickers(self, symbols=None, params={}): self.load_markets() response = self.publicGetFundsTickers(params) tickers = self.index_by(response['tickers'], 'fund_id') ids = list(tickers.keys()) result = {} for i in range(0, len(ids)): id = ids[i] market = self.markets_by_id[id] symbol = market['symbol'] ticker = tickers[id] result[symbol] = self.parse_ticker(ticker, market) return result def fetch_ticker(self, symbol, params={}): self.load_markets() market = self.market(symbol) ticker = self.publicGetFundsIdTicker(self.extend({ 'id': market['id'], }, params)) return self.parse_ticker(ticker, market) def parse_trade(self, trade, market=None): if not market: market = self.markets_by_id[trade['fund_id']] timestamp = self.parse8601(trade['date']) return { 'info': trade, 'id': str(trade['id']), 'order': None, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': market['symbol'], 'type': None, 'side': trade['side'], 'price': trade['price'], 'amount': trade['amount'], } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) response = self.publicGetFundsIdTrades(self.extend({ 'id': market['id'], }, params)) return self.parse_trades(response['trades'], market, since, limit) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() if type == 'market': price = 0 response = self.privatePostFundsFundIdOrders(self.extend({ 'fund_id': self.market_id(symbol), 'side': side, 'amount': amount, 'price': price, }, params)) return { 'info': response, 'id': str(response['id']), } def cancel_order(self, id, symbol=None, params={}): self.load_markets() return self.privateDeleteFundsFundIdOrdersId(self.extend({ 'id': id, }, params)) def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): url = self.urls['api'] + '/' + self.version + '/' + self.implode_params(path, params) query = self.omit(params, self.extract_params(path)) if api == 'private': self.check_required_credentials() nonce = str(self.nonce()) auth = nonce + url headers = { 'X-TRT-KEY': self.apiKey, 'X-TRT-NONCE': nonce, 'X-TRT-SIGN': self.hmac(self.encode(auth), self.encode(self.secret), hashlib.sha512), } if query: body = self.json(query) headers['Content-Type'] = 'application/json' return {'url': url, 'method': method, 'body': body, 'headers': headers} def request(self, path, api='public', method='GET', params={}, headers=None, body=None): response = self.fetch2(path, api, method, params, headers, body) if 'errors' in response: raise ExchangeError(self.id + ' ' + self.json(response)) return response