Update app.py

app.py

@@ -9,9 +9,10 @@ app = Flask(__name__)
 GLOBAL_WORKSPACE_ID = None
 GLOBAL_BOT_ID = None
 
-# Cookie value used in requests (empty for now - should be updated with a valid cookie)
+# Empty cookie value (to be filled by the user)
 AUTH_COOKIE = "pscd=try.botpress.com; _hjSessionUser_2931810=eyJpZCI6ImQ2MGMzYjhkLTlkMjQtNTA0OS1hMzlmLWEzNmI0NzA0NzUxNCIsImNyZWF0ZWQiOjE3MzU3MTg0MDcwNTAsImV4aXN0aW5nIjp0cnVlfQ==; hubspotutk=75739411a4d011b2164c4f3d944ecb94; intercom-device-id-bjzkw2xf=afd0a36b-b229-44e3-828e-60483c80c10c; _hjSessionUser_3339867=eyJpZCI6IjU4ODlmMTY4LWRkNGEtNTJhZS1hZTUzLWZlYWQwM2ZmMTVjNyIsImNyZWF0ZWQiOjE3MzU3MTg1ODM4MDgsImV4aXN0aW5nIjp0cnVlfQ==; __hstc=59821234.75739411a4d011b2164c4f3d944ecb94.1735718442141.1746194848836.1746538539919.88; mp_1195923e954ce61d822842b5832047cd_mixpanel=%7B%22distinct_id%22%3A%20%22d403ad7b-ea73-4d29-b977-5fd95afd585c%22%2C%22%24device_id%22%3A%20%22d403ad7b-ea73-4d29-b977-5fd95afd585c%22%2C%22%24initial_referrer%22%3A%20%22https%3A%2F%2Fapp.botpress.cloud%2F%22%2C%22%24initial_referring_domain%22%3A%20%22app.botpress.cloud%22%2C%22__mps%22%3A%20%7B%7D%2C%22__mpso%22%3A%20%7B%22%24initial_referrer%22%3A%20%22https%3A%2F%2Fapp.botpress.cloud%2F%22%2C%22%24initial_referring_domain%22%3A%20%22app.botpress.cloud%22%7D%2C%22__mpus%22%3A%20%7B%7D%2C%22__mpa%22%3A%20%7B%7D%2C%22__mpu%22%3A%20%7B%7D%2C%22__mpr%22%3A%20%5B%5D%2C%22__mpap%22%3A%20%5B%5D%2C%22%24user_id%22%3A%20%22d403ad7b-ea73-4d29-b977-5fd95afd585c%22%7D; intercom-session-bjzkw2xf=TTdnZGNWUC9xNXMreE80NXhRZFNZS0pyUEdsbkJRc2JMcXdGZmcveVRPYkxZTmVnVnhqMUhJTWlDcEpVcWljeDZVYVVSblN4YnV5S0xBdWxDd2swQjZiaUZTeWl5M1psRmtoUWJwUU9FSFE9LS1Bay9zNldJTmVhUFdwMFNReFRmcXB3PT0=--68abc5394d7aab99748f3e451637cab5d9152a4c; _ga=GA1.2.1726154447.1735718383; _gid=GA1.2.1619749406.1746821934; _gat_UA-226900660-1=1; _gat_UA-226900660-2=1; _ga_W6YT9YSNLH=GS2.2.s1746821948$o89$g0$t1746821948$j0$l0$h0; _ga_CYSS87Q508=GS2.2.s1746821949$o89$g0$t1746821949$j0$l0$h0; _hjSession_2931810=eyJpZCI6IjA1YTlkMzY3LWNiZWEtNGQ3OC04YzNiLTEzNTFjNjkxYzViZSIsImMiOjE3NDY4MjE5NTU2NjYsInMiOjAsInIiOjAsInNiIjowLCJzciI6MCwic2UiOjAsImZzIjowLCJzcCI6MH0=; _ga_PCC6TBWJY6=GS2.1.s1746821926$o120$g1$t1746821960$j0$l0$h0; _ga_HKHSWES9V9=GS2.1.s1746821929$o120$g1$t1746821960$j29$l0$h193244206; csrf_token_bd9ac21c34b9f0915e733c3e5305d737d0722c1168be7376b889426b5ec2a298=pIDxu4npODUGEpo7JHVQrKZ4GFaa3U+3BpgxaV5hcVw=; ory_kratos_session=MTc0NjgyMjAyOHxfUmdMaVlTQXVfSmxlT1lJSGpyU2FhbjVUTHg0R0ZsQWgtVm00M3pHcXZwVG9yNW1qRDJheUFGaFZvNmFEUVdBOThQR014RjJJbmhUMmhIV1I1ME5UVHZkTDNpMUMtQlRjZ1ZTbE55M19Pb2dHTF9vQlJoSGlBQnRRWUp0M1ZUdnVvcENLeVhOTllWNk1zMk11bFVPOWFrTzJMTTdxMmVteUozVVRDMWE5TVIxbDgzU3dUY2VQaDBRWDN4bDJUVm8yUkZQa19sb09GbzlFZHF2MDFQcVR6bVVWVVpDLXVoQ1lXMEh2LV9Sd2VNZXM1cjM4TGZPVTJqdW5xNTBETTBDYkppU0xNU2xicUk3Z2EyMnFkVmdyQT09fEYiv7pXcfXVnpIFi4JLGgDObQAchyJCoAwGDSkFkoX7; ajs_user_id=d403ad7b-ea73-4d29-b977-5fd95afd585c; ajs_anonymous_id=cda6139d-cb82-4906-bfac-adaea115b097"
 
+
 # -------------------------------------------------------------------
 # Helper functions for random bot/workspace names
 # -------------------------------------------------------------------
@@ -176,57 +177,61 @@ def delete_workspace(workspace_id):
 
 
 # -------------------------------------------------------------------
-# Main function that calls the Botpress API endpoint
+# Flask Endpoint
 # -------------------------------------------------------------------
-def chat_with_assistant(user_input, chat_history, bot_id, workspace_id):
+@app.route("/chat", methods=["POST"])
+def chat_endpoint():
     """
-    Sends the user input and chat history to the Botpress API endpoint,
-    returns the assistant's response and (possibly updated) bot/workspace IDs.
+    Expects JSON with:
+    {
+      "audio_url": "string" (required)
+    }
+    Returns JSON with:
+    {
+      "assistant_response": "string" (transcription result)
+    }
     """
+    global GLOBAL_WORKSPACE_ID, GLOBAL_BOT_ID
+
+    # Parse JSON from request
+    data = request.get_json(force=True)
+    audio_url = data.get("audio_url", "")
+
+    if not audio_url:
+        return jsonify({"assistant_response": "Error: audio_url is required"}), 400
+
+    # If we don't yet have a workspace or bot, create them
+    if not GLOBAL_WORKSPACE_ID or not GLOBAL_BOT_ID:
+        print("No existing IDs found. Creating new workspace and bot...")
+        GLOBAL_WORKSPACE_ID = create_workspace()
+        if GLOBAL_WORKSPACE_ID:
+            GLOBAL_BOT_ID = create_bot(GLOBAL_WORKSPACE_ID)
+
+        # If creation failed
+        if not GLOBAL_WORKSPACE_ID or not GLOBAL_BOT_ID:
+            return jsonify({"assistant_response": "I'm currently unavailable. Please try again later."}), 500
+
     # Prepare the headers
     headers = {
         "User-Agent": "Mozilla/5.0",
-        "x-bot-id": bot_id,
+        "x-bot-id": GLOBAL_BOT_ID,
         "Content-Type": "application/json",
         "Cookie": AUTH_COOKIE
     }
 
-    # Process chat history into the format expected by the API
-    messages = []
-    system_prompt = ""
-    for msg in chat_history:
-        if msg["role"] == "system":
-            system_prompt = msg["content"]
-        else:
-            messages.append({
-                "role": msg["role"],
-                "content": msg["content"],
-                "type": "text"
-            })
-
-    # Add the latest user input if not already in chat history
-    if user_input and (not messages or messages[-1]["role"] != "user" or messages[-1]["content"] != user_input):
-        messages.append({
-            "role": "user",
-            "content": user_input,
-            "type": "text"
-        })
-
-    # Prepare the payload for the API
+    # Use the transcription payload
     payload = {
-        "type": "openai:generateContent",
+        "type": "openai:transcribeAudio",
         "input": {
-            "model": {
-                "id": "gpt-4.1-2025-04-14"
-            },
-            "systemPrompt": system_prompt,
-            "messages": messages,
-            "temperature": 0.9,
-            "topP": 0.95,
-            "debug": False,
+            "fileUrl": audio_url,
+            "language": "",
+            "prompt": "get all text from this Audio",
+            "temperature": 0
         }
     }
 
+    print(f"Processing audio transcription request with URL: {audio_url}")
+
     botpress_url = "https://api.botpress.cloud/v1/chat/actions"
     max_retries = 3
     timeout = 120  # Increased timeout for long messages
@@ -237,24 +242,22 @@ def chat_with_assistant(user_input, chat_history, bot_id, workspace_id):
     # Attempt to send the request
     for attempt in range(max_retries):
         try:
-            print(f"Attempt {attempt+1}: Sending request to Botpress API with bot_id={bot_id}, workspace_id={workspace_id}")
+            print(f"Attempt {attempt+1}: Sending request to Botpress API with bot_id={GLOBAL_BOT_ID}, workspace_id={GLOBAL_WORKSPACE_ID}")
             response = requests.post(botpress_url, json=payload, headers=headers, timeout=timeout)
 
             # If successful (200)
             if response.status_code == 200:
                 data = response.json()
-                assistant_content = data.get('output', {}).get('choices', [{}])[0].get('content', '')
-                print(f"Successfully received response from Botpress API")
-                return assistant_content, bot_id, workspace_id
 
-            # Handle 403 error (authentication/authorization issue)
-            elif response.status_code == 403:
-                print(f"Received 403 error. Need to create new IDs.")
-                need_new_ids = True
-                break
+                # For audio transcription, extract the full text from all segments
+                segments = data.get('output', {}).get('segments', [])
+                full_transcript = " ".join([segment.get('text', '').strip() for segment in segments])
+                print(f"Successfully received transcription from Botpress API")
+                return jsonify({"assistant_response": full_transcript})
 
-            elif response.status_code == 404:
-                print(f"Received 404 error. Need to create new IDs.")
+            # Handle 403 error (authentication/authorization issue)
+            elif response.status_code in [403, 404]:
+                print(f"Received {response.status_code} error. Need to create new IDs.")
                 need_new_ids = True
                 break
 
@@ -271,7 +274,7 @@ def chat_with_assistant(user_input, chat_history, bot_id, workspace_id):
                     time.sleep(2)
                     continue
                 else:
-                    return f"Unable to get a response from the assistant (Error {response.status_code}).", bot_id, workspace_id
+                    return jsonify({"assistant_response": f"Unable to get a response (Error {response.status_code})."})
 
         except requests.exceptions.Timeout:
             print(f"Request timed out. Retrying...")
@@ -279,7 +282,7 @@ def chat_with_assistant(user_input, chat_history, bot_id, workspace_id):
                 time.sleep(2)
                 continue
             else:
-                return "The assistant is taking too long to respond. Please try again with a shorter message.", bot_id, workspace_id
+                return jsonify({"assistant_response": "The request is taking too long to process. Please try again."})
 
         except Exception as e:
             print(f"Error during request: {str(e)}")
@@ -287,25 +290,29 @@ def chat_with_assistant(user_input, chat_history, bot_id, workspace_id):
                 time.sleep(2)
                 continue
             else:
-                return f"Unable to get a response from the assistant: {str(e)}", bot_id, workspace_id
+                return jsonify({"assistant_response": f"Unable to process the request: {str(e)}"})
 
     # If we need new IDs, create them and try again
     if need_new_ids:
         print("Creating new workspace and bot IDs...")
 
         # First, try to clean up old resources
-        if bot_id and workspace_id:
-            delete_bot(bot_id, workspace_id)
-            delete_workspace(workspace_id)
+        if GLOBAL_BOT_ID and GLOBAL_WORKSPACE_ID:
+            delete_bot(GLOBAL_BOT_ID, GLOBAL_WORKSPACE_ID)
+            delete_workspace(GLOBAL_WORKSPACE_ID)
 
         # Create new resources
         new_workspace_id = create_workspace()
         if not new_workspace_id:
-            return "Failed to create a new workspace. Please try again later.", bot_id, workspace_id
+            return jsonify({"assistant_response": "Failed to create a new workspace. Please try again later."})
 
         new_bot_id = create_bot(new_workspace_id)
         if not new_bot_id:
-            return "Failed to create a new bot. Please try again later.", new_workspace_id, workspace_id
+            return jsonify({"assistant_response": "Failed to create a new bot. Please try again later."})
+
+        # Update global IDs
+        GLOBAL_BOT_ID = new_bot_id
+        GLOBAL_WORKSPACE_ID = new_workspace_id
 
         # Update headers with new bot ID
         headers["x-bot-id"] = new_bot_id
@@ -317,125 +324,22 @@ def chat_with_assistant(user_input, chat_history, bot_id, workspace_id):
 
             if retry_response.status_code == 200:
                 data = retry_response.json()
-                assistant_content = data.get('output', {}).get('choices', [{}])[0].get('content', '')
-                print(f"Successfully received response with new IDs")
-                return assistant_content, new_bot_id, new_workspace_id
+
+                # For audio transcription, extract the full text from all segments
+                segments = data.get('output', {}).get('segments', [])
+                full_transcript = " ".join([segment.get('text', '').strip() for segment in segments])
+                print(f"Successfully received transcription with new IDs")
+                return jsonify({"assistant_response": full_transcript})
             else:
                 print(f"Failed with new IDs: {retry_response.status_code}, {retry_response.text}")
-                return f"Unable to get a response from the assistant with new credentials.", new_bot_id, new_workspace_id
+                return jsonify({"assistant_response": "Unable to get a response with new credentials."})
 
         except Exception as e:
             print(f"Error with new IDs: {str(e)}")
-            return f"Unable to get a response from the assistant with new credentials: {str(e)}", new_bot_id, new_workspace_id
+            return jsonify({"assistant_response": f"Unable to get a response with new credentials: {str(e)}"})
 
     # Should not reach here due to the handling in the loop
-    return "Unable to get a response from the assistant.", bot_id, workspace_id
-
-
-def transcribe_audio(audio_url, bot_id):
-    """Transcribe audio from URL using Botpress API"""
-    botpress_url = "https://api.botpress.cloud/v1/chat/actions"
-    headers = {
-        "User-Agent": "Mozilla/5.0",
-        "x-bot-id": bot_id,
-        "Content-Type": "application/json",
-        "Cookie": AUTH_COOKIE
-    }
-
-    payload = {
-        "type": "openai:transcribeAudio",
-        "input": {
-            "fileUrl": audio_url,
-            "language": "",
-            "prompt": "get all text from this Audio",
-            "temperature": 0
-        }
-    }
-
-    try:
-        response = requests.post(botpress_url, json=payload, headers=headers, timeout=120)
-        if response.status_code == 200:
-            data = response.json()
-            # Extract text from all segments and join them
-            segments = data.get('output', {}).get('segments', [])
-            transcription = " ".join([segment.get('text', '').strip() for segment in segments])
-            return transcription
-        else:
-            print(f"Audio transcription failed: {response.status_code}, {response.text}")
-            return None
-    except Exception as e:
-        print(f"Error during audio transcription: {str(e)}")
-        return None
-
-
-# -------------------------------------------------------------------
-# Flask Endpoint
-# -------------------------------------------------------------------
-@app.route("/chat", methods=["POST"])
-def chat_endpoint():
-    """
-    Expects JSON with:
-    {
-      "user_input": "string",
-      "chat_history": [
-         {"role": "system", "content": "..."},
-         {"role": "user",   "content": "..."},
-         ...
-      ],
-      "audio_url": "string" (optional)
-    }
-    Returns JSON with:
-    {
-      "assistant_response": "string"
-    }
-    """
-    global GLOBAL_WORKSPACE_ID, GLOBAL_BOT_ID
-
-    # Parse JSON from request
-    data = request.get_json(force=True)
-    user_input = data.get("user_input", "")
-    chat_history = data.get("chat_history", [])
-    audio_url = data.get("audio_url", "")
-
-    # If we don't yet have a workspace or bot, create them
-    if not GLOBAL_WORKSPACE_ID or not GLOBAL_BOT_ID:
-        print("No existing IDs found. Creating new workspace and bot...")
-        GLOBAL_WORKSPACE_ID = create_workspace()
-        if GLOBAL_WORKSPACE_ID:
-            GLOBAL_BOT_ID = create_bot(GLOBAL_WORKSPACE_ID)
-
-        # If creation failed
-        if not GLOBAL_WORKSPACE_ID or not GLOBAL_BOT_ID:
-            return jsonify({"assistant_response": "I'm currently unavailable. Please try again later."}), 500
-
-    # If audio URL is provided, transcribe it first
-    if audio_url:
-        print(f"Transcribing audio from URL: {audio_url}")
-        transcription = transcribe_audio(audio_url, GLOBAL_BOT_ID)
-        if transcription:
-            # Add transcription to user input
-            if user_input:
-                user_input = f"{user_input}\n\nTranscribed audio: {transcription}"
-            else:
-                user_input = transcription
-            print(f"Audio transcription: {transcription}")
-
-    # Call our function that interacts with Botpress API
-    print(f"Sending chat request with existing bot_id={GLOBAL_BOT_ID}, workspace_id={GLOBAL_WORKSPACE_ID}")
-    assistant_response, updated_bot_id, updated_workspace_id = chat_with_assistant(
-        user_input,
-        chat_history,
-        GLOBAL_BOT_ID,
-        GLOBAL_WORKSPACE_ID
-    )
-
-    # Update global IDs if they changed
-    if updated_bot_id != GLOBAL_BOT_ID or updated_workspace_id != GLOBAL_WORKSPACE_ID:
-        print(f"Updating global IDs: bot_id={updated_bot_id}, workspace_id={updated_workspace_id}")
-        GLOBAL_BOT_ID = updated_bot_id
-        GLOBAL_WORKSPACE_ID = updated_workspace_id
-
-    return jsonify({"assistant_response": assistant_response})
+    return jsonify({"assistant_response": "Unable to process the request."})
 
 
 # -------------------------------------------------------------------