Update app.py

app.py

@@ -1,17 +1,11 @@
-import os
-import random
-import requests
-import json
-import feedparser
-from flask import Flask, request, Response, stream_with_context
+import os, random, requests, json, feedparser
+from flask import Flask, request, jsonify
 from flask_cors import CORS
 
 app = Flask(__name__)
-# 🔱 සියලුම Origins වලට අවසර ලබා දීම (CORS Fix)
-CORS(app, resources={r"/*": {"origins": "*"}})
+CORS(app)
 
-# 🔱 API KEYS DIRECT INTEGRATION
-# ඔබේ Keys 5ම මෙහි ඉතා නිවැරදිව පේළියෙන් පේළියට ඇත
+# 🔱 ඔබ ලබා දුන් API Keys
 API_KEYS = [
     "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",
     "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",
@@ -20,73 +14,39 @@ API_KEYS = [
     "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"
 ]
 
-def fetch_web_intel(query):
-    intel = ""
-    try:
-        url = f'https://news.google.com/rss/search?q={query}&hl=en-US'
-        feed = feedparser.parse(url)
-        for entry in feed.entries[:3]:
-            intel += f"\n- {entry.title}"
-    except: pass
-    return intel
-
 @app.route('/api/chat', methods=['POST'])
 def chat():
-    data = request.json
-    user_msg = data.get("message", "")
-    web_data = fetch_web_intel(user_msg)
-    
-    # 🔱 Random Key Rotation
-    selected_key = random.choice(API_KEYS)
-    
-    headers = {
-        "Authorization": f"Bearer {selected_key}",
-        "Content-Type": "application/json",
-        "HTTP-Referer": "https://huggingface.co/spaces/minzo456/Elephant-AI-Core",
-        "X-Title": "Elephant AI Core"
-    }
-    
-    payload = {
-        "model": "minimax/minimax-m2.5:free",
-        "messages": [
-            {"role": "system", "content": f"You are Elephant AI, a professional assistant for Commander MINZO-PRIME. Web Data: {web_data}"},
-            {"role": "user", "content": user_msg}
-        ],
-        "stream": True
-    }
-
-    def generate():
-        try:
-            resp = requests.post(
-                "https://openrouter.ai/api/v1/chat/completions",
-                headers=headers,
-                json=payload,
-                stream=True,
-                timeout=60
-            )
-            for line in resp.iter_lines():
-                if line:
-                    decoded = line.decode('utf-8')
-                    if decoded.startswith("data: "):
-                        data_str = decoded[6:]
-                        if data_str.strip() == "[DONE]": break
-                        try:
-                            chunk = json.loads(data_str)
-                            content = chunk['choices'][0]['delta'].get('content', '')
-                            if content: yield content
-                        except: continue
-        except Exception as e:
-            yield f"Core Connectivity Error: {str(e)}"
-
-    response = Response(stream_with_context(generate()), mimetype='text/plain')
-    # 🔱 Buffering වැළැක්වීමට අවශ්‍ය Headers
-    response.headers['X-Accel-Buffering'] = 'no'
-    response.headers['Cache-Control'] = 'no-cache'
-    return response
+    try:
+        data = request.json
+        user_msg = data.get("message", "")
+        
+        headers = {
+            "Authorization": f"Bearer {random.choice(API_KEYS)}",
+            "Content-Type": "application/json"
+        }
+        
+        payload = {
+            "model": "minimax/minimax-m2.5:free",
+            "messages": [
+                {"role": "system", "content": "You are Elephant AI created by MINZO-PRIME. Be helpful and professional."},
+                {"role": "user", "content": user_msg}
+            ],
+            "stream": False # 🔱 ස්ථාවරත්වය සඳහා Streaming අක්‍රීය කළා
+        }
+
+        resp = requests.post("https://openrouter.ai/api/v1/chat/completions", headers=headers, json=payload)
+        res_data = resp.json()
+        
+        # පිළිතුර ලබා ගැනීම
+        ai_reply = res_data['choices'][0]['message']['content']
+        return jsonify({"reply": ai_reply})
+
+    except Exception as e:
+        return jsonify({"reply": f"Core Error: {str(e)}"}), 500
 
 @app.route('/')
 def health():
-    return "🐘 Elephant AI Core Status: ACTIVE | Authorized: MINZO-PRIME"
+    return "🐘 Elephant AI Core: ONLINE"
 
 if __name__ == "__main__":
     app.run(host='0.0.0.0', port=7860)