Merge pull request #1 from balureddy003/codex/create-simple-chat-agent-implementation

Add simple chat agent with chat history persistence

Author: balureddy003

src/backend/kernel_agents/simple_chat_agent.py

@@ -1,11 +1,79 @@
-from kernel_agents.generic_agent import GenericAgent
-from models.messages_kernel import AgentType
 
+from typing import List, Optional
 
-class SimpleChatAgent(GenericAgent):
-    """Agent for basic conversational interactions."""
+from context.cosmos_memory_kernel import CosmosMemoryContext
+from kernel_agents.agent_base import BaseAgent
+from models.messages_kernel import MessageRole, StoredMessage
+from semantic_kernel.functions import KernelFunction
+
+
+class SimpleChatAgent(BaseAgent):
+    """A minimal chat agent for open-ended conversation."""
+
+    def __init__(
+        self,
+        session_id: str,
+        user_id: str,
+        memory_store: CosmosMemoryContext,
+        tools: Optional[List[KernelFunction]] = None,
+        system_message: Optional[str] = None,
+        agent_name: str = "SimpleChatAgent",
+        client=None,
+        definition=None,
+    ) -> None:
+        super().__init__(
+            agent_name=agent_name,
+            session_id=session_id,
+            user_id=user_id,
+            memory_store=memory_store,
+            tools=tools,
+            system_message=system_message,
+            client=client,
+            definition=definition,
+        )
 
     @staticmethod
-    def default_system_message(agent_name: str = AgentType.SIMPLE_CHAT.value) -> str:
-        """Get the default system message for the SimpleChatAgent."""
-        return "You are a Simple Chat agent that engages in basic conversation and provides helpful responses."
+    def default_system_message(agent_name: str | None = None) -> str:
+        """Return the default system message for open-ended chat."""
+        name = agent_name or "assistant"
+        return (
+            f"You are {name}, a friendly AI for open-ended conversation. "
+            "Engage with the user naturally and helpfully."
+        )
+
+    async def handle_user_message(self, content: str) -> str:
+        """Process a user message, storing it and returning the agent's reply."""
+        # Record the user message locally and persist it
+        self._chat_history.append({"role": "user", "content": content})
+        await self._memory_store.add_item(
+            StoredMessage(
+                session_id=self._session_id,
+                user_id=self._user_id,
+                role=MessageRole.user,
+                content=content,
+                source=self._agent_name,
+            )
+        )
+
+        # Generate a reply from the underlying model
+        async_generator = self.invoke(messages=str(self._chat_history), thread=None)
+        response_content = ""
+        async for chunk in async_generator:
+            if chunk is not None:
+                response_content += str(chunk)
+
+        # Record the assistant's response
+        self._chat_history.append({"role": "assistant", "content": response_content})
+        await self._memory_store.add_item(
+            StoredMessage(
+                session_id=self._session_id,
+                user_id=self._user_id,
+                role=MessageRole.assistant,
+                content=response_content,
+                source=self._agent_name,
+            )
+        )
+
+        return response_content
+
+

src/backend/tests/test_simple_chat_agent.py

@@ -0,0 +1,45 @@
+import os
+import pytest
+
+# Set required environment variables before importing the agent
+os.environ.setdefault("AZURE_OPENAI_ENDPOINT", "https://mock-endpoint")
+os.environ.setdefault("AZURE_AI_SUBSCRIPTION_ID", "sub")
+os.environ.setdefault("AZURE_AI_RESOURCE_GROUP", "rg")
+os.environ.setdefault("AZURE_AI_PROJECT_NAME", "proj")
+os.environ.setdefault("AZURE_AI_AGENT_ENDPOINT", "https://agent-endpoint")
+
+from kernel_agents.simple_chat_agent import SimpleChatAgent
+from models.messages_kernel import MessageRole
+
+
+class DummyMemoryStore:
+    def __init__(self):
+        self.items = []
+
+    async def add_item(self, item):
+        self.items.append(item)
+
+
+@pytest.mark.asyncio
+async def test_handle_user_message_stores_and_replies():
+    memory_store = DummyMemoryStore()
+    agent = SimpleChatAgent(session_id="s", user_id="u", memory_store=memory_store)
+
+    async def fake_invoke(self, messages=None, thread=None):
+        yield "Hi there!"
+
+    agent.invoke = fake_invoke.__get__(agent, SimpleChatAgent)
+
+    response = await agent.handle_user_message("Hello")
+
+    assert response == "Hi there!"
+    assert agent._chat_history[-2:] == [
+        {"role": "user", "content": "Hello"},
+        {"role": "assistant", "content": "Hi there!"},
+    ]
+    assert len(memory_store.items) == 2
+    assert memory_store.items[0].content == "Hello"
+    assert memory_store.items[0].role == MessageRole.user
+    assert memory_store.items[1].content == "Hi there!"
+    assert memory_store.items[1].role == MessageRole.assistant
+