# -*- coding: utf-8 -*- from ccxt.base.exchange import Exchange # ----------------------------------------------------------------------------- try: basestring # Python 3 except NameError: basestring = str # Python 2 import math from ccxt.base.errors import ExchangeError class coingi (Exchange): def describe(self): return self.deep_extend(super(coingi, self).describe(), { 'id': 'coingi', 'name': 'Coingi', 'rateLimit': 1000, 'countries': ['PA', 'BG', 'CN', 'US'], # Panama, Bulgaria, China, US 'hasFetchTickers': True, 'hasCORS': False, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/28619707-5c9232a8-7212-11e7-86d6-98fe5d15cc6e.jpg', 'api': { 'www': 'https://coingi.com', 'current': 'https://api.coingi.com', 'user': 'https://api.coingi.com', }, 'www': 'https://coingi.com', 'doc': 'http://docs.coingi.apiary.io/', }, 'api': { 'www': { 'get': [ '', ], }, 'current': { 'get': [ 'order-book/{pair}/{askCount}/{bidCount}/{depth}', 'transactions/{pair}/{maxCount}', '24hour-rolling-aggregation', ], }, 'user': { 'post': [ 'balance', 'add-order', 'cancel-order', 'orders', 'transactions', 'create-crypto-withdrawal', ], }, }, 'fees': { 'trading': { 'tierBased': False, 'percentage': True, 'taker': 0.2 / 100, 'maker': 0.2 / 100, }, 'funding': { 'tierBased': False, 'percentage': False, 'withdraw': { 'BTC': 0.001, 'LTC': 0.01, 'DOGE': 2, 'PPC': 0.02, 'VTC': 0.2, 'NMC': 2, 'DASH': 0.002, 'USD': 10, 'EUR': 10, }, 'deposit': { 'BTC': 0, 'LTC': 0, 'DOGE': 0, 'PPC': 0, 'VTC': 0, 'NMC': 0, 'DASH': 0, 'USD': 5, 'EUR': 1, }, }, }, }) def fetch_markets(self): self.parseJsonResponse = False response = self.wwwGet() self.parseJsonResponse = True parts = response.split('do=currencyPairSelector-selectCurrencyPair" class="active">') currencyParts = parts[1].split('
') result = [] for i in range(1, len(currencyParts)): currencyPart = currencyParts[i] idParts = currencyPart.split('
') id = idParts[0] symbol = id id = id.replace('/', '-') id = id.lower() base, quote = symbol.split('/') precision = { 'amount': 8, 'price': 8, } lot = math.pow(10, -precision['amount']) result.append({ 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'info': id, 'lot': lot, 'active': True, 'precision': precision, 'limits': { 'amount': { 'min': lot, 'max': math.pow(10, precision['amount']), }, 'price': { 'min': math.pow(10, -precision['price']), 'max': None, }, 'cost': { 'min': 0, 'max': None, }, }, }) return result def fetch_balance(self, params={}): self.load_markets() lowercaseCurrencies = [] currencies = list(self.currencies.keys()) for i in range(0, len(currencies)): currency = currencies[i] lowercaseCurrencies.append(currency.lower()) balances = self.userPostBalance({ 'currencies': ','.join(lowercaseCurrencies) }) result = {'info': balances} for b in range(0, len(balances)): balance = balances[b] currency = balance['currency']['name'] currency = currency.upper() account = { 'free': balance['available'], 'used': balance['blocked'] + balance['inOrders'] + balance['withdrawing'], 'total': 0.0, } account['total'] = self.sum(account['free'], account['used']) result[currency] = account return self.parse_balance(result) def fetch_order_book(self, symbol, params={}): self.load_markets() market = self.market(symbol) orderbook = self.currentGetOrderBookPairAskCountBidCountDepth(self.extend({ 'pair': market['id'], 'askCount': 512, # maximum returned number of asks 1-512 'bidCount': 512, # maximum returned number of bids 1-512 'depth': 32, # maximum number of depth range steps 1-32 }, params)) return self.parse_order_book(orderbook, None, 'bids', 'asks', 'price', 'baseAmount') def parse_ticker(self, ticker, market=None): timestamp = self.milliseconds() symbol = None if market: symbol = market['symbol'] return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'high': ticker['high'], 'low': ticker['low'], 'bid': ticker['highestBid'], 'ask': ticker['lowestAsk'], 'vwap': None, 'open': None, 'close': None, 'first': None, 'last': None, 'change': None, 'percentage': None, 'average': None, 'baseVolume': ticker['baseVolume'], 'quoteVolume': ticker['counterVolume'], 'info': ticker, } return ticker def fetch_tickers(self, symbols=None, params={}): self.load_markets() response = self.currentGet24hourRollingAggregation(params) result = {} for t in range(0, len(response)): ticker = response[t] base = ticker['currencyPair']['base'].upper() quote = ticker['currencyPair']['counter'].upper() symbol = base + '/' + quote market = None if symbol in self.markets: market = self.markets[symbol] result[symbol] = self.parse_ticker(ticker, market) return result def fetch_ticker(self, symbol, params={}): self.load_markets() tickers = self.fetch_tickers(None, params) if symbol in tickers: return tickers[symbol] raise ExchangeError(self.id + ' return did not contain ' + symbol) def parse_trade(self, trade, market=None): if not market: market = self.markets_by_id[trade['currencyPair']] return { 'id': trade['id'], 'info': trade, 'timestamp': trade['timestamp'], 'datetime': self.iso8601(trade['timestamp']), 'symbol': market['symbol'], 'type': None, 'side': None, # type '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.currentGetTransactionsPairMaxCount(self.extend({ 'pair': market['id'], 'maxCount': 128, }, params)) return self.parse_trades(response, market, since, limit) def create_order(self, symbol, type, side, amount, price=None, params={}): self.load_markets() order = { 'currencyPair': self.market_id(symbol), 'volume': amount, 'price': price, 'orderType': 0 if (side == 'buy') else 1, } response = self.userPostAddOrder(self.extend(order, params)) return { 'info': response, 'id': response['result'], } def cancel_order(self, id, symbol=None, params={}): self.load_markets() return self.userPostCancelOrder({'orderId': id}) def sign(self, path, api='current', method='GET', params={}, headers=None, body=None): url = self.urls['api'][api] if api != 'www': url += '/' + api + '/' + self.implode_params(path, params) query = self.omit(params, self.extract_params(path)) if api == 'current': if query: url += '?' + self.urlencode(query) elif api == 'user': self.check_required_credentials() nonce = self.nonce() request = self.extend({ 'token': self.apiKey, 'nonce': nonce, }, query) auth = str(nonce) + '$' + self.apiKey request['signature'] = self.hmac(self.encode(auth), self.encode(self.secret)) body = self.json(request) headers = { 'Content-Type': 'application/json', } return {'url': url, 'method': method, 'body': body, 'headers': headers} def request(self, path, api='current', method='GET', params={}, headers=None, body=None): response = self.fetch2(path, api, method, params, headers, body) if not isinstance(response, basestring): if 'errors' in response: raise ExchangeError(self.id + ' ' + self.json(response)) return response