# -*- coding: utf-8 -*- from ccxt.base.exchange import Exchange import hashlib from ccxt.base.errors import ExchangeError class zaif (Exchange): def describe(self): return self.deep_extend(super(zaif, self).describe(), { 'id': 'zaif', 'name': 'Zaif', 'countries': 'JP', 'rateLimit': 2000, 'version': '1', 'hasCORS': False, 'hasFetchOpenOrders': True, 'hasFetchClosedOrders': True, 'hasWithdraw': True, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/27766927-39ca2ada-5eeb-11e7-972f-1b4199518ca6.jpg', 'api': 'https://api.zaif.jp', 'www': 'https://zaif.jp', 'doc': [ 'http://techbureau-api-document.readthedocs.io/ja/latest/index.html', 'https://corp.zaif.jp/api-docs', 'https://corp.zaif.jp/api-docs/api_links', 'https://www.npmjs.com/package/zaif.jp', 'https://github.com/you21979/node-zaif', ], }, 'api': { 'public': { 'get': [ 'depth/{pair}', 'currencies/{pair}', 'currencies/all', 'currency_pairs/{pair}', 'currency_pairs/all', 'last_price/{pair}', 'ticker/{pair}', 'trades/{pair}', ], }, 'private': { 'post': [ 'active_orders', 'cancel_order', 'deposit_history', 'get_id_info', 'get_info', 'get_info2', 'get_personal_info', 'trade', 'trade_history', 'withdraw', 'withdraw_history', ], }, 'ecapi': { 'post': [ 'createInvoice', 'getInvoice', 'getInvoiceIdsByOrderNumber', 'cancelInvoice', ], }, 'tlapi': { 'post': [ 'get_positions', 'position_history', 'active_positions', 'create_position', 'change_position', 'cancel_position', ], }, 'fapi': { 'get': [ 'groups/{group_id}', 'last_price/{group_id}/{pair}', 'ticker/{group_id}/{pair}', 'trades/{group_id}/{pair}', 'depth/{group_id}/{pair}', ], }, }, }) def fetch_markets(self): markets = self.publicGetCurrencyPairsAll() result = [] for p in range(0, len(markets)): market = markets[p] id = market['currency_pair'] symbol = market['name'] base, quote = symbol.split('/') result.append({ 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'info': market, }) return result def fetch_balance(self, params={}): self.load_markets() response = self.privatePostGetInfo() balances = response['return'] result = {'info': balances} currencies = list(balances['funds'].keys()) for c in range(0, len(currencies)): currency = currencies[c] balance = balances['funds'][currency] uppercase = currency.upper() account = { 'free': balance, 'used': 0.0, 'total': balance, } if 'deposit' in balances: if currency in balances['deposit']: account['total'] = balances['deposit'][currency] account['used'] = account['total'] - account['free'] result[uppercase] = account return self.parse_balance(result) def fetch_order_book(self, symbol, params={}): self.load_markets() orderbook = self.publicGetDepthPair(self.extend({ 'pair': self.market_id(symbol), }, params)) return self.parse_order_book(orderbook) def fetch_ticker(self, symbol, params={}): self.load_markets() ticker = self.publicGetTickerPair(self.extend({ 'pair': self.market_id(symbol), }, params)) timestamp = self.milliseconds() vwap = ticker['vwap'] baseVolume = ticker['volume'] quoteVolume = baseVolume * vwap return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': ticker['high'], 'low': ticker['low'], 'bid': ticker['bid'], 'ask': ticker['ask'], 'vwap': vwap, 'open': None, 'close': None, 'first': None, 'last': ticker['last'], 'change': None, 'percentage': None, 'average': None, 'baseVolume': baseVolume, 'quoteVolume': quoteVolume, 'info': ticker, } def parse_trade(self, trade, market=None): side = 'buy' if (trade['trade_type'] == 'bid') else 'sell' timestamp = trade['date'] * 1000 id = self.safe_string(trade, 'id') id = self.safe_string(trade, 'tid', id) if not market: market = self.markets_by_id[trade['currency_pair']] return { 'id': str(id), 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': market['symbol'], 'type': None, 'side': side, 'price': trade['price'], 'amount': trade['amount'], } def fetch_trades(self, symbol, since=None, limit=None, params={}): self.load_markets() market = self.market(symbol) response = self.publicGetTradesPair(self.extend({ 'pair': market['id'], }, params)) return self.parse_trades(response, market, since, limit) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() if type == 'market': raise ExchangeError(self.id + ' allows limit orders only') response = self.privatePostTrade(self.extend({ 'currency_pair': self.market_id(symbol), 'action': 'bid' if (side == 'buy') else 'ask', 'amount': amount, 'price': price, }, params)) return { 'info': response, 'id': str(response['return']['order_id']), } def cancel_order(self, id, symbol=None, params={}): return self.privatePostCancelOrder(self.extend({ 'order_id': id, }, params)) def parse_order(self, order, market=None): side = 'buy' if (order['action'] == 'bid') else 'sell' timestamp = int(order['timestamp']) * 1000 if not market: market = self.markets_by_id[order['currency_pair']] price = order['price'] amount = order['amount'] return { 'id': str(order['id']), 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'status': 'open', 'symbol': market['symbol'], 'type': 'limit', 'side': side, 'price': price, 'cost': price * amount, 'amount': amount, 'filled': None, 'remaining': None, 'trades': None, 'fee': None, } def parse_orders(self, orders, market=None, since=None, limit=None): ids = list(orders.keys()) result = [] for i in range(0, len(ids)): id = ids[i] order = orders[id] extended = self.extend(order, {'id': id}) result.append(self.parse_order(extended, market)) return self.filter_by_since_limit(result, since, limit) def fetch_open_orders(self, symbol=None, since=None, limit=None, params={}): self.load_markets() market = None request = { # 'is_token': False, # 'is_token_both': False, } if symbol: market = self.market(symbol) request['currency_pair'] = market['id'] response = self.privatePostActiveOrders(self.extend(request, params)) return self.parse_orders(response['return'], market, since, limit) def fetch_closed_orders(self, symbol=None, since=None, limit=None, params={}): self.load_markets() market = None request = { # 'from': 0, # 'count': 1000, # 'from_id': 0, # 'end_id': 1000, # 'order': 'DESC', # 'since': 1503821051, # 'end': 1503821051, # 'is_token': False, } if symbol: market = self.market(symbol) request['currency_pair'] = market['id'] response = self.privatePostTradeHistory(self.extend(request, params)) return self.parse_orders(response['return'], market, since, limit) def withdraw(self, currency, amount, address, params={}): self.load_markets() if currency == 'JPY': raise ExchangeError(self.id + ' does not allow ' + currency + ' withdrawals') result = self.privatePostWithdraw(self.extend({ 'currency': currency, 'amount': amount, 'address': address, # 'message': 'Hinot ', # XEM only # 'opt_fee': 0.003, # BTC and MONA only }, params)) return { 'info': result, 'id': result['return']['txid'], 'fee': result['return']['fee'], } def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): url = self.urls['api'] + '/' if api == 'public': url += 'api/' + self.version + '/' + self.implode_params(path, params) elif api == 'fapi': url += 'fapi/' + self.version + '/' + self.implode_params(path, params) else: self.check_required_credentials() if api == 'ecapi': url += 'ecapi' elif api == 'tlapi': url += 'tlapi' else: url += 'tapi' nonce = self.nonce() body = self.urlencode(self.extend({ 'method': path, 'nonce': nonce, }, params)) headers = { 'Content-Type': 'application/x-www-form-urlencoded', 'Key': self.apiKey, 'Sign': self.hmac(self.encode(body), self.encode(self.secret), hashlib.sha512), } return {'url': url, 'method': method, 'body': body, 'headers': headers} def request(self, path, api='api', method='GET', params={}, headers=None, body=None): response = self.fetch2(path, api, method, params, headers, body) if 'error' in response: raise ExchangeError(self.id + ' ' + response['error']) if 'success' in response: if not response['success']: raise ExchangeError(self.id + ' ' + self.json(response)) return response