Update app.py

app.py

@@ -1,5 +1,5 @@
 """
-Agent Ken — Data-Informed PM + Social Impact Copilot
+Agent Ken — Data-Informed PM + AI Copilot
 Powered by Azure AI Foundry + Microsoft Fabric
 Hugging Face Space (Gradio) — with file upload support
 """
@@ -11,14 +11,14 @@ from azure.ai.projects import AIProjectClient
 from azure.identity import ClientSecretCredential
 from azure.ai.agents.models import ListSortOrder, FilePurpose, MessageAttachment, CodeInterpreterTool
 
-# Azure config 
+# Azure config
 PROJECT_ENDPOINT = os.environ["PROJECT_ENDPOINT"]
 AGENT_ID = os.environ["AGENT_ID"]
 AZURE_TENANT_ID = os.environ["AZURE_TENANT_ID"]
 AZURE_CLIENT_ID = os.environ["AZURE_CLIENT_ID"]
 AZURE_CLIENT_SECRET = os.environ["AZURE_CLIENT_SECRET"]
 
-# Azure client
+# Azure client 
 credential = ClientSecretCredential(
     tenant_id=AZURE_TENANT_ID,
     client_id=AZURE_CLIENT_ID,
@@ -36,7 +36,7 @@ def get_agent():
     return _agent
 
 
-# Supported file types
+# Supported file types 
 SUPPORTED_EXTENSIONS = {
     ".csv", ".xlsx", ".xls", ".json",
     ".txt", ".md", ".pdf",
@@ -54,9 +54,16 @@ def is_supported_file(filename: str) -> bool:
 
 # Chat logic 
 def respond(user_message: str, uploaded_files, history: list, thread_state: dict | None):
-    if not user_message.strip() and not uploaded_files:
+    # Normalize inputs
+    user_message = (user_message or "").strip()
+    if not uploaded_files:
+        uploaded_files = []
+
+    # Nothing to send
+    if not user_message and not uploaded_files:
         return history, thread_state
 
+    # Create thread if needed
     if thread_state is None or "thread_id" not in thread_state:
         thread = project.agents.threads.create()
         thread_state = {"thread_id": thread.id}
@@ -66,28 +73,42 @@ def respond(user_message: str, uploaded_files, history: list, thread_state: dict
     try:
         agent = get_agent()
 
-        # Handle file uploads
+        # Handle file uploads 
         attachments = []
         file_names = []
 
-        if uploaded_files:
-            for file_path in uploaded_files:
-                filename = os.path.basename(file_path)
-
-                if not is_supported_file(filename):
-                    history.append({"role": "user", "content": user_message})
-                    history.append({
-                        "role": "assistant",
-                        "content": f"⚠️ File `{filename}` tidak didukung. Format yang didukung: CSV, Excel, PDF, Word, TXT, PNG, JPG, JSON, dan lainnya."
-                    })
-                    return history, thread_state
+        for file_path in uploaded_files:
+            # Gradio returns NamedString or str path
+            path_str = str(file_path)
+            filename = os.path.basename(path_str)
+
+            # Check file exists on disk
+            if not os.path.exists(path_str):
+                history.append({"role": "user", "content": user_message or f"📎 {filename}"})
+                history.append({
+                    "role": "assistant",
+                    "content": f"⚠️ File `{filename}` could not be read. Please re-upload and try again."
+                })
+                return history, thread_state
+
+            # Check supported type
+            if not is_supported_file(filename):
+                history.append({"role": "user", "content": user_message or f"📎 {filename}"})
+                history.append({
+                    "role": "assistant",
+                    "content": (
+                        f"⚠️ File `{filename}` is not supported.\n\n"
+                        f"**Supported formats:** CSV, Excel, PDF, Word, TXT, PNG, JPG, JSON, PowerPoint, Python, HTML, XML."
+                    )
+                })
+                return history, thread_state
 
-                # Upload file to Azure
+            # Upload to Azure
+            try:
                 uploaded = project.agents.files.upload_and_poll(
-                    file_path=file_path,
+                    file_path=path_str,
                     purpose=FilePurpose.AGENTS,
                 )
-
                 attachments.append(
                     MessageAttachment(
                         file_id=uploaded.id,
@@ -95,29 +116,45 @@ def respond(user_message: str, uploaded_files, history: list, thread_state: dict
                     )
                 )
                 file_names.append(filename)
+            except Exception as upload_err:
+                history.append({"role": "user", "content": user_message or f"📎 {filename}"})
+                history.append({
+                    "role": "assistant",
+                    "content": f"⚠️ Failed to upload `{filename}`: {str(upload_err)}\n\nPlease try again."
+                })
+                return history, thread_state
 
         # Build message content
-        if file_names and user_message.strip():
-            content = f"{user_message}\n\n📎 Files uploaded: {', '.join(file_names)}"
+        if file_names and user_message:
+            # User typed something + uploaded files
+            content = (
+                f"{user_message}\n\n"
+                f"📎 Uploaded files: {', '.join(file_names)}\n\n"
+                f"Instructions: Read and analyze the uploaded file(s) immediately using code interpreter. "
+                f"Show the data structure, key findings, and actionable insights. "
+                f"Do NOT ask the user to re-upload or confirm — the file is already attached and accessible."
+            )
         elif file_names:
-            content = f"Analisa file berikut: {', '.join(file_names)}"
+            # Only files, no message
+            content = (
+                f"📎 Uploaded files: {', '.join(file_names)}\n\n"
+                f"Instructions: Read and analyze the uploaded file(s) immediately using code interpreter. "
+                f"Show a summary of the data (columns, rows, data types), then provide key findings, "
+                f"trends, and actionable insights. Start analyzing right away."
+            )
         else:
             content = user_message
 
-        # Send message with attachments
+        # Send message to Azure
+        msg_kwargs = {
+            "thread_id": thread_id,
+            "role": "user",
+            "content": content,
+        }
         if attachments:
-            project.agents.messages.create(
-                thread_id=thread_id,
-                role="user",
-                content=content,
-                attachments=attachments,
-            )
-        else:
-            project.agents.messages.create(
-                thread_id=thread_id,
-                role="user",
-                content=content,
-            )
+            msg_kwargs["attachments"] = attachments
+
+        project.agents.messages.create(**msg_kwargs)
 
         # Run agent
         run = project.agents.runs.create_and_process(
@@ -134,7 +171,7 @@ def respond(user_message: str, uploaded_files, history: list, thread_state: dict
             messages = project.agents.messages.list(
                 thread_id=thread_id, order=ListSortOrder.DESCENDING
             )
-            assistant_reply = "🤔 No response received."
+            assistant_reply = "🤔 No response received. Please try again."
             for msg in messages:
                 if msg.role == "assistant" and msg.text_messages:
                     assistant_reply = msg.text_messages[-1].text.value
@@ -142,13 +179,13 @@ def respond(user_message: str, uploaded_files, history: list, thread_state: dict
 
     except Exception as e:
         assistant_reply = (
-            f"❌ Error: {str(e)}\n\n"
-            "Please try again. If this persists, the Azure endpoint may be unavailable."
+            f"❌ Connection error: {str(e)}\n\n"
+            "Please try again. If this persists, the Azure endpoint may be temporarily unavailable."
         )
 
-    # Display with file indicator
+    # Display in chat
     if file_names:
-        display_msg = f"{user_message}\n\n📎 {', '.join(file_names)}" if user_message.strip() else f"📎 {', '.join(file_names)}"
+        display_msg = f"{user_message}\n\n📎 {', '.join(file_names)}" if user_message else f"📎 {', '.join(file_names)}"
     else:
         display_msg = user_message
 
@@ -161,7 +198,7 @@ def new_conversation():
     return [], None
 
 
-# CSS 
+# CSS
 CSS = """
 @import url('https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap');
 
@@ -348,14 +385,14 @@ EXAMPLES = [
     ["Were there any anomalies in our metrics recently?"],
 ]
 
-# UI/UX 
+# UI
 with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
 
     # Header
     gr.HTML("""
         <div class="header-main">
             <h1>🤖 Agent Ken</h1>
-            <p class="tagline">Data-Informed PM + Social Impact Copilot</p>
+            <p class="tagline">Your AI Companion for Product Management & Data</p>
         </div>
     """)
 
@@ -373,8 +410,10 @@ with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
     gr.HTML("""
         <div class="welcome-card">
             <span class="wave">👋</span>
-            <h2>Hi, I'm Agent Ken — your Data-Informed Product Manager Copilot</h2>
-            <p>I help you learn product management — from strategy and frameworks to real-world execution. I also share practical insights on AI technology and my own findings from building data pipelines and ML models in Microsoft Fabric.</p>
+            <h2>Hi, I'm Agent Ken — your AI Companion for Product Management & Data</h2>
+            <p>I help you learn product management, explore AI technology, and discover insights from
+            my hands-on experience with Microsoft Fabric — including data pipelines, ML models,
+            and turning raw data into real product decisions.</p>
             <div class="welcome-tags">
                 <span>📊 Live Product Data</span>
                 <span>🔮 Churn Prediction</span>
@@ -382,7 +421,7 @@ with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
                 <span>⚠️ Anomaly Detection</span>
                 <span>🧪 A/B Test Results</span>
                 <span>📝 PRDs & Strategy</span>
-                <span>♿ Inclusive Design</span>
+                <span>🤖 AI & Tech</span>
             </div>
         </div>
     """)
@@ -425,7 +464,6 @@ with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
         <div class="upload-hint">
             📎 <strong>You can also upload your files!</strong> (Supported: CSV, Excel, PDF, Word, Images, TXT, JSON.)
             I'll analyze them and give you insights — and if you want, I can compare your data against our Fabric benchmark.
-
         </div>
     """)
 
@@ -437,10 +475,10 @@ with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
 
     thread_state = gr.State(value=None)
 
-    # Input row (text + send only)
+    # Input row (text + send)
     with gr.Row():
         msg_input = gr.Textbox(
-            placeholder="Ask about metrics, AI, tech, my Fabric finding or any other related PM question...",
+            placeholder="Ask about metrics, upload a file, or any PM/tech question...",
             label="",
             show_label=False,
             scale=5,
@@ -454,7 +492,7 @@ with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
     with gr.Row():
         clear_btn = gr.Button("🗑️ New Conversation", variant="secondary", size="sm", scale=1)
 
-    # File upload (hidden inside accordion — clean)
+    # File upload (inside accordion — clean)
     with gr.Accordion("📎 Upload a file (CSV, Excel, PDF, Word, Images, JSON)", open=False):
         file_input = gr.File(
             label="",
@@ -484,7 +522,7 @@ with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
         </div>
     """)
 
-    # Events 
+    # Events
     send_btn.click(
         fn=respond,
         inputs=[msg_input, file_input, chatbot, thread_state],
@@ -503,4 +541,4 @@ with gr.Blocks(title="Agent Ken — Data-Informed PM Copilot") as demo:
     )
 
 if __name__ == "__main__":
-    demo.launch(server_name="0.0.0.0", server_port=7860, css=CSS, theme=gr.themes.Soft())
+    demo.launch(server_name="0.0.0.0", server_port=7860, css=CSS, theme=gr.themes.Soft())