Nanobot 项目最终整合报告

class Tool(ABC):
    @property
    @abstractmethod
    def name(self) -> str:
        """工具名称"""
        pass

    @property
    @abstractmethod
    def description(self) -> str:
        """工具描述 (给 LLM)"""
        pass

    @property
    @abstractmethod
    def parameters(self) -> dict[str, Any]:
        """JSON Schema 参数"""
        pass

    @abstractmethod
    async def execute(self, **kwargs: Any) -> str:
        """异步执行，返回字符串结果"""
        pass

msg = InboundMessage(
    channel="system",
    sender_id="subagent",
    chat_id=f"{origin_channel}:{origin_chat_id}",  # 路由信息
    content=announce_content,
)
await bus.publish_inbound(msg)

# HEARTBEAT.md 示例
# Pending Tasks

- [ ] Review PR #123
- [ ] Update documentation
- [ ] Deploy to staging

async def execute(self, command: str, **kwargs) -> str:
    process = await asyncio.create_subprocess_shell(
        command,
        stdout=asyncio.subprocess.PIPE,
        stderr=asyncio.subprocess.PIPE,
        cwd=cwd,
    )
    
    try:
        stdout, stderr = await asyncio.wait_for(
            process.communicate(),
            timeout=self.timeout  # 默认 60 秒
        )
    except asyncio.TimeoutError:
        process.kill()  # 立即终止进程
        return f"Error: Command timed out after {self.timeout} seconds"

async def execute(self, url: str, **kwargs) -> str:
    async with httpx.AsyncClient() as client:
        r = await client.get(
            url,
            headers={"User-Agent": USER_AGENT},
            follow_redirects=True,
            timeout=30.0
        )
        r.raise_for_status()
    # ... 处理响应 ...

class MessageTool(Tool):
    def __init__(
        self,
        send_callback: Callable[[OutboundMessage], Awaitable[None]],
        default_channel: str = "",
        default_chat_id: str = ""
    ):
        self._send_callback = send_callback
        self._default_channel = default_channel   # 动态上下文
        self._default_chat_id = default_chat_id  # 动态上下文
    
    def set_context(self, channel: str, chat_id: str) -> None:
        """Set current message context."""
        self._default_channel = channel
        self._default_chat_id = chat_id

# 每次处理消息前更新上下文
message_tool = self.tools.get("message")
if isinstance(message_tool, MessageTool):
    message_tool.set_context(msg.channel, msg.chat_id)

class SpawnTool(Tool):
    def __init__(self, manager: "SubagentManager"):
        self._manager = manager
        self._origin_channel = "cli"    # 默认值
        self._origin_chat_id = "direct"  # 默认值
    
    def set_context(self, channel: str, chat_id: str) -> None:
        """Set origin context for subagent announcements."""
        self._origin_channel = channel
        self._origin_chat_id = chat_id

channel = channel or self._default_channel  # 1. 显式参数优先
chat_id = chat_id or self._default_chat_id

# 工具返回错误
"Error: File not found: /tmp/data.json"

# LLM 看到错误后调整策略
# LLM: 让我检查一下目录