Update sentiment_news.py

sentiment_news.py

@@ -1,10 +1,11 @@
-# sentiment_news.py (محدث V3.2 - توسيع نافذة البحث إلى 12 ساعة)
+# sentiment_news.py (محدث V3.3 - Fix API Name & Return Type)
 import os, asyncio
 import httpx
 from gnews import GNews
 import feedparser
 from datetime import datetime, timedelta, timezone
 import time
+from typing import Dict, Any
 
 # 
 # 🔴 تم التعديل: توسيع قائمة مصادر RSS لتشمل تغطية أوسع للعملات البديلة
@@ -33,10 +34,8 @@ class NewsFetcher:
                 'Cache-Control': 'no-cache'
             }
         )
-        # 🔴 --- START OF CHANGE (V3.2) --- 🔴
-        # (توسيع نافذة البحث إلى 12 ساعة وزيادة النتائج)
+        # 🔴 (توسيع نافذة البحث إلى 12 ساعة وزيادة النتائج)
         self.gnews = GNews(language='en', country='US', period='12h', max_results=15)
-        # 🔴 --- END OF CHANGE --- 🔴
         
         self.rss_cache = {}
         self.cache_lock = asyncio.Lock()
@@ -69,7 +68,6 @@ class NewsFetcher:
 
     async def _get_cached_rss_feed(self, feed_url: str, source_name: str):
         """
-        (جديد V3.1)
         دالة مساعدة لجلب ملف RSS مع تخزين مؤقت (لمدة 5 دقائق).
         هذا يمنع خطأ 429 عند طلب نفس المصدر لعدة عملات.
         """
@@ -80,11 +78,9 @@ class NewsFetcher:
             if feed_url in self.rss_cache:
                 cached_data, cache_time = self.rss_cache[feed_url]
                 if (current_time - cache_time) < self.cache_duration:
-                    # print(f"   [NewsCache] Using cached data for {source_name}")
-                    return cached_data # (إرجاع البيانات المخزنة)
+                    return cached_data 
 
             # 2. (إذا لم يكن في الذاكرة أو كان قديماً) الجلب من المصدر
-            # print(f"   [NewsCache] Fetching fresh data for {source_name}...")
             max_redirects = 2
             current_url = feed_url
             response_text = None
@@ -101,10 +97,8 @@ class NewsFetcher:
                             current_url = e.response.headers['Location']
                             continue
                         else:
-                            # (التعامل مع 429 هنا أيضاً، لا تخزن الخطأ)
                             if e.response.status_code == 429:
                                 print(f"   ⚠️ [NewsCache] Rate limited (429) by {source_name}. Skipping for this cycle.")
-                                # (سنخزن "فارغ" لمنع إعادة المحاولة الفورية)
                                 self.rss_cache[feed_url] = ([], current_time) 
                                 return []
                             raise
@@ -121,7 +115,6 @@ class NewsFetcher:
 
             except Exception as e:
                 print(f"   ❌ [NewsCache] Failed to fetch/parse {source_name}: {e}")
-                # (لا تخزن الخطأ، للسماح بإعادة المحاولة في الدورة القادمة)
                 if feed_url in self.rss_cache:
                     del self.rss_cache[feed_url] 
                 return []
@@ -131,7 +124,6 @@ class NewsFetcher:
         try:
             base_symbol = symbol.split('/')[0]
             
-            # (الجلب من الذاكرة المؤقتة أو المصدر)
             feed_entries = await self._get_cached_rss_feed(feed_url, source_name)
             if not feed_entries:
                 return []
@@ -139,36 +131,27 @@ class NewsFetcher:
             news_items = []
             search_term = base_symbol.lower()
             
-            # 🔴 --- START OF CHANGE (V3.2) --- 🔴
-            # (حساب الوقت قبل 12 ساعة (باستخدام التوقيت العالمي UTC))
             twelve_hours_ago = datetime.now(timezone.utc) - timedelta(hours=12)
-            # 🔴 --- END OF CHANGE --- 🔴
 
             for entry in feed_entries:
                 title = entry.title.lower() if hasattr(entry, 'title') else ''
                 summary = entry.summary.lower() if hasattr(entry, 'summary') else entry.description.lower() if hasattr(entry, 'description') else ''
                 
-                # التحقق من تاريخ النشر
                 published_tuple = entry.get('published_parsed')
                 if not published_tuple:
-                    continue # تخطي الخبر إذا لم يكن له تاريخ نشر
+                    continue 
                 
-                # تحويل تاريخ النشر إلى كائن datetime مع دعم التوقيت العالمي (UTC)
                 try:
                     published_time = datetime.fromtimestamp(time.mktime(published_tuple), timezone.utc)
                 except Exception:
-                    # في حال فشل التحويل، نفترض أنه قديم
                     continue
 
-                # 🔴 --- START OF CHANGE (V3.2) --- 🔴
-                # (تطبيق الفلتر الزمني (آخر 12 ساعة) وفلتر اسم العملة)
                 if (search_term in title or search_term in summary) and (published_time >= twelve_hours_ago):
-                # 🔴 --- END OF CHANGE --- 🔴
                     news_items.append({
                         'title': entry.title, 
                         'description': summary, 
                         'source': source_name,
-                        'published': published_time.isoformat() # إرسال التاريخ بتنسيق ISO
+                        'published': published_time.isoformat() 
                     })
                     
             return news_items
@@ -176,7 +159,14 @@ class NewsFetcher:
             print(f"Failed to fetch specific news from {source_name} RSS for {symbol}: {e}")
             return []
             
-    async def get_news_for_symbol(self, symbol: str) -> str:
+    # [ 🚀 🚀 🚀 ]
+    # [ 💡 💡 💡 ]  تم التعديل: تغيير الاسم إلى get_news وإرجاع قاموس
+    # [ 🚀 🚀 🚀 ]
+    async def get_news(self, symbol: str) -> Dict[str, Any]:
+        """
+        جلب الأخبار المجمعة لعملة محددة.
+        الإرجاع: قاموس يحتوي على 'summary' (نص) ليناسب app.py.
+        """
         base_symbol = symbol.split("/")[0]
         
         # إنشاء قائمة المهام (GNews + جميع مصادر RSS)
@@ -192,33 +182,30 @@ class NewsFetcher:
                 continue
                 
             for item in result:
-                # نستخدم الفلتر الثانوي للتأكد من أن الخبر يركز فعلاً على العملة
                 if self._is_directly_relevant_to_symbol(item, base_symbol):
                     title = item.get('title', 'No Title')
                     description = item.get('description', 'No Description')
                     source = item.get('source', 'Unknown Source')
-                    published = item.get('published', '') # الحصول على التاريخ/الوقت
+                    published = item.get('published', '') 
                     
                     news_entry = f"[{source}] {title}. {description}"
-                    
                     if published:
                         news_entry += f" (Published: {published})"
                     
                     all_news_text.append(news_entry)
         
         if not all_news_text: 
-            # 🔴 --- START OF CHANGE (V3.2) --- 🔴
-            return f"No specific news found for {base_symbol} in the last 12 hours."
-            # 🔴 --- END OF CHANGE --- 🔴
+            return {'summary': f"No specific news found for {base_symbol} in the last 12 hours."}
         
-        # أخذ أهم 5 أخبار (الأكثر حداثة أو صلة)
+        # أخذ أهم 5 أخبار
         important_news = all_news_text[:5]
-        return " | ".join(important_news)
+        
+        # [ 🚀 ] إرجاع قاموس كما يتوقع app.py
+        return {'summary': " | ".join(important_news)}
 
     def _is_directly_relevant_to_symbol(self, news_item, base_symbol):
         """
-        فلتر ثانوي للتأكد من أن الخبر ليس مجرد ذكر عابر للعملة،
-        بل يتعلق فعلاً بجوانب التداول أو السوق.
+        فلتر ثانوي للتأكد من أن الخبر ليس مجرد ذكر عابر للعملة.
         """
         title = news_item.get('title', '').lower()
         description = news_item.get('description', '').lower()
@@ -228,7 +215,6 @@ class NewsFetcher:
         if symbol_lower not in title and symbol_lower not in description:
             return False
         
-        # يجب أن يحتوي الخبر على كلمات مفتاحية تدل على أنه خبر مالي/تداولي
         crypto_keywords = [
             'crypto', 'cryptocurrency', 'token', 'blockchain', 
             'price', 'market', 'trading', 'exchange', 'defi',
@@ -245,11 +231,7 @@ class SentimentAnalyzer:
         self.data_manager = data_manager
 
     async def get_market_sentiment(self):
-        """
-        جلب سياق السوق العام (يعتمد بالكامل على DataManager).
-        """
         try:
-            # هذه الدالة تجلب (BTC/ETH/Fear&Greed) فقط
             market_context = await self.data_manager.get_market_context_async()
             if not market_context:
                 return await self.get_fallback_market_context()
@@ -259,9 +241,6 @@ class SentimentAnalyzer:
             return await self.get_fallback_market_context()
 
     async def get_fallback_market_context(self):
-        """
-        (محدث) سياق احتياطي مبسط يعكس الواقع (بدون بيانات حيتان عامة).
-        """
         return {
             'timestamp': datetime.now().isoformat(),
             'btc_sentiment': 'NEUTRAL',
@@ -271,6 +250,4 @@ class SentimentAnalyzer:
             'data_quality': 'LOW'
         }
 
-# 🔴 --- START OF CHANGE (V3.2) --- 🔴
-print("✅ Sentiment News loaded - V3.2 (Expanded 12h Window)")
-# 🔴 --- END OF CHANGE --- 🔴
+print("✅ Sentiment News loaded - V3.3 (Fixed API Mismatch)")