Upload app (2).py

app (2).py

@@ -0,0 +1,180 @@
+"""
+Agent Ken — PM + Social Impact Copilot
+Hugging Face Space (Gradio) → Azure AI Foundry Agent Service
+"""
+
+import os
+import gradio as gr
+from azure.ai.projects import AIProjectClient
+from azure.identity import ClientSecretCredential
+from azure.ai.agents.models import ListSortOrder
+
+# ── Azure config (from HF Space secrets) ──────────────────────────
+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 (singleton) ──────────────────────────────────────
+credential = ClientSecretCredential(
+    tenant_id=AZURE_TENANT_ID,
+    client_id=AZURE_CLIENT_ID,
+    client_secret=AZURE_CLIENT_SECRET,
+)
+project = AIProjectClient(credential=credential, endpoint=PROJECT_ENDPOINT)
+agent = project.agents.get_agent(AGENT_ID)
+
+
+# ── Chat logic ────────────────────────────────────────────────────
+def respond(user_message: str, history: list, thread_state: dict | None):
+    """
+    Gradio calls this for every user message.
+    - Creates a new Azure thread on first message (per session).
+    - Sends user message → runs agent → returns assistant reply.
+    """
+    if not user_message.strip():
+        return history, thread_state
+
+    # First message in session → create new thread
+    if thread_state is None or "thread_id" not in thread_state:
+        thread = project.agents.threads.create()
+        thread_state = {"thread_id": thread.id}
+
+    thread_id = thread_state["thread_id"]
+
+    try:
+        # Send user message
+        project.agents.messages.create(
+            thread_id=thread_id,
+            role="user",
+            content=user_message,
+        )
+
+        # Run agent
+        run = project.agents.runs.create_and_process(
+            thread_id=thread_id,
+            agent_id=agent.id,
+        )
+
+        if run.status == "failed":
+            assistant_reply = (
+                f"⚠️ Agent run failed: {run.last_error}\n\n"
+                "Please try again or start a new conversation."
+            )
+        else:
+            # Get latest assistant message
+            messages = project.agents.messages.list(
+                thread_id=thread_id, order=ListSortOrder.DESCENDING
+            )
+            assistant_reply = "🤔 No response received."
+            for msg in messages:
+                if msg.role == "assistant" and msg.text_messages:
+                    assistant_reply = msg.text_messages[-1].text.value
+                    break
+
+    except Exception as e:
+        assistant_reply = (
+            f"❌ Error: {str(e)}\n\n"
+            "Please try again. If this persists, the Azure endpoint may be unavailable."
+        )
+
+    history.append({"role": "user", "content": user_message})
+    history.append({"role": "assistant", "content": assistant_reply})
+    return history, thread_state
+
+
+def new_conversation():
+    """Reset chat history and thread state."""
+    return [], None
+
+
+# ── Gradio UI ─────────────────────────────────────────────────────
+DESCRIPTION = """
+# 🤖 Agent Ken — PM + Social Impact Copilot
+
+A **Product Manager Copilot** with a social worker's empathy and harm-reduction lens.  
+Built on Azure AI Foundry Agent Service.
+
+**What I can help with:**
+- 🔍 Product discovery (JTBD, personas, problem statements)
+- 📊 Prioritization (RICE scoring, MoSCoW)
+- 📝 PRDs, user stories, acceptance criteria
+- 🧪 Experiment design (A/B tests, hypothesis templates)
+- 📈 Metrics & OKRs (North Star, funnels, guardrails)
+- 🤝 Stakeholder communication (memos, updates, FAQs)
+- ♿ Inclusive & ethical design considerations
+
+---
+*Created by Kendrick Filbert • Powered by Azure AI Foundry*
+"""
+
+EXAMPLES = [
+    "Help me write a PRD for a mobile mental health check-in feature",
+    "Score these 3 features using RICE: onboarding revamp, dark mode, referral program",
+    "Design an A/B test for our new checkout flow",
+    "What metrics should I track for a community-driven marketplace?",
+    "Help me draft a stakeholder memo about delaying our launch by 2 weeks",
+    "Review this user story for accessibility concerns",
+]
+
+CSS = """
+.gradio-container { max-width: 850px !important; }
+footer { display: none !important; }
+"""
+
+with gr.Blocks(css=CSS, title="Agent Ken — PM Copilot", theme=gr.themes.Soft()) as demo:
+
+    gr.Markdown(DESCRIPTION)
+
+    chatbot = gr.Chatbot(
+        label="Agent Ken",
+        height=500,
+        type="messages",
+        avatar_images=(None, "https://em-content.zobj.net/source/twitter/408/robot_1f916.png"),
+        show_copy_button=True,
+    )
+
+    # State: thread_id per session (not visible to user)
+    thread_state = gr.State(value=None)
+
+    with gr.Row():
+        msg_input = gr.Textbox(
+            placeholder="Ask Agent Ken anything about product management...",
+            label="Your message",
+            scale=5,
+            lines=1,
+            max_lines=4,
+        )
+        send_btn = gr.Button("Send 🚀", variant="primary", scale=1)
+
+    with gr.Row():
+        clear_btn = gr.Button("🗑️ New Conversation", variant="secondary")
+
+    with gr.Accordion("💡 Example prompts", open=False):
+        gr.Examples(
+            examples=EXAMPLES,
+            inputs=msg_input,
+        )
+
+    # ── Event bindings ────────────────────────────────────────────
+    send_btn.click(
+        fn=respond,
+        inputs=[msg_input, chatbot, thread_state],
+        outputs=[chatbot, thread_state],
+    ).then(lambda: "", outputs=msg_input)
+
+    msg_input.submit(
+        fn=respond,
+        inputs=[msg_input, chatbot, thread_state],
+        outputs=[chatbot, thread_state],
+    ).then(lambda: "", outputs=msg_input)
+
+    clear_btn.click(
+        fn=new_conversation,
+        outputs=[chatbot, thread_state],
+    )
+
+# ── Launch ────────────────────────────────────────────────────────
+if __name__ == "__main__":
+    demo.launch(server_name="0.0.0.0", server_port=7860)