Update ml_engine/indicators.py

ml_engine/indicators.py

@@ -1,4 +1,4 @@
-# ml_engine/indicators.py (V5.1 - Fixed VWAP DatetimeIndex Error)
+# ml_engine/indicators.py (V5.2 - Fixed 'volume' not defined bug)
 import pandas as pd
 import pandas_ta as ta
 import numpy as np
@@ -71,7 +71,7 @@ class AdvancedTechnicalAnalyzer:
                         if base_line is not None and not base_line.empty and not pd.isna(base_line.iloc[-1]): 
                             trend['ichimoku_base'] = float(base_line.iloc[-1])
                 except Exception as ichimoku_error:
-                    pass # (تقليل التشويش)
+                    pass 
             
             if len(dataframe) >= 14:
                 try:
@@ -81,7 +81,7 @@ class AdvancedTechnicalAnalyzer:
                         if adx_value is not None and not adx_value.empty and not pd.isna(adx_value.iloc[-1]): 
                             trend['adx'] = float(adx_value.iloc[-1])
                 except Exception as adx_error:
-                    pass # (تقليل التشويش)
+                    pass 
         
         except Exception as e:
             print(f"⚠️ خطأ في حساب مؤشرات الاتجاه: {e}")
@@ -163,9 +163,11 @@ class AdvancedTechnicalAnalyzer:
         except Exception as e:
             print(f"⚠️ خطأ في حساب مؤشرات التقلب: {e}")
         
-        return {key: value for key, value in volume.items() if value is not None and not np.isnan(value)}
+        # 🔴 --- START OF CHANGE (V5.2 - FIX) --- 🔴
+        # (إصلاح: إعادة 'volatility' بدلاً من 'volume')
+        return {key: value for key, value in volatility.items() if value is not None and not np.isnan(value)}
+        # 🔴 --- END OF CHANGE --- 🔴
     
-    # 🔴 --- START OF CHANGE (V5.1 - VWAP FIX) --- 🔴
     def _calculate_volume_indicators(self, dataframe, timeframe):
         """حساب مؤشرات الحجم"""
         volume = {}
@@ -178,19 +180,15 @@ class AdvancedTechnicalAnalyzer:
                 try:
                     df_vwap = dataframe.copy()
                     
-                    # (التحقق من الفهرس وترتيبه - كما كان)
                     if not isinstance(df_vwap.index, pd.DatetimeIndex):
                         if 'timestamp' in df_vwap.columns:
                             df_vwap['timestamp'] = pd.to_datetime(df_vwap['timestamp'], unit='ms')
                             df_vwap.set_index('timestamp', inplace=True)
                         else:
-                             # (إذا لم يكن هناك فهرس زمني ولا عمود، لا يمكن المتابعة)
                              raise ValueError("DataFrame needs 'timestamp' column or DatetimeIndex")
                     
                     df_vwap.sort_index(inplace=True)
                     
-                    # (الإصلاح: إعادة تعيين الفهرس لتمرير أعمدة Series بسيطة إلى ta.vwap)
-                    # (هذا يتجنب مشاكل مكتبة pandas_ta مع الفهرس الزمني)
                     df_vwap_reset = df_vwap.reset_index()
                     
                     volume_weighted_average_price = ta.vwap(
@@ -200,16 +198,13 @@ class AdvancedTechnicalAnalyzer:
                         volume=df_vwap_reset['volume']
                     )
                     
-                    # (استخدام القيمة الأخيرة من السلسلة الناتجة)
                     if volume_weighted_average_price is not None and not volume_weighted_average_price.empty and not pd.isna(volume_weighted_average_price.iloc[-1]): 
                         volume['vwap'] = float(volume_weighted_average_price.iloc[-1])
                         
                 except Exception as vwap_error:
-                    # (تقليل التشويش: طباعة فقط إذا كان الخطأ جوهرياً)
                     if "Index" not in str(vwap_error):
                         print(f"⚠️ خطأ في حساب VWAP لـ {timeframe}: {vwap_error}")
                     
-                    # (الكود الاحتياطي يبقى كما هو)
                     if len(dataframe) >= 20:
                         try:
                             typical_price = (dataframe['high'] + dataframe['low'] + dataframe['close']) / 3
@@ -219,7 +214,6 @@ class AdvancedTechnicalAnalyzer:
                         except Exception as simple_vwap_error:
                             pass
             
-            # (باقي مؤشرات الحجم - لا تغيير)
             try:
                 on_balance_volume = ta.obv(dataframe['close'], dataframe['volume'])
                 if on_balance_volume is not None and not on_balance_volume.empty and not pd.isna(on_balance_volume.iloc[-1]): 
@@ -250,7 +244,6 @@ class AdvancedTechnicalAnalyzer:
             print(f"⚠️ خطأ في حساب مؤشرات الحجم: {e}")
         
         return {key: value for key, value in volume.items() if value is not None and not np.isnan(value)}
-    # 🔴 --- END OF CHANGE (V5.1 - VWAP FIX) --- ��
     
     def _calculate_cycle_indicators(self, dataframe):
         """حساب مؤشرات الدورة"""
@@ -277,4 +270,4 @@ class AdvancedTechnicalAnalyzer:
         
         return {key: value for key, value in cycle.items() if value is not None and not np.isnan(value)}
 
-print("✅ ML Module: Technical Indicators loaded (V5.1 - VWAP Fix)")
+print("✅ ML Module: Technical Indicators loaded (V5.2 - 'volume' not defined Fix)")