Function run_agent

core/agent.py:613–1257

(user_message, history, yolo=False, use_plan=False, no_plan=False, _in_subtask=False, _plan_rag_block="")

def run_agent(user_message, history, yolo=False, use_plan=False, no_plan=False, _in_subtask=False, _plan_rag_block=""):
    # Reset streaming flag at start of each agent turn
    import core.inference_v2 as _inf_mod
    _inf_mod._last_was_streamed = False

    # Learn preferences from natural language in the user's message
    _get_learning().learn_from_message(user_message)

    # ── Explicit peer delegation ──────────────────────────────────────────────
    # Handle: "ask gemini to X", "have claude do X", etc.
    # The peer runs, its output is injected as context, then the agent applies it.
    if not _in_subtask:
        _peer_name, _peer_task = _detect_peer_delegation(user_message)
        if _peer_name and _peer_task:
            from core.peer_cli import get_peer_cli_manager
            _mgr = get_peer_cli_manager()
            _by_name = {c.name: c for c in _mgr.available()}
            if _peer_name in _by_name:
                _cli = _by_name[_peer_name]

                # For review/check/verify tasks, build rich context with current file contents
                # so the peer actually has something to review.
                _REVIEW_KW = {
                    "check", "review", "verify", "test", "examine",
                    "correct", "validate", "look at", "is it right", "did i"
                }
                _is_review = any(k in _peer_task.lower() for k in _REVIEW_KW)

                # ── Design-only phase detection ───────────────────────────────
                # When the peer is asked to "design / plan / spec / outline"
                # without any implement/build/code verb, we use prose instructions
                # and save the output as a .md design document instead of trying
                # to extract code blocks — which would corrupt the pipeline.
                _STRONG_DESIGN = re.compile(
                    r'\b(design|plan|spec(?:ify)?|specification|outline|blueprint|'
                    r'architecture|feature\s+list|roadmap|requirements?)\b',
                    re.IGNORECASE,
                )
                _STRONG_IMPLEMENT = re.compile(
                    r'\b(implement|build|code|develop|program|write\s+(?:code|it|the)|'
                    r'make\s+it\s+work|working\s+version)\b',
                    re.IGNORECASE,
                )
                _is_design_only = (
                    not _is_review  # review tasks always use code output format
                    and bool(_STRONG_DESIGN.search(_peer_task))
                    and not bool(_STRONG_IMPLEMENT.search(_peer_task))
                )

                # Output format instructions — Codey extracts code blocks to write files.
                # Claude -p returns plain text; without explicit format instructions it
                # asks for permission or returns prose instead of extractable code.
                _FORMAT_INSTRUCTIONS = (
                    "\n\nOUTPUT FORMAT (required — Codey will parse this automatically):\n"
                    "You are responding to an automated system. Do NOT ask for permission.\n"
                    "Do NOT ask clarifying questions. Act immediately.\n"
                    "For each file to create or modify, output it using this exact format:\n\n"
                    "**`filename.py`**\n"