# -*- coding: utf-8 -*- from ccxt.base.exchange import Exchange import hashlib import math import json from ccxt.base.errors import ExchangeError from ccxt.base.errors import NotSupported from ccxt.base.errors import AuthenticationError from ccxt.base.errors import InvalidOrder from ccxt.base.errors import OrderNotFound class livecoin (Exchange): def describe(self): return self.deep_extend(super(livecoin, self).describe(), { 'id': 'livecoin', 'name': 'LiveCoin', 'countries': ['US', 'UK', 'RU'], 'rateLimit': 1000, 'hasCORS': False, # obsolete metainfo interface 'hasFetchTickers': True, 'hasFetchCurrencies': True, # new metainfo interface 'has': { 'fetchTickers': True, 'fetchCurrencies': True, }, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/27980768-f22fc424-638a-11e7-89c9-6010a54ff9be.jpg', 'api': 'https://api.livecoin.net', 'www': 'https://www.livecoin.net', 'doc': 'https://www.livecoin.net/api?lang=en', }, 'api': { 'public': { 'get': [ 'exchange/all/order_book', 'exchange/last_trades', 'exchange/maxbid_minask', 'exchange/order_book', 'exchange/restrictions', 'exchange/ticker', # omit params to get all tickers at once 'info/coinInfo', ], }, 'private': { 'get': [ 'exchange/client_orders', 'exchange/order', 'exchange/trades', 'exchange/commission', 'exchange/commissionCommonInfo', 'payment/balances', 'payment/balance', 'payment/get/address', 'payment/history/size', 'payment/history/transactions', ], 'post': [ 'exchange/buylimit', 'exchange/buymarket', 'exchange/cancellimit', 'exchange/selllimit', 'exchange/sellmarket', 'payment/out/capitalist', 'payment/out/card', 'payment/out/coin', 'payment/out/okpay', 'payment/out/payeer', 'payment/out/perfectmoney', 'payment/voucher/amount', 'payment/voucher/make', 'payment/voucher/redeem', ], }, }, 'fees': { 'trading': { 'tierBased': False, 'percentage': True, 'maker': 0.18 / 100, 'taker': 0.18 / 100, }, }, }) def fetch_markets(self): markets = self.publicGetExchangeTicker() restrictions = self.publicGetExchangeRestrictions() restrictionsById = self.index_by(restrictions['restrictions'], 'currencyPair') result = [] for p in range(0, len(markets)): market = markets[p] id = market['symbol'] symbol = id base, quote = symbol.split('/') coinRestrictions = self.safe_value(restrictionsById, symbol) precision = { 'price': 5, 'amount': 8, 'cost': 8, } limits = { 'amount': { 'min': math.pow(10, -precision['amount']), 'max': math.pow(10, precision['amount']), }, } if coinRestrictions: precision['price'] = self.safe_integer(coinRestrictions, 'priceScale', 5) limits['amount']['min'] = self.safe_float(coinRestrictions, 'minLimitQuantity', limits['amount']['min']) limits['price'] = { 'min': math.pow(10, -precision['price']), 'max': math.pow(10, precision['price']), } result.append(self.extend(self.fees['trading'], { 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'precision': precision, 'limits': limits, 'info': market, })) return result def fetch_currencies(self, params={}): response = self.publicGetInfoCoinInfo(params) currencies = response['info'] result = {} for i in range(0, len(currencies)): currency = currencies[i] id = currency['symbol'] # todo: will need to rethink the fees # to add support for multiple withdrawal/deposit methods and # differentiated fees for each particular method code = self.common_currency_code(id) precision = 8 # default precision, todo: fix "magic constants" active = (currency['walletStatus'] == 'normal') result[code] = { 'id': id, 'code': code, 'info': currency, 'name': currency['name'], 'active': active, 'status': 'ok', 'fee': currency['withdrawFee'], # todo: redesign 'precision': precision, 'limits': { 'amount': { 'min': currency['minOrderAmount'], 'max': math.pow(10, precision), }, 'price': { 'min': math.pow(10, -precision), 'max': math.pow(10, precision), }, 'cost': { 'min': currency['minOrderAmount'], 'max': None, }, 'withdraw': { 'min': currency['minWithdrawAmount'], 'max': math.pow(10, precision), }, 'deposit': { 'min': currency['minDepositAmount'], 'max': None, }, }, } return result def fetch_balance(self, params={}): self.load_markets() balances = self.privateGetPaymentBalances() result = {'info': balances} for b in range(0, len(balances)): balance = balances[b] currency = balance['currency'] account = None if currency in result: account = result[currency] else: account = self.account() if balance['type'] == 'total': account['total'] = float(balance['value']) if balance['type'] == 'available': account['free'] = float(balance['value']) if balance['type'] == 'trade': account['used'] = float(balance['value']) result[currency] = account return self.parse_balance(result) def fetch_fees(self, params={}): self.load_markets() commissionInfo = self.privateGetExchangeCommissionCommonInfo() commission = self.safe_float(commissionInfo, 'commission') return { 'info': commissionInfo, 'maker': commission, 'taker': commission, 'withdraw': 0.0, } def fetch_order_book(self, symbol, params={}): self.load_markets() orderbook = self.publicGetExchangeOrderBook(self.extend({ 'currencyPair': self.market_id(symbol), 'groupByPrice': 'false', 'depth': 100, }, params)) timestamp = orderbook['timestamp'] return self.parse_order_book(orderbook, timestamp) def parse_ticker(self, ticker, market=None): timestamp = self.milliseconds() symbol = None if market: symbol = market['symbol'] vwap = float(ticker['vwap']) baseVolume = float(ticker['volume']) quoteVolume = baseVolume * vwap return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': float(ticker['high']), 'low': float(ticker['low']), 'bid': float(ticker['best_bid']), 'ask': float(ticker['best_ask']), 'vwap': float(ticker['vwap']), 'open': None, 'close': None, 'first': None, 'last': float(ticker['last']), 'change': None, 'percentage': None, 'average': None, 'baseVolume': baseVolume, 'quoteVolume': quoteVolume, 'info': ticker, } def fetch_tickers(self, symbols=None, params={}): self.load_markets() response = self.publicGetExchangeTicker(params) tickers = self.index_by(response, 'symbol') 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.publicGetExchangeTicker(self.extend({ 'currencyPair': market['id'], }, params)) return self.parse_ticker(ticker, market) def parse_trade(self, trade, market): timestamp = trade['time'] * 1000 return { 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': market['symbol'], 'id': str(trade['id']), 'order': None, 'type': None, 'side': trade['type'].lower(), 'price': trade['price'], 'amount': trade['quantity'], } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) response = self.publicGetExchangeLastTrades(self.extend({ 'currencyPair': market['id'], }, params)) return self.parse_trades(response, market, since, limit) def parse_order(self, order, market=None): timestamp = self.safe_integer(order, 'lastModificationTime') if not timestamp: timestamp = self.parse8601(order['lastModificationTime']) trades = None if 'trades' in order: # TODO currently not supported by livecoin # trades = self.parse_trades(order['trades'], market, since, limit) trades = None status = None if order['orderStatus'] == 'OPEN' or order['orderStatus'] == 'PARTIALLY_FILLED': status = 'open' elif order['orderStatus'] == 'EXECUTED' or order['orderStatus'] == 'PARTIALLY_FILLED_AND_CANCELLED': status = 'closed' else: status = 'canceled' symbol = order['currencyPair'] base, quote = symbol.split('/') type = None side = None if order['type'].find('MARKET') >= 0: type = 'market' else: type = 'limit' if order['type'].find('SELL') >= 0: side = 'sell' else: side = 'buy' price = self.safe_float(order, 'price', 0.0) cost = self.safe_float(order, 'commissionByTrade', 0.0) remaining = self.safe_float(order, 'remainingQuantity', 0.0) amount = self.safe_float(order, 'quantity', remaining) filled = amount - remaining return { 'info': order, 'id': order['id'], 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'status': status, 'symbol': symbol, 'type': type, 'side': side, 'price': price, 'cost': cost, 'amount': amount, 'filled': filled, 'remaining': remaining, 'trades': trades, 'fee': { 'cost': cost, 'currency': quote, }, } def fetch_orders(self, symbol=None, since=None, limit=None, params={}): self.load_markets() market = None if symbol: market = self.market(symbol) pair = market['id'] if market else None request = {} if pair: request['currencyPair'] = pair if since: request['issuedFrom'] = int(since) if limit: request['endRow'] = limit - 1 response = self.privateGetExchangeClientOrders(self.extend(request, params)) result = [] rawOrders = [] if response['data']: rawOrders = response['data'] for i in range(0, len(rawOrders)): order = rawOrders[i] result.append(self.parse_order(order, market)) return result def fetch_open_orders(self, symbol=None, since=None, limit=None, params={}): result = self.fetch_orders(symbol, since, limit, self.extend({ 'openClosed': 'OPEN', }, params)) return result def fetch_closed_orders(self, symbol=None, since=None, limit=None, params={}): result = self.fetch_orders(symbol, since, limit, self.extend({ 'openClosed': 'CLOSED', }, params)) return result def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() method = 'privatePostExchange' + self.capitalize(side) + type market = self.market(symbol) order = { 'quantity': self.amount_to_precision(symbol, amount), 'currencyPair': market['id'], } if type == 'limit': order['price'] = self.price_to_precision(symbol, price) response = getattr(self, method)(self.extend(order, params)) return { 'info': response, 'id': str(response['orderId']), } def cancel_order(self, id, symbol=None, params={}): if not symbol: raise ExchangeError(self.id + ' cancelOrder requires a symbol argument') self.load_markets() market = self.market(symbol) currencyPair = market['id'] response = self.privatePostExchangeCancellimit(self.extend({ 'orderId': id, 'currencyPair': currencyPair, }, params)) message = self.safe_string(response, 'message', self.json(response)) if 'success' in response: if not response['success']: raise InvalidOrder(message) elif 'cancelled' in response: if response['cancelled']: return response else: raise OrderNotFound(message) raise ExchangeError(self.id + ' cancelOrder() failed: ' + self.json(response)) def fetch_deposit_address(self, currency, params={}): request = { 'currency': currency, } response = self.privateGetPaymentGetAddress(self.extend(request, params)) address = self.safe_string(response, 'wallet') return { 'currency': currency, 'address': address, 'status': 'ok', 'info': response, } def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): url = self.urls['api'] + '/' + path query = self.urlencode(self.keysort(params)) if method == 'GET': if params: url += '?' + query if api == 'private': self.check_required_credentials() if method == 'POST': body = query signature = self.hmac(self.encode(query), self.encode(self.secret), hashlib.sha256) headers = { 'Api-Key': self.apiKey, 'Sign': signature.upper(), 'Content-Type': 'application/x-www-form-urlencoded', } return {'url': url, 'method': method, 'body': body, 'headers': headers} def handle_errors(self, code, reason, url, method, headers, body): if code >= 300: if body[0] == "{": response = json.loads(body) if 'errorCode' in response: error = response['errorCode'] if error == 1: raise ExchangeError(self.id + ' ' + self.json(response)) elif error == 2: if 'errorMessage' in response: if response['errorMessage'] == 'User not found': raise AuthenticationError(self.id + ' ' + response['errorMessage']) else: raise ExchangeError(self.id + ' ' + self.json(response)) elif (error == 10) or (error == 11) or (error == 12) or (error == 20) or (error == 30) or (error == 101) or (error == 102): raise AuthenticationError(self.id + ' ' + self.json(response)) elif error == 31: raise NotSupported(self.id + ' ' + self.json(response)) elif error == 32: raise ExchangeError(self.id + ' ' + self.json(response)) elif error == 100: raise ExchangeError(self.id + ': Invalid parameters ' + self.json(response)) elif error == 103: raise InvalidOrder(self.id + ': Invalid currency ' + self.json(response)) elif error == 104: raise InvalidOrder(self.id + ': Invalid amount ' + self.json(response)) elif error == 105: raise InvalidOrder(self.id + ': Unable to block funds ' + self.json(response)) else: raise ExchangeError(self.id + ' ' + self.json(response)) raise ExchangeError(self.id + ' ' + body) 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 not response['success']: raise ExchangeError(self.id + ' error: ' + self.json(response)) return response