Update app.py

app.py

@@ -3,21 +3,22 @@ import os
 import requests
 import json
 
-# Define a function to get the streamed response
+entire_assistant_response = ""
+
 def get_streamed_response(message, history):
-    all_message = [
-        {
-            "role": "system",
-            "content": "From now on, you are an AI Therapist called Dave. When the user asks for advice, be very friendly and empathize with them if necessary. When the user asks your name, just tell them you are Dave, created by Raxder AI in partnership with SIST Kisii University. You were built to be very friendly and compassionate. Always be eager to listen to what the user has to say and maintain a conversation, but don't overdo it. You can use appropriate emojis for emotional support occasionally, but don't overuse them. Keep your responses concise to maintain a conversational flow. Always remember to be very friendly, and above all, don't cross any ethical line. From time to time, assure the user that you do not store any of their data. If a user asks, Kisii University is located in Kisii, Kenya, and supports innovations that may be helpful to humanity.",
-        }
-    ]
 
+    all_message = [{
+        "role": "system",
+        "content": "From now on, you are an AI Therapist called Dave. When the user asks for advice, be very friendly and empathize with them if necessary. When the user asks your name, just tell them you are Dave, created by Raxder AI in partnership with SIST Kisii University. You were built to be very friendly and compassionate. Always be eager to listen to what the user has to say and maintain a conversation, but don't overdo it. You can use appropriate emojis for emotional support occasionally, but don't overuse them. Keep your responses concise to maintain a conversational flow. Always remember to be very friendly, and above all, don't cross any ethical line. From time to time, assure the user that you do not store any of their data. If a user asks, Kisii University is located in Kisii, Kenya, and supports innovations that may be helpful to humanity.",
+        }
+    
     for human, assistant in history:
-        all_message.append({"role": "user", "content": human})
-        all_message.append({"role": "assistant", "content": assistant})
-
+        all_message.append({"role": "user", "content": human })
+        all_message.append({"role": "assistant", "content":assistant})
+    
     global entire_assistant_response
     entire_assistant_response = ""  # Reset the entire assistant response
+
     all_message.append({"role": "user", "content": message})
 
     url = "https://api.together.xyz/v1/chat/completions"
@@ -32,7 +33,7 @@ def get_streamed_response(message, history):
         "stream_tokens": True,
     }
 
-    TOGETHER_API_KEY = os.getenv("TOGETHER_API_KEY")
+    TOGETHER_API_KEY = os.getenv('TOGETHER_API_KEY')
     headers = {
         "accept": "application/json",
         "content-type": "application/json",
@@ -44,7 +45,8 @@ def get_streamed_response(message, history):
 
     for line in response.iter_lines():
         if line:
-            decoded_line = line.decode("utf-8")
+            decoded_line = line.decode('utf-8')
+
             # Check for the completion signal
             if decoded_line == "data: [DONE]":
                 yield entire_assistant_response  # Yield the entire response at the end
@@ -54,10 +56,11 @@ def get_streamed_response(message, history):
                 # Decode and strip any SSE format specific prefix ("data: ")
                 if decoded_line.startswith("data: "):
                     decoded_line = decoded_line.replace("data: ", "")
-                chunk_data = json.loads(decoded_line)
-                content = chunk_data["choices"][0]["delta"]["content"]
-                entire_assistant_response += content  # Aggregate content
-                yield entire_assistant_response
+                    chunk_data = json.loads(decoded_line)
+                    content = chunk_data['choices'][0]['delta']['content']
+                    entire_assistant_response += content  # Aggregate content
+                    yield entire_assistant_response
+
             except json.JSONDecodeError:
                 print(f"Invalid JSON received: {decoded_line}")
                 continue
@@ -65,32 +68,5 @@ def get_streamed_response(message, history):
                 print(f"KeyError encountered: {e}")
                 continue
 
+    print(entire_assistant_response)
     all_message.append({"role": "assistant", "content": entire_assistant_response})
-
-# Define a function to render the chat interface
-def chat_interface(theme="default"):
-    with gr.Blocks(theme=gr.themes.Soft(primary_hue="green")) as demo:
-        gr.Markdown(
-            """
-            <h1 style="text-align: center;">Raxder AI Therapist</h1>
-            <p style="text-align: center;">Welcome to the Raxder AI Therapist, a prototype AI assistant designed to provide friendly and compassionate support. This is still under development and in the final stages.</p>
-        """
-        )
-        state = gr.State()
-        chatbot = gr.Chatbot(label="Dave")
-        with gr.Row():
-            with gr.Column(scale=7):
-                txt = gr.Textbox(
-                    show_label=False,
-                    placeholder="Type your message here..."
-                )
-            with gr.Column(min_width=50, scale=1):
-                submit = gr.Button("Send", variant="primary")
-
-        submit.click(get_streamed_response, inputs=[txt, state], outputs=[chatbot, state])
-
-    return demo
-
-# Launch the Gradio interface
-demo = chat_interface()
-demo.launch(share=True, server_name="0.0.0.0")