Update app.py

app.py

@@ -5,7 +5,6 @@ import ssl
 import struct
 import logging
 import time
-import asyncio
 from datetime import datetime
 import requests
 from fastapi import FastAPI, Request, Form, HTTPException
@@ -873,8 +872,8 @@ async def webhook(request: Request):
     ticker = data.get("ticker", "").upper()
     price = data.get("price")
     
-    if action not in ["BUY", "SELL", "STOP-TRADE", "CLOSE", "ANCHOR"]:
-        raise HTTPException(status_code=400, detail="Invalid action. Must be BUY, SELL, STOP-TRADE, CLOSE, or ANCHOR")
+    if action not in ["BUY", "SELL", "STOP-TRADE", "CLOSE"]:
+        raise HTTPException(status_code=400, detail="Invalid action. Must be BUY, SELL, STOP-TRADE, or CLOSE")
         
     # Load and refresh tokens
     tokens = get_valid_tokens()
@@ -885,7 +884,7 @@ async def webhook(request: Request):
     access_token = tokens["access_token"]
     
     log_time = datetime.now().strftime("%H:%M:%S")
-    color = "#60a5fa" if action == "BUY" else "#f87171" if action == "SELL" else "#fb923c" if action == "CLOSE" else "#FF9800" if action == "ANCHOR" else "#94a3b8"
+    color = "#60a5fa" if action == "BUY" else "#f87171" if action == "SELL" else "#fb923c" if action == "CLOSE" else "#94a3b8"
     
     try:
         # Establish SSL Socket connection to cTrader Open API
@@ -980,42 +979,6 @@ async def webhook(request: Request):
             else:
                 execution_msg = f"No open positions on {ticker} to close."
                 
-        elif action == "ANCHOR":
-            # ANCHOR = consolidation detected. Open opposite trade, wait 5 sec, then close ALL.
-            anchor_direction = data.get("direction", "").upper()
-            
-            # Step 1: Open the opposite (hedging) trade
-            if anchor_direction == "BUY":
-                logger.info(f"ANCHOR: Opening hedging BUY on {ticker}...")
-                res = place_market_order(ssl_sock, account_id, symbol_id, ProtoOATradeSide.BUY, current_trade_volume)
-                logger.info(f"ANCHOR: Hedging BUY opened. Result: {res.get('status')} {res.get('message', '')}")
-            elif anchor_direction == "SELL":
-                logger.info(f"ANCHOR: Opening hedging SELL on {ticker}...")
-                res = place_market_order(ssl_sock, account_id, symbol_id, ProtoOATradeSide.SELL, current_trade_volume)
-                logger.info(f"ANCHOR: Hedging SELL opened. Result: {res.get('status')} {res.get('message', '')}")
-            else:
-                logger.warning(f"ANCHOR: No direction specified, skipping hedge trade.")
-            
-            # Step 2: Wait 5 seconds for the hedge trade to fully settle
-            ssl_sock.close()
-            logger.info(f"ANCHOR: Waiting 5 seconds before closing all positions on {ticker}...")
-            await asyncio.sleep(5)
-            
-            # Step 3: Reconnect and close ALL positions on this symbol
-            ssl_sock = get_authenticated_socket(account_id, access_token)
-            symbol_id = resolve_symbol_id(ssl_sock, account_id, ticker)
-            positions = get_open_positions(ssl_sock, account_id)
-            symbol_positions = [p for p in positions if p.tradeData.symbolId == symbol_id]
-            
-            closed_count = 0
-            for p in symbol_positions:
-                side = ProtoOATradeSide.SELL if p.tradeData.tradeSide == 1 else ProtoOATradeSide.BUY
-                logger.info(f"ANCHOR: Closing {'BUY' if p.tradeData.tradeSide == 1 else 'SELL'} position {p.positionId}")
-                place_market_order(ssl_sock, account_id, symbol_id, side, p.tradeData.volume, position_id=p.positionId)
-                closed_count += 1
-            
-            execution_msg = f"ANCHOR: Opened hedging {anchor_direction}, then closed {closed_count} position(s) on {ticker}. Consolidation neutralized."
-                
         ssl_sock.close()
         
         # Log to in-memory dashboard logs