Update helpers.py

helpers.py

@@ -1,4 +1,4 @@
-import re
+import os, re
 from datetime import datetime
 
 def safe_float_conversion(value, default=0.0):
@@ -27,9 +27,58 @@ def _apply_patience_logic(decision, hold_minutes, trade_data, processed_data):
             profit_loss_percent = 0
         
         if profit_loss_percent < 2:
-            print(f"🛑 Blocked premature selling! Only {hold_minutes:.1f} minutes held, PnL: {profit_loss_percent:.2f}%")
+            print(f"Blocked premature selling! Only {hold_minutes:.1f} minutes held, PnL: {profit_loss_percent:.2f}%")
             decision['action'] = "HOLD"
             decision['reasoning'] = f"Patience Filter: Blocked premature sell. Held for {hold_minutes:.1f}m. Giving trade more time."
             return decision
     
-    return decision
+    return decision
+
+def parse_json_from_response(response_text: str):
+    """استخراج JSON من رد النموذج"""
+    try:
+        json_match = re.search(r'```json\n(.*?)\n```', response_text, re.DOTALL)
+        if json_match:
+            return json_match.group(1).strip()
+        
+        json_match = re.search(r'\{.*\}', response_text, re.DOTALL)
+        if json_match:
+            return json_match.group()
+        
+        return None
+    except Exception:
+        return None
+
+def validate_required_fields(data_dict: dict, required_fields: list) -> bool:
+    """التحقق من وجود الحقول المطلوبة"""
+    return all(field in data_dict for field in required_fields)
+
+def format_technical_indicators(advanced_indicators):
+    """تنسيق المؤشرات الفنية"""
+    if not advanced_indicators:
+        return "No data for advanced indicators."
+    
+    summary = []
+    for timeframe, indicators in advanced_indicators.items():
+        if indicators:
+            parts = []
+            if 'rsi' in indicators: parts.append(f"RSI: {indicators['rsi']:.2f}")
+            if 'macd_hist' in indicators: parts.append(f"MACD Hist: {indicators['macd_hist']:.4f}")
+            if 'volume_ratio' in indicators: parts.append(f"Volume: {indicators['volume_ratio']:.2f}x")
+            if parts:
+                summary.append(f"{timeframe}: {', '.join(parts)}")
+    
+    return "\n".join(summary) if summary else "Insufficient indicator data."
+
+def format_strategy_scores(strategy_scores, recommended_strategy):
+    """تنسيق نتائج الاستراتيجيات"""
+    if not strategy_scores:
+        return "No strategy data available."
+    
+    summary = [f"Recommended Strategy: {recommended_strategy}"]
+    sorted_scores = sorted(strategy_scores.items(), key=lambda item: item[1], reverse=True)
+    for strategy, score in sorted_scores:
+        score_display = f"{score:.3f}" if isinstance(score, (int, float)) else str(score)
+        summary.append(f"   • {strategy}: {score_display}")
+    
+    return "\n".join(summary)