Update app.py

app.py

@@ -5,11 +5,19 @@ import json
 from flask import Flask, request, jsonify
 from flask_cors import CORS
 from datetime import datetime
-from duckduckgo_search import DDGS # 🔱 Library එකේ import එක එලෙසම තබන්න
+
+# 🔱 DuckDuckGo Library එක Import කිරීමේදී සිදුවන Error එක වැළැක්වීමට
+try:
+    from duckduckgo_search import DDGS
+except ImportError:
+    # මෙය Hugging Face වලදී Module එක නැවත තහවුරු කිරීමටයි
+    os.system('pip install duckduckgo_search')
+    from duckduckgo_search import DDGS
 
 app = Flask(__name__)
 CORS(app, resources={r"/api/*": {"origins": "*"}})
 
+# AUTHORIZED API KEYS
 API_KEYS = [
     "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",
     "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",
@@ -19,17 +27,16 @@ API_KEYS = [
 ]
 
 def fetch_duckduckgo_intel(query):
-    """Warning-free DuckDuckGo Search Integration"""
     intel = ""
     try:
-        # 🔱 අලුත් library version එකට ගැලපෙන පරිදි සකස් කළා
-        ddgs = DDGS()
-        results = ddgs.text(query, max_results=4)
-        for r in results:
-            intel += f"\n- {r['title']}: {r['body']}"
+        # 🔱 Latest version logic
+        with DDGS() as ddgs:
+            results = ddgs.text(query, max_results=4)
+            for r in results:
+                intel += f"\n- {r['title']}: {r['body']}"
     except Exception as e:
         print(f"Search Warning: {e}")
-        intel = "Global intelligence access is restricted for this query."
+        intel = "Global intelligence access restricted."
     return intel
 
 @app.route('/api/chat', methods=['POST'])
@@ -55,34 +62,22 @@ def chat():
             "X-Title": "Elephant AI Core"
         }
 
-        system_prompt = f"""You are {tier.upper()} mode of Elephant AI, a sovereign intelligence developed by MINZO-PRIME.
-        System Time: {current_time}.
-        Live Web Data: {web_context}
-        Provide strategic and highly accurate responses based on the available data."""
+        system_prompt = f"You are {tier.upper()} mode of Elephant AI by MINZO-PRIME. Time: {current_time}. Data: {web_context}"
 
         payload = {
             "model": selected_model,
-            "messages": [
-                {"role": "system", "content": system_prompt},
-                {"role": "user", "content": user_msg}
-            ]
+            "messages": [{"role": "system", "content": system_prompt}, {"role": "user", "content": user_msg}]
         }
 
         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 Alert: Node response failed. Try Prime mode."}), 500
+        return jsonify({"reply": resp.json()['choices'][0]['message']['content']})
 
     except Exception as e:
-        return jsonify({"reply": f"Internal Core Disruption: {str(e)}"}), 500
+        return jsonify({"reply": f"Core Disruption: {str(e)}"}), 500
 
 @app.route('/')
 def health():
-    return "🐘 Elephant AI Core: ONLINE | Operator: MINZO-PRIME"
+    return "🐘 Elephant AI Core: ONLINE"
 
 if __name__ == "__main__":
     app.run(host='0.0.0.0', port=7860)