wehub-resource-sync
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")
|