# -*- 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 hashlib import math from ccxt.base.errors import ExchangeError from ccxt.base.errors import AuthenticationError from ccxt.base.errors import AccountSuspended from ccxt.base.errors import ArgumentsRequired from ccxt.base.errors import BadRequest from ccxt.base.errors import InsufficientFunds from ccxt.base.errors import InvalidOrder from ccxt.base.errors import OrderNotFound from ccxt.base.errors import NotSupported from ccxt.base.errors import DDoSProtection from ccxt.base.errors import ExchangeNotAvailable from ccxt.base.errors import InvalidNonce class kucoin (Exchange): def describe(self): return self.deep_extend(super(kucoin, self).describe(), { 'id': 'kucoin', 'name': 'KuCoin', 'countries': ['SC'], 'rateLimit': 334, 'version': 'v2', 'certified': True, 'comment': 'Platform 2.0', 'has': { 'fetchMarkets': True, 'fetchCurrencies': True, 'fetchTicker': True, 'fetchTickers': True, 'fetchOrderBook': True, 'fetchOrder': True, 'fetchClosedOrders': True, 'fetchOpenOrders': True, 'fetchDepositAddress': True, 'createDepositAddress': True, 'withdraw': True, 'fetchDeposits': True, 'fetchWithdrawals': True, 'fetchBalance': True, 'fetchTrades': True, 'fetchMyTrades': True, 'createOrder': True, 'cancelOrder': True, 'fetchAccounts': True, 'fetchFundingFee': True, 'fetchOHLCV': True, }, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/51909432-b0a72780-23dd-11e9-99ba-73d23c8d4eed.jpg', 'referral': 'https://www.kucoin.com/ucenter/signup?rcode=E5wkqe', 'api': { 'public': 'https://openapi-v2.kucoin.com', 'private': 'https://openapi-v2.kucoin.com', }, 'test': { 'public': 'https://openapi-sandbox.kucoin.com', 'private': 'https://openapi-sandbox.kucoin.com', }, 'www': 'https://www.kucoin.com', 'doc': [ 'https://docs.kucoin.com', ], }, 'requiredCredentials': { 'apiKey': True, 'secret': True, 'password': True, }, 'api': { 'public': { 'get': [ 'timestamp', 'symbols', 'market/allTickers', 'market/orderbook/level{level}', 'market/histories', 'market/candles', 'market/stats', 'currencies', 'currencies/{currency}', ], 'post': [ 'bullet-public', ], }, 'private': { 'get': [ 'accounts', 'accounts/{accountId}', 'accounts/{accountId}/ledgers', 'accounts/{accountId}/holds', 'deposit-addresses', 'deposits', 'hist-deposits', 'hist-orders', 'hist-withdrawals', 'withdrawals', 'withdrawals/quotas', 'orders', 'orders/{orderId}', 'fills', 'limit/fills', ], 'post': [ 'accounts', 'accounts/inner-transfer', 'deposit-addresses', 'withdrawals', 'orders', 'bullet-private', ], 'delete': [ 'withdrawals/{withdrawalId}', 'orders/{orderId}', ], }, }, 'timeframes': { '1m': '1min', '3m': '3min', '5m': '5min', '15m': '15min', '30m': '30min', '1h': '1hour', '2h': '2hour', '4h': '4hour', '6h': '6hour', '8h': '8hour', '12h': '12hour', '1d': '1day', '1w': '1week', }, 'exceptions': { '400': BadRequest, '401': AuthenticationError, '403': NotSupported, '404': NotSupported, '405': NotSupported, '429': DDoSProtection, '500': ExchangeError, '503': ExchangeNotAvailable, '200004': InsufficientFunds, '300000': InvalidOrder, '400001': AuthenticationError, '400002': InvalidNonce, '400003': AuthenticationError, '400004': AuthenticationError, '400005': AuthenticationError, '400006': AuthenticationError, '400007': AuthenticationError, '400008': NotSupported, '400100': ArgumentsRequired, '411100': AccountSuspended, '500000': ExchangeError, 'order_not_exist': OrderNotFound, # {"code":"order_not_exist","msg":"order_not_exist"} ¯\_(ツ)_/¯ 'order_not_exist_or_not_allow_to_cancel': InvalidOrder, # {"code":"400100","msg":"order_not_exist_or_not_allow_to_cancel"} 'Order size below the minimum requirement.': InvalidOrder, # {"code":"400100","msg":"Order size below the minimum requirement."} }, 'fees': { 'trading': { 'tierBased': False, 'percentage': True, 'taker': 0.001, 'maker': 0.001, }, 'funding': { 'tierBased': False, 'percentage': False, 'withdraw': {}, 'deposit': {}, }, }, 'options': { 'version': 'v1', 'symbolSeparator': '-', }, }) def nonce(self): return self.milliseconds() def load_time_difference(self): response = self.publicGetTimestamp() after = self.milliseconds() kucoinTime = self.safe_integer(response, 'data') self.options['timeDifference'] = int(after - kucoinTime) return self.options['timeDifference'] def fetch_markets(self, params={}): response = self.publicGetSymbols(params) # # {quoteCurrency: 'BTC', # symbol: 'KCS-BTC', # quoteMaxSize: '9999999', # quoteIncrement: '0.000001', # baseMinSize: '0.01', # quoteMinSize: '0.00001', # enableTrading: True, # priceIncrement: '0.00000001', # name: 'KCS-BTC', # baseIncrement: '0.01', # baseMaxSize: '9999999', # baseCurrency: 'KCS'} # data = response['data'] result = {} for i in range(0, len(data)): market = data[i] id = market['name'] baseId = market['baseCurrency'] quoteId = market['quoteCurrency'] base = self.common_currency_code(baseId) quote = self.common_currency_code(quoteId) symbol = base + '/' + quote active = market['enableTrading'] baseMaxSize = self.safe_float(market, 'baseMaxSize') baseMinSize = self.safe_float(market, 'baseMinSize') quoteMaxSize = self.safe_float(market, 'quoteMaxSize') quoteMinSize = self.safe_float(market, 'quoteMinSize') # quoteIncrement = self.safe_float(market, 'quoteIncrement') precision = { 'amount': self.precision_from_string(self.safe_string(market, 'baseIncrement')), 'price': self.precision_from_string(self.safe_string(market, 'priceIncrement')), } limits = { 'amount': { 'min': baseMinSize, 'max': baseMaxSize, }, 'price': { 'min': self.safe_float(market, 'priceIncrement'), 'max': quoteMaxSize / baseMinSize, }, 'cost': { 'min': quoteMinSize, 'max': quoteMaxSize, }, } result[symbol] = { 'id': id, 'symbol': symbol, 'baseId': baseId, 'quoteId': quoteId, 'base': base, 'quote': quote, 'active': active, 'precision': precision, 'limits': limits, 'info': market, } return result def fetch_currencies(self, params={}): response = self.publicGetCurrencies(params) # # {precision: 10, # name: 'KCS', # fullName: 'KCS shares', # currency: 'KCS'} # responseData = response['data'] result = {} for i in range(0, len(responseData)): entry = responseData[i] id = self.safe_string(entry, 'name') name = entry['fullName'] code = self.common_currency_code(id) precision = self.safe_integer(entry, 'precision') result[code] = { 'id': id, 'name': name, 'code': code, 'precision': precision, 'info': entry, } return result def fetch_accounts(self, params={}): response = self.privateGetAccounts(params) # # {code: "200000", # data: [{ balance: "0.00009788", # available: "0.00009788", # holds: "0", # currency: "BTC", # id: "5c6a4fd399a1d81c4f9cc4d0", # type: "trade" }, # ..., # { balance: "0.00000001", # available: "0.00000001", # holds: "0", # currency: "ETH", # id: "5c6a49ec99a1d819392e8e9f", # type: "trade" } ]} # data = self.safe_value(response, 'data') result = [] for i in range(0, len(data)): account = data[i] accountId = self.safe_string(account, 'id') currencyId = self.safe_string(account, 'currency') code = self.common_currency_code(currencyId) type = self.safe_string(account, 'type') # main or trade result.append({ 'id': accountId, 'type': type, 'currency': code, 'info': account, }) return result def fetch_funding_fee(self, code, params={}): currencyId = self.currencyId(code) request = { 'currency': currencyId, } response = self.privateGetWithdrawalsQuotas(self.extend(request, params)) data = response['data'] withdrawFees = {} withdrawFees[code] = self.safe_float(data, 'withdrawMinFee') return { 'info': response, 'withdraw': withdrawFees, 'deposit': {}, } def parse_ticker(self, ticker, market=None): # # { # 'buy': '0.00001168', # 'changePrice': '-0.00000018', # 'changeRate': '-0.0151', # 'datetime': 1550661146316, # 'high': '0.0000123', # 'last': '0.00001169', # 'low': '0.00001159', # 'sell': '0.00001182', # 'symbol': 'LOOM-BTC', # 'vol': '44399.5669' # } # percentage = self.safe_float(ticker, 'changeRate') if percentage is not None: percentage = percentage * 100 last = self.safe_float(ticker, 'last') symbol = None marketId = self.safe_string(ticker, 'symbol') if marketId is not None: if marketId in self.markets_by_id: market = self.markets_by_id[marketId] symbol = market['symbol'] else: baseId, quoteId = marketId.split('-') base = self.common_currency_code(baseId) quote = self.common_currency_code(quoteId) symbol = base + '/' + quote if symbol is None: if market is not None: symbol = market['symbol'] return { 'symbol': symbol, 'timestamp': None, 'datetime': None, 'high': self.safe_float(ticker, 'high'), 'low': self.safe_float(ticker, 'low'), 'bid': self.safe_float(ticker, 'buy'), 'bidVolume': None, 'ask': self.safe_float(ticker, 'sell'), 'askVolume': None, 'vwap': None, 'open': self.safe_float(ticker, 'open'), 'close': last, 'last': last, 'previousClose': None, 'change': self.safe_float(ticker, 'changePrice'), 'percentage': percentage, 'average': None, 'baseVolume': self.safe_float(ticker, 'vol'), 'quoteVolume': self.safe_float(ticker, 'volValue'), 'info': ticker, } def fetch_tickers(self, symbols=None, params={}): self.load_markets() response = self.publicGetMarketAllTickers(params) # # { # "code": "200000", # "data": { # "date": 1550661940645, # "ticker": [ # 'buy': '0.00001168', # 'changePrice': '-0.00000018', # 'changeRate': '-0.0151', # 'datetime': 1550661146316, # 'high': '0.0000123', # 'last': '0.00001169', # 'low': '0.00001159', # 'sell': '0.00001182', # 'symbol': 'LOOM-BTC', # 'vol': '44399.5669' # }, # ] # } # data = self.safe_value(response, 'data', {}) tickers = self.safe_value(data, 'ticker', []) result = {} for i in range(0, len(tickers)): ticker = self.parse_ticker(tickers[i]) symbol = self.safe_string(ticker, 'symbol') if symbol is not None: result[symbol] = ticker return result def fetch_ticker(self, symbol, params={}): self.load_markets() market = self.market(symbol) request = { 'symbol': market['id'], } response = self.publicGetMarketStats(self.extend(request, params)) # # { # "code": "200000", # "data": { # 'buy': '0.00001168', # 'changePrice': '-0.00000018', # 'changeRate': '-0.0151', # 'datetime': 1550661146316, # 'high': '0.0000123', # 'last': '0.00001169', # 'low': '0.00001159', # 'sell': '0.00001182', # 'symbol': 'LOOM-BTC', # 'vol': '44399.5669' # }, # } # return self.parse_ticker(response['data'], market) def parse_ohlcv(self, ohlcv, market=None, timeframe='1m', since=None, limit=None): # # [ # "1545904980", # Start time of the candle cycle # "0.058", # opening price # "0.049", # closing price # "0.058", # highest price # "0.049", # lowest price # "0.018", # base volume # "0.000945", # quote volume # ] # return [ int(ohlcv[0]) * 1000, float(ohlcv[1]), float(ohlcv[3]), float(ohlcv[4]), float(ohlcv[2]), float(ohlcv[5]), ] def fetch_ohlcv(self, symbol, timeframe='15m', since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) marketId = market['id'] request = { 'symbol': marketId, 'endAt': self.seconds(), # required param 'type': self.timeframes[timeframe], } if since is not None: request['startAt'] = int(math.floor(since / 1000)) response = self.publicGetMarketCandles(self.extend(request, params)) responseData = response['data'] return self.parse_ohlcvs(responseData, market, timeframe, since, limit) def create_deposit_address(self, code, params={}): self.load_markets() currencyId = self.currencyId(code) request = {'currency': currencyId} response = self.privatePostDepositAddresses(self.extend(request, params)) # BCH {"code":"200000","data":{"address":"bitcoincash:qza3m4nj9rx7l9r0cdadfqxts6f92shvhvr5ls4q7z","memo":""}} # BTC {"code":"200000","data":{"address":"36SjucKqQpQSvsak9A7h6qzFjrVXpRNZhE","memo":""}} data = self.safe_value(response, 'data', {}) address = self.safe_string(data, 'address') # BCH/BSV is returned with a "bitcoincash:" prefix, which we cut off here and only keep the address address = address.replace('bitcoincash:', '') tag = self.safe_string(data, 'memo') self.check_address(address) return { 'info': response, 'currency': code, 'address': address, 'tag': tag, } def fetch_deposit_address(self, code, params={}): self.load_markets() currencyId = self.currencyId(code) request = {'currency': currencyId} response = self.privateGetDepositAddresses(self.extend(request, params)) # BCH {"code":"200000","data":{"address":"bitcoincash:qza3m4nj9rx7l9r0cdadfqxts6f92shvhvr5ls4q7z","memo":""}} # BTC {"code":"200000","data":{"address":"36SjucKqQpQSvsak9A7h6qzFjrVXpRNZhE","memo":""}} data = self.safe_value(response, 'data', {}) address = self.safe_string(data, 'address') # BCH/BSV is returned with a "bitcoincash:" prefix, which we cut off here and only keep the address if address is not None: address = address.replace('bitcoincash:', '') tag = self.safe_string(data, 'memo') self.check_address(address) return { 'info': response, 'currency': code, 'address': address, 'tag': tag, } def fetch_order_book(self, symbol, limit=None, params={}): self.load_markets() marketId = self.market_id(symbol) request = self.extend({'symbol': marketId, 'level': 2}, params) response = self.publicGetMarketOrderbookLevelLevel(request) # # {sequence: '1547731421688', # asks: [['5c419328ef83c75456bd615c', '0.9', '0.09'], ...], # bids: [['5c419328ef83c75456bd615c', '0.9', '0.09'], ...],} # data = response['data'] timestamp = self.safe_integer(data, 'sequence') # level can be a string such as 2_20 or 2_100 levelString = self.safe_string(request, 'level') levelParts = levelString.split('_') level = int(levelParts[0]) return self.parse_order_book(data, timestamp, 'bids', 'asks', level - 2, level - 1) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() marketId = self.market_id(symbol) # required param, cannot be used twice clientOid = self.uuid() request = { 'clientOid': clientOid, 'side': side, 'size': self.amount_to_precision(symbol, amount), 'symbol': marketId, 'type': type, } if type != 'market': request['price'] = self.price_to_precision(symbol, price) response = self.privatePostOrders(self.extend(request, params)) responseData = response['data'] return { 'id': responseData['orderId'], 'symbol': symbol, 'type': type, 'side': side, 'status': 'open', 'clientOid': clientOid, 'info': responseData, } def cancel_order(self, id, symbol=None, params={}): request = {'orderId': id} response = self.privateDeleteOrdersOrderId(self.extend(request, params)) return response def fetch_orders_by_status(self, status, symbol=None, since=None, limit=None, params={}): self.load_markets() request = { 'status': status, } market = None if symbol is not None: market = self.market(symbol) request['symbol'] = market['id'] if since is not None: request['startAt'] = since if limit is not None: request['pageSize'] = limit response = self.privateGetOrders(self.extend(request, params)) # # { # code: '200000', # data: { # "currentPage": 1, # "pageSize": 1, # "totalNum": 153408, # "totalPage": 153408, # "items": [ # { # "id": "5c35c02703aa673ceec2a168", #orderid # "symbol": "BTC-USDT", #symbol # "opType": "DEAL", # operation type,deal is pending order,cancel is cancel order # "type": "limit", # order type,e.g. limit,markrt,stop_limit. # "side": "buy", # transaction direction,include buy and sell # "price": "10", # order price # "size": "2", # order quantity # "funds": "0", # order funds # "dealFunds": "0.166", # deal funds # "dealSize": "2", # deal quantity # "fee": "0", # fee # "feeCurrency": "USDT", # charge fee currency # "stp": "", # self trade prevention,include CN,CO,DC,CB # "stop": "", # stop type # "stopTriggered": False, # stop order is triggered # "stopPrice": "0", # stop price # "timeInForce": "GTC", # time InForce,include GTC,GTT,IOC,FOK # "postOnly": False, # postOnly # "hidden": False, # hidden order # "iceberg": False, # iceberg order # "visibleSize": "0", # display quantity for iceberg order # "cancelAfter": 0, # cancel orders time，requires timeInForce to be GTT # "channel": "IOS", # order source # "clientOid": "", # user-entered order unique mark # "remark": "", # remark # "tags": "", # tag order source # "isActive": False, # status before unfilled or uncancelled # "cancelExist": False, # order cancellation transaction record # "createdAt": 1547026471000 # time # }, # ] # } # } responseData = self.safe_value(response, 'data', {}) orders = self.safe_value(responseData, 'items', []) return self.parse_orders(orders, market, since, limit) def fetch_closed_orders(self, symbol=None, since=None, limit=None, params={}): return self.fetch_orders_by_status('done', symbol, since, limit, params) def fetch_open_orders(self, symbol=None, since=None, limit=None, params={}): return self.fetch_orders_by_status('active', symbol, since, limit, params) def fetch_order(self, id, symbol=None, params={}): self.load_markets() request = { 'orderId': id, } market = None if symbol is not None: market = self.market(symbol) response = self.privateGetOrdersOrderId(self.extend(request, params)) responseData = response['data'] return self.parse_order(responseData, market) def parse_order(self, order, market=None): # # fetchOpenOrders, fetchClosedOrders # # { # "id": "5c35c02703aa673ceec2a168", #orderid # "symbol": "BTC-USDT", #symbol # "opType": "DEAL", # operation type,deal is pending order,cancel is cancel order # "type": "limit", # order type,e.g. limit,markrt,stop_limit. # "side": "buy", # transaction direction,include buy and sell # "price": "10", # order price # "size": "2", # order quantity # "funds": "0", # order funds # "dealFunds": "0.166", # deal funds # "dealSize": "2", # deal quantity # "fee": "0", # fee # "feeCurrency": "USDT", # charge fee currency # "stp": "", # self trade prevention,include CN,CO,DC,CB # "stop": "", # stop type # "stopTriggered": False, # stop order is triggered # "stopPrice": "0", # stop price # "timeInForce": "GTC", # time InForce,include GTC,GTT,IOC,FOK # "postOnly": False, # postOnly # "hidden": False, # hidden order # "iceberg": False, # iceberg order # "visibleSize": "0", # display quantity for iceberg order # "cancelAfter": 0, # cancel orders time，requires timeInForce to be GTT # "channel": "IOS", # order source # "clientOid": "", # user-entered order unique mark # "remark": "", # remark # "tags": "", # tag order source # "isActive": False, # status before unfilled or uncancelled # "cancelExist": False, # order cancellation transaction record # "createdAt": 1547026471000 # time # } # symbol = None marketId = self.safe_string(order, 'symbol') if marketId is not None: if marketId in self.markets_by_id: market = self.markets_by_id[marketId] symbol = market['symbol'] else: baseId, quoteId = marketId.split('-') base = self.common_currency_code(baseId) quote = self.common_currency_code(quoteId) symbol = base + '/' + quote market = self.safe_value(self.markets_by_id, marketId) if symbol is None: if market is not None: symbol = market['symbol'] orderId = self.safe_string(order, 'id') type = self.safe_string(order, 'type') timestamp = self.safe_integer(order, 'createdAt') datetime = self.iso8601(timestamp) price = self.safe_float(order, 'price') side = self.safe_string(order, 'side') feeCurrencyId = self.safe_string(order, 'feeCurrency') feeCurrency = self.common_currency_code(feeCurrencyId) feeCost = self.safe_float(order, 'fee') amount = self.safe_float(order, 'size') filled = self.safe_float(order, 'dealSize') cost = self.safe_float(order, 'dealFunds') remaining = amount - filled # bool status = 'open' if order['isActive'] else 'closed' fee = { 'currency': feeCurrency, 'cost': feeCost, } return { 'id': orderId, 'symbol': symbol, 'type': type, 'side': side, 'amount': amount, 'price': price, 'cost': cost, 'filled': filled, 'remaining': remaining, 'timestamp': timestamp, 'datetime': datetime, 'fee': fee, 'status': status, 'info': order, } def fetch_my_trades(self, symbol=None, since=None, limit=None, params={}): self.load_markets() request = {} market = None if symbol is not None: market = self.market(symbol) request['symbol'] = market['id'] if limit is not None: request['pageSize'] = limit method = 'privateGetFills' if since is not None: # if since is earlier than 2019-02-18T00:00:00Z if since < 1550448000000: request['startAt'] = int(since / 1000) # despite that self endpoint is called `HistOrders` # it returns historical trades instead of orders method = 'privateGetHistOrders' else: request['startAt'] = since response = getattr(self, method)(self.extend(request, params)) # # { # "currentPage": 1, # "pageSize": 50, # "totalNum": 1, # "totalPage": 1, # "items": [ # { # "symbol":"BTC-USDT", # symbol # "tradeId":"5c35c02709e4f67d5266954e", # trade id # "orderId":"5c35c02703aa673ceec2a168", # order id # "counterOrderId":"5c1ab46003aa676e487fa8e3", # counter order id # "side":"buy", # transaction direction,include buy and sell # "liquidity":"taker", # include taker and maker # "forceTaker":true, # forced to become taker # "price":"0.083", # order price # "size":"0.8424304", # order quantity # "funds":"0.0699217232", # order funds # "fee":"0", # fee # "feeRate":"0", # fee rate # "feeCurrency":"USDT", # charge fee currency # "stop":"", # stop type # "type":"limit", # order type, e.g. limit, market, stop_limit. # "createdAt":1547026472000 # time # }, # #------------------------------------------------------ # # v1(historical) trade response structure # { # "symbol": "SNOV-ETH", # "dealPrice": "0.0000246", # "dealValue": "0.018942", # "amount": "770", # "fee": "0.00001137", # "side": "sell", # "createdAt": 1540080199 # "id":"5c4d389e4c8c60413f78e2e5", # } # ] # } # data = self.safe_value(response, 'data', {}) trades = self.safe_value(data, 'items', []) return self.parse_trades(trades, market, since, limit) def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) request = { 'symbol': market['id'], } if since is not None: request['startAt'] = int(math.floor(since / 1000)) if limit is not None: request['pageSize'] = limit response = self.publicGetMarketHistories(self.extend(request, params)) # # { # "code": "200000", # "data": [ # { # "sequence": "1548764654235", # "side": "sell", # "size":"0.6841354", # "price":"0.03202", # "time":1548848575203567174 # } # ] # } # trades = self.safe_value(response, 'data', []) return self.parse_trades(trades, market, since, limit) def parse_trade(self, trade, market=None): # # fetchTrades(public) # # { # "sequence": "1548764654235", # "side": "sell", # "size":"0.6841354", # "price":"0.03202", # "time":1548848575203567174 # } # # fetchMyTrades(private) v2 # # { # "symbol":"BTC-USDT", # "tradeId":"5c35c02709e4f67d5266954e", # "orderId":"5c35c02703aa673ceec2a168", # "counterOrderId":"5c1ab46003aa676e487fa8e3", # "side":"buy", # "liquidity":"taker", # "forceTaker":true, # "price":"0.083", # "size":"0.8424304", # "funds":"0.0699217232", # "fee":"0", # "feeRate":"0", # "feeCurrency":"USDT", # "stop":"", # "type":"limit", # "createdAt":1547026472000 # } # # fetchMyTrades(private) v1(historical) # # { # "symbol": "SNOV-ETH", # "dealPrice": "0.0000246", # "dealValue": "0.018942", # "amount": "770", # "fee": "0.00001137", # "side": "sell", # "createdAt": 1540080199 # "id":"5c4d389e4c8c60413f78e2e5", # } # symbol = None marketId = self.safe_string(trade, 'symbol') if marketId is not None: if marketId in self.markets_by_id: market = self.markets_by_id[marketId] symbol = market['symbol'] else: baseId, quoteId = marketId.split('-') base = self.common_currency_code(baseId) quote = self.common_currency_code(quoteId) symbol = base + '/' + quote if symbol is None: if market is not None: symbol = market['symbol'] id = self.safe_string_2(trade, 'tradeId', 'id') if id is not None: id = str(id) orderId = self.safe_string(trade, 'orderId') takerOrMaker = self.safe_string(trade, 'liquidity') amount = self.safe_float_2(trade, 'size', 'amount') timestamp = self.safe_integer(trade, 'time') if timestamp is not None: timestamp = int(timestamp / 1000000) else: timestamp = self.safe_integer(trade, 'createdAt') # if it's a historical v1 trade, the exchange returns timestamp in seconds if takerOrMaker is None and timestamp is not None: timestamp = timestamp * 1000 price = self.safe_float_2(trade, 'price', 'dealPrice') side = self.safe_string(trade, 'side') fee = None feeCost = self.safe_float(trade, 'fee') if feeCost is not None: feeCurrencyId = self.safe_string(trade, 'feeCurrency') feeCurrency = self.common_currency_code(feeCurrencyId) if feeCurrency is None: if market is not None: feeCurrency = market['quote'] if (side == 'sell') else market['base'] fee = { 'cost': feeCost, 'currency': feeCurrency, 'rate': self.safe_float(trade, 'feeRate'), } type = self.safe_string(trade, 'type') cost = self.safe_float_2(trade, 'funds', 'dealValue') if cost is None: if amount is not None: if price is not None: cost = amount * price return { 'info': trade, 'id': id, 'order': orderId, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': symbol, 'type': type, 'takerOrMaker': takerOrMaker, 'side': side, 'price': price, 'amount': amount, 'cost': cost, 'fee': fee, } def withdraw(self, code, amount, address, tag=None, params={}): self.load_markets() self.check_address(address) currency = self.currencyId(code) request = { 'currency': currency, 'address': address, 'amount': amount, } if tag is not None: request['memo'] = tag response = self.privatePostWithdrawals(self.extend(request, params)) # # {"withdrawalId": "5bffb63303aa675e8bbe18f9"} # responseData = response['data'] return { 'id': self.safe_string(responseData, 'withdrawalId'), 'info': responseData, } def parse_transaction_status(self, status): statuses = { 'SUCCESS': 'ok', 'PROCESSING': 'ok', 'FAILURE': 'failed', } return self.safe_string(statuses, status) def parse_transaction(self, transaction, currency=None): # # fetchDeposits # # { # "address": "0x5f047b29041bcfdbf0e4478cdfa753a336ba6989", # "memo": "5c247c8a03aa677cea2a251d", # "amount": 1, # "fee": 0.0001, # "currency": "KCS", # "isInner": False, # "walletTxId": "5bbb57386d99522d9f954c5a@test004", # "status": "SUCCESS", # "createdAt": 1544178843000, # "updatedAt": 1544178891000 # } # # fetchWithdrawals # # { # "id": "5c2dc64e03aa675aa263f1ac", # "address": "0x5bedb060b8eb8d823e2414d82acce78d38be7fe9", # "memo": "", # "currency": "ETH", # "amount": 1.0000000, # "fee": 0.0100000, # "walletTxId": "3e2414d82acce78d38be7fe9", # "isInner": False, # "status": "FAILURE", # "createdAt": 1546503758000, # "updatedAt": 1546504603000 # } # code = None currencyId = self.safe_string(transaction, 'currency') currency = self.safe_value(self.currencies_by_id, currencyId) if currency is not None: code = currency['code'] else: code = self.common_currency_code(currencyId) address = self.safe_string(transaction, 'address') amount = self.safe_float(transaction, 'amount') txid = self.safe_string(transaction, 'walletTxId') if txid is not None: txidParts = txid.split('@') numTxidParts = len(txidParts) if numTxidParts > 1: if address is None: if len(txidParts[1]) > 1: address = txidParts[1] txid = txidParts[0] type = txid is 'withdrawal' if None else 'deposit' rawStatus = self.safe_string(transaction, 'status') status = self.parse_transaction_status(rawStatus) fee = None feeCost = self.safe_float(transaction, 'fee') if feeCost is not None: rate = None if amount is not None: rate = feeCost / amount fee = { 'cost': feeCost, 'rate': rate, 'currency': code, } tag = self.safe_string(transaction, 'memo') timestamp = self.safe_integer_2(transaction, 'createdAt', 'createAt') id = self.safe_string(transaction, 'id') updated = self.safe_integer(transaction, 'updatedAt') isV1 = not('createdAt' in list(transaction.keys())) # if it's a v1 structure if isV1: type = 'withdrawal' if ('address' in list(transaction.keys())) else 'deposit' if timestamp is not None: timestamp = timestamp * 1000 if updated is not None: updated = updated * 1000 return { 'id': id, 'address': address, 'tag': tag, 'currency': code, 'amount': amount, 'txid': txid, 'type': type, 'status': status, 'fee': fee, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'updated': updated, 'info': transaction, } def fetch_deposits(self, code=None, since=None, limit=None, params={}): self.load_markets() request = {} currency = None if code is not None: currency = self.currency(code) request['currency'] = currency['id'] if limit is not None: request['pageSize'] = limit method = 'privateGetDeposits' if since is not None: # if since is earlier than 2019-02-18T00:00:00Z if since < 1550448000000: request['startAt'] = int(since / 1000) method = 'privateGetHistDeposits' else: request['startAt'] = since response = getattr(self, method)(self.extend(request, params)) # # { # code: '200000', # data: { # "currentPage": 1, # "pageSize": 5, # "totalNum": 2, # "totalPage": 1, # "items": [ # #-------------------------------------------------- # # version 2 deposit response structure # { # "address": "0x5f047b29041bcfdbf0e4478cdfa753a336ba6989", # "memo": "5c247c8a03aa677cea2a251d", # "amount": 1, # "fee": 0.0001, # "currency": "KCS", # "isInner": False, # "walletTxId": "5bbb57386d99522d9f954c5a@test004", # "status": "SUCCESS", # "createdAt": 1544178843000, # "updatedAt": 1544178891000 # }, # #-------------------------------------------------- # # version 1(historical) deposit response structure # { # "currency": "BTC", # "createAt": 1528536998, # "amount": "0.03266638", # "walletTxId": "55c643bc2c68d6f17266383ac1be9e454038864b929ae7cee0bc408cc5c869e8@12ffGWmMMD1zA1WbFm7Ho3JZ1w6NYXjpFk@234", # "isInner": False, # "status": "SUCCESS", # } # ] # } # } # responseData = response['data']['items'] return self.parseTransactions(responseData, currency, since, limit) def fetch_withdrawals(self, code=None, since=None, limit=None, params={}): self.load_markets() request = {} currency = None if code is not None: currency = self.currency(code) request['currency'] = currency['id'] if limit is not None: request['pageSize'] = limit method = 'privateGetWithdrawals' if since is not None: # if since is earlier than 2019-02-18T00:00:00Z if since < 1550448000000: request['startAt'] = int(since / 1000) method = 'privateGetHistWithdrawals' else: request['startAt'] = since response = getattr(self, method)(self.extend(request, params)) # # { # code: '200000', # data: { # "currentPage": 1, # "pageSize": 5, # "totalNum": 2, # "totalPage": 1, # "items": [ # #-------------------------------------------------- # # version 2 withdrawal response structure # { # "id": "5c2dc64e03aa675aa263f1ac", # "address": "0x5bedb060b8eb8d823e2414d82acce78d38be7fe9", # "memo": "", # "currency": "ETH", # "amount": 1.0000000, # "fee": 0.0100000, # "walletTxId": "3e2414d82acce78d38be7fe9", # "isInner": False, # "status": "FAILURE", # "createdAt": 1546503758000, # "updatedAt": 1546504603000 # }, # #-------------------------------------------------- # # version 1(historical) withdrawal response structure # { # "currency": "BTC", # "createAt": 1526723468, # "amount": "0.534", # "address": "33xW37ZSW4tQvg443Pc7NLCAs167Yc2XUV", # "walletTxId": "aeacea864c020acf58e51606169240e96774838dcd4f7ce48acf38e3651323f4", # "isInner": False, # "status": "SUCCESS" # } # ] # } # } # responseData = response['data']['items'] return self.parseTransactions(responseData, currency, since, limit) def fetch_balance(self, params={}): self.load_markets() request = { 'type': 'trade', } response = self.privateGetAccounts(self.extend(request, params)) responseData = response['data'] result = {'info': responseData} for i in range(0, len(responseData)): entry = responseData[i] currencyId = entry['currency'] code = self.common_currency_code(currencyId) account = {} account['total'] = self.safe_float(entry, 'balance', 0) account['free'] = self.safe_float(entry, 'available', 0) account['used'] = self.safe_float(entry, 'holds', 0) result[code] = account return self.parse_balance(result) def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): # # the v2 URL is https://openapi-v2.kucoin.com/api/v1/endpoint # † ↑ # endpoint = '/api/' + self.options['version'] + '/' + self.implode_params(path, params) query = self.omit(params, self.extract_params(path)) endpart = '' headers = headers is not headers if None else {} if query: if method != 'GET': body = self.json(query) endpart = body headers['Content-Type'] = 'application/json' else: endpoint += '?' + self.urlencode(query) url = self.urls['api'][api] + endpoint if api == 'private': self.check_required_credentials() timestamp = str(self.nonce()) headers = self.extend({ 'KC-API-KEY': self.apiKey, 'KC-API-TIMESTAMP': timestamp, 'KC-API-PASSPHRASE': self.password, }, headers) payload = timestamp + method + endpoint + endpart signature = self.hmac(self.encode(payload), self.encode(self.secret), hashlib.sha256, 'base64') headers['KC-API-SIGN'] = self.decode(signature) return {'url': url, 'method': method, 'body': body, 'headers': headers} def handle_errors(self, code, reason, url, method, headers, body, response): if not response: return # # bad # {"code": "400100", "msg": "validation.createOrder.clientOidIsRequired"} # good # {code: '200000', data: {...}} # errorCode = self.safe_string(response, 'code') message = self.safe_string(response, 'msg') ExceptionClass = self.safe_value_2(self.exceptions, message, errorCode) if ExceptionClass is not None: raise ExceptionClass(self.id + ' ' + message)