ccxt_lib v4

import ccxt.async_support as ccxt
import asyncio
from collections import defaultdict
from requests import Request, Session
from requests.exceptions import ConnectionError, Timeout, TooManyRedirects
import json
import requests


def cmc(starting_rank, number_of_tokens):
    url = "https://pro-api.coinmarketcap.com/v1/cryptocurrency/listings/latest"
    parameters = {
       'start':'1',
       'limit': str(number_of_tokens),
       'convert':'USD'
    }
    headers = {
       'Accepts': 'application/json',
       'X-CMC_PRO_API_KEY': 'your api_key',
    }
    session = Session()
    session.headers.update(headers)
    
    try:
      response = session.get(url, params=parameters)
      data = json.loads(response.text)
      #print(data)
    except (ConnectionError, Timeout, TooManyRedirects) as e:
      print(e)
    
    # exclude stablecoins
    cmc_coin_list = []
    for coin in data['data']:
        if starting_rank <= coin['cmc_rank'] < number_of_tokens and 'stablecoin' not in coin['tags']:
            cmc_coin_list.append(coin['symbol'])
    return cmc_coin_list
coins = cmc(0, 500)

async def fetch_all_fees_and_statuses(exchanges, symbols):
    withdrawal_fees = {}
    trading_fees = defaultdict(lambda: defaultdict(dict))
    coin_statuses = defaultdict(lambda: defaultdict(dict))

    async def fetch_fees_and_statuses_for_exchange(exchange_id, exchange):
        try:
            currencies = await exchange.fetch_currencies()
            withdrawal_fees[exchange_id] = {
                coin: currencies[coin]['fee'] if coin in currencies and 'fee' in currencies[coin] else None
                for coin in coins
            }
            
            for coin in coins:
                if coin in currencies:
                    coin_statuses[exchange_id][coin] = {
                        'withdrawable': currencies[coin].get('withdraw', False),
                        'depositable': currencies[coin].get('deposit', False)
                    }
                else:
                    coin_statuses[exchange_id][coin] = {
                        'withdrawable': False,
                        'depositable': False
                    }
            
            for symbol in symbols:
                try:
                    fees = await exchange.fetch_trading_fee(symbol)
                    trading_fees[exchange_id][symbol] = fees
                except Exception as e:
                    print(f"Error fetching trading fees for {exchange_id} {symbol}: {str(e)}")
                    trading_fees[exchange_id][symbol] = {'maker': 0.001, 'taker': 0.001}
        except Exception as e:
            print(f"Error fetching fees and statuses for {exchange_id}: {str(e)}")
            withdrawal_fees[exchange_id] = {coin: None for coin in coins}
            coin_statuses[exchange_id] = {coin: {'withdrawable': False, 'depositable': False} for coin in coins}

    await asyncio.gather(*[fetch_fees_and_statuses_for_exchange(exchange_id, exchange) for exchange_id, exchange in exchanges.items()])
    return withdrawal_fees, dict(trading_fees), dict(coin_statuses)

async def fetch_order_books(exchanges, symbols):
    order_books = defaultdict(dict)

    async def fetch_order_book_for_symbol(exchange_id, exchange, symbol):
        try:
            order_book = await exchange.fetch_order_book(symbol)
            order_books[symbol][exchange_id] = order_book
        except Exception as e:
            print(f"Error fetching order book for {exchange_id} {symbol}: {str(e)}")

    await asyncio.gather(*[fetch_order_book_for_symbol(exchange_id, exchange, symbol) 
                           for exchange_id, exchange in exchanges.items() 
                           for symbol in symbols])
    return dict(order_books)

def calculate_profit_with_fees(buy_exchange, sell_exchange, buy_price, sell_price, amount, withdrawal_fees, trading_fees, symbol):
    buy_fee_rate = trading_fees[buy_exchange][symbol].get('taker', 0.001)
    buy_fee = amount * buy_fee_rate
    coins_bought = (amount - buy_fee) / buy_price

    coin = symbol.split('/')[0]
    withdrawal_fee = withdrawal_fees[buy_exchange].get(coin, 0) or 0
    coins_after_withdrawal = coins_bought - withdrawal_fee

    sell_fee_rate = trading_fees[sell_exchange][symbol].get('maker', 0.001)
    sale_amount_before_fee = coins_after_withdrawal * sell_price
    sell_fee = sale_amount_before_fee * sell_fee_rate
    sale_amount = sale_amount_before_fee - sell_fee

    profit = sale_amount - amount
    profit_percentage = (profit / amount) * 100
    return profit, profit_percentage

def find_arbitrage_opportunities(all_order_books, initial_capital, withdrawal_fees, trading_fees, coin_statuses, min_profit_percentage):
    opportunities = []
    for symbol, order_books in all_order_books.items():
        exchange_names = list(order_books.keys())
        for i in range(len(exchange_names)):
            for j in range(i + 1, len(exchange_names)):
                buy_exchange = exchange_names[i]
                sell_exchange = exchange_names[j]
                
                if not order_books[buy_exchange]['asks'] or not order_books[sell_exchange]['bids']:
                    continue

                coin = symbol.split('/')[0]
                
                buy_price = order_books[buy_exchange]['asks'][0][0]
                sell_price = order_books[sell_exchange]['bids'][0][0]
                
                profit, profit_percentage = calculate_profit_with_fees(
                    buy_exchange, sell_exchange, buy_price, sell_price, 
                    initial_capital, withdrawal_fees, trading_fees, symbol
                )
                
                if profit_percentage > min_profit_percentage:
                    opportunities.append({
                        'symbol': symbol,
                        'buy_exchange': buy_exchange,
                        'sell_exchange': sell_exchange,
                        'buy_price': buy_price,
                        'sell_price': sell_price,
                        'profit': profit,
                        'profit_percentage': profit_percentage,
                        'buy_withdrawable': coin_statuses[buy_exchange][coin]['withdrawable'],
                        'sell_depositable': coin_statuses[sell_exchange][coin]['depositable']
                    })
    
    return opportunities

async def main():
    exchanges = {
        'binance': ccxt.binance({
            'apiKey': '',
            'secret': '',
        }),
        'huobi': ccxt.huobi({
            'apiKey': '',
            'secret': ''
        }),
        'kucoin': ccxt.kucoin({
            'apiKey': '',
            'secret': ''
        }),
        'bitget': ccxt.bitget({
            'apiKey': '',
            'secret': ''
        }),
    }
    
    coins = cmc(0, 500)
    symbols = [f"{coin}/USDT" for coin in coins]
    initial_capital = 5000  # $5000 initial capital
    min_profit_percentage = 0.1  # 0.1% minimum profit
    
    # Fetch all fees and statuses once at the start
    withdrawal_fees, trading_fees, coin_statuses = await fetch_all_fees_and_statuses(exchanges, symbols)
    
    try:
        while True:
            all_order_books = await fetch_order_books(exchanges, symbols)
            opportunities = find_arbitrage_opportunities(all_order_books, initial_capital, withdrawal_fees, trading_fees, coin_statuses, min_profit_percentage)
            
            if opportunities:
                print("Arbitrage opportunities found:")
                for opportunity in opportunities:
                    print(f"Symbol: {opportunity['symbol']}")
                    print(f"Buy from {opportunity['buy_exchange']} at {opportunity['buy_price']}")
                    print(f"Sell on {opportunity['sell_exchange']} at {opportunity['sell_price']}")
                    print(f"Potential profit: ${opportunity['profit']:.2f} ({opportunity['profit_percentage']:.2f}%)")
                    
                    status_messages = []
                    if not opportunity['buy_withdrawable']:
                        status_messages.append(f"Cannot withdraw from {opportunity['buy_exchange']}")
                    if not opportunity['sell_depositable']:
                        status_messages.append(f"Cannot deposit to {opportunity['sell_exchange']}")
                    
                    if status_messages:
                        print("Status: " + ", ".join(status_messages))
                    else:
                        print("Status: Fully executable")
                    
                    print("---")
            else:
                print("No profitable arbitrage opportunities found.")
            
            await asyncio.sleep(10)  # Wait for 10 seconds before checking again
    finally:
        # Close all exchange instances
        await asyncio.gather(*[exchange.close() for exchange in exchanges.values()])

if __name__ == "__main__":
    asyncio.run(main())