# -*- 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.async_support.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 BadRequest from ccxt.base.errors import InvalidOrder from ccxt.base.errors import OrderNotFound from ccxt.base.errors import DDoSProtection from ccxt.base.errors import InvalidNonce from ccxt.base.decimal_to_precision import ROUND class latoken(Exchange): def describe(self): return self.deep_extend(super(latoken, self).describe(), { 'id': 'latoken', 'name': 'Latoken', 'countries': ['KY'], # Cayman Islands 'version': 'v1', 'rateLimit': 2000, 'certified': False, 'userAgent': self.userAgents['chrome'], 'has': { 'CORS': False, 'publicAPI': True, 'privateAPI': True, 'cancelOrder': True, 'cancelAllOrders': True, 'createMarketOrder': False, 'createOrder': True, 'fetchBalance': True, 'fetchCanceledOrders': True, 'fetchClosedOrders': True, 'fetchCurrencies': True, 'fetchMyTrades': True, 'fetchOpenOrders': True, 'fetchOrder': False, 'fetchOrdersByStatus': True, 'fetchOrderBook': True, 'fetchTicker': True, 'fetchTickers': True, 'fetchTime': True, 'fetchTrades': True, }, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/61511972-24c39f00-aa01-11e9-9f7c-471f1d6e5214.jpg', 'api': 'https://api.latoken.com', 'www': 'https://latoken.com', 'doc': [ 'https://api.latoken.com', ], }, 'api': { 'public': { 'get': [ 'ExchangeInfo/time', 'ExchangeInfo/limits', 'ExchangeInfo/pairs', 'ExchangeInfo/pairs/{currency}', 'ExchangeInfo/pair', 'ExchangeInfo/currencies', 'ExchangeInfo/currencies/{symbol}', 'MarketData/tickers', 'MarketData/ticker/{symbol}', 'MarketData/orderBook/{symbol}', 'MarketData/orderBook/{symbol}/{limit}', 'MarketData/trades/{symbol}', 'MarketData/trades/{symbol}/{limit}', ], }, 'private': { 'get': [ 'Account/balances', 'Account/balances/{currency}', 'Order/status', 'Order/active', 'Order/get_order', 'Order/trades', ], 'post': [ 'Order/new', 'Order/test-order', 'Order/cancel', 'Order/cancel_all', ], }, }, 'fees': { 'trading': { 'tierBased': False, 'percentage': True, 'maker': 0.1 / 100, 'taker': 0.1 / 100, }, }, 'commonCurrencies': { 'MT': 'Monarch', 'TSL': 'Treasure SL', }, 'options': { 'createOrderMethod': 'private_post_order_new', # private_post_order_test_order }, 'exceptions': { 'exact': { 'Signature or ApiKey is not valid': AuthenticationError, 'Request is out of time': InvalidNonce, 'Symbol must be specified': BadRequest, }, 'broad': { 'Request limit reached': DDoSProtection, 'Pair': BadRequest, 'Price needs to be greater than': InvalidOrder, 'Amount needs to be greater than': InvalidOrder, 'The Symbol field is required': InvalidOrder, 'OrderType is not valid': InvalidOrder, 'Side is not valid': InvalidOrder, 'Cancelable order whit': OrderNotFound, 'Order': OrderNotFound, }, }, }) def nonce(self): return self.milliseconds() async def fetch_time(self, params={}): response = await self.publicGetExchangeInfoTime(params) # # { # "time": "2019-04-18T9:00:00.0Z", # "unixTimeSeconds": 1555578000, # "unixTimeMiliseconds": 1555578000000 # } # return self.safe_integer(response, 'unixTimeMiliseconds') async def fetch_markets(self, params={}): response = await self.publicGetExchangeInfoPairs(params) # # [ # { # "pairId": 502, # "symbol": "LAETH", # "baseCurrency": "LA", # "quotedCurrency": "ETH", # "makerFee": 0.01, # "takerFee": 0.01, # "pricePrecision": 8, # "amountPrecision": 8, # "minQty": 0.1 # } # ] # result = [] for i in range(0, len(response)): market = response[i] id = self.safe_string(market, 'symbol') # the exchange shows them inverted baseId = self.safe_string(market, 'baseCurrency') quoteId = self.safe_string(market, 'quotedCurrency') numericId = self.safe_integer(market, 'pairId') base = self.safe_currency_code(baseId) quote = self.safe_currency_code(quoteId) symbol = base + '/' + quote precision = { 'price': self.safe_integer(market, 'pricePrecision'), 'amount': self.safe_integer(market, 'amountPrecision'), } limits = { 'amount': { 'min': self.safe_float(market, 'minQty'), 'max': None, }, 'price': { 'min': math.pow(10, -precision['price']), 'max': None, }, 'cost': { 'min': None, 'max': None, }, } result.append({ 'id': id, 'numericId': numericId, 'info': market, 'symbol': symbol, 'base': base, 'quote': quote, 'baseId': baseId, 'quoteId': quoteId, 'active': None, # assuming True 'precision': precision, 'limits': limits, }) return result async def fetch_currencies(self, params={}): response = await self.publicGetExchangeInfoCurrencies(params) # # [ # { # "currencyId": 102, # "symbol": "LA", # "name": "Latoken", # "precission": 8, # "type": "ERC20", # "fee": 0.1 # } # ] # result = {} for i in range(0, len(response)): currency = response[i] id = self.safe_string(currency, 'symbol') numericId = self.safe_integer(currency, 'currencyId') code = self.safe_currency_code(id) precision = self.safe_integer(currency, 'precission') fee = self.safe_float(currency, 'fee') active = None result[code] = { 'id': id, 'numericId': numericId, 'code': code, 'info': currency, 'name': code, 'active': active, 'fee': fee, 'precision': precision, 'limits': { 'amount': { 'min': None, 'max': None, }, 'price': { 'min': None, 'max': None, }, 'cost': { 'min': None, 'max': None, }, 'withdraw': { 'min': None, 'max': None, }, }, } return result def calculate_fee(self, symbol, type, side, amount, price, takerOrMaker='taker', params={}): market = self.markets[symbol] key = 'quote' rate = market[takerOrMaker] cost = amount * rate precision = market['precision']['price'] if side == 'sell': cost *= price else: key = 'base' precision = market['precision']['amount'] cost = self.decimal_to_precision(cost, ROUND, precision, self.precisionMode) return { 'type': takerOrMaker, 'currency': market[key], 'rate': rate, 'cost': float(cost), } async def fetch_balance(self, params={}): await self.load_markets() response = await self.privateGetAccountBalances(params) # # [ # { # "currencyId": 102, # "symbol": "LA", # "name": "Latoken", # "amount": 1054.66, # "available": 900.66, # "frozen": 154, # "pending": 0 # } # ] # result = { 'info': response, } for i in range(0, len(response)): balance = response[i] currencyId = self.safe_string(balance, 'symbol') code = self.safe_currency_code(currencyId) frozen = self.safe_float(balance, 'frozen') pending = self.safe_float(balance, 'pending') used = self.sum(frozen, pending) account = { 'free': self.safe_float(balance, 'available'), 'used': used, 'total': self.safe_float(balance, 'amount'), } result[code] = account return self.parse_balance(result) async def fetch_order_book(self, symbol, limit=None, params={}): await self.load_markets() market = self.market(symbol) request = { 'symbol': market['id'], 'limit': 10, } if limit is not None: request['limit'] = limit # default 10, max 100 response = await self.publicGetMarketDataOrderBookSymbolLimit(self.extend(request, params)) # # { # "pairId": 502, # "symbol": "LAETH", # "spread": 0.07, # "asks": [ # {"price": 136.3, "quantity": 7.024} # ], # "bids": [ # {"price": 136.2, "quantity": 6.554} # ] # } # return self.parse_order_book(response, None, 'bids', 'asks', 'price', 'quantity') def parse_ticker(self, ticker, market=None): # # { # "pairId":"63b41092-f3f6-4ea4-9e7c-4525ed250dad", # "symbol":"ETHBTC", # "volume":11317.037494474000000000, # "open":0.020033000000000000, # "low":0.019791000000000000, # "high":0.020375000000000000, # "close":0.019923000000000000, # "priceChange":-0.1500 # } # marketId = self.safe_string(ticker, 'symbol') symbol = self.safe_symbol(marketId, market) open = self.safe_float(ticker, 'open') close = self.safe_float(ticker, 'close') change = None if open is not None and close is not None: change = close - open percentage = self.safe_float(ticker, 'priceChange') timestamp = self.nonce() return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'low': self.safe_float(ticker, 'low'), 'high': self.safe_float(ticker, 'high'), 'bid': None, 'bidVolume': None, 'ask': None, 'askVolume': None, 'vwap': None, 'open': open, 'close': close, 'last': close, 'previousClose': None, 'change': change, 'percentage': percentage, 'average': None, 'baseVolume': None, 'quoteVolume': self.safe_float(ticker, 'volume'), 'info': ticker, } async def fetch_ticker(self, symbol, params={}): await self.load_markets() market = self.market(symbol) request = { 'symbol': market['id'], } response = await self.publicGetMarketDataTickerSymbol(self.extend(request, params)) # # { # "pairId": 502, # "symbol": "LAETH", # "volume": 1023314.3202, # "open": 134.82, # "low": 133.95, # "high": 136.22, # "close": 135.12, # "priceChange": 0.22 # } # return self.parse_ticker(response, market) async def fetch_tickers(self, symbols=None, params={}): await self.load_markets() response = await self.publicGetMarketDataTickers(params) # # [ # { # "pairId": 502, # "symbol": "LAETH", # "volume": 1023314.3202, # "open": 134.82, # "low": 133.95, # "high": 136.22, # "close": 135.12, # "priceChange": 0.22 # } # ] # result = {} for i in range(0, len(response)): ticker = self.parse_ticker(response[i]) symbol = ticker['symbol'] result[symbol] = ticker return self.filter_by_array(result, 'symbol', symbols) def parse_trade(self, trade, market=None): # # fetchTrades(public) # # { # side: 'buy', # price: 0.33634, # amount: 0.01, # timestamp: 1564240008000 # milliseconds # } # # fetchMyTrades(private) # # { # id: '1564223032.892829.3.tg15', # orderId: '1564223032.671436.707548@1379:1', # commission: 0, # side: 'buy', # price: 0.32874, # amount: 0.607, # timestamp: 1564223033 # seconds # } # type = None timestamp = self.safe_integer_2(trade, 'timestamp', 'time') if timestamp is not None: # 03 Jan 2009 - first block if timestamp < 1230940800000: timestamp *= 1000 price = self.safe_float(trade, 'price') amount = self.safe_float(trade, 'amount') side = self.safe_string(trade, 'side') cost = None if amount is not None: if price is not None: cost = amount * price symbol = None if market is not None: symbol = market['symbol'] id = self.safe_string(trade, 'id') orderId = self.safe_string(trade, 'orderId') feeCost = self.safe_float(trade, 'commission') fee = None if feeCost is not None: fee = { 'cost': feeCost, 'currency': None, } return { 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': symbol, 'id': id, 'order': orderId, 'type': type, 'takerOrMaker': None, 'side': side, 'price': price, 'amount': amount, 'cost': cost, 'fee': fee, } async def fetch_trades(self, symbol, since=None, limit=None, params={}): await self.load_markets() market = self.market(symbol) request = { 'symbol': market['id'], } if limit is not None: request['limit'] = limit # default 50, max 100 response = await self.publicGetMarketDataTradesSymbol(self.extend(request, params)) # # { # "pairId":370, # "symbol":"ETHBTC", # "tradeCount":51, # "trades": [ # { # side: 'buy', # price: 0.33634, # amount: 0.01, # timestamp: 1564240008000 # milliseconds # } # ] # } # trades = self.safe_value(response, 'trades', []) return self.parse_trades(trades, market, since, limit) async 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') await self.load_markets() market = self.market(symbol) request = { 'symbol': market['id'], } response = await self.privateGetOrderTrades(self.extend(request, params)) # # { # "pairId": 502, # "symbol": "LAETH", # "tradeCount": 1, # "trades": [ # { # id: '1564223032.892829.3.tg15', # orderId: '1564223032.671436.707548@1379:1', # commission: 0, # side: 'buy', # price: 0.32874, # amount: 0.607, # timestamp: 1564223033 # seconds # } # ] # } # trades = self.safe_value(response, 'trades', []) return self.parse_trades(trades, market, since, limit) def parse_order_status(self, status): statuses = { 'active': 'open', 'partiallyFilled': 'open', 'filled': 'closed', 'cancelled': 'canceled', } return self.safe_string(statuses, status, status) def parse_order(self, order, market=None): # # createOrder # # { # "orderId":"1563460093.134037.704945@0370:2", # "cliOrdId":"", # "pairId":370, # "symbol":"ETHBTC", # "side":"sell", # "orderType":"limit", # "price":1.0, # "amount":1.0 # } # # cancelOrder, fetchOrder, fetchOpenOrders, fetchClosedOrders, fetchCanceledOrders # # { # "orderId": "1555492358.126073.126767@0502:2", # "cliOrdId": "myNewOrder", # "pairId": 502, # "symbol": "LAETH", # "side": "buy", # "orderType": "limit", # "price": 136.2, # "amount": 0.57, # "orderStatus": "partiallyFilled", # "executedAmount": 0.27, # "reaminingAmount": 0.3, # "timeCreated": 155551580736, # "timeFilled": 0 # } # id = self.safe_string(order, 'orderId') timestamp = self.safe_timestamp(order, 'timeCreated') marketId = self.safe_string(order, 'symbol') symbol = self.safe_symbol(marketId, market) side = self.safe_string(order, 'side') type = self.safe_string(order, 'orderType') price = self.safe_float(order, 'price') amount = self.safe_float(order, 'amount') filled = self.safe_float(order, 'executedAmount') remaining = None if amount is not None: if filled is not None: remaining = amount - filled status = self.parse_order_status(self.safe_string(order, 'orderStatus')) cost = None if filled is not None: if price is not None: cost = filled * price timeFilled = self.safe_timestamp(order, 'timeFilled') lastTradeTimestamp = None if (timeFilled is not None) and (timeFilled > 0): lastTradeTimestamp = timeFilled clientOrderId = self.safe_string(order, 'cliOrdId') return { 'id': id, 'clientOrderId': clientOrderId, 'info': order, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'lastTradeTimestamp': lastTradeTimestamp, 'status': status, 'symbol': symbol, 'type': type, 'timeInForce': None, 'postOnly': None, 'side': side, 'price': price, 'stopPrice': None, 'cost': cost, 'amount': amount, 'filled': filled, 'average': None, 'remaining': remaining, 'fee': None, 'trades': None, } async def fetch_open_orders(self, symbol=None, since=None, limit=None, params={}): return self.fetch_orders_with_method('private_get_order_active', symbol, since, limit, params) async def fetch_closed_orders(self, symbol=None, since=None, limit=None, params={}): return self.fetch_orders_by_status('filled', symbol, since, limit, params) async def fetch_canceled_orders(self, symbol=None, since=None, limit=None, params={}): return self.fetch_orders_by_status('cancelled', symbol, since, limit, params) async def fetch_orders_by_status(self, status, symbol=None, since=None, limit=None, params={}): request = { 'status': status, } return self.fetch_orders_with_method('private_get_order_status', symbol, since, limit, self.extend(request, params)) async def fetch_orders_with_method(self, method, symbol=None, since=None, limit=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchOrdersWithMethod() requires a symbol argument') await self.load_markets() market = self.market(symbol) request = { 'symbol': market['id'], } if limit is not None: request['limit'] = limit # default 100 response = await getattr(self, method)(self.extend(request, params)) # # [ # { # "orderId": "1555492358.126073.126767@0502:2", # "cliOrdId": "myNewOrder", # "pairId": 502, # "symbol": "LAETH", # "side": "buy", # "orderType": "limit", # "price": 136.2, # "amount": 0.57, # "orderStatus": "partiallyFilled", # "executedAmount": 0.27, # "reaminingAmount": 0.3, # "timeCreated": 155551580736, # "timeFilled": 0 # } # ] # return self.parse_orders(response, market, since, limit) async def fetch_order(self, id, symbol=None, params={}): await self.load_markets() request = { 'orderId': id, } response = await self.privateGetOrderGetOrder(self.extend(request, params)) # # { # "orderId": "1555492358.126073.126767@0502:2", # "cliOrdId": "myNewOrder", # "pairId": 502, # "symbol": "LAETH", # "side": "buy", # "orderType": "limit", # "price": 136.2, # "amount": 0.57, # "orderStatus": "partiallyFilled", # "executedAmount": 0.27, # "reaminingAmount": 0.3, # "timeCreated": 155551580736, # "timeFilled": 0 # } # return self.parse_order(response) async def create_order(self, symbol, type, side, amount, price=None, params={}): await self.load_markets() if type != 'limit': raise ExchangeError(self.id + ' allows limit orders only') request = { 'symbol': self.market_id(symbol), 'side': side, 'price': self.price_to_precision(symbol, price), 'amount': self.amount_to_precision(symbol, amount), 'orderType': type, } method = self.safe_string(self.options, 'createOrderMethod', 'private_post_order_new') response = await getattr(self, method)(self.extend(request, params)) # # { # "orderId":"1563460093.134037.704945@0370:2", # "cliOrdId":"", # "pairId":370, # "symbol":"ETHBTC", # "side":"sell", # "orderType":"limit", # "price":1.0, # "amount":1.0 # } # return self.parse_order(response) async def cancel_order(self, id, symbol=None, params={}): await self.load_markets() request = { 'orderId': id, } response = await self.privatePostOrderCancel(self.extend(request, params)) # # { # "orderId": "1555492358.126073.126767@0502:2", # "cliOrdId": "myNewOrder", # "pairId": 502, # "symbol": "LAETH", # "side": "buy", # "orderType": "limit", # "price": 136.2, # "amount": 0.57, # "orderStatus": "partiallyFilled", # "executedAmount": 0.27, # "reaminingAmount": 0.3, # "timeCreated": 155551580736, # "timeFilled": 0 # } # return self.parse_order(response) async def cancel_all_orders(self, symbol=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' cancelAllOrders() requires a symbol argument') await self.load_markets() marketId = self.market_id(symbol) request = { 'symbol': marketId, } response = await self.privatePostOrderCancelAll(self.extend(request, params)) # # { # "pairId": 502, # "symbol": "LAETH", # "cancelledOrders": [ # "1555492358.126073.126767@0502:2" # ] # } # result = [] canceledOrders = self.safe_value(response, 'cancelledOrders', []) for i in range(0, len(canceledOrders)): order = self.parse_order({ 'symbol': marketId, 'orderId': canceledOrders[i], 'orderStatus': 'canceled', }) result.append(order) return result def sign(self, path, api='public', method='GET', params=None, headers=None, body=None): request = '/api/' + self.version + '/' + self.implode_params(path, params) query = self.omit(params, self.extract_params(path)) if api == 'private': nonce = self.nonce() query = self.extend({ 'timestamp': nonce, }, query) urlencodedQuery = self.urlencode(query) if query: request += '?' + urlencodedQuery if api == 'private': self.check_required_credentials() signature = self.hmac(self.encode(request), self.encode(self.secret)) headers = { 'X-LA-KEY': self.apiKey, 'X-LA-SIGNATURE': signature, } if method == 'POST': headers['Content-Type'] = 'application/x-www-form-urlencoded' body = urlencodedQuery url = self.urls['api'] + request return {'url': url, 'method': method, 'body': body, 'headers': headers} def handle_errors(self, code, reason, url, method, headers, body, response, requestHeaders, requestBody): if not response: return # # {"message": "Request limit reached!", "details": "Request limit reached. Maximum allowed: 1 per 1s. Please try again in 1 second(s)."} # {"error": {"message": "Pair 370 is not found","errorType":"RequestError","statusCode":400}} # {"error": {"message": "Signature or ApiKey is not valid","errorType":"RequestError","statusCode":400}} # {"error": {"message": "Request is out of time", "errorType": "RequestError", "statusCode":400}} # {"error": {"message": "Price needs to be greater than 0","errorType":"ValidationError","statusCode":400}} # {"error": {"message": "Side is not valid, Price needs to be greater than 0, Amount needs to be greater than 0, The Symbol field is required., OrderType is not valid","errorType":"ValidationError","statusCode":400}} # {"error": {"message": "Cancelable order whit ID 1563460289.571254.704945@0370:1 not found","errorType":"RequestError","statusCode":400}} # {"error": {"message": "Symbol must be specified","errorType":"RequestError","statusCode":400}} # {"error": {"message": "Order 1563460289.571254.704945@0370:1 is not found","errorType":"RequestError","statusCode":400}} # message = self.safe_string(response, 'message') feedback = self.id + ' ' + body if message is not None: self.throw_exactly_matched_exception(self.exceptions['exact'], message, feedback) self.throw_broadly_matched_exception(self.exceptions['broad'], message, feedback) error = self.safe_value(response, 'error', {}) errorMessage = self.safe_string(error, 'message') if errorMessage is not None: self.throw_exactly_matched_exception(self.exceptions['exact'], errorMessage, feedback) self.throw_broadly_matched_exception(self.exceptions['broad'], errorMessage, feedback) raise ExchangeError(feedback) # unknown message