# -*- coding: utf-8 -*- from ccxt.base.exchange import Exchange import hashlib from ccxt.base.errors import ExchangeError class exmo (Exchange): def describe(self): return self.deep_extend(super(exmo, self).describe(), { 'id': 'exmo', 'name': 'EXMO', 'countries': ['ES', 'RU'], # Spain, Russia 'rateLimit': 1000, # once every 350 ms ≈ 180 requests per minute ≈ 3 requests per second 'version': 'v1', 'hasCORS': False, 'hasFetchTickers': True, 'hasWithdraw': True, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/27766491-1b0ea956-5eda-11e7-9225-40d67b481b8d.jpg', 'api': 'https://api.exmo.com', 'www': 'https://exmo.me', 'doc': [ 'https://exmo.me/en/api_doc', 'https://github.com/exmo-dev/exmo_api_lib/tree/master/nodejs', ], }, 'api': { 'public': { 'get': [ 'currency', 'order_book', 'pair_settings', 'ticker', 'trades', ], }, 'private': { 'post': [ 'user_info', 'order_create', 'order_cancel', 'user_open_orders', 'user_trades', 'user_cancelled_orders', 'order_trades', 'required_amount', 'deposit_address', 'withdraw_crypt', 'withdraw_get_txid', 'excode_create', 'excode_load', 'wallet_history', ], }, }, 'fees': { 'trading': { 'maker': 0.2 / 100, 'taker': 0.2 / 100, }, }, }) def fetch_markets(self): markets = self.publicGetPairSettings() keys = list(markets.keys()) result = [] for p in range(0, len(keys)): id = keys[p] market = markets[id] symbol = id.replace('_', '/') base, quote = symbol.split('/') result.append({ 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'limits': { 'amount': { 'min': market['min_quantity'], 'max': market['max_quantity'], }, 'price': { 'min': market['min_price'], 'max': market['max_price'], }, 'cost': { 'min': market['min_amount'], 'max': market['max_amount'], }, }, 'precision': { 'amount': 8, 'price': 8, }, 'info': market, }) return result def fetch_balance(self, params={}): self.load_markets() response = self.privatePostUserInfo() result = {'info': response} currencies = list(self.currencies.keys()) for i in range(0, len(currencies)): currency = currencies[i] account = self.account() if currency in response['balances']: account['free'] = float(response['balances'][currency]) if currency in response['reserved']: account['used'] = float(response['reserved'][currency]) account['total'] = self.sum(account['free'], account['used']) result[currency] = account return self.parse_balance(result) def fetch_order_book(self, symbol, params={}): self.load_markets() market = self.market(symbol) response = self.publicGetOrderBook(self.extend({ 'pair': market['id'], }, params)) orderbook = response[market['id']] return self.parse_order_book(orderbook, None, 'bid', 'ask') def parse_ticker(self, ticker, market=None): timestamp = ticker['updated'] * 1000 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['buy_price']), 'ask': float(ticker['sell_price']), 'vwap': None, 'open': None, 'close': None, 'first': None, 'last': float(ticker['last_trade']), 'change': None, 'percentage': None, 'average': float(ticker['avg']), 'baseVolume': float(ticker['vol']), 'quoteVolume': float(ticker['vol_curr']), 'info': ticker, } def fetch_tickers(self, symbols=None, params={}): self.load_markets() response = self.publicGetTicker(params) result = {} ids = list(response.keys()) for i in range(0, len(ids)): id = ids[i] market = self.markets_by_id[id] symbol = market['symbol'] ticker = response[id] result[symbol] = self.parse_ticker(ticker, market) return result def fetch_ticker(self, symbol, params={}): self.load_markets() response = self.publicGetTicker(params) market = self.market(symbol) return self.parse_ticker(response[market['id']], market) def parse_trade(self, trade, market): timestamp = trade['date'] * 1000 return { 'id': str(trade['trade_id']), 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': market['symbol'], 'order': None, 'type': None, 'side': trade['type'], 'price': float(trade['price']), 'amount': float(trade['quantity']), } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) response = self.publicGetTrades(self.extend({ 'pair': market['id'], }, params)) return self.parse_trades(response[market['id']], market, since, limit) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() prefix = '' if type == 'market': prefix = 'market_' if price is None: price = 0 order = { 'pair': self.market_id(symbol), 'quantity': amount, 'price': price, 'type': prefix + side, } response = self.privatePostOrderCreate(self.extend(order, params)) return { 'info': response, 'id': str(response['order_id']), } def cancel_order(self, id, symbol=None, params={}): self.load_markets() return self.privatePostOrderCancel({'order_id': id}) def withdraw(self, currency, amount, address, params={}): self.load_markets() result = self.privatePostWithdrawCrypt(self.extend({ 'amount': amount, 'currency': currency, 'address': address, }, params)) return { 'info': result, 'id': result['task_id'], } def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): url = self.urls['api'] + '/' + self.version + '/' + path if api == 'public': if params: url += '?' + self.urlencode(params) else: self.check_required_credentials() nonce = self.nonce() body = self.urlencode(self.extend({'nonce': nonce}, params)) headers = { 'Content-Type': 'application/x-www-form-urlencoded', 'Key': self.apiKey, 'Sign': self.hmac(self.encode(body), self.encode(self.secret), hashlib.sha512), } 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 'result' in response: if response['result']: return response raise ExchangeError(self.id + ' ' + self.json(response)) return response