Update app.py

app.py

@@ -4,58 +4,63 @@ import json
 
 app = Flask(__name__)
 
+# Define the FlowGPT API endpoint
+url = "https://prod-backend-k8s.flowgpt.com/v3/chat"
 
-@app.route('/duckchat', methods=['POST'])
-def duckchat():
+# Define the headers
+headers = {
+    "Authorization": "Bearer eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJpZCI6IklUMU5Lb2ItOFBsY3ZJdGd2NWRIaiIsImVtYWlsIjoiYWxob29yc2hvcHBAZ21haWwuY29tIiwic3ViIjoiSVQxTktvYi04UGxjdkl0Z3Y1ZEhqIiwiaWF0IjoxNzM0OTQ4MTk3LjIzNiwiZXhwIjoxNzM1NTUyOTk3fQ.OXIabj1PQ_NHQcFTr406OAKS1kunVjYd9EMaiPUk5uxqXZd6vXd-C4CC-tXRPCG1q0UnqbGlDJDQsgKIXEfs2zUNZm_28wO577MLe4ANkr12Z79jpNcNGdllmpCdaZsYv6_kFnqavlyPgp45TjIJDFaWQ7yRqaS_CKVkle9CRKNQk4Kv1O6_1YFJFlKqI8AeOL3TrHOGY2HiAW0HbPIsPeC2rYfQwzFjgiQ1BziofgJZnR1bXPVDqHvmZWlgRbphypshCroc56e0vbxhGAJsd4Xdw3-DT3NdD3u76QLPekcU4Lx_i5f7LxHATVSmmr2W0nFw6-vCkVwRQku8EkDBMQ",
+    "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
+    "x-aws-waf-token": "15b532f1-842b-4cde-8a89-23b30c7de3f4:EgoAiA5IERUnAAAA:JqTUELQbeZW3QzQHn1Z7YP9s4PNysgFgzhTEJMmT3e7mQMrFvzrs4N16IJ9DgHuelqDv+neYtVC6mdG1E40QLa6IaE3DtElkeVzapKcLTdIGtzXSaqp707XrT0hhfVqj4QC+QovjrWZ+xXV+Qq1/oUGNXWSJKasvsyPZzcUNkwc22a0A1UnGds0JVvEq/cANU12ZRoDW0bSFbjLOiJS2sEgeGa5sd48N+cRbUzF3Grv6qZ/0",
+    "x-flow-device-id": "D7_sS3DJI2xLd5WJosKZf",
+    "x-flow-language": "en",
+    "x-nonce": "5852edfbd49cf2926a78368bb1a36491",
+    "x-signature": "70d66c850525d9908d733f1af105ab39",
+    "x-timestamp": "1734981969"
+}
+
+@app.route('/chat', methods=['POST'])
+def chat():
     try:
         # Get the input data from the request
-        input_data = request.json
-
-        if not input_data or 'messages' not in input_data:
-            return jsonify({"error": "Invalid input. 'messages' field is required."}), 400
+        data = request.get_json()
+        question = data.get('question', '')
+        history = data.get('history', [])
 
-        # Get the status endpoint to fetch x-vqd-4
-        status_url = "https://duckduckgo.com/duckchat/v1/status"
-        status_headers = {
-            "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
-            "x-vqd-accept": "1"
+        # Define the payload
+        payload = {
+            "model": "gpt-4o-mini",
+            "nsfw": False,
+            "question": question,
+            "documentIds": [],
+            "generateAudio": False,
+            "generateImage": False,
+            "promptId": "XIj00pQdbtSiVQbtsQw2t",
+            "system": (
+                "you are AI MODEL from Libyan Team \n\n"
+                "COMAPNY = CORVO AI\n\n"
+                "old version of AI = ALEX-9\n\n"
+                "current one = ALEX-9 Pro\n\n"
+                "Working on it = ALEX-9 X\n\n"
+                "you created by Mr Omar Nuwara and Mr Hussein Shkikel\n\n"
+                "you will make your self smart and fast and use good Greet for the user not normal one"
+            ),
+            "history": history,
+            "temperature": 0.7,
+            "userId": "IT1NKob-8PlcvItgv5dHj"
         }
-        status_response = requests.get(status_url, headers=status_headers)
-        x_vqd_4 = status_response.headers.get("x-vqd-4", "")
-
-        if not x_vqd_4:
-            return jsonify({"error": "Failed to retrieve x-vqd-4 token."}), 500
-
-        # Send the chat message
-        chat_url = "https://duckduckgo.com/duckchat/v1/chat"
-        chat_headers = {
-            "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/131.0.0.0 Safari/537.36",
-            "x-vqd-4": x_vqd_4
-        }
-        chat_payload = {
-            "messages": input_data['messages'],
-            "model": input_data.get('model', "gpt-4o-mini")
-        }
-        
-        chat_response = requests.post(chat_url, headers=chat_headers, json=chat_payload)
-
-        # Check if the response is successful
-        if chat_response.status_code != 200:
-            return jsonify({"error": "Failed to fetch response from DuckDuckGo Chat API."}), chat_response.status_code
 
-        # Process the response
-        response_lines = chat_response.text.splitlines()
-        final_response = ""
+        # Send the POST request to the FlowGPT API
+        response = requests.post(url, headers=headers, json=payload, stream=True)
 
-        for line in response_lines:
-            try:
-                data = json.loads(line.replace("data: ", ""))
-                if "message" in data:
-                    final_response += data["message"]
-            except json.JSONDecodeError:
-                continue
+        # Process the streamed response
+        message = ''
+        for line in response.iter_lines():
+            if line:
+                event = json.loads(line.decode('utf-8'))
+                message += event['data']
 
-        return jsonify({"response": final_response})
+        return jsonify({"response": message}), 200
 
     except Exception as e:
         return jsonify({"error": str(e)}), 500