# -*- 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 from ccxt.base.errors import ExchangeError from ccxt.base.errors import ArgumentsRequired from ccxt.base.errors import BadRequest from ccxt.base.errors import BadSymbol from ccxt.base.errors import OrderNotFound from ccxt.base.errors import OnMaintenance class coinone(Exchange): def describe(self): return self.deep_extend(super(coinone, self).describe(), { 'id': 'coinone', 'name': 'CoinOne', 'countries': ['KR'], # Korea # 'enableRateLimit': False, 'rateLimit': 667, 'version': 'v2', 'has': { 'cancelOrder': True, 'CORS': False, 'createMarketOrder': False, 'createOrder': True, 'fetchBalance': True, 'fetchCurrencies': False, 'fetchMarkets': True, 'fetchMyTrades': True, 'fetchOpenOrders': True, 'fetchOrder': True, 'fetchOrderBook': True, 'fetchTicker': True, 'fetchTickers': True, 'fetchTrades': True, # https://github.com/ccxt/ccxt/pull/7067 # the endpoint that should return closed orders actually returns trades 'fetchClosedOrders': False, }, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/38003300-adc12fba-323f-11e8-8525-725f53c4a659.jpg', 'api': 'https://api.coinone.co.kr', 'www': 'https://coinone.co.kr', 'doc': 'https://doc.coinone.co.kr', }, 'requiredCredentials': { 'apiKey': True, 'secret': True, }, 'api': { 'public': { 'get': [ 'orderbook/', 'trades/', 'ticker/', ], }, 'private': { 'post': [ 'account/btc_deposit_address/', 'account/balance/', 'account/daily_balance/', 'account/user_info/', 'account/virtual_account/', 'order/cancel_all/', 'order/cancel/', 'order/limit_buy/', 'order/limit_sell/', 'order/complete_orders/', 'order/limit_orders/', 'order/order_info/', 'transaction/auth_number/', 'transaction/history/', 'transaction/krw/history/', 'transaction/btc/', 'transaction/coin/', ], }, }, 'fees': { 'trading': { 'tierBased': False, 'percentage': True, 'taker': 0.002, 'maker': 0.002, }, }, 'precision': { 'price': 4, 'amount': 4, 'cost': 8, }, 'exceptions': { '405': OnMaintenance, # {"errorCode":"405","status":"maintenance","result":"error"} '104': OrderNotFound, # {"errorCode":"104","errorMsg":"Order id is not exist","result":"error"} '108': BadSymbol, # {"errorCode":"108","errorMsg":"Unknown CryptoCurrency","result":"error"} '107': BadRequest, # {"errorCode":"107","errorMsg":"Parameter error","result":"error"} }, }) def fetch_markets(self, params={}): request = { 'currency': 'all', } response = self.publicGetTicker(request) result = [] quoteId = 'krw' quote = self.safe_currency_code(quoteId) baseIds = list(response.keys()) for i in range(0, len(baseIds)): baseId = baseIds[i] ticker = self.safe_value(response, baseId, {}) currency = self.safe_value(ticker, 'currency') if currency is None: continue base = self.safe_currency_code(baseId) result.append({ 'id': baseId, 'symbol': base + '/' + quote, 'base': base, 'quote': quote, 'baseId': baseId, 'quoteId': quoteId, 'active': True, }) return result def fetch_balance(self, params={}): self.load_markets() response = self.privatePostAccountBalance(params) result = {'info': response} balances = self.omit(response, [ 'errorCode', 'result', 'normalWallets', ]) currencyIds = list(balances.keys()) for i in range(0, len(currencyIds)): currencyId = currencyIds[i] balance = balances[currencyId] code = self.safe_currency_code(currencyId) account = self.account() account['free'] = self.safe_float(balance, 'avail') account['total'] = self.safe_float(balance, 'balance') result[code] = account return self.parse_balance(result) def fetch_order_book(self, symbol, limit=None, params={}): self.load_markets() market = self.market(symbol) request = { 'currency': market['id'], 'format': 'json', } response = self.publicGetOrderbook(self.extend(request, params)) timestamp = self.safe_timestamp(response, 'timestamp') return self.parse_order_book(response, timestamp, 'bid', 'ask', 'price', 'qty') def fetch_tickers(self, symbols=None, params={}): self.load_markets() request = { 'currency': 'all', 'format': 'json', } response = self.publicGetTicker(self.extend(request, params)) result = {} ids = list(response.keys()) timestamp = self.safe_timestamp(response, 'timestamp') for i in range(0, len(ids)): id = ids[i] symbol = id market = None if id in self.markets_by_id: market = self.markets_by_id[id] symbol = market['symbol'] ticker = response[id] result[symbol] = self.parse_ticker(ticker, market) result[symbol]['timestamp'] = timestamp return self.filter_by_array(result, 'symbol', symbols) def fetch_ticker(self, symbol, params={}): self.load_markets() market = self.market(symbol) request = { 'currency': market['id'], 'format': 'json', } response = self.publicGetTicker(self.extend(request, params)) return self.parse_ticker(response, market) def parse_ticker(self, ticker, market=None): timestamp = self.safe_timestamp(ticker, 'timestamp') first = self.safe_float(ticker, 'first') last = self.safe_float(ticker, 'last') average = None if first is not None and last is not None: average = self.sum(first, last) / 2 previousClose = self.safe_float(ticker, 'yesterday_last') change = None percentage = None if last is not None and previousClose is not None: change = last - previousClose if previousClose != 0: percentage = change / previousClose * 100 symbol = market['symbol'] if (market is not None) else None return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': self.safe_float(ticker, 'high'), 'low': self.safe_float(ticker, 'low'), 'bid': None, 'bidVolume': None, 'ask': None, 'askVolume': None, 'vwap': None, 'open': first, 'close': last, 'last': last, 'previousClose': previousClose, 'change': change, 'percentage': percentage, 'average': average, 'baseVolume': self.safe_float(ticker, 'volume'), 'quoteVolume': None, 'info': ticker, } def parse_trade(self, trade, market=None): # # fetchTrades(public) # # { # "timestamp": "1416893212", # "price": "420000.0", # "qty": "0.1", # "is_ask": "1" # } # # fetchMyTrades(private) # # { # "timestamp": "1416561032", # "price": "419000.0", # "type": "bid", # "qty": "0.001", # "feeRate": "-0.0015", # "fee": "-0.0000015", # "orderId": "E84A1AC2-8088-4FA0-B093-A3BCDB9B3C85" # } # timestamp = self.safe_timestamp(trade, 'timestamp') symbol = market['symbol'] if (market is not None) else None is_ask = self.safe_string(trade, 'is_ask') side = self.safe_string(trade, 'type') if is_ask is not None: if is_ask == '1': side = 'sell' elif is_ask == '0': side = 'buy' else: if side == 'ask': side = 'sell' elif side == 'bid': side = 'buy' price = self.safe_float(trade, 'price') amount = self.safe_float(trade, 'qty') cost = None if price is not None: if amount is not None: cost = price * amount orderId = self.safe_string(trade, 'orderId') feeCost = self.safe_float(trade, 'fee') fee = None if feeCost is not None: feeCost = abs(feeCost) feeRate = self.safe_float(trade, 'feeRate') feeRate = abs(feeRate) feeCurrencyCode = None if market is not None: feeCurrencyCode = market['quote'] if (side == 'sell') else market['base'] fee = { 'cost': feeCost, 'currency': feeCurrencyCode, 'rate': feeRate, } return { 'id': self.safe_string(trade, 'id'), 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'order': orderId, 'symbol': symbol, 'type': None, 'side': side, 'takerOrMaker': None, 'price': price, 'amount': amount, 'cost': cost, 'fee': fee, } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) request = { 'currency': market['id'], 'format': 'json', } response = self.publicGetTrades(self.extend(request, params)) # # { # "result": "success", # "errorCode": "0", # "timestamp": "1416895635", # "currency": "btc", # "completeOrders": [ # { # "timestamp": "1416893212", # "price": "420000.0", # "qty": "0.1", # "is_ask": "1" # } # ] # } # completeOrders = self.safe_value(response, 'completeOrders', []) return self.parse_trades(completeOrders, market, since, limit) def create_order(self, symbol, type, side, amount, price=None, params={}): if type != 'limit': raise ExchangeError(self.id + ' allows limit orders only') self.load_markets() request = { 'price': price, 'currency': self.market_id(symbol), 'qty': amount, } method = 'privatePostOrder' + self.capitalize(type) + self.capitalize(side) response = getattr(self, method)(self.extend(request, params)) # # { # "result": "success", # "errorCode": "0", # "orderId": "8a82c561-40b4-4cb3-9bc0-9ac9ffc1d63b" # } # return self.parse_order(response) def fetch_order(self, id, symbol=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchOrder() requires a symbol argument') self.load_markets() market = self.market(symbol) request = { 'order_id': id, 'currency': market['id'], } response = self.privatePostOrderOrderInfo(self.extend(request, params)) # # { # "result": "success", # "errorCode": "0", # "status": "live", # "info": { # "orderId": "32FF744B-D501-423A-8BA1-05BB6BE7814A", # "currency": "BTC", # "type": "bid", # "price": "2922000.0", # "qty": "115.4950", # "remainQty": "45.4950", # "feeRate": "0.0003", # "fee": "0", # "timestamp": "1499340941" # } # } # info = self.safe_value(response, 'info', {}) info['status'] = self.safe_string(info, 'status') return self.parse_order(info, market) def parse_order_status(self, status): statuses = { 'live': 'open', 'partially_filled': 'open', 'filled': 'closed', } return self.safe_string(statuses, status, status) def parse_order(self, order, market=None): # # createOrder # # { # "result": "success", # "errorCode": "0", # "orderId": "8a82c561-40b4-4cb3-9bc0-9ac9ffc1d63b" # } # # fetchOrder # # { # "status": "live", # injected in fetchOrder # "orderId": "32FF744B-D501-423A-8BA1-05BB6BE7814A", # "currency": "BTC", # "type": "bid", # "price": "2922000.0", # "qty": "115.4950", # "remainQty": "45.4950", # "feeRate": "0.0003", # "fee": "0", # "timestamp": "1499340941" # } # # fetchOpenOrders # # { # "index": "0", # "orderId": "68665943-1eb5-4e4b-9d76-845fc54f5489", # "timestamp": "1449037367", # "price": "444000.0", # "qty": "0.3456", # "type": "ask", # "feeRate": "-0.0015" # } # id = self.safe_string(order, 'orderId') price = self.safe_float(order, 'price') timestamp = self.safe_timestamp(order, 'timestamp') side = self.safe_string(order, 'type') if side == 'ask': side = 'sell' elif side == 'bid': side = 'buy' remaining = self.safe_float(order, 'remainQty') filled = None amount = self.safe_float(order, 'qty') status = self.safe_string(order, 'status') # https://github.com/ccxt/ccxt/pull/7067 if status == 'live': if (remaining is not None) and (amount is not None): if remaining < amount: status = 'canceled' if (remaining is not None) and (amount is not None): filled = max(amount - remaining) status = self.parse_order_status(status) cost = None if (price is not None) and (filled is not None): cost = price * filled symbol = None base = None quote = None marketId = self.safe_string_lower(order, 'currency') if marketId is not None: if marketId in self.markets_by_id: market = self.markets_by_id[marketId] else: base = self.safe_currency_code(marketId) quote = 'KRW' symbol = base + '/' + quote if (symbol is None) and (market is not None): symbol = market['symbol'] base = market['base'] quote = market['quote'] fee = None feeCost = self.safe_float(order, 'fee') if feeCost is not None: feeCurrencyCode = quote if (side == 'sell') else base fee = { 'cost': feeCost, 'rate': self.safe_float(order, 'feeRate'), 'currency': feeCurrencyCode, } return { 'info': order, 'id': id, 'clientOrderId': None, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'lastTradeTimestamp': None, 'symbol': symbol, 'type': 'limit', 'timeInForce': None, 'postOnly': None, 'side': side, 'price': price, 'stopPrice': None, 'cost': cost, 'average': None, 'amount': amount, 'filled': filled, 'remaining': amount, 'status': status, 'fee': fee, 'trades': None, } def fetch_open_orders(self, symbol=None, since=None, limit=None, params={}): # The returned amount might not be same as the ordered amount. If an order is partially filled, the returned amount means the remaining amount. # For the same reason, the returned amount and remaining are always same, and the returned filled and cost are always zero. if symbol is None: raise ExchangeError(self.id + ' allows fetching closed orders with a specific symbol') self.load_markets() market = self.market(symbol) request = { 'currency': market['id'], } response = self.privatePostOrderLimitOrders(self.extend(request, params)) # # { # "result": "success", # "errorCode": "0", # "limitOrders": [ # { # "index": "0", # "orderId": "68665943-1eb5-4e4b-9d76-845fc54f5489", # "timestamp": "1449037367", # "price": "444000.0", # "qty": "0.3456", # "type": "ask", # "feeRate": "-0.0015" # } # ] # } # limitOrders = self.safe_value(response, 'limitOrders', []) return self.parse_orders(limitOrders, market, since, limit) 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') self.load_markets() market = self.market(symbol) request = { 'currency': market['id'], } response = self.privatePostOrderCompleteOrders(self.extend(request, params)) # # despite the name of the endpoint it returns trades which may have a duplicate orderId # https://github.com/ccxt/ccxt/pull/7067 # # { # "result": "success", # "errorCode": "0", # "completeOrders": [ # { # "timestamp": "1416561032", # "price": "419000.0", # "type": "bid", # "qty": "0.001", # "feeRate": "-0.0015", # "fee": "-0.0000015", # "orderId": "E84A1AC2-8088-4FA0-B093-A3BCDB9B3C85" # } # ] # } # completeOrders = self.safe_value(response, 'completeOrders', []) return self.parse_trades(completeOrders, market, since, limit) def cancel_order(self, id, symbol=None, params={}): if symbol is None: # eslint-disable-next-line quotes raise ArgumentsRequired(self.id + " cancelOrder() requires a symbol argument. To cancel the order, pass a symbol argument and {'price': 12345, 'qty': 1.2345, 'is_ask': 0} in the params argument of cancelOrder.") price = self.safe_float(params, 'price') qty = self.safe_float(params, 'qty') isAsk = self.safe_integer(params, 'is_ask') if (price is None) or (qty is None) or (isAsk is None): # eslint-disable-next-line quotes raise ArgumentsRequired(self.id + " cancelOrder() requires {'price': 12345, 'qty': 1.2345, 'is_ask': 0} in the params argument.") self.load_markets() request = { 'order_id': id, 'price': price, 'qty': qty, 'is_ask': isAsk, 'currency': self.market_id(symbol), } response = self.privatePostOrderCancel(self.extend(request, params)) # # { # "result": "success", # "errorCode": "0" # } # return response def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): request = self.implode_params(path, params) query = self.omit(params, self.extract_params(path)) url = self.urls['api'] + '/' if api == 'public': url += request if query: url += '?' + self.urlencode(query) else: self.check_required_credentials() url += self.version + '/' + request nonce = str(self.nonce()) json = self.json(self.extend({ 'access_token': self.apiKey, 'nonce': nonce, }, params)) payload = self.string_to_base64(json) body = self.decode(payload) secret = self.secret.upper() signature = self.hmac(payload, self.encode(secret), hashlib.sha512) headers = { 'Content-Type': 'application/json', 'X-COINONE-PAYLOAD': payload, 'X-COINONE-SIGNATURE': signature, } return {'url': url, 'method': method, 'body': body, 'headers': headers} def handle_errors(self, code, reason, url, method, headers, body, response, requestHeaders, requestBody): if response is None: return if 'result' in response: result = response['result'] if result != 'success': # # { "errorCode": "405", "status": "maintenance", "result": "error"} # errorCode = self.safe_string(response, 'errorCode') feedback = self.id + ' ' + body self.throw_exactly_matched_exception(self.exceptions, errorCode, feedback) raise ExchangeError(feedback) else: raise ExchangeError(self.id + ' ' + body)