Update trade_manager.py

trade_manager.py

@@ -1,4 +1,4 @@
-# trade_manager.py (Updated to V6.6 - Fixed Take-Profit Execution Logic)
+# trade_manager.py (Updated to V6.7 - 1M Indicator & Order Book Trigger)
 import asyncio
 import json
 import time
@@ -8,12 +8,21 @@ from datetime import datetime, timedelta
 from typing import Dict, Any, List
 from collections import deque, defaultdict 
 
+# 🔴 --- START OF CHANGE (V6.7) --- 🔴
+# (إضافة pandas لتحليل مؤشرات 1-دقيقة)
+import pandas as pd
+try:
+    import pandas_ta as ta
+except ImportError:
+    print("⚠️ مكتبة pandas_ta غير موجودة، مؤشرات الحارس (Sentry 1m) ستفشل.")
+    ta = None
+# 🔴 --- END OF CHANGE --- 🔴
+
 try:
     import ccxt.async_support as ccxtasync
     CCXT_ASYNC_AVAILABLE = True
 except ImportError:
     print("❌❌❌ خطأ فادح: فشل استيراد 'ccxt.async_support'. ❌❌❌")
-    print("يرجى التأكد من تثبيت 'ccxt' (الإصدار 4 أو أحدث) بنجاح.")
     CCXT_ASYNC_AVAILABLE = False
 
 import numpy as np
@@ -21,15 +30,15 @@ from helpers import safe_float_conversion
 
 class TacticalData:
     """
-    (محدث) لتخزين بيانات تأكيد من مصادر متعددة بدلاً من Binance فقط.
+    (محدث V6.7)
+    لتخزين بيانات 1-دقيقة الحقيقية ومؤشراتها.
     """
     def __init__(self, symbol):
         self.symbol = symbol
-        self.order_book = None # (بيانات KuCoin الأساسية)
-        self.trades = deque(maxlen=100) # (بيانات KuCoin الأساسية)
-        self.cvd = 0.0 # (بيانات KuCoin الأساسية)
+        self.order_book = None 
+        self.trades = deque(maxlen=100) 
+        self.cvd = 0.0 
         self.large_trades = []
-        self.one_min_rsi = 50.0
         self.last_update = time.time()
         
         self.confirmation_trades = defaultdict(lambda: deque(maxlen=50))
@@ -37,12 +46,20 @@ class TacticalData:
         
         self.last_kucoin_trade_id = None
         self.last_confirmation_trade_ids = defaultdict(lambda: None)
+        
+        # 🔴 --- START OF CHANGE (V6.7) --- 🔴
+        # (حذف: self.one_min_rsi)
+        # (إضافة: بيانات ومؤشرات 1-دقيقة)
+        self.ohlcv_1m = deque(maxlen=100) # (لتخزين 100 شمعة 1-دقيقة)
+        self.indicators_1m = {} # (لتخزين EMA 9, EMA 21, MACD Hist)
+        self.last_1m_candle_timestamp = None
+        # 🔴 --- END OF CHANGE --- 🔴
 
     def add_trade(self, trade):
         """إضافة صفقة KuCoin (الأساسية)"""
         trade_id = trade.get('id')
         if trade_id and trade_id == self.last_kucoin_trade_id:
-            return # صفقة مكررة
+            return 
         self.last_kucoin_trade_id = trade_id
 
         self.trades.append(trade)
@@ -63,7 +80,7 @@ class TacticalData:
         """(جديد) إضافة صفقة تأكيد (Bybit, OKX, etc.)"""
         trade_id = trade.get('id')
         if trade_id and trade_id == self.last_confirmation_trade_ids[exchange_id]:
-            return # صفقة مكررة
+            return 
         self.last_confirmation_trade_ids[exchange_id] = trade_id
         
         self.confirmation_trades[exchange_id].append(trade)
@@ -78,43 +95,87 @@ class TacticalData:
         self.last_update = time.time()
 
     def analyze_order_book(self):
-        if not self.order_book: return {"bids_depth": 0, "asks_depth": 0, "top_wall": "None"}
+        if not self.order_book: return {"bids_depth": 0, "asks_depth": 0}
         try:
             bids = self.order_book.get('bids', []); asks = self.order_book.get('asks', [])
             bids_depth = sum(price * amount for price, amount in bids[:10])
             asks_depth = sum(price * amount for price, amount in asks[:10])
             return {"bids_depth": bids_depth, "asks_depth": asks_depth}
-        except Exception: return {"bids_depth": 0, "asks_depth": 0, "top_wall": "Error"}
+        except Exception: return {"bids_depth": 0, "asks_depth": 0}
 
-    def get_1m_rsi(self):
+    # 🔴 --- START OF CHANGE (V6.7) --- 🔴
+    # (حذف دالة get_1m_rsi التقريبية)
+
+    def add_1m_ohlcv(self, ohlcv_data: List):
+        """(جديد V6.7) إضافة شموع 1-دقيقة وحساب المؤشرات"""
+        if not ohlcv_data:
+            return
+        
+        # (إضافة الشموع الجديدة فقط)
+        new_candles_added = False
+        for candle in ohlcv_data:
+            timestamp = candle[0]
+            if timestamp and timestamp != self.last_1m_candle_timestamp:
+                if self.ohlcv_1m and timestamp < self.ohlcv_1m[-1][0]:
+                    continue # (تجاهل الشموع القديمة إذا حدث تداخل)
+                
+                self.ohlcv_1m.append(candle)
+                self.last_1m_candle_timestamp = timestamp
+                new_candles_added = True
+        
+        # (حساب المؤشرات فقط إذا تغيرت البيانات)
+        if new_candles_added and len(self.ohlcv_1m) >= 26: # (26 كافية لـ EMA 21 و MACD)
+            self._analyze_1m_indicators()
+
+    def _analyze_1m_indicators(self):
+        """(جديد V6.7) حساب مؤشرات 1-دقيقة الحقيقية"""
+        if ta is None or len(self.ohlcv_1m) < 26:
+            self.indicators_1m = {}
+            return
+            
         try:
-            if len(self.trades) < 20: return 50.0
-            closes = np.array([trade['price'] for trade in self.trades if 'price' in trade])[-20:]
-            if len(closes) < 15: return 50.0
-            deltas = np.diff(closes); seed = deltas[:14]
-            gains = np.sum(seed[seed >= 0]); losses = np.sum(np.abs(seed[seed < 0]))
-            if losses == 0: self.one_min_rsi = 100.0; return 100.0
-            if gains == 0: self.one_min_rsi = 0.0; return 0.0
-            rs = gains / losses; rsi = 100.0 - (100.0 / (1.0 + rs))
-            for delta in deltas[14:]:
-                gain = max(delta, 0); loss = max(-delta, 0)
-                gains = (gains * 13 + gain) / 14; losses = (losses * 13 + loss) / 14
-                if losses == 0: rsi = 100.0
-                else: rs = gains / losses; rsi = 100.0 - (100.0 / (1.0 + rs))
-            self.one_min_rsi = rsi; return rsi
-        except Exception: return self.one_min_rsi
+            # (تحويل deque إلى DataFrame للمعالجة)
+            df = pd.DataFrame(list(self.ohlcv_1m), columns=['timestamp', 'open', 'high', 'low', 'close', 'volume'])
+            df[['open', 'high', 'low', 'close', 'volume']] = df[['open', 'high', 'low', 'close', 'volume']].astype(float)
+            close = df['close']
+
+            # (حساب المؤشرات المطلوبة)
+            ema_9 = ta.ema(close, length=9)
+            ema_21 = ta.ema(close, length=21)
+            macd_data = ta.macd(close, fast=12, slow=26, signal=9)
+            
+            if ema_9 is not None and not ema_9.empty and \
+               ema_21 is not None and not ema_21.empty and \
+               macd_data is not None and not macd_data.empty:
+                
+                self.indicators_1m = {
+                    'ema_9': ema_9.iloc[-1],
+                    'ema_21': ema_21.iloc[-1],
+                    'macd_hist': macd_data['MACDh_12_26_9'].iloc[-1]
+                }
+            else:
+                self.indicators_1m = {}
+                
+        except Exception as e:
+            # print(f"⚠️ [Sentry] خطأ في حساب مؤشرات 1m لـ {self.symbol}: {e}")
+            self.indicators_1m = {}
+    # 🔴 --- END OF CHANGE --- 🔴
 
     def get_tactical_snapshot(self):
-        """(محدث) لإرجاع بيانات التأكيد المجمعة"""
+        """(محدث V6.7) لإرجاع مؤشرات 1-دقيقة الحقيقية"""
         agg_cvd = sum(self.confirmation_cvd.values())
+        
+        # 🔴 --- (تغيير V6.7) --- 🔴
         return {
             "cvd_kucoin": self.cvd,
             "cvd_confirmation_sources": dict(self.confirmation_cvd),
             "cvd_confirmation_aggregate": agg_cvd,
             "large_trades_count_5m": len([t for t in self.large_trades if t.get('timestamp') and (time.time() - t['timestamp']/1000) < 300]),
-            "rsi_1m_approx": self.get_1m_rsi(),
+            # (حذف rsi_1m_approx)
+            "indicators_1m": self.indicators_1m, # (إضافة المؤشرات الجديدة)
             "ob_analysis": self.analyze_order_book()
         }
+        # 🔴 --- نهاية التغيير --- 🔴
 
 
 class TradeManager:
@@ -139,9 +200,6 @@ class TradeManager:
         self.confirmation_polling_interval = 3.0
 
     async def initialize_sentry_exchanges(self): 
-        """
-        (محدث V6.1) تهيئة KuCoin (أساسي) ومنصات تأكيد متعددة (ثانوية).
-        """
         try:
             print("🔄 [Sentry] تهيئة منصات التداول (KuCoin REST ومنصات التأكيد)...")
             
@@ -179,7 +237,6 @@ class TradeManager:
             raise
 
     async def start_sentry_and_monitoring_loops(self):
-        """الحلقة الرئيسية للحارس (Sentry) ومراقب الخروج (Exit Monitor)."""
         self.is_running = True
         print(f"✅ [Sentry] بدء حلقات المراقبة التكتيكية (Layer 2 - API Polling)...")
         while self.is_running:
@@ -228,7 +285,6 @@ class TradeManager:
                 print(f"❌ [Sentry] خطأ في الحلقة الرئيسية: {error}"); traceback.print_exc(); await asyncio.sleep(60)
 
     async def stop_sentry_loops(self):
-        """إيقاف جميع مهام المراقبة وإغلاق جميع اتصالات REST"""
         self.is_running = False
         print("🛑 [Sentry] إيقاف جميع حلقات المراقبة...")
         for task in self.sentry_tasks.values(): task.cancel()
@@ -249,13 +305,11 @@ class TradeManager:
         except Exception as e: print(f"⚠️ [Sentry] خطأ أثناء إغلاق الاتصالات: {e}")
 
     async def update_sentry_watchlist(self, candidates: List[Dict]):
-        """تحديث قائمة المراقبة التي يستخدمها الحارس (Sentry)."""
         async with self.sentry_lock: 
             self.sentry_watchlist = {c['symbol']: c for c in candidates}
             print(f"ℹ️ [Sentry] تم تحديث Watchlist. عدد المرشحين: {len(self.sentry_watchlist)}")
 
     def get_sentry_status(self):
-        """لواجهة برمجة التطبيقات /system-status"""
         active_monitoring_count = len(self.sentry_tasks)
         watchlist_symbols_list = list(self.sentry_watchlist.keys())
         
@@ -268,9 +322,6 @@ class TradeManager:
         }
 
     async def _monitor_symbol_activity_polling(self, symbol: str, strategy_hint: str):
-        """
-        يشغل حلقات Polling متوازية (KuCoin + منصات التأكيد) ويشغل منطق التحليل.
-        """
         if symbol not in self.tactical_data_cache:
             self.tactical_data_cache[symbol] = TacticalData(symbol)
 
@@ -295,7 +346,7 @@ class TradeManager:
                 del self.tactical_data_cache[symbol]
 
     async def _poll_kucoin_data(self, symbol):
-        """حلقة استقصاء (Polling) لبيانات KuCoin (الأساسية)"""
+        """(محدث V6.7) حلقة استقصاء (Polling) لبيانات KuCoin (تتضمن 1m OHLCV)"""
         while self.is_running:
             try:
                 if not self.kucoin_rest:
@@ -303,18 +354,34 @@ class TradeManager:
                     await asyncio.sleep(10)
                     continue
 
-                # 1. جلب دفتر الطلبات
-                ob = await self.kucoin_rest.fetch_order_book(symbol, limit=20)
-                if symbol in self.tactical_data_cache:
-                    self.tactical_data_cache[symbol].set_order_book(ob)
+                # 🔴 --- START OF CHANGE (V6.7) --- 🔴
+                # (جلب 3 أنواع بيانات بالتوازي)
+                tasks = {
+                    'ob': asyncio.create_task(self.kucoin_rest.fetch_order_book(symbol, limit=20)),
+                    'trades': asyncio.create_task(self.kucoin_rest.fetch_trades(symbol, since=int((time.time() - 60) * 1000), limit=50)),
+                    'ohlcv_1m': asyncio.create_task(self.kucoin_rest.fetch_ohlcv(symbol, '1m', limit=50))
+                }
 
-                # 2. جلب آخر الصفقات
-                since_timestamp = int((time.time() - 60) * 1000) 
-                trades = await self.kucoin_rest.fetch_trades(symbol, since=since_timestamp, limit=50)
-                if symbol in self.tactical_data_cache:
+                await asyncio.wait(tasks.values(), return_when=asyncio.ALL_COMPLETED)
+                
+                if symbol not in self.tactical_data_cache:
+                    continue # (ربما تم إيقاف المراقبة أثناء الجلب)
+
+                # 1. معالجة دفتر الطلبات
+                if not tasks['ob'].exception():
+                    self.tactical_data_cache[symbol].set_order_book(tasks['ob'].result())
+
+                # 2. معالجة آخر الصفقات
+                if not tasks['trades'].exception():
+                    trades = tasks['trades'].result()
                     trades.sort(key=lambda x: x['timestamp'])
                     for trade in trades:
                         self.tactical_data_cache[symbol].add_trade(trade)
+                
+                # 3. معالجة شموع 1-دقيقة
+                if not tasks['ohlcv_1m'].exception():
+                    self.tactical_data_cache[symbol].add_1m_ohlcv(tasks['ohlcv_1m'].result())
+                # 🔴 --- END OF CHANGE --- 🔴
 
                 await asyncio.sleep(self.polling_interval)
 
@@ -328,9 +395,7 @@ class TradeManager:
                 await asyncio.sleep(5)
     
     async def _poll_confirmation_data(self, symbol):
-        """(جديد) حلقة استقصاء (Polling) لبيانات منصات التأكيد (Bybit, OKX, etc.)"""
         if not self.confirmation_exchanges:
-            print(f"   [Sentry Conf] {symbol} - لا توجد منصات تأكيد، سيتم الاعتماد على KuCoin فقط.")
             return 
 
         await asyncio.sleep(self.confirmation_polling_interval / 2) 
@@ -351,7 +416,6 @@ class TradeManager:
                 await asyncio.sleep(10) 
 
     async def _fetch_confirmation_trades(self, ex_id: str, exchange: ccxtasync.Exchange, symbol: str):
-        """(جديد) دالة مساعدة لجلب الصفقات من منصة تأكيد واحدة"""
         try:
             if symbol not in exchange.markets:
                 return
@@ -374,9 +438,9 @@ class TradeManager:
     
 
     async def _run_tactical_analysis_loop(self, symbol: str, strategy_hint: str):
-        """(محدث V6.6) (دماغ الحارس) يشغل التحليل التكتيكي كل ثانية."""
+        """(محدث V6.7) (دماغ الحارس) يشغل التحليل التكتيكي كل ثانية."""
         while self.is_running:
-            await asyncio.sleep(1) # (الت��ليل السريع كل ثانية)
+            await asyncio.sleep(1) 
             try:
                 if self.state_manager.trade_analysis_lock.locked(): continue
                 trade = await self.get_trade_by_symbol(symbol)
@@ -386,22 +450,16 @@ class TradeManager:
                 snapshot = tactical_data.get_tactical_snapshot()
                 
                 if trade:
-                    # 🔴 --- (الإصلاح V6.6) --- 🔴
-                    # (سيتم تمرير snapshot إلى الدالة المحدثة)
                     exit_reason = self._check_exit_trigger(trade, snapshot, tactical_data)
                     if exit_reason:
                         print(f"🛑 [Sentry] زناد خروج استراتيجي لـ {symbol}: {exit_reason}")
                         
-                        # (تحديد السعر الحقيقي للإغلاق)
                         current_price_to_close = None
                         if "Take Profit" in exit_reason:
-                            # إذا كان جني الأرباح، نستخدم السعر الذي حقق الهدف
                             current_price_to_close = trade.get('take_profit')
                         elif tactical_data.order_book and tactical_data.order_book.get('bids') and len(tactical_data.order_book['bids']) > 0:
-                            # إذا كان وقف الخسارة، نستخدم أفضل سعر شراء (Bid)
                             current_price_to_close = tactical_data.order_book['bids'][0][0]
                         else:
-                            # (احتياطي: إذا فشل كل شيء، استخدم آخر سعر صفقة)
                             if tactical_data.trades:
                                 current_price_to_close = tactical_data.trades[-1].get('price')
 
@@ -414,6 +472,8 @@ class TradeManager:
                         is_still_on_watchlist = symbol in self.sentry_watchlist
 
                     if is_still_on_watchlist:
+                        # 🔴 --- (تغيير V6.7) --- 🔴
+                        # (snapshot يحتوي الآن على مؤشرات 1-دقيقة الحقيقية)
                         trigger = self._check_entry_trigger(symbol, strategy_hint, snapshot)
                         if trigger:
                             print(f"✅ [Sentry] زناد دخول تكتيكي لـ {symbol} (استراتيجية: {strategy_hint})")
@@ -429,40 +489,62 @@ class TradeManager:
                 raise 
             except Exception as e: print(f"❌ [Sentry] خطأ في حلقة التحليل التكتيكي لـ {symbol}: {e}"); traceback.print_exc()
 
+    # 🔴 --- START OF CHANGE (V6.7) --- 🔴
     def _check_entry_trigger(self, symbol: str, strategy_hint: str, data: Dict) -> bool:
-        """(محدث V5.9) إضافة trend_following إلى منطق الزناد."""
+        """(محدث V6.7) زناد ثلاثي: CVD + دفتر الطلبات + مؤشرات 1-دقيقة"""
         
-        rsi = data.get('rsi_1m_approx', 50)
+        # --- جلب البيانات ---
         cvd_kucoin = data.get('cvd_kucoin', 0)
-        large_trades = data.get('large_trades_count_5m', 0)
         
-        cvd_conf_agg = data.get('cvd_confirmation_aggregate', 0)
-        cvd_conf_sources_count = len(data.get('cvd_confirmation_sources', {}))
+        ob_analysis = data.get('ob_analysis', {})
+        bids_depth = ob_analysis.get('bids_depth', 0)
+        asks_depth = ob_analysis.get('asks_depth', 0)
+
+        indicators_1m = data.get('indicators_1m', {})
+        ema_9_1m = indicators_1m.get('ema_9')
+        ema_21_1m = indicators_1m.get('ema_21')
         
+        # (للاستراتيجيات الأخرى)
+        large_trades = data.get('large_trades_count_5m', 0)
+
+        # --- منطق الزناد ---
         if strategy_hint in ['breakout_momentum', 'trend_following']:
-            if cvd_kucoin <= 0:
-                return False 
-            if (rsi > 55):
-                 if cvd_conf_sources_count > 0 and cvd_conf_agg < (cvd_kucoin * -0.5):
-                     print(f"   [Trigger Hold] {symbol} Breakout/Trend: KuCoin CVD ({cvd_kucoin:.0f}) إيجابي، لكن منصات التأكيد ({cvd_conf_agg:.0f}) تبيع بقوة.")
-                     return False
-                 
-                 print(f"   [Trigger] {symbol} Breakout/Trend: K_CVD={cvd_kucoin:.0f}, C_CVD_Agg={cvd_conf_agg:.0f}, RSI={rsi:.1f}"); 
-                 return True
+            
+            # (الشرط 0: يجب أن تتوفر بيانات 1-دقيقة)
+            if ema_9_1m is None or ema_21_1m is None:
+                return False
+                
+            # (الشرط 1: زخم الصفقات - CVD)
+            cvd_check = (cvd_kucoin > 0)
+            
+            # (الشرط 2: زخم دفتر الطلبات - OB Depth)
+            ob_check = (bids_depth > asks_depth)
+            
+            # (الشرط 3: زخم الاتجاه - 1m EMAs)
+            ema_check = (ema_9_1m > ema_21_1m)
+
+            if cvd_check and ob_check and ema_check:
+                print(f"   [Trigger] {symbol} (Momentum): CVD+, OB+, 1m_EMA+. الدخول!")
+                return True
+            # (إذا فشل، لا نطبع شيئاً لتقليل التشويش)
                  
         elif strategy_hint == 'mean_reversion':
-            if (rsi < 35): 
-                print(f"   [Trigger] {symbol} Reversion: RSI={rsi:.1f}, K_CVD={cvd_kucoin:.0f} (CVD check ignored)")
-                return True
+            # (لم نطور منطق 1-دقيقة للانعكاس بعد، نستخدم المنطق القديم)
+            # (ملاحظة: مؤشر rsi_1m_approx لم يعد موجوداً، لذا هذا الزناد معطل مؤقتاً)
+            # rsi = data.get('rsi_1m_approx', 50) # (محذوف)
+            # if (rsi < 35): 
+            #     print(f"   [Trigger] {symbol} Reversion: RSI={rsi:.1f}")
+            #     return True
+            pass # (يبقى معطلاً حتى نضيف مؤشرات انعكاس 1-دقيقة)
                 
         elif strategy_hint == 'volume_spike':
              if (large_trades > 0): 
-                 print(f"   [Trigger] {symbol} Volume Spike: LargeTrades={large_trades}, K_CVD={cvd_kucoin:.0f} (CVD check ignored)")
+                 print(f"   [Trigger] {symbol} Volume Spike: LargeTrades={large_trades}")
                  return True
                  
         return False
+    # 🔴 --- END OF CHANGE --- 🔴
 
-    # 🔴 --- START OF CHANGE (V6.6 - TP FIX) --- 🔴
     def _check_exit_trigger(self, trade: Dict, data: Dict, tactical_data: TacticalData) -> str:
         """(محدث V6.6) يراقب وقف الخسارة وجني الأرباح باستخدام (Bid) و (Last Trade Price)"""
         
@@ -470,44 +552,34 @@ class TradeManager:
         hard_stop = trade.get('stop_loss')
         take_profit = trade.get('take_profit')
         
-        # --- 1. جلب الأسعار المتاحة ---
-        
-        # السعر 1: أفضل سعر شراء (Bid) - (الأكثر أماناً لوقف الخسارة)
         best_bid_price = None
         if tactical_data.order_book and tactical_data.order_book.get('bids') and len(tactical_data.order_book['bids']) > 0:
             best_bid_price = tactical_data.order_book['bids'][0][0]
 
-        # السعر 2: آخر سعر تداول (Last Trade) - (الأكثر دقة لجني الأرباح)
         last_trade_price = None
-        if tactical_data.trades: # (trades هو deque)
+        if tactical_data.trades:
             try:
                 last_trade_price = tactical_data.trades[-1].get('price')
             except (IndexError, AttributeError):
-                pass # (يبقى None إذا كان deque فارغاً)
+                pass 
 
-        # (يجب أن يكون لدينا سعر واحد على الأقل للمتابعة)
         if best_bid_price is None and last_trade_price is None:
-            return None # لا يمكن تحديد السعر، انتظر الدورة التالية
+            return None 
 
-        # (استخدم bid إذا فشل last_trade، أو العكس)
         current_price_for_sl = best_bid_price if best_bid_price is not None else last_trade_price
         
-        # (استخدم السعر الأعلى بينهما لجني الأرباح)
         current_price_for_tp = max(
             filter(None, [best_bid_price, last_trade_price]), 
             default=None
         )
 
-        # --- 2. التحقق من وقف الخسارة الاستراتيجي (يستخدم سعر Bid الآمن) ---
         if hard_stop and current_price_for_sl and current_price_for_sl <= hard_stop: 
             return f"Strategic Stop Loss hit: {current_price_for_sl} <= {hard_stop}"
         
-        # --- 3. التحقق من جني الأرباح الاستراتيجي (يستخدم السعر الأعلى المتاح) ---
         if take_profit and current_price_for_tp and current_price_for_tp >= take_profit: 
             return f"Strategic Take Profit hit: {current_price_for_tp} >= {take_profit}"
         
-        return None # لا يوجد سبب للخروج
-    # 🔴 --- END OF CHANGE --- 🔴
+        return None 
 
 
     async def _execute_smart_entry(self, symbol: str, strategy_hint: str, tactical_data: Dict, explorer_context: Dict):
@@ -557,7 +629,6 @@ class TradeManager:
             exit_profile = llm_decision.get('exit_profile', 'ATR_TRAILING')
             exit_parameters = llm_decision.get('exit_parameters', {})
 
-            # (V6.5 - فحص السلامة)
             if not (stop_loss_price and take_profit_price):
                 print(f"❌ [Executor] {symbol}: بيانات SL/TP غير صالحة من النموذج. تم الإلغاء.")
                 return
@@ -663,7 +734,6 @@ class TradeManager:
             raise
 
     async def close_trade(self, trade_to_close, close_price, reason="System Close"):
-        """(لا تغيير جوهري) - لا يزال مسؤولاً عن حساب PnL وتحديث R2 وتشغيل LearningHub"""
         try:
             symbol = trade_to_close.get('symbol'); trade_to_close['status'] = 'CLOSED'
             trade_to_close['close_price'] = close_price; trade_to_close['close_timestamp'] = datetime.now().isoformat()
@@ -698,7 +768,6 @@ class TradeManager:
         except Exception as e: print(f"❌ [Executor] فشل فادح أثناء إغلاق الصفقة (الوهمية) {symbol}: {e}"); traceback.print_exc(); raise
 
     async def immediate_close_trade(self, symbol, close_price, reason="Immediate Close"):
-        """(معدل) - للإغلاق الفوري بناءً على زناد Sentry"""
         if not self.r2_service.acquire_lock(): print(f"⚠️ [Executor] فشل في الحصول على قفل R2 لـ {symbol} (Immediate Close)"); return False
         try:
             open_trades = await self.r2_service.get_open_trades_async()
@@ -711,7 +780,6 @@ class TradeManager:
             if self.r2_service.lock_acquired: self.r2_service.release_lock()
 
     async def update_trade_strategy(self, trade_to_update, re_analysis_decision):
-        """(يستدعى من المستكشف) لتحديث الأهداف الاستراتيجية فقط"""
         try:
             symbol = trade_to_update.get('symbol')
             if re_analysis_decision.get('action') == "UPDATE_TRADE":
@@ -771,4 +839,4 @@ class TradeManager:
         except Exception as e: print(f"❌ Failed to get trade by symbol {symbol}: {e}"); return None
 
 
-print(f"✅ Trade Manager loaded - V6.6 (Fixed TP Execution Logic) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")
+print(f"✅ Trade Manager loaded - V6.7 (1M Indicator & OB Trigger) (ccxt.async_support: {CCXT_ASYNC_AVAILABLE})")