Class DeepCodeRespondTool

nanobot/nanobot/agent/tools/deepcode.py:388–469

Respond to a DeepCode User-in-Loop interaction request.

class DeepCodeRespondTool(Tool):
    """Respond to a DeepCode User-in-Loop interaction request."""

    def __init__(self, api_url: str | None = None):
        self._api_url = api_url or _get_deepcode_url()

    @property
    def name(self) -> str:
        return "deepcode_respond"

    @property
    def description(self) -> str:
        return (
            "Respond to a DeepCode User-in-Loop interaction. "
            "When a DeepCode task is waiting for user input (e.g. requirement clarification, "
            "plan review), use this tool to submit the user's response. "
            "First check deepcode_status to see the pending interaction details."
        )

    @property
    def parameters(self) -> dict[str, Any]:
        return {
            "type": "object",
            "properties": {
                "task_id": {
                    "type": "string",
                    "description": "The task ID that is waiting for input",
                },
                "action": {
                    "type": "string",
                    "enum": ["submit", "confirm", "modify", "skip", "cancel"],
                    "description": "User's action: submit answers, confirm plan, modify, skip, or cancel",
                },
                "data": {
                    "type": "object",
                    "description": "Response data (e.g. answers to questions, modification feedback)",
                },
                "skipped": {
                    "type": "boolean",
                    "description": "Whether the user chose to skip this interaction. Default: false",
                },
            },
            "required": ["task_id", "action"],
        }

    async def execute(
        self,
        task_id: str,
        action: str,
        data: dict | None = None,
        skipped: bool = False,
        **kwargs: Any,
    ) -> str:
        try:
            async with httpx.AsyncClient(timeout=30.0) as client:
                response = await client.post(
                    f"{self._api_url}/api/v1/workflows/respond/{task_id}",
                    json={