Update app.py

app.py

@@ -1,12 +1,16 @@
-import os, random, requests, json, feedparser
-from flask import Flask, request, jsonify
+import os
+import random
+import requests
+import json
+from flask import Flask, request, jsonify, send_from_directory
 from flask_cors import CORS
 from datetime import datetime
+from duckduckgo_search import DDGS # 🔱 DuckDuckGo Search Engine
 
-app = Flask(__name__)
-CORS(app)
+app = Flask(__name__, static_folder='.')
+CORS(app, resources={r"/api/*": {"origins": "*"}}) # 🔱 External Hosting සදහා අවසර දීම
 
-# 🔱 AUTHORIZED API KEYS
+# AUTHORIZED API KEYS
 API_KEYS = [
     "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",
     "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",
@@ -15,16 +19,17 @@ API_KEYS = [
     "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"
 ]
 
-def fetch_web_intel(query):
-    """RSS Intelligence හරහා අන්තර්ජාලය පරීක්ෂා කිරීම"""
+def fetch_duckduckgo_intel(query):
+    """DuckDuckGo හරහා සජීවී වෙබ් තොරතුරු ලබා ගැනීම"""
     intel = ""
     try:
-        search_url = f'https://news.google.com/rss/search?q={query}&hl=en-US'
-        feed = feedparser.parse(search_url)
-        for entry in feed.entries[:3]:
-            intel += f"\n- Title: {entry.title}"
-    except:
-        pass
+        with DDGS() as ddgs:
+            results = [r for r in ddgs.text(query, max_results=4)]
+            for r in results:
+                intel += f"\n- {r['title']}: {r['body']}"
+    except Exception as e:
+        print(f"Search Error: {e}")
+        intel = "Web intelligence currently unavailable."
     return intel
 
 @app.route('/api/chat', methods=['POST'])
@@ -32,18 +37,20 @@ def chat():
     try:
         data = request.json
         user_msg = data.get("message", "")
-        tier = data.get("tier", "prime") # Prime or Nexus
+        tier = data.get("tier", "prime")
 
-        # 🔱 Sovereign Model Mapping
+        # Sovereign Model Mapping
         model_map = {
             "prime": "minimax/minimax-m2.5:free",
             "nexus": "thm/glm-4.5-air:free"
         }
         selected_model = model_map.get(tier, "minimax/minimax-m2.5:free")
 
-        # Get Real-time Context
+        # Get Real-time Metadata
         current_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-        web_context = fetch_web_intel(user_msg)
+        
+        # 🔱 අන්තර්ජාලය පරීක්ෂා කිරීම
+        web_context = fetch_duckduckgo_intel(user_msg)
 
         headers = {
             "Authorization": f"Bearer {random.choice(API_KEYS)}",
@@ -52,11 +59,14 @@ def chat():
             "X-Title": "Elephant AI Core"
         }
 
-        # System Instruction for Sovereign Identity
+        # System Instruction
         system_prompt = f"""You are {tier.upper()} mode of Elephant AI, a sovereign intelligence developed by MINZO-PRIME.
         Current Date and Time: {current_time}.
-        Web Intelligence Context: {web_context}
-        Always maintain your identity as Elephant AI and provide professional, accurate answers."""
+        Live Web Search Results (DuckDuckGo): 
+        {web_context}
+        
+        If the user asks about current events, news, or technical documentation, use the search results above to provide a precise answer. 
+        Always remain in character as Elephant AI."""
 
         payload = {
             "model": selected_model,
@@ -67,21 +77,21 @@ def chat():
             "stream": False
         }
 
-        resp = requests.post("https://openrouter.ai/api/v1/chat/completions", headers=headers, json=payload, timeout=40)
+        resp = requests.post("https://openrouter.ai/api/v1/chat/completions", headers=headers, json=payload, timeout=60)
         res_data = resp.json()
 
         if 'choices' in res_data:
             ai_reply = res_data['choices'][0]['message']['content']
             return jsonify({"reply": ai_reply})
         else:
-            return jsonify({"reply": "Core Error: Connectivity to sovereign node lost."}), 500
+            return jsonify({"reply": "Core Alert: Model relay failed. Check API balance or status."}), 500
 
     except Exception as e:
-        return jsonify({"reply": f"System Alert: {str(e)}"}), 500
+        return jsonify({"reply": f"Internal System Error: {str(e)}"}), 500
 
 @app.route('/')
-def health():
-    return "🐘 Elephant AI Core: ONLINE | WEB INTEL: ACTIVE"
+def index():
+    return "🐘 Elephant AI Core API is Running | Web Search: DuckDuckGo Active"
 
 if __name__ == "__main__":
     app.run(host='0.0.0.0', port=7860)