# -*- coding: utf-8 -*-

import ccxt
import time
import json

import argparse


class Argv (object):
    pass


argv = Argv()

parser = argparse.ArgumentParser()
parser.add_argument('--nonce', type=int, help='integer')
parser.add_argument('exchange', type=str, help='exchange id in lowercase', nargs='?')
parser.add_argument('symbol', type=str, help='symbol in uppercase', nargs='?')
parser.parse_args(namespace=argv)

exchanges = {}

# ------------------------------------------------------------------------------
# string coloring functions

def style(s, style): return str(s)  # style + str (s) + '\033[0m'
def green(s): return style(s, '\033[92m')
def blue(s): return style(s, '\033[94m')
def yellow(s): return style(s, '\033[93m')
def red(s): return style(s, '\033[91m')
def pink(s): return style(s, '\033[95m')
def bold(s): return style(s, '\033[1m')
def underline(s): return style(s, '\033[4m')

# print a colored string
def dump(*args):
    print(' '.join([str(arg) for arg in args]))

# ------------------------------------------------------------------------------

def test_exchange_symbol_orderbook(exchange, symbol):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), green(symbol), 'fetching order book...')
    orderbook = exchange.fetch_order_book(symbol)
    dump(
        green(exchange.id),
        green(symbol),
        'order book',
        orderbook['datetime'],
        'bid: ' +       str(orderbook['bids'][0][0] if len(orderbook['bids']) else 'N/A'),
        'bidVolume: ' + str(orderbook['bids'][0][1] if len(orderbook['bids']) else 'N/A'),
        'ask: ' +       str(orderbook['asks'][0][0] if len(orderbook['asks']) else 'N/A'),
        'askVolume: ' + str(orderbook['asks'][0][1] if len(orderbook['asks']) else 'N/A'))

# ------------------------------------------------------------------------------

def test_exchange_symbol_ohlcv(exchange, symbol):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    if exchange.hasFetchOHLCV:
        ohlcvs = exchange.fetch_ohlcv(symbol)
        dump(green(exchange.id), 'fetched', green(len(ohlcvs)), 'OHLCVs')
    else:
        dump(yellow(exchange.id), 'fetching OHLCV not supported')

# ------------------------------------------------------------------------------

def test_exchange_all_tickers(exchange):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), 'fetching all tickers at once...')
    if exchange.hasFetchTickers:
        tickers = exchange.fetch_tickers()
        dump(green(exchange.id), 'fetched', green(len(list(tickers.keys()))), 'tickers')
    else:
        dump(yellow(exchange.id), 'fetching all tickers at once not supported')

# ------------------------------------------------------------------------------

def test_exchange_symbol_ticker(exchange, symbol):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), green(symbol), 'fetching ticker...')
    ticker = exchange.fetch_ticker(symbol)
    dump(
        green(exchange.id),
        green(symbol),
        'ticker',
        ticker['datetime'],
        'high: ' +   str(ticker['high']),
        'low: ' +    str(ticker['low']),
        'bid: ' +    str(ticker['bid']),
        'ask: ' +    str(ticker['ask']),
        'volume: ' + str(ticker['quoteVolume']))

# ------------------------------------------------------------------------------

def test_exchange_symbol_trades(exchange, symbol):

    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), green(symbol), 'fetching trades...')
    try:
        trades = exchange.fetch_trades(symbol)
        dump(green(exchange.id), green(symbol), 'fetched', green(len(list(trades))), 'trades')
    except ccxt.ExchangeError as e:
        dump(yellow(type(e).__name__), e.args)
    except ccxt.NotSupported as e:
        dump(yellow(type(e).__name__), e.args)

# ------------------------------------------------------------------------------

def test_exchange_symbol(exchange, symbol):
    dump(green('SYMBOL: ' + symbol))
    test_exchange_symbol_ticker(exchange, symbol)

    if exchange.id == 'coinmarketcap':
        dump(green(exchange.fetchGlobal()))
    else:
        test_exchange_symbol_orderbook(exchange, symbol)
        test_exchange_symbol_trades(exchange, symbol)

    test_exchange_all_tickers(exchange)
    test_exchange_symbol_ohlcv(exchange, symbol)

# ------------------------------------------------------------------------------

def load_exchange(exchange):
    exchange.load_markets()

def test_exchange(exchange):

    dump(green('EXCHANGE: ' + exchange.id))
    # delay = 2
    keys = list(exchange.markets.keys())

    # ..........................................................................
    # public API

    symbol = keys[0]
    symbols = [
        'BTC/USD',
        'BTC/CNY',
        'BTC/EUR',
        'BTC/ETH',
        'ETH/BTC',
        'BTC/JPY',
        'LTC/BTC',
        'USD/SLL',
    ]

    for s in symbols:
        if s in keys:
            symbol = s
            break

    if symbol.find('.d') < 0:
        test_exchange_symbol(exchange, symbol)

    # ..........................................................................
    # private API

    if (not hasattr(exchange, 'apiKey') or (len(exchange.apiKey) < 1)):
        return

    dump(green(exchange.id), 'fetching balance...')
    balance = exchange.fetch_balance()
    dump(green(exchange.id), 'balance', balance)
    # time.sleep(delay)

    # amount = 1
    # price = 0.0161

    # marketBuy = exchange.create_market_buy_order(symbol, amount)
    # print(marketBuy)
    # time.sleep(delay)

    # marketSell = exchange.create_market_sell_order(symbol, amount)
    # print(marketSell)
    # time.sleep(delay)

    # limitBuy = exchange.create_limit_buy_order(symbol, amount, price)
    # print(limitBuy)
    # time.sleep(delay)

    # limitSell = exchange.create_limit_sell_order(symbol, amount, price)
    # print(limitSell)
    # time.sleep(delay)

# ------------------------------------------------------------------------------

def try_all_proxies(exchange, proxies):
    current_proxy = 0
    max_retries = len(proxies)
    # a special case for ccex
    if exchange.id == 'ccex':
        current_proxy = 1
    for num_retries in range(0, max_retries):
        try:
            exchange.proxy = proxies[current_proxy]
            current_proxy = (current_proxy + 1) % len(proxies)
            load_exchange(exchange)
            test_exchange(exchange)
            break
        except ccxt.RequestTimeout as e:
            dump(yellow(type(e).__name__), str(e))
        except ccxt.NotSupported as e:
            dump(yellow(type(e).__name__), e.args)
        except ccxt.DDoSProtection as e:
            dump(yellow(type(e).__name__), e.args)
        except ccxt.ExchangeNotAvailable as e:
            dump(yellow(type(e).__name__), e.args)
        except ccxt.AuthenticationError as e:
            dump(yellow(type(e).__name__), str(e))
        except ccxt.ExchangeError as e:
            dump(yellow(type(e).__name__), e.args)

# ------------------------------------------------------------------------------

proxies = [
    '',
    'https://cors-anywhere.herokuapp.com/',
    'https://crossorigin.me/',
    # 'http://cors-proxy.htmldriven.com/?url=', # we don't want this for now
]

# load the api keys from config
with open('./keys.json') as file:
    config = json.load(file)

# instantiate all exchanges
for id in ccxt.exchanges:
    exchange = getattr(ccxt, id)
    exchanges[id] = exchange({'verbose': False})

# set up api keys appropriately
tuples = list(ccxt.Exchange.keysort(config).items())
for (id, params) in tuples:
    options = list(params.items())
    for key in params:
        setattr(exchanges[id], key, params[key])

# move gdax to sandbox
exchanges['gdax'].urls['api'] = 'https://api-public.sandbox.gdax.com'

# ------------------------------------------------------------------------------

if argv.exchange:

    exchange = exchanges[argv.exchange]
    symbol = argv.symbol

    if symbol:
        load_exchange(exchange)
        test_exchange_symbol(exchange, symbol)
    else:
        try_all_proxies(exchange, proxies)

else:

    tuples = list(ccxt.Exchange.keysort(exchanges).items())
    for (id, params) in tuples:
        exchange = exchanges[id]
        try_all_proxies(exchange, proxies)

# -*- coding: utf-8 -*-

import ccxt
import time
import json

import argparse


class Argv (object):
    pass


argv = Argv()

parser = argparse.ArgumentParser()
parser.add_argument('--nonce', type=int, help='integer')
parser.add_argument('exchange', type=str, help='exchange id in lowercase', nargs='?')
parser.add_argument('symbol', type=str, help='symbol in uppercase', nargs='?')
parser.parse_args(namespace=argv)

exchanges = {}

# ------------------------------------------------------------------------------
# string coloring functions

def style(s, style): return str(s)  # style + str (s) + '\033[0m'
def green(s): return style(s, '\033[92m')
def blue(s): return style(s, '\033[94m')
def yellow(s): return style(s, '\033[93m')
def red(s): return style(s, '\033[91m')
def pink(s): return style(s, '\033[95m')
def bold(s): return style(s, '\033[1m')
def underline(s): return style(s, '\033[4m')

# print a colored string
def dump(*args):
    print(' '.join([str(arg) for arg in args]))

# ------------------------------------------------------------------------------

def test_exchange_symbol_orderbook(exchange, symbol):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), green(symbol), 'fetching order book...')
    orderbook = exchange.fetch_order_book(symbol)
    dump(
        green(exchange.id),
        green(symbol),
        'order book',
        orderbook['datetime'],
        'bid: ' +       str(orderbook['bids'][0][0] if len(orderbook['bids']) else 'N/A'),
        'bidVolume: ' + str(orderbook['bids'][0][1] if len(orderbook['bids']) else 'N/A'),
        'ask: ' +       str(orderbook['asks'][0][0] if len(orderbook['asks']) else 'N/A'),
        'askVolume: ' + str(orderbook['asks'][0][1] if len(orderbook['asks']) else 'N/A'))

# ------------------------------------------------------------------------------

def test_exchange_symbol_ohlcv(exchange, symbol):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    if exchange.hasFetchOHLCV:
        ohlcvs = exchange.fetch_ohlcv(symbol)
        dump(green(exchange.id), 'fetched', green(len(ohlcvs)), 'OHLCVs')
    else:
        dump(yellow(exchange.id), 'fetching OHLCV not supported')

# ------------------------------------------------------------------------------

def test_exchange_all_tickers(exchange):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), 'fetching all tickers at once...')
    if exchange.hasFetchTickers:
        tickers = exchange.fetch_tickers()
        dump(green(exchange.id), 'fetched', green(len(list(tickers.keys()))), 'tickers')
    else:
        dump(yellow(exchange.id), 'fetching all tickers at once not supported')

# ------------------------------------------------------------------------------

def test_exchange_symbol_ticker(exchange, symbol):
    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), green(symbol), 'fetching ticker...')
    ticker = exchange.fetch_ticker(symbol)
    dump(
        green(exchange.id),
        green(symbol),
        'ticker',
        ticker['datetime'],
        'high: ' +   str(ticker['high']),
        'low: ' +    str(ticker['low']),
        'bid: ' +    str(ticker['bid']),
        'ask: ' +    str(ticker['ask']),
        'volume: ' + str(ticker['quoteVolume']))

# ------------------------------------------------------------------------------

def test_exchange_symbol_trades(exchange, symbol):

    delay = int(exchange.rateLimit / 1000)
    time.sleep(delay)
    dump(green(exchange.id), green(symbol), 'fetching trades...')
    try:
        trades = exchange.fetch_trades(symbol)
        dump(green(exchange.id), green(symbol), 'fetched', green(len(list(trades))), 'trades')
    except ccxt.ExchangeError as e:
        dump(yellow(type(e).__name__), e.args)
    except ccxt.NotSupported as e:
        dump(yellow(type(e).__name__), e.args)

# ------------------------------------------------------------------------------

def test_exchange_symbol(exchange, symbol):
    dump(green('SYMBOL: ' + symbol))
    test_exchange_symbol_ticker(exchange, symbol)

    if exchange.id == 'coinmarketcap':
        dump(green(exchange.fetchGlobal()))
    else:
        test_exchange_symbol_orderbook(exchange, symbol)
        test_exchange_symbol_trades(exchange, symbol)

    test_exchange_all_tickers(exchange)
    test_exchange_symbol_ohlcv(exchange, symbol)

# ------------------------------------------------------------------------------

def load_exchange(exchange):
    exchange.load_markets()

def test_exchange(exchange):

    dump(green('EXCHANGE: ' + exchange.id))
    # delay = 2
    keys = list(exchange.markets.keys())

    # ..........................................................................
    # public API

    symbol = keys[0]
    symbols = [
        'BTC/USD',
        'BTC/CNY',
        'BTC/EUR',
        'BTC/ETH',
        'ETH/BTC',
        'BTC/JPY',
        'LTC/BTC',
        'USD/SLL',
    ]

    for s in symbols:
        if s in keys:
            symbol = s
            break

    if symbol.find('.d') < 0:
        test_exchange_symbol(exchange, symbol)

    # ..........................................................................
    # private API

    if (not hasattr(exchange, 'apiKey') or (len(exchange.apiKey) < 1)):
        return

    dump(green(exchange.id), 'fetching balance...')
    balance = exchange.fetch_balance()
    dump(green(exchange.id), 'balance', balance)
    # time.sleep(delay)

    # amount = 1
    # price = 0.0161

    # marketBuy = exchange.create_market_buy_order(symbol, amount)
    # print(marketBuy)
    # time.sleep(delay)

    # marketSell = exchange.create_market_sell_order(symbol, amount)
    # print(marketSell)
    # time.sleep(delay)

    # limitBuy = exchange.create_limit_buy_order(symbol, amount, price)
    # print(limitBuy)
    # time.sleep(delay)

    # limitSell = exchange.create_limit_sell_order(symbol, amount, price)
    # print(limitSell)
    # time.sleep(delay)

# ------------------------------------------------------------------------------

def try_all_proxies(exchange, proxies):
    current_proxy = 0
    max_retries = len(proxies)
    # a special case for ccex
    if exchange.id == 'ccex':
        current_proxy = 1
    for num_retries in range(0, max_retries):
        try:
            exchange.proxy = proxies[current_proxy]
            current_proxy = (current_proxy + 1) % len(proxies)
            load_exchange(exchange)
            test_exchange(exchange)
            break
        except ccxt.RequestTimeout as e:
            dump(yellow(type(e).__name__), str(e))
        except ccxt.NotSupported as e:
            dump(yellow(type(e).__name__), e.args)
        except ccxt.DDoSProtection as e:
            dump(yellow(type(e).__name__), e.args)
        except ccxt.ExchangeNotAvailable as e:
            dump(yellow(type(e).__name__), e.args)
        except ccxt.AuthenticationError as e:
            dump(yellow(type(e).__name__), str(e))
        except ccxt.ExchangeError as e:
            dump(yellow(type(e).__name__), e.args)

# ------------------------------------------------------------------------------

proxies = [
    '',
    'https://cors-anywhere.herokuapp.com/',
    'https://crossorigin.me/',
    # 'http://cors-proxy.htmldriven.com/?url=', # we don't want this for now
]

# load the api keys from config
with open('./keys.json') as file:
    config = json.load(file)

# instantiate all exchanges
for id in ccxt.exchanges:
    exchange = getattr(ccxt, id)
    exchanges[id] = exchange({'verbose': False})

# set up api keys appropriately
tuples = list(ccxt.Exchange.keysort(config).items())
for (id, params) in tuples:
    options = list(params.items())
    for key in params:
        setattr(exchanges[id], key, params[key])

# move gdax to sandbox
exchanges['gdax'].urls['api'] = 'https://api-public.sandbox.gdax.com'

# ------------------------------------------------------------------------------

if argv.exchange:

    exchange = exchanges[argv.exchange]
    symbol = argv.symbol

    if symbol:
        load_exchange(exchange)
        test_exchange_symbol(exchange, symbol)
    else:
        try_all_proxies(exchange, proxies)

else:

    tuples = list(ccxt.Exchange.keysort(exchanges).items())
    for (id, params) in tuples:
        exchange = exchanges[id]
        try_all_proxies(exchange, proxies)

# -*- coding: utf-8 -*- # ------------------------------------------------------------------------------ # string coloring functions # style + str (s) + '\033[0m' # print a colored string # ------------------------------------------------------------------------------ # ------------------------------------------------------------------------------ # ------------------------------------------------------------------------------ # ------------------------------------------------------------------------------ # ------------------------------------------------------------------------------ # ------------------------------------------------------------------------------ # ------------------------------------------------------------------------------ # delay = 2 # .......................................................................... # public API # .......................................................................... # private API # time.sleep(delay) # amount = 1 # price = 0.0161 # marketBuy = exchange.create_market_buy_order(symbol, amount) # print(marketBuy) # time.sleep(delay) # marketSell = exchange.create_market_sell_order(symbol, amount) # print(marketSell) # time.sleep(delay) # limitBuy = exchange.create_limit_buy_order(symbol, amount, price) # print(limitBuy) # time.sleep(delay) # limitSell = exchange.create_limit_sell_order(symbol, amount, price) # print(limitSell) # time.sleep(delay) # ------------------------------------------------------------------------------ # a special case for ccex # ------------------------------------------------------------------------------ # 'http://cors-proxy.htmldriven.com/?url=', # we don't want this for now # load the api keys from config # instantiate all exchanges # set up api keys appropriately # move gdax to sandbox # ------------------------------------------------------------------------------