popov/gogo2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MEXC INTEGRATION WORKS!!!

Browse Source
This commit is contained in:
Dobromir Popov
2025-07-14 11:23:13 +03:00
parent d42c9ada8c
commit 0c54899fef
2 changed files with 144 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

103
NN/exchanges/mexc/test_live_trading.py
View File

@ -32,10 +32,14 @@ async def test_live_trading():
logger.info("Initializing Trading Executor...")
executor = TradingExecutor("config.yaml")
# Enable test mode to bypass safety checks
executor.set_test_mode(True)
# Check trading mode
logger.info(f"Trading Mode: {executor.trading_mode}")
logger.info(f"Simulation Mode: {executor.simulation_mode}")
logger.info(f"Trading Enabled: {executor.trading_enabled}")
logger.info(f"Test Mode: {getattr(executor, '_test_mode', False)}")
if executor.simulation_mode:
logger.warning("WARNING: Still in simulation mode. Check config.yaml")
@ -84,8 +88,34 @@ async def test_live_trading():
logger.error(f"Error getting market data: {e}")
return
# Test 3: Calculate position sizing
logger.info("\n=== TEST 3: POSITION SIZING ===")
# Test 3: Check for open orders
logger.info("\n=== TEST 3: OPEN ORDERS CHECK ===")
try:
open_orders = executor.exchange.get_open_orders("ETH/USDT")
if open_orders and len(open_orders) > 0:
logger.info(f"Found {len(open_orders)} open orders:")
for order in open_orders:
order_id = order.get('orderId', 'N/A')
side = order.get('side', 'N/A')
qty = order.get('origQty', 'N/A')
price = order.get('price', 'N/A')
logger.info(f" Order {order_id}: {side} {qty} ETH at ${price}")
# Ask if user wants to cancel existing orders
user_input = input("Cancel existing open orders? (type 'YES' to confirm): ")
if user_input.upper() == 'YES':
cancelled = executor._cancel_open_orders("ETH/USDT")
if cancelled:
logger.info("✅ Open orders cancelled successfully")
else:
logger.warning("⚠️ Some orders may not have been cancelled")
else:
logger.info("No open orders found")
except Exception as e:
logger.error(f"Error checking open orders: {e}")
# Test 4: Calculate position sizing
logger.info("\n=== TEST 4: POSITION SIZING ===")
try:
# Test position size calculation with different confidence levels
test_confidences = [0.3, 0.5, 0.7, 0.9]
@ -99,8 +129,8 @@ async def test_live_trading():
logger.error(f"Error calculating position sizes: {e}")
return
# Test 4: Small test trade (optional - requires confirmation)
logger.info("\n=== TEST 4: TEST TRADE (OPTIONAL) ===")
# Test 5: Small test trade (optional - requires confirmation)
logger.info("\n=== TEST 5: TEST TRADE (OPTIONAL) ===")
user_input = input("Do you want to execute a SMALL test trade? (type 'YES' to confirm): ")
if user_input.upper() == 'YES':
@ -118,22 +148,32 @@ async def test_live_trading():
if success:
logger.info("✅ Test BUY order executed successfully!")
# Wait a moment, then try to sell
await asyncio.sleep(2)
logger.info("Executing corresponding SELL order...")
success = executor.execute_signal(
symbol="ETH/USDT",
action="SELL",
confidence=0.9, # High confidence to ensure execution
current_price=current_price
)
if success:
logger.info("✅ Test SELL order executed successfully!")
logger.info("✅ Full test trade cycle completed!")
# Check order status
await asyncio.sleep(1)
positions = executor.get_positions()
if "ETH/USDT" in positions:
position = positions["ETH/USDT"]
logger.info(f"Position created: {position.side} {position.quantity:.6f} ETH @ ${position.entry_price:.2f}")
# Wait a moment, then try to sell immediately (test mode should allow this)
logger.info("Waiting 1 second before attempting SELL...")
await asyncio.sleep(1)
logger.info("Executing corresponding SELL order...")
success = executor.execute_signal(
symbol="ETH/USDT",
action="SELL",
confidence=0.9, # High confidence to ensure execution
current_price=current_price
)
if success:
logger.info("✅ Test SELL order executed successfully!")
logger.info("✅ Full test trade cycle completed!")
else:
logger.warning("❌ Test SELL order failed")
else:
logger.warning("❌ Test SELL order failed")
logger.warning("❌ No position found after BUY order")
else:
logger.warning("❌ Test BUY order failed")
@ -142,8 +182,8 @@ async def test_live_trading():
else:
logger.info("Test trade skipped")
# Test 5: Position and trade history
logger.info("\n=== TEST 5: POSITIONS AND HISTORY ===")
# Test 6: Position and trade history
logger.info("\n=== TEST 6: POSITIONS AND HISTORY ===")
try:
positions = executor.get_positions()
trade_history = executor.get_trade_history()
@ -160,9 +200,30 @@ async def test_live_trading():
except Exception as e:
logger.error(f"Error getting positions/history: {e}")
# Test 7: Final open orders check
logger.info("\n=== TEST 7: FINAL OPEN ORDERS CHECK ===")
try:
open_orders = executor.exchange.get_open_orders("ETH/USDT")
if open_orders and len(open_orders) > 0:
logger.warning(f"⚠️ {len(open_orders)} open orders still pending:")
for order in open_orders:
order_id = order.get('orderId', 'N/A')
side = order.get('side', 'N/A')
qty = order.get('origQty', 'N/A')
price = order.get('price', 'N/A')
status = order.get('status', 'N/A')
logger.info(f" Order {order_id}: {side} {qty} ETH at ${price} - Status: {status}")
else:
logger.info("✅ No pending orders")
except Exception as e:
logger.error(f"Error checking final open orders: {e}")
logger.info("\n=== LIVE TRADING TEST COMPLETED ===")
logger.info("If all tests passed, live trading is ready!")
# Disable test mode
executor.set_test_mode(False)
except Exception as e:
logger.error(f"Error in live trading test: {e}")