Update app.py

app.py

@@ -45,7 +45,19 @@ def load_memory():
             return "".join(f.readlines()[-20:])
     return "Core memory empty."
 
-# 📡 HYBRID WEB SEARCH (RSS + DDG)
+# 📚 WIKIPEDIA INTELLIGENCE NODE
+def get_wikipedia_intel(query):
+    """Wikipedia API එකෙන් සාරාංශයක් ලබා ගැනීම"""
+    try:
+        wiki_url = f"https://en.wikipedia.org/api/rest_v1/page/summary/{urllib.parse.quote(query)}"
+        res = requests.get(wiki_url, timeout=5)
+        if res.status_code == 200:
+            data = res.json()
+            return f"📚 WIKIPEDIA: {data.get('title')}\n📝 {data.get('extract')}\n🔗 {data.get('content_urls', {}).get('desktop', {}).get('page')}"
+    except: pass
+    return None
+
+# 📡 HYBRID WEB SEARCH (RSS + WIKI + DDG)
 def detect_intel_category(q):
     ql = q.lower()
     if any(w in ql for w in ['exploit', 'cve', 'vulnerability', 'payload']): return 'exploits'
@@ -55,20 +67,23 @@ def detect_intel_category(q):
     return 'world'
 
 def get_hybrid_intel(query):
-    """RSS feeds පරීක්ෂා කර පසුව Web Search වෙත යයි"""
     category = detect_intel_category(query)
     intel_output = []
 
-    # 1. RSS Retrieval (වඩාත් ස්ථාවරයි)
+    # 1. Wikipedia Search (High-Level Fact Checking)
+    wiki_data = get_wikipedia_intel(query)
+    if wiki_data: intel_output.append(wiki_data)
+
+    # 2. RSS Retrieval
     for feed_url in RSS_SOURCES.get(category, RSS_SOURCES['world']):
         try:
             feed = feedparser.parse(feed_url)
-            for entry in feed.entries[:3]:
+            for entry in feed.entries[:2]:
                 snippet = re.sub('<[^>]+>', '', entry.get('summary', ''))[:200]
                 intel_output.append(f"📡 RSS: {entry.title}\n📝 {snippet}\n🔗 {entry.link}")
         except: continue
 
-    # 2. DuckDuckGo Fallback (RSS වල දත්ත මදි නම්)
+    # 3. DuckDuckGo Fallback
     if len(intel_output) < 2:
         try:
             from duckduckgo_search import DDGS
@@ -102,7 +117,6 @@ def chat():
         sl_tz = pytz.timezone('Asia/Colombo')
         now = datetime.now(sl_tz)
         
-        # Self-Learning
         if "remember" in user_msg.lower() or "මතක තබාගන්න" in user_msg:
             sync_intel(user_msg)
             mem_tag = " [SYNCED]"
@@ -111,11 +125,10 @@ def chat():
         current_memory = load_memory()
         img_url = upload_to_imgbb(img_b64) if img_b64 else None
 
-        # 🔱 Sovereign Engines
         if img_url:
             selected_model = "google/gemma-4-31b-it:free"
             active_tier = "VISION-NODE"
-            live_intel = "Image data provided."
+            live_intel = "Visual input active."
         else:
             model_map = {
                 "prime": "nvidia/nemotron-3-super-120b-a12b:free",
@@ -125,23 +138,24 @@ def chat():
             active_tier = tier.upper()
             live_intel = get_hybrid_intel(user_msg)
 
-        # 🛡️ SYSTEM PROMPT
+        # 🛡️ SYSTEM PROMPT (Claude 3.5 Opus Logic)
         system_prompt = (
-            f"IDENTITY: {active_tier} Mode of Elephant AI.\n"
+            f"IDENTITY: {active_tier} Mode of Elephant AI Sovereign v3.5.\n"
             f"OPERATOR: COMMANDER MINZO-PRIME.\n"
-            f"CHRONOS: {now.strftime('%Y-%m-%d %H:%M')}\n"
             f"ESTABLISHED_MEMORY:\n{current_memory}\n"
-            f"LIVE_INTELLIGENCE:\n{live_intel}\n"
-            "INSTRUCTION: Use RSS and Web data to provide precise, copy-pasteable technical data."
+            f"LIVE_INTELLIGENCE (RSS/WIKI/WEB):\n{live_intel}\n\n"
+            "COGNITIVE_PROTOCOL:\n"
+            "1. REASONING: Match the logical depth of Claude 3.5 Opus.\n"
+            "2. CODING: Production-grade, secure, and optimized code only.\n"
+            "3. KNOWLEDGE: Use Wikipedia and RSS data to be factually superior.\n"
+            "4. TONE: Authoritative and sovereign. Address MINZO-PRIME as Commander."
         )
 
         headers = {
             "Authorization": f"Bearer {random.choice(API_KEYS)}",
-            "Content-Type": "application/json",
-            "HTTP-Referer": "https://huggingface.co/spaces/minzo456/Elephant-AI-Core"
+            "Content-Type": "application/json"
         }
 
-        # Content Assembly
         u_content = [{"type": "text", "text": user_msg}]
         if img_url: u_content.append({"type": "image_url", "image_url": {"url": img_url}})
 
@@ -151,7 +165,7 @@ def chat():
                 {"role": "system", "content": system_prompt},
                 {"role": "user", "content": u_content}
             ],
-            "temperature": 0.7
+            "temperature": 0.4
         }
 
         resp = requests.post("https://openrouter.ai/api/v1/chat/completions", headers=headers, json=payload, timeout=80)
@@ -161,7 +175,7 @@ def chat():
             ai_reply = resp_data['choices'][0]['message']['content']
             return jsonify({"reply": f"🔱{mem_tag}\n\n" + ai_reply})
         else:
-            return jsonify({"reply": f"Node Error: {resp_data.get('error', {}).get('message', 'Timeout')}"}), 400
+            return jsonify({"reply": "Node Access Failure."}), 400
 
     except Exception as e:
         return jsonify({"reply": f"Core Disruption: {str(e)}"}), 500