Inter-agent communication

class Message:
    def __init__(self, sender, recipient, content, msg_type="request"):
        self.sender = sender
        self.recipient = recipient
        self.content = content
        self.msg_type = msg_type

class CommunicationHub:
    def __init__(self):
        self.agents = {}
        self.message_history = []

    def register_agent(self, agent):
        self.agents[agent.name] = agent

    def send_message(self, sender, recipient, content, msg_type="request"):
        message = Message(sender, recipient, content, msg_type)
        self.agents[recipient].receive_message(message)
        self.message_history.append(message)
        return message

    def process_all_messages(self):
        responses = []
        for agent in self.agents.values():
            agent_responses = agent.process_messages()
            responses.extend(agent_responses)
        # Deliver responses back
        for response in responses:
            self.agents[response.recipient].receive_message(response)