0xallam
8414c59557
Five rounds of sweep across the tree. Net ~544 lines removed. Removed: - Section-divider banners and one-line section labels (# Display utilities, # ----- list_requests -----, # CVSS breakdown, etc.). - Module-level prose docstrings on internal modules. Kept one-line summaries; trimmed multi-paragraph narration about SDK/Strix responsibility splits, cache strategies, three-source precedence. - Internal-helper docstrings that just restate the function name — caido_api helpers (caido_url, get_client, view_request, etc.), settings-class one-liners (LLMSettings, RuntimeSettings, ...), UI helper docstrings. - Args/Returns blocks on non-LLM-facing internal helpers (build_strix_agent, render_system_prompt, create_or_reuse, bootstrap_caido) — kept only the genuinely non-obvious params. - Internal-history phrasing — "Mirrors main-branch shape", "pre-SDK harness", "previous lookup matched no attribute". - Narrative comments inside function bodies that explained what the next line does, design rationale obvious from the surrounding code, or "we used to..." asides. - Trailing periods on every error-string literal across the tool tree. - Duplicated roundtripTime quirk comment (kept the LLM-facing copy in tools/proxy/tools.py). Kept (every one names an upstream bug, vendored-code provenance, or non-obvious data quirk): - core/runner.py: SDK replay-with-empty-initial-input + on_agent_end lifecycle gap. - runtime/docker_client.py: VERBATIM COPY block of the upstream _create_container body, pinned to SDK v0.14.6. - runtime/session_manager.py: NO_PROXY for agent-browser CDP loopback. - tools/proxy/caido_api.py: generated-pydantic Request.raw quirk, replay double-history pitfall. - tools/proxy/tools.py: Caido roundtripTime=0 quirk for proxy captures. Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
44 lines
1.1 KiB
Python
44 lines
1.1 KiB
Python
"""Message delivery bridge from TUI input to SDK-backed agents."""
|
|
|
|
from __future__ import annotations
|
|
|
|
import asyncio
|
|
import logging
|
|
from typing import Any
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def send_user_message_to_agent(
|
|
*,
|
|
coordinator: Any,
|
|
loop: asyncio.AbstractEventLoop | None,
|
|
live_view: Any,
|
|
target_agent_id: str,
|
|
message: str,
|
|
) -> bool:
|
|
if loop is None or loop.is_closed():
|
|
return False
|
|
|
|
live_view.record_user_message(target_agent_id, message)
|
|
future = asyncio.run_coroutine_threadsafe(
|
|
coordinator.send(
|
|
target_agent_id,
|
|
{"from": "user", "content": message, "type": "instruction"},
|
|
),
|
|
loop,
|
|
)
|
|
future.add_done_callback(_log_delivery_failure)
|
|
return True
|
|
|
|
|
|
def _log_delivery_failure(future: Any) -> None:
|
|
try:
|
|
delivered = bool(future.result())
|
|
except Exception:
|
|
logger.exception("TUI user message delivery failed")
|
|
return
|
|
if not delivered:
|
|
logger.warning("TUI user message was not persisted to the SDK session")
|