# -*- coding: utf-8 -*- from ccxt.base.exchange import Exchange import hashlib import math from ccxt.base.errors import ExchangeError class zb (Exchange): def describe(self): return self.deep_extend(super(zb, self).describe(), { 'id': 'zb', 'name': 'ZB', 'countries': 'CN', 'rateLimit': 1000, 'version': 'v1', 'hasCORS': False, 'hasFetchOrder': True, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/32859187-cd5214f0-ca5e-11e7-967d-96568e2e2bd1.jpg', 'api': { 'public': 'http://api.zb.com/data', # no https for public API 'private': 'https://trade.zb.com/api', }, 'www': 'https://trade.zb.com/api', 'doc': 'https://www.zb.com/i/developer', }, 'api': { 'public': { 'get': [ 'markets', 'ticker', 'depth', 'trades', 'kline', ], }, 'private': { 'post': [ 'order', 'cancelOrder', 'getOrder', 'getOrders', 'getOrdersNew', 'getOrdersIgnoreTradeType', 'getUnfinishedOrdersIgnoreTradeType', 'getAccountInfo', 'getUserAddress', 'getWithdrawAddress', 'getWithdrawRecord', 'getChargeRecord', 'getCnyWithdrawRecord', 'getCnyChargeRecord', 'withdraw', ], }, }, }) def get_trading_fee_from_base_quote(self, base, quote): # base: quote fees = { 'BTC': {'USDT': 0.0}, 'BCH': {'BTC': 0.001, 'USDT': 0.001}, 'LTC': {'BTC': 0.001, 'USDT': 0.0}, 'ETH': {'BTC': 0.001, 'USDT': 0.0}, 'ETC': {'BTC': 0.001, 'USDT': 0.0}, 'BTS': {'BTC': 0.001, 'USDT': 0.001}, 'EOS': {'BTC': 0.001, 'USDT': 0.001}, 'HSR': {'BTC': 0.001, 'USDT': 0.001}, 'QTUM': {'BTC': 0.001, 'USDT': 0.001}, 'USDT': {'BTC': 0.0}, } if base in fees: quoteFees = fees[base] if quote in quoteFees: return quoteFees[quote] return None def fetch_markets(self): markets = self.publicGetMarkets() keys = list(markets.keys()) result = [] for i in range(0, len(keys)): id = keys[i] market = markets[id] baseId, quoteId = id.split('_') base = self.common_currency_code(baseId.upper()) quote = self.common_currency_code(quoteId.upper()) symbol = base + '/' + quote fee = self.get_trading_fee_from_base_quote(base, quote) precision = { 'amount': market['amountScale'], 'price': market['priceScale'], } lot = math.pow(10, -precision['amount']) result.append({ 'id': id, 'symbol': symbol, 'baseId': baseId, 'quoteId': quoteId, 'base': base, 'quote': quote, 'info': market, 'maker': fee, 'taker': fee, 'lot': lot, 'active': True, 'precision': precision, 'limits': { 'amount': { 'min': lot, 'max': None, }, 'price': { 'min': math.pow(10, -precision['price']), 'max': None, }, 'cost': { 'min': 0, 'max': None, }, }, }) return result def fetch_balance(self, params={}): self.load_markets() response = self.privatePostGetAccountInfo() balances = response['result'] result = {'info': balances} currencies = list(self.currencies.keys()) for i in range(0, len(currencies)): currency = currencies[i] account = self.account() if currency in balances['balance']: account['free'] = float(balances['balance'][currency]['amount']) if currency in balances['frozen']: account['used'] = float(balances['frozen'][currency]['amount']) account['total'] = self.sum(account['free'], account['used']) result[currency] = account return self.parse_balance(result) def get_market_field_name(self): return 'market' def fetch_order_book(self, symbol, params={}): self.load_markets() market = self.market(symbol) marketFieldName = self.get_market_field_name() request = {} request[marketFieldName] = market['id'] orderbook = self.publicGetDepth(self.extend(request, params)) timestamp = self.milliseconds() bids = None asks = None if 'bids' in orderbook: bids = orderbook['bids'] if 'asks' in orderbook: asks = orderbook['asks'] result = { 'bids': bids, 'asks': asks, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), } if result['bids']: result['bids'] = self.sort_by(result['bids'], 0, True) if result['asks']: result['asks'] = self.sort_by(result['asks'], 0) return result def fetch_ticker(self, symbol, params={}): self.load_markets() market = self.market(symbol) marketFieldName = self.get_market_field_name() request = {} request[marketFieldName] = market['id'] response = self.publicGetTicker(self.extend(request, params)) ticker = response['ticker'] timestamp = self.milliseconds() return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': float(ticker['high']), 'low': float(ticker['low']), 'bid': float(ticker['buy']), 'ask': float(ticker['sell']), 'vwap': None, 'open': None, 'close': None, 'first': None, 'last': float(ticker['last']), 'change': None, 'percentage': None, 'average': None, 'baseVolume': float(ticker['vol']), 'quoteVolume': None, 'info': ticker, } def parse_trade(self, trade, market=None): timestamp = trade['date'] * 1000 side = 'buy' if (trade['trade_type'] == 'bid') else 'sell' return { 'info': trade, 'id': str(trade['tid']), 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': market['symbol'], 'type': None, 'side': side, 'price': float(trade['price']), 'amount': float(trade['amount']), } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) marketFieldName = self.get_market_field_name() request = {} request[marketFieldName] = market['id'] response = self.publicGetTrades(self.extend(request, params)) return self.parse_trades(response, market, since, limit) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() paramString = '&price=' + str(price) paramString += '&amount=' + str(amount) tradeType = '1' if (side == 'buy') else '0' paramString += '&tradeType=' + tradeType paramString += '¤cy=' + self.market_id(symbol) response = self.privatePostOrder(paramString) return { 'info': response, 'id': response['id'], } def cancel_order(self, id, symbol=None, params={}): self.load_markets() paramString = '&id=' + str(id) if 'currency' in params: paramString += '¤cy=' + params['currency'] return self.privatePostCancelOrder(paramString) def fetch_order(self, id, symbol=None, params={}): self.load_markets() paramString = '&id=' + str(id) if 'currency' in params: paramString += '¤cy=' + params['currency'] return self.privatePostGetOrder(paramString) def nonce(self): return self.milliseconds() def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): url = self.urls['api'][api] if api == 'public': url += '/' + self.version + '/' + path if params: url += '?' + self.urlencode(params) else: self.check_required_credentials() paramsLength = len(params) # params should be a string here nonce = self.nonce() auth = 'method=' + path auth += '&accesskey=' + self.apiKey auth += params if paramsLength else '' secret = self.hash(self.encode(self.secret), 'sha1') signature = self.hmac(self.encode(auth), self.encode(secret), hashlib.md5) suffix = 'sign=' + signature + '&reqTime=' + str(nonce) url += '/' + path + '?' + auth + '&' + suffix 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 api == 'private': if 'code' in response: raise ExchangeError(self.id + ' ' + self.json(response)) return response