Update sentiment_news.py

sentiment_news.py

@@ -2,14 +2,23 @@ import os, asyncio
 import httpx
 from gnews import GNews
 import feedparser
-from datetime import datetime
+from datetime import datetime, timedelta, timezone
+import time
 
+# 
+# 🔴 تم التعديل: توسيع قائمة مصادر RSS لتشمل تغطية أوسع للعملات البديلة
+#
 CRYPTO_RSS_FEEDS = {
     "Cointelegraph": "https://cointelegraph.com/rss",
     "CoinDesk": "https://www.coindesk.com/arc/outboundfeeds/rss/",
     "CryptoSlate": "https://cryptoslate.com/feed/",
     "NewsBTC": "https://www.newsbtc.com/feed/",
-    "Bitcoin.com": "https://news.bitcoin.com/feed/"
+    "Bitcoin.com": "https://news.bitcoin.com/feed/",
+    "The Block": "https://www.theblock.co/rss.xml",
+    "Decrypt": "https://decrypt.co/feed",
+    "AMBCrypto": "https://ambcrypto.com/feed/",
+    "CryptoPotato": "https://cryptopotato.com/feed/",
+    "U.Today": "https://u.today/rss"
 }
 
 class NewsFetcher:
@@ -23,14 +32,33 @@ class NewsFetcher:
                 'Cache-Control': 'no-cache'
             }
         )
+        # GNews مفلترة مسبقاً لـ 3 ساعات
         self.gnews = GNews(language='en', country='US', period='3h', max_results=8)
 
     async def _fetch_from_gnews(self, symbol: str) -> list:
         try:
             base_symbol = symbol.split("/")[0]
+            # نستخدم الكلمات المفتاحية السلبية لمحاولة عزل أخبار العملة نفسها
             query = f'"{base_symbol}" cryptocurrency -bitcoin -ethereum -BTC -ETH'
+            
+            # GNews تعمل بشكل متزامن، لذا نستخدم to_thread
             news_items = await asyncio.to_thread(self.gnews.get_news, query)
-            return news_items
+            
+            # 
+            # 🔴 تم التعديل: توحيد تنسيق الإخراج ليتضمن مفتاح 'published'
+            #
+            formatted_items = []
+            for item in news_items:
+                # GNews توفر تاريخ النشر كنص (وهو مفلتر مسبقاً لـ 3 ساعات)
+                published_text = item.get('published date', 'Recent')
+                formatted_items.append({
+                    'title': item.get('title', 'No Title'),
+                    'description': item.get('description', 'No Description'),
+                    'source': item.get('source', {}).get('title', 'GNews'),
+                    'published': published_text # تمرير التاريخ/الوقت
+                })
+            return formatted_items
+            
         except Exception as e:
             print(f"Failed to fetch specific news from GNews for {symbol}: {e}")
             return []
@@ -40,6 +68,8 @@ class NewsFetcher:
             base_symbol = symbol.split('/')[0]
             max_redirects = 2
             current_url = feed_url
+            
+            # منطق معالجة إعادة التوجيه
             for attempt in range(max_redirects):
                 try:
                     response = await self.http_client.get(current_url)
@@ -56,16 +86,41 @@ class NewsFetcher:
             news_items = []
             search_term = base_symbol.lower()
             
-            for entry in feed.entries[:15]:
+            # 
+            # 🔴 تم التعديل: حساب الوقت قبل 3 ساعات (باستخدام التوقيت العالمي UTC)
+            #
+            three_hours_ago = datetime.now(timezone.utc) - timedelta(hours=3)
+
+            # 
+            # 🔴 تم التعديل: إزالة قيد '[:15]' والفلترة حسب الوقت
+            #
+            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 ''
-                if search_term in title or search_term in summary:
+                
+                # التحقق من تاريخ النشر
+                published_tuple = entry.get('published_parsed')
+                if not published_tuple:
+                    continue # تخطي الخبر إذا لم يكن له تاريخ نشر
+                
+                # تحويل تاريخ النشر إلى كائن datetime مع دعم التوقيت العالمي (UTC)
+                try:
+                    published_time = datetime.fromtimestamp(time.mktime(published_tuple), timezone.utc)
+                except Exception:
+                    # في حال فشل التحويل، نفترض أنه قديم
+                    continue
+
+                # 
+                # 🔴 تم التعديل: تطبيق الفلتر الزمني (آخر 3 ساعات) وفلتر اسم العملة
+                #
+                if (search_term in title or search_term in summary) and (published_time >= three_hours_ago):
                     news_items.append({
                         'title': entry.title, 
                         'description': summary, 
                         'source': source_name,
-                        'published': entry.get('published', '')
+                        'published': published_time.isoformat() # إرسال التاريخ بتنسيق ISO
                     })
+                    
             return news_items
         except Exception as e:
             print(f"Failed to fetch specific news from {source_name} RSS for {symbol}: {e}")
@@ -73,6 +128,8 @@ class NewsFetcher:
             
     async def get_news_for_symbol(self, symbol: str) -> str:
         base_symbol = symbol.split("/")[0]
+        
+        # إنشاء قائمة المهام (GNews + جميع مصادر RSS)
         tasks = [self._fetch_from_gnews(symbol)]
         for name, url in CRYPTO_RSS_FEEDS.items():
             tasks.append(self._fetch_from_rss_feed(url, name, symbol))
@@ -83,14 +140,24 @@ class NewsFetcher:
         for result in results:
             if isinstance(result, Exception):
                 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})"
                     
@@ -99,25 +166,36 @@ class NewsFetcher:
         if not all_news_text: 
             return f"No specific news found for {base_symbol} in the last 3 hours."
         
+        # أخذ أهم 5 أخبار (الأكثر حداثة أو صلة)
         important_news = all_news_text[:5]
         return " | ".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()
         symbol_lower = base_symbol.lower()
         
+        # يجب أن يكون الرمز موجوداً في العنوان أو الوصف
         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',
-            'coin', 'digital currency', 'altcoin'
+            'coin', 'digital currency', 'altcoin', 'airdrop', 'listing',
+            'partnership', 'update', 'mainnet', 'protocol'
         ]
         
         return any(keyword in title or keyword in description for keyword in crypto_keywords)
 
+# --- (باقي الملف: SentimentAnalyzer و format_whale_analysis) ---
+# --- (لم يتم المساس بهذه الأجزاء لأنها خارج نطاق الطلب) ---
+
 class SentimentAnalyzer:
     def __init__(self, data_manager):
         self.data_manager = data_manager