# -*- 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.async_support.base.exchange import Exchange import hashlib import math from ccxt.base.errors import ExchangeError from ccxt.base.errors import ArgumentsRequired from ccxt.base.errors import InvalidOrder class mercado(Exchange): def describe(self): return self.deep_extend(super(mercado, self).describe(), { 'id': 'mercado', 'name': 'Mercado Bitcoin', 'countries': ['BR'], # Brazil 'rateLimit': 1000, 'version': 'v3', 'has': { 'cancelOrder': True, 'CORS': True, 'createMarketOrder': True, 'createOrder': True, 'fetchBalance': True, 'fetchMarkets': True, 'fetchMyTrades': 'emulated', 'fetchOHLCV': True, 'fetchOpenOrders': True, 'fetchOrder': True, 'fetchOrderBook': True, 'fetchOrders': True, 'fetchTicker': True, 'fetchTickers': False, 'fetchTrades': True, 'withdraw': True, }, 'timeframes': { '1m': '1m', '5m': '5m', '15m': '15m', '30m': '30m', '1h': '1h', '6h': '6h', '12h': '12h', '1d': '1d', '3d': '3d', '1w': '1w', '2w': '2w', }, 'urls': { 'logo': 'https://user-images.githubusercontent.com/1294454/27837060-e7c58714-60ea-11e7-9192-f05e86adb83f.jpg', 'api': { 'public': 'https://www.mercadobitcoin.net/api', 'private': 'https://www.mercadobitcoin.net/tapi', 'v4Public': 'https://www.mercadobitcoin.com.br/v4', }, 'www': 'https://www.mercadobitcoin.com.br', 'doc': [ 'https://www.mercadobitcoin.com.br/api-doc', 'https://www.mercadobitcoin.com.br/trade-api', ], }, 'api': { 'public': { 'get': [ 'coins', '{coin}/orderbook/', # last slash critical '{coin}/ticker/', '{coin}/trades/', '{coin}/trades/{from}/', '{coin}/trades/{from}/{to}', '{coin}/day-summary/{year}/{month}/{day}/', ], }, 'private': { 'post': [ 'cancel_order', 'get_account_info', 'get_order', 'get_withdrawal', 'list_system_messages', 'list_orders', 'list_orderbook', 'place_buy_order', 'place_sell_order', 'place_market_buy_order', 'place_market_sell_order', 'withdraw_coin', ], }, 'v4Public': { 'get': [ '{coin}/candle/', ], }, }, 'fees': { 'trading': { 'maker': 0.003, 'taker': 0.007, }, }, 'options': { 'limits': { 'BTC': 0.001, 'BCH': 0.001, 'ETH': 0.01, 'LTC': 0.01, 'XRP': 0.1, }, }, }) async def fetch_markets(self, params={}): response = await self.publicGetCoins(params) # # [ # "BCH", # "BTC", # "ETH", # "LTC", # "XRP", # "MBPRK01", # "MBPRK02", # "MBPRK03", # "MBPRK04", # "MBCONS01", # "USDC", # "WBX", # "CHZ", # "MBCONS02", # "PAXG", # "MBVASCO01", # "LINK" # ] # result = [] amountLimits = self.safe_value(self.options, 'limits', {}) for i in range(0, len(response)): coin = response[i] baseId = coin quoteId = 'BRL' base = self.safe_currency_code(baseId) quote = self.safe_currency_code(quoteId) symbol = base + '/' + quote id = quote + base precision = { 'amount': 8, 'price': 5, } result.append({ 'id': id, 'symbol': symbol, 'base': base, 'quote': quote, 'baseId': baseId, 'quoteId': quoteId, 'active': None, 'info': coin, 'precision': precision, 'limits': { 'amount': { 'min': self.safe_float(amountLimits, baseId), 'max': None, }, 'price': { 'min': 1 / math.pow(10, precision['price']), 'max': None, }, 'cost': { 'min': None, 'max': None, }, }, }) return result async def fetch_order_book(self, symbol, limit=None, params={}): await self.load_markets() market = self.market(symbol) request = { 'coin': market['base'], } response = await self.publicGetCoinOrderbook(self.extend(request, params)) return self.parse_order_book(response) async def fetch_ticker(self, symbol, params={}): await self.load_markets() market = self.market(symbol) request = { 'coin': market['base'], } response = await self.publicGetCoinTicker(self.extend(request, params)) ticker = self.safe_value(response, 'ticker', {}) timestamp = self.safe_timestamp(ticker, 'date') last = self.safe_float(ticker, 'last') return { 'symbol': symbol, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), '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': None, 'close': last, 'last': last, 'previousClose': None, 'change': None, 'percentage': None, 'average': None, 'baseVolume': self.safe_float(ticker, 'vol'), 'quoteVolume': None, 'info': ticker, } def parse_trade(self, trade, market=None): timestamp = self.safe_timestamp_2(trade, 'date', 'executed_timestamp') symbol = None if market is not None: symbol = market['symbol'] id = self.safe_string_2(trade, 'tid', 'operation_id') type = None side = self.safe_string(trade, 'type') price = self.safe_float(trade, 'price') amount = self.safe_float_2(trade, 'amount', 'quantity') cost = None if price is not None: if amount is not None: cost = price * amount feeCost = self.safe_float(trade, 'fee_rate') fee = None if feeCost is not None: fee = { 'cost': feeCost, 'currency': None, } return { 'id': id, 'info': trade, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'symbol': symbol, 'order': None, 'type': type, 'side': side, 'takerOrMaker': None, 'price': price, 'amount': amount, 'cost': cost, 'fee': fee, } async def fetch_trades(self, symbol, since=None, limit=None, params={}): await self.load_markets() market = self.market(symbol) method = 'publicGetCoinTrades' request = { 'coin': market['base'], } if since is not None: method += 'From' request['from'] = int(since / 1000) to = self.safe_integer(params, 'to') if to is not None: method += 'To' response = await getattr(self, method)(self.extend(request, params)) return self.parse_trades(response, market, since, limit) async def fetch_balance(self, params={}): await self.load_markets() response = await self.privatePostGetAccountInfo(params) data = self.safe_value(response, 'response_data', {}) balances = self.safe_value(data, 'balance', {}) result = {'info': response} currencyIds = list(balances.keys()) for i in range(0, len(currencyIds)): currencyId = currencyIds[i] code = self.safe_currency_code(currencyId) if currencyId in balances: balance = self.safe_value(balances, currencyId, {}) account = self.account() account['free'] = self.safe_float(balance, 'available') account['total'] = self.safe_float(balance, 'total') result[code] = account return self.parse_balance(result) async def create_order(self, symbol, type, side, amount, price=None, params={}): await self.load_markets() request = { 'coin_pair': self.market_id(symbol), } method = self.capitalize(side) + 'Order' if type == 'limit': method = 'privatePostPlace' + method request['limit_price'] = self.price_to_precision(symbol, price) request['quantity'] = self.amount_to_precision(symbol, amount) else: method = 'privatePostPlaceMarket' + method if side == 'buy': if price is None: raise InvalidOrder(self.id + ' createOrder() requires the price argument with market buy orders to calculate total order cost(amount to spend), where cost = amount * price. Supply a price argument to createOrder() call if you want the cost to be calculated for you from price and amount') request['cost'] = self.price_to_precision(symbol, amount * price) else: request['quantity'] = self.amount_to_precision(symbol, amount) response = await getattr(self, method)(self.extend(request, params)) # TODO: replace self with a call to parseOrder for unification return { 'info': response, 'id': str(response['response_data']['order']['order_id']), } async def cancel_order(self, id, symbol=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' cancelOrder() requires a symbol argument') await self.load_markets() market = self.market(symbol) request = { 'coin_pair': market['id'], 'order_id': id, } response = await self.privatePostCancelOrder(self.extend(request, params)) # # { # response_data: { # order: { # order_id: 2176769, # coin_pair: 'BRLBCH', # order_type: 2, # status: 3, # has_fills: False, # quantity: '0.10000000', # limit_price: '1996.15999', # executed_quantity: '0.00000000', # executed_price_avg: '0.00000', # fee: '0.00000000', # created_timestamp: '1536956488', # updated_timestamp: '1536956499', # operations: [] # } # }, # status_code: 100, # server_unix_timestamp: '1536956499' # } # responseData = self.safe_value(response, 'response_data', {}) order = self.safe_value(responseData, 'order', {}) return self.parse_order(order, market) def parse_order_status(self, status): statuses = { '2': 'open', '3': 'canceled', '4': 'closed', } return self.safe_string(statuses, status, status) def parse_order(self, order, market=None): # # { # "order_id": 4, # "coin_pair": "BRLBTC", # "order_type": 1, # "status": 2, # "has_fills": True, # "quantity": "2.00000000", # "limit_price": "900.00000", # "executed_quantity": "1.00000000", # "executed_price_avg": "900.00000", # "fee": "0.00300000", # "created_timestamp": "1453838494", # "updated_timestamp": "1453838494", # "operations": [ # { # "operation_id": 1, # "quantity": "1.00000000", # "price": "900.00000", # "fee_rate": "0.30", # "executed_timestamp": "1453838494", # }, # ], # } # id = self.safe_string(order, 'order_id') side = None if 'order_type' in order: side = 'buy' if (order['order_type'] == 1) else 'sell' status = self.parse_order_status(self.safe_string(order, 'status')) marketId = self.safe_string(order, 'coin_pair') market = self.safe_market(marketId, market) timestamp = self.safe_timestamp(order, 'created_timestamp') fee = { 'cost': self.safe_float(order, 'fee'), 'currency': market['quote'], } price = self.safe_float(order, 'limit_price') # price = self.safe_float(order, 'executed_price_avg', price) average = self.safe_float(order, 'executed_price_avg') amount = self.safe_float(order, 'quantity') filled = self.safe_float(order, 'executed_quantity') remaining = amount - filled cost = filled * average lastTradeTimestamp = self.safe_timestamp(order, 'updated_timestamp') rawTrades = self.safe_value(order, 'operations', []) trades = self.parse_trades(rawTrades, market, None, None, { 'side': side, 'order': id, }) return { 'info': order, 'id': id, 'clientOrderId': None, 'timestamp': timestamp, 'datetime': self.iso8601(timestamp), 'lastTradeTimestamp': lastTradeTimestamp, 'symbol': market['symbol'], 'type': 'limit', 'timeInForce': None, 'postOnly': None, 'side': side, 'price': price, 'stopPrice': None, 'cost': cost, 'average': average, 'amount': amount, 'filled': filled, 'remaining': remaining, 'status': status, 'fee': fee, 'trades': trades, } async def fetch_order(self, id, symbol=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchOrder() requires a symbol argument') await self.load_markets() market = self.market(symbol) request = { 'coin_pair': market['id'], 'order_id': int(id), } response = await self.privatePostGetOrder(self.extend(request, params)) responseData = self.safe_value(response, 'response_data', {}) order = self.safe_value(responseData, 'order') return self.parse_order(order, market) async def withdraw(self, code, amount, address, tag=None, params={}): self.check_address(address) await self.load_markets() currency = self.currency(code) request = { 'coin': currency['id'], 'quantity': '{:.10f}'.format(amount), 'address': address, } if code == 'BRL': account_ref = ('account_ref' in params) if not account_ref: raise ArgumentsRequired(self.id + ' withdraw() requires account_ref parameter to withdraw ' + code) elif code != 'LTC': tx_fee = ('tx_fee' in params) if not tx_fee: raise ArgumentsRequired(self.id + ' withdraw() requires tx_fee parameter to withdraw ' + code) if code == 'XRP': if tag is None: if not ('destination_tag' in params): raise ArgumentsRequired(self.id + ' withdraw() requires a tag argument or destination_tag parameter to withdraw ' + code) else: request['destination_tag'] = tag response = await self.privatePostWithdrawCoin(self.extend(request, params)) return { 'info': response, 'id': response['response_data']['withdrawal']['id'], } def parse_ohlcv(self, ohlcv, market=None): return [ self.safe_timestamp(ohlcv, 'timestamp'), self.safe_float(ohlcv, 'open'), self.safe_float(ohlcv, 'high'), self.safe_float(ohlcv, 'low'), self.safe_float(ohlcv, 'close'), self.safe_float(ohlcv, 'volume'), ] async def fetch_ohlcv(self, symbol, timeframe='5m', since=None, limit=None, params={}): await self.load_markets() market = self.market(symbol) request = { 'precision': self.timeframes[timeframe], 'coin': market['id'].lower(), } if limit is not None and since is not None: request['from'] = int(since / 1000) request['to'] = self.sum(request['from'], limit * self.parse_timeframe(timeframe)) elif since is not None: request['from'] = int(since / 1000) request['to'] = self.sum(self.seconds(), 1) elif limit is not None: request['to'] = self.seconds() request['from'] = request['to'] - (limit * self.parse_timeframe(timeframe)) response = await self.v4PublicGetCoinCandle(self.extend(request, params)) candles = self.safe_value(response, 'candles', []) return self.parse_ohlcvs(candles, market, timeframe, since, limit) async def fetch_orders(self, symbol=None, since=None, limit=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchOrders() requires a symbol argument') await self.load_markets() market = self.market(symbol) request = { 'coin_pair': market['id'], } response = await self.privatePostListOrders(self.extend(request, params)) responseData = self.safe_value(response, 'response_data', {}) orders = self.safe_value(responseData, 'orders', []) return self.parse_orders(orders, market, since, limit) async def fetch_open_orders(self, symbol=None, since=None, limit=None, params={}): if symbol is None: raise ArgumentsRequired(self.id + ' fetchOpenOrders() requires a symbol argument') await self.load_markets() market = self.market(symbol) request = { 'coin_pair': market['id'], 'status_list': '[2]', # open only } response = await self.privatePostListOrders(self.extend(request, params)) responseData = self.safe_value(response, 'response_data', {}) orders = self.safe_value(responseData, 'orders', []) return self.parse_orders(orders, market, since, limit) async 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') await self.load_markets() market = self.market(symbol) request = { 'coin_pair': market['id'], 'has_fills': True, } response = await self.privatePostListOrders(self.extend(request, params)) responseData = self.safe_value(response, 'response_data', {}) ordersRaw = self.safe_value(responseData, 'orders', []) orders = self.parse_orders(ordersRaw, market, since, limit) trades = self.orders_to_trades(orders) return self.filter_by_symbol_since_limit(trades, symbol, since, limit) def orders_to_trades(self, orders): result = [] for i in range(0, len(orders)): trades = self.safe_value(orders[i], 'trades', []) for y in range(0, len(trades)): result.append(trades[y]) return result def sign(self, path, api='public', method='GET', params={}, headers=None, body=None): url = self.urls['api'][api] + '/' query = self.omit(params, self.extract_params(path)) if api == 'public' or (api == 'v4Public'): url += self.implode_params(path, params) if query: url += '?' + self.urlencode(query) else: self.check_required_credentials() url += self.version + '/' nonce = self.nonce() body = self.urlencode(self.extend({ 'tapi_method': path, 'tapi_nonce': nonce, }, params)) auth = '/tapi/' + self.version + '/' + '?' + body headers = { 'Content-Type': 'application/x-www-form-urlencoded', 'TAPI-ID': self.apiKey, 'TAPI-MAC': self.hmac(self.encode(auth), self.encode(self.secret), hashlib.sha512), } return {'url': url, 'method': method, 'body': body, 'headers': headers} async def request(self, path, api='public', method='GET', params={}, headers=None, body=None): response = await self.fetch2(path, api, method, params, headers, body) if 'error_message' in response: raise ExchangeError(self.id + ' ' + self.json(response)) return response