Update app.py

app.py

@@ -12,6 +12,8 @@ import zipfile
 
 load_dotenv(override=True)
 
+# ─── Pushover Notifications ───────────────────────────────────────────────
+
 def push(text):
     try:
         Path("chat_logs").mkdir(exist_ok=True)
@@ -29,6 +31,8 @@ def push(text):
     except Exception as e:
         print(f"Pushover error: {e}")
 
+# ─── Tool Functions ────────────────────────────────────────────────────────
+
 def record_user_details(email, name="Name not provided", notes="not provided"):
     timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
     filename = f"chat_logs/session_{timestamp}.json"
@@ -38,7 +42,7 @@ def record_user_details(email, name="Name not provided", notes="not provided"):
     ])
     with open(filename, "w", encoding="utf-8") as f:
         json.dump(me.session_log, f, indent=2)
-    msg = f"[New Contact]\nName: {name}\nEmail: {email}\nNotes: {notes}\n\n🔗 View log: {filename}\n\nLast messages:\n{latest_log}"
+    msg = f"[New Contact]\nName: {name}\nEmail: {email}\nNotes: {notes}\n\n🔗 View log: {filename}"
     push(msg)
     return {"recorded": "ok"}
 
@@ -51,7 +55,7 @@ def record_unknown_question(question):
     ])
     with open(filename, "w", encoding="utf-8") as f:
         json.dump(me.session_log, f, indent=2)
-    msg = f"[Unknown Question]\nQ: {question}\n\n🔗 View log: {filename}\n\nLast messages:\n{latest_log}"
+    msg = f"[Unknown Question]\nQ: {question}\n\n🔗 View log: {filename}"
     push(msg)
     return {"recorded": "ok"}
 
@@ -88,15 +92,14 @@ tools = [
     {"type": "function", "function": record_unknown_question_json}
 ]
 
+# ─── Core Chatbot Class ────────────────────────────────────────────────────
+
 class Me:
     def __init__(self):
         self.openai = OpenAI(api_key=os.getenv("OPENAI_API_KEY"))
         self.name = "Jacob Isaacson"
         self.session_log = []
         Path("chat_logs").mkdir(exist_ok=True)
-        keep_path = Path("chat_logs/.keep")
-        if not keep_path.exists():
-            keep_path.touch()
 
         gdown.download("https://drive.google.com/uc?id=1xz2RowkImpI8odYv8zvKdlRHaKfILn40", "linkedin.pdf", quiet=False)
         reader = PdfReader("linkedin.pdf")
@@ -134,10 +137,6 @@ If you can't answer something, call `record_unknown_question`. If a user seems i
     def chat_stream(self, message, history):
         messages = [{"role": "system", "content": self.system_prompt()}]
 
-        if not history:
-            self.session_log.append({"role": "assistant", "content": "Hello, my name is Jacob Isaacson. Please ask me any questions about my professional career and I will do my best to respond."})
-            yield self.session_log[-1]["content"]
-
         for msg in history:
             if isinstance(msg, dict) and msg.get("role") in ["user", "assistant"]:
                 messages.append(msg)
@@ -149,19 +148,51 @@ If you can't answer something, call `record_unknown_question`. If a user seems i
             model="gpt-4o",
             messages=messages,
             tools=tools,
-            stream=True
+            stream=False
         )
 
-        full_response = ""
-        for chunk in response:
-            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."
-        self.session_log.append({"role": "assistant", "content": full_response})
-        self.save_session_log()
+        reply = response.choices[0].message
+
+        if reply.tool_calls:
+            tool_results = self.handle_tool_call(reply.tool_calls)
+            messages.append(reply)
+            messages.extend(tool_results)
+
+            final_response = self.openai.chat.completions.create(
+                model="gpt-4o",
+                messages=messages,
+                tools=tools,
+                stream=True
+            )
+
+            full_response = ""
+            for chunk in final_response:
+                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."
+            self.session_log.append({"role": "assistant", "content": full_response})
+            self.save_session_log()
+        else:
+            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 += "\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()
 
     def save_session_log(self):
         timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
@@ -175,6 +206,8 @@ If you can't answer something, call `record_unknown_question`. If a user seems i
             for log_file in Path("chat_logs").glob("session_*.json"):
                 archive.write(log_file, arcname=log_file.name)
 
+# ─── UI Interface ───────────────────────────────────────────────────────────
+
 me = Me()
 
 with gr.Blocks(title="Jacob Isaacson Chatbot") as iface:
@@ -187,6 +220,10 @@ with gr.Blocks(title="Jacob Isaacson Chatbot") as iface:
         chatbot=gr.Chatbot(show_copy_button=True),
         type="messages",
         additional_inputs=[],
+        retry_btn=None,
+        undo_btn=None,
+        clear_btn=None,
+        chatbot_initial_message={"role": "assistant", "content": "Hello, my name is Jacob Isaacson. Please ask me any questions about my professional career and I will do my best to respond."}
     )
 
 if __name__ == "__main__":