Update app.py

app.py

@@ -1,15 +1,17 @@
 import os
+import asyncio
+import tempfile
 import requests
-from flask import Flask, request, Response, stream_with_context, render_template_string
+import edge_tts
+from flask import Flask, request, Response, stream_with_context, render_template_string, send_file
 
 app = Flask(__name__)
 
-# 🔐 100% सुरक्षित: सब कुछ केवल 'Secrets' से कॉल होगा, कोई हार्डकोडेड डेटा नहीं।
+# 🔐 100% Secure Secrets
 API_KEY = os.environ.get("YOUR_VEDIKA_API_KEY") 
 BASE_URL = os.environ.get("BASE_URL")
 MODEL_ID = os.environ.get("MODEL_ID")
 
-# URL को सुरक्षित रूप से बनाना ताकि कोई डिफ़ॉल्ट लिंक न दिखे
 INVOKE_URL = ""
 if BASE_URL:
     if not BASE_URL.endswith("/chat/completions"):
@@ -28,7 +30,6 @@ def home():
 
 @app.route('/api/chat', methods=['POST'])
 def chat():
-    # सुरक्षा जांच: अगर सीक्रेट्स सेट नहीं हैं, तो रिक्वेस्ट आगे नहीं जाएगी
     if not API_KEY or not INVOKE_URL or not MODEL_ID:
         return Response("Server Error: Configuration secrets are missing.", status=500)
 
@@ -36,16 +37,20 @@ def chat():
     user_message = data.get("message", "")
     attachments = data.get("attachments", []) 
     system_prompt = data.get("system_prompt", "")
+    history = data.get("history", []) 
     max_tokens = data.get("max_tokens", 4096)
-    temperature = data.get("temperature", 0.6)
+    temperature = data.get("temperature", 0.7)
 
     messages = []
-
-    # 1. सिस्टम प्रॉम्प्ट
     if system_prompt.strip():
         messages.append({"role": "system", "content": system_prompt})
 
-    # 2. मल्टीमोडल इनपुट
+    for msg in history:
+        role = msg.get("role", "user")
+        content = msg.get("content", "")
+        if content:
+            messages.append({"role": role, "content": content})
+
     content_payload = []
     if user_message.strip():
         content_payload.append({"type": "text", "text": user_message})
@@ -53,7 +58,6 @@ def chat():
     for att in attachments:
         att_type = att.get("type")
         b64_data = att.get("data")
-        
         if att_type == "image":
             content_payload.append({"type": "image_url", "image_url": {"url": f"data:image/jpeg;base64,{b64_data}"}})
         elif att_type in ["audio", "file"]:
@@ -79,19 +83,38 @@ def chat():
     }
 
     try:
-        # सुरक्षित स्ट्रीमिंग रिक्वेस्ट
         response = requests.post(INVOKE_URL, headers=headers, json=payload, stream=True)
-        
         def generate():
             for line in response.iter_lines():
                 if line:
                     decoded_line = line.decode("utf-8")
                     if decoded_line.startswith("data: "):
                         yield decoded_line + "\n\n"
-                        
         return Response(stream_with_context(generate()), mimetype='text/event-stream')
     except Exception as e:
         return Response("Internal Error: Unable to process request securely.", status=500)
 
+# 🎙️ PRABHAT NEURAL TTS ENDPOINT (भारी आवाज़ के लिए)
+@app.route('/api/tts', methods=['POST'])
+def tts():
+    data = request.get_json() or {}
+    text = data.get("text", "")
+    
+    if not text:
+        return Response("No text provided", status=400)
+        
+    temp_path = tempfile.mktemp(suffix=".mp3")
+    
+    # प्रभात न्यूरल (India Male) - Pitch और Rate एडजस्ट किया गया है ताकि भारी और प्रोफेशनल लगे।
+    async def generate_audio():
+        communicate = edge_tts.Communicate(text, "en-IN-PrabhatNeural", pitch="-15%", rate="-5%")
+        await communicate.save(temp_path)
+        
+    try:
+        asyncio.run(generate_audio())
+        return send_file(temp_path, mimetype="audio/mpeg", as_attachment=False)
+    except Exception as e:
+        return Response(f"TTS Error: {str(e)}", status=500)
+
 if __name__ == '__main__':
-    app.run(host='0.0.0.0', port=7860)
+    app.run(host='0.0.0.0', port=7860)