Update app.py

app.py

@@ -5,7 +5,7 @@ from flask_cors import CORS
 app = Flask(__name__)
 CORS(app)
 
-# 🔱 ඔබ ලබා දුන් API Keys
+# 🔱 AUTHORIZED API KEYS
 API_KEYS = [
     "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",
     "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",
@@ -14,39 +14,73 @@ API_KEYS = [
     "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"
 ]
 
+def fetch_web_intel(query):
+    """අන්තර්ජාලයෙන් නවතම තොරතුරු ලබා ගැනීම (RSS Intelligence)"""
+    intel = ""
+    try:
+        # Google News RSS හරහා සෙවීම
+        search_url = f'https://news.google.com/rss/search?q={query}&hl=en-US'
+        feed = feedparser.parse(search_url)
+        # මුල් ලිපි 3ක තොරතුරු එකතු කිරීම
+        for entry in feed.entries[:3]:
+            intel += f"\n- Title: {entry.title} (Source: {entry.source.text if 'source' in entry else 'Web'})"
+    except Exception as e:
+        print(f"Web Intel Error: {e}")
+    return intel
+
 @app.route('/api/chat', methods=['POST'])
 def chat():
     try:
         data = request.json
         user_msg = data.get("message", "")
         
+        # 1. 🔱 WEB SEARCH EXECUTION
+        # පද්ධතිය බුද්ධිමත් ලෙස සෙවුම් වාරයක් ක්‍රියාත්මක කරයි
+        web_context = fetch_web_intel(user_msg)
+        
         headers = {
             "Authorization": f"Bearer {random.choice(API_KEYS)}",
-            "Content-Type": "application/json"
+            "Content-Type": "application/json",
+            "HTTP-Referer": "https://huggingface.co/spaces/minzo456/Elephant-AI-Core",
+            "X-Title": "Elephant AI Core"
         }
         
+        # 2. 🔱 INTEGRATING INTEL INTO SYSTEM PROMPT
+        system_prompt = f"""You are Elephant AI, an advanced intelligence created by MINZO-PRIME. 
+        You have access to real-time web information. 
+        If relevant, use this fresh data to answer: {web_context}
+        Always prioritize accuracy and be professional."""
+
         payload = {
             "model": "minimax/minimax-m2.5:free",
             "messages": [
-                {"role": "system", "content": "You are Elephant AI created by MINZO-PRIME. Be helpful and professional."},
+                {"role": "system", "content": system_prompt},
                 {"role": "user", "content": user_msg}
             ],
-            "stream": False # 🔱 ස්ථාවරත්වය සඳහා Streaming අක්‍රීය කළා
+            "stream": False
         }
 
-        resp = requests.post("https://openrouter.ai/api/v1/chat/completions", headers=headers, json=payload)
+        resp = requests.post(
+            "https://openrouter.ai/api/v1/chat/completions", 
+            headers=headers, 
+            json=payload,
+            timeout=45
+        )
+        
         res_data = resp.json()
         
-        # පිළිතුර ලබා ගැනීම
-        ai_reply = res_data['choices'][0]['message']['content']
-        return jsonify({"reply": ai_reply})
+        if 'choices' in res_data:
+            ai_reply = res_data['choices'][0]['message']['content']
+            return jsonify({"reply": ai_reply})
+        else:
+            return jsonify({"reply": "Core Error: Failed to retrieve intelligence from OpenRouter."}), 500
 
     except Exception as e:
-        return jsonify({"reply": f"Core Error: {str(e)}"}), 500
+        return jsonify({"reply": f"Internal System Error: {str(e)}"}), 500
 
 @app.route('/')
 def health():
-    return "🐘 Elephant AI Core: ONLINE"
+    return "🐘 Elephant AI Core: ONLINE | WEB INTEL: ACTIVE"
 
 if __name__ == "__main__":
     app.run(host='0.0.0.0', port=7860)