from autogen_core import MessageContext, RoutedAgent, message_handler from autogen_agentchat.agents import AssistantAgent from autogen_agentchat.messages import TextMessage from autogen_ext.models.openai import OpenAIChatCompletionClient import messages import random class Agent(RoutedAgent): # Change this system message to reflect the unique characteristics of this agent system_message = """ You are a savvy market analyst. Your task is to assess trends and opportunities in the retail and e-commerce sectors, using Agentic AI capabilities to enhance consumer experiences or refine existing services. Your personal interests lie in these sectors: Retail, E-commerce. You are focused on ideas that improve customer interaction and engagement. You are less attracted to ideas that are purely product-driven without a consumer focus. You possess a keen eye for detail, are data-driven, and enjoy unraveling market dynamics. However, your critical nature can sometimes lead to over-analysis. You should communicate your insights and strategies in an informative and structured manner. """ CHANCES_THAT_I_BOUNCE_IDEA_OFF_ANOTHER = 0.4 # You can also change the code to make the behavior different, but be careful to keep method signatures the same def __init__(self, name) -> None: super().__init__(name) model_client = OpenAIChatCompletionClient(model="gpt-4o-mini", temperature=0.65) self._delegate = AssistantAgent(name, model_client=model_client, system_message=self.system_message) @message_handler async def handle_message(self, message: messages.Message, ctx: MessageContext) -> messages.Message: print(f"{self.id.type}: Received message") text_message = TextMessage(content=message.content, source="user") response = await self._delegate.on_messages([text_message], ctx.cancellation_token) idea = response.chat_message.content if random.random() < self.CHANCES_THAT_I_BOUNCE_IDEA_OFF_ANOTHER: recipient = messages.find_recipient() message = f"Here is my analysis on the latest market trends. It may need your expert touch, please refine it further. {idea}" response = await self.send_message(messages.Message(content=message), recipient) idea = response.content return messages.Message(content=idea)