Update app.py

app.py

@@ -5,6 +5,7 @@ from multiprocessing import freeze_support
 import importlib
 import inspect
 import json
+import logging
 
 # === Fix path to include src/txagent
 sys.path.insert(0, os.path.join(os.path.dirname(__file__), "src"))
@@ -14,10 +15,13 @@ import txagent.txagent
 importlib.reload(txagent.txagent)
 from txagent.txagent import TxAgent
 
-# === Debug print
+# === Debug info
 print(">>> TxAgent loaded from:", inspect.getfile(TxAgent))
 print(">>> TxAgent has run_gradio_chat:", hasattr(TxAgent, "run_gradio_chat"))
 
+# === Logging
+logging.basicConfig(level=logging.INFO)
+
 # === Environment
 current_dir = os.path.abspath(os.path.dirname(__file__))
 os.environ["MKL_THREADING_LAYER"] = "GNU"
@@ -36,63 +40,44 @@ question_examples = [
     ["What treatment options exist for HER2+ breast cancer resistant to trastuzumab?"]
 ]
 
-# === Helper: extract tool name from content
-def extract_tool_name_and_clean_content(message_obj):
-    import logging
-    logging.basicConfig(level=logging.INFO)
-
+# === Extract tool name and format output
+def extract_tool_name_and_clean_content(msg):
     tool_name = "Tool Result"
-    content = ""
-
-    if isinstance(message_obj, dict):
-        role = message_obj.get("role", "assistant")
-        content = message_obj.get("content", "")
-        tool_calls = message_obj.get("tool_calls", None)
-    else:
-        role = getattr(message_obj, "role", "assistant")
-        content = getattr(message_obj, "content", "")
-        tool_calls = getattr(message_obj, "tool_calls", None)
-
-    # Try to extract tool name from `tool_calls`
+    content = msg.get("content") if isinstance(msg, dict) else getattr(msg, "content", "")
+    tool_calls = msg.get("tool_calls") if isinstance(msg, dict) else getattr(msg, "tool_calls", None)
+
     if tool_calls:
         try:
             if isinstance(tool_calls, str):
-                import json
                 tool_calls = json.loads(tool_calls)
             tool_name = tool_calls[0].get("name", "Tool Result")
-            logging.info(f"[extract_tool_name] Extracted from tool_calls: {tool_name}")
+            logging.info(f"[extract_tool_name] Parsed tool name: {tool_name}")
         except Exception as e:
-            logging.warning(f"[extract_tool_name] Failed tool_calls parsing: {e}")
+            logging.warning(f"[extract_tool_name] Failed parsing tool_calls: {e}")
 
-    # Format clean output
     if isinstance(content, (dict, list)):
-        formatted = json.dumps(content, indent=2)
-    else:
-        formatted = str(content)
-
-    return f"Tool: {tool_name}", formatted
+        content = json.dumps(content, indent=2)
+    return f"Tool: {tool_name}", content
 
-
-# === Helper: formatted collapsible output
+# === Format answer in collapsible box
 def format_collapsible(content, title="Answer"):
     return (
-        f"<details style='border: 1px solid #ccc; padding: 8px; margin-top: 8px;'>"
-        f"<summary style='font-weight: bold;'>{title}</summary>"
-        f"<div style='margin-top: 8px; white-space: pre-wrap;'>{content}</div></details>"
+        f"<details style='border: 1px solid #ccc; border-radius: 8px; padding: 10px; margin-top: 10px;'>"
+        f"<summary style='font-size: 16px; font-weight: bold; color: #3B82F6;'>{title}</summary>"
+        f"<div style='margin-top: 8px; font-size: 15px; line-height: 1.6; white-space: pre-wrap;'>{content}</div></details>"
     )
 
-# === UI creation
+# === Build UI
 def create_ui(agent):
     with gr.Blocks(theme=gr.themes.Soft()) as demo:
-        gr.Markdown("<h1 style='text-align: center;'>TxAgent: Therapeutic Reasoning</h1>")
-        gr.Markdown("Ask biomedical or therapeutic questions. Powered by step-by-step reasoning and tools.")
+        gr.Markdown("<h1 style='text-align: center;'>💊 TxAgent: Therapeutic Reasoning</h1>")
+        gr.Markdown("Ask biomedical or therapeutic questions. Powered by tool-augmented reasoning.")
 
         chatbot = gr.Chatbot(label="TxAgent", height=600, type="messages")
-        message_input = gr.Textbox(placeholder="Ask your biomedical question...", show_label=False)
+        message_input = gr.Textbox(placeholder="Ask a biomedical question...", show_label=False)
         send_button = gr.Button("Send", variant="primary")
         conversation_state = gr.State([])
 
-        # === Core handler (streaming generator)
         def handle_chat(message, history, conversation):
             generator = agent.run_gradio_chat(
                 message=message,
@@ -104,32 +89,30 @@ def create_ui(agent):
                 conversation=conversation,
                 max_round=30
             )
-
             for update in generator:
-                formatted_messages = []
+                formatted = []
                 for m in update:
-                    role = m["role"] if isinstance(m, dict) else getattr(m, "role", "assistant")
-                    content = m["content"] if isinstance(m, dict) else getattr(m, "content", "")
+                    role = m.get("role") if isinstance(m, dict) else getattr(m, "role", "assistant")
                     if role == "assistant":
-                        title, clean = extract_tool_name_and_clean_content(content)
+                        title, clean = extract_tool_name_and_clean_content(m)
                         content = format_collapsible(clean, title)
-                    formatted_messages.append({"role": role, "content": content})
-                yield formatted_messages
+                    else:
+                        content = m.get("content") if isinstance(m, dict) else getattr(m, "content", "")
+                    formatted.append({"role": role, "content": content})
+                yield formatted
 
-        # === Trigger handlers
         inputs = [message_input, chatbot, conversation_state]
         send_button.click(fn=handle_chat, inputs=inputs, outputs=chatbot)
         message_input.submit(fn=handle_chat, inputs=inputs, outputs=chatbot)
 
         gr.Examples(examples=question_examples, inputs=message_input)
-        gr.Markdown("**DISCLAIMER**: This demo is for research purposes only and does not provide medical advice.")
+        gr.Markdown("<small style='color: gray;'>DISCLAIMER: This demo is for research purposes only and does not provide medical advice.</small>")
 
     return demo
 
-# === Startup
+# === Main
 if __name__ == "__main__":
     freeze_support()
-
     try:
         agent = TxAgent(
             model_name=model_name,
@@ -150,10 +133,8 @@ if __name__ == "__main__":
         demo.queue().launch(
             server_name="0.0.0.0",
             server_port=7860,
-            show_error=True,
-            share=True
+            show_error=True
         )
-
     except Exception as e:
         print(f"❌ App failed to start: {e}")
         raise