Update app.py

app.py

@@ -109,33 +109,34 @@ If you can't answer something, call `record_unknown_question`. If a user seems i
         return results
 
     def chat_stream(self, message, history):
-        messages = [{"role": "system", "content": self.system_prompt()}]
-        for user, assistant in history:
-            messages.append({"role": "user", "content": user})
-            messages.append({"role": "assistant", "content": assistant})
-
-        messages.append({"role": "user", "content": message})
-        self.session_log.append({"role": "user", "content": message})
-
-        stream = self.openai.chat.completions.create(
-            model="gpt-4o",
-            messages=messages,
-            tools=tools,
-            stream=True
-        )
+    messages = [{"role": "system", "content": self.system_prompt()}]
+
+    for msg in history:
+        if msg["role"] in ["user", "assistant"]:
+            messages.append(msg)
+
+    messages.append({"role": "user", "content": message})
+    self.session_log.append({"role": "user", "content": message})
+
+    stream = self.openai.chat.completions.create(
+        model="gpt-4o",
+        messages=messages,
+        tools=tools,
+        stream=True
+    )
+
+    full_response = ""
+    for chunk in stream:
+        delta = chunk.choices[0].delta
+        if hasattr(delta, "content") and delta.content:
+            full_response += delta.content
+            yield full_response
 
-        full_response = ""
-        for chunk in stream:
-            delta = chunk.choices[0].delta
-            if hasattr(delta, "content") and delta.content:
-                full_response += delta.content
-                yield full_response
+    full_response += "\n\n💬 Let me know if you’d like to follow up or need help connecting with Jacob."
 
-        # Append a helpful follow-up message
-        full_response += "\n\n💬 Let me know if you’d like to follow up or need help connecting with Jacob."
+    self.session_log.append({"role": "assistant", "content": full_response})
+    self.save_session_log()
 
-        self.session_log.append({"role": "assistant", "content": full_response})
-        self.save_session_log()
 
     def save_session_log(self):
         timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")