def connect_to(self, ai_bus:AIBus,target_id: str) -> None:
        """
        Connect to the agent with the given id
        """
        if self.is_connected:
            logger.warning(f"tunnel {self.tunnel_id} is already connected to {self.target_id}")
            return
        self.target_id = target_id
        self.target_type = "agent"
        self.ai_bus = ai_bus
        self.is_connected = True

        Connect to the agent with the given id
        
src/aios/frame/tunnel.py