߲j-\dZddlZddlZddlmZej dZGddZy)a<User-facing status / warning / notice plumbing for ``AIAgent``. Safe printing, quiet-mode gating, deduped context-overflow warnings, and the buffered retry chatter that is shown only when every retry/fallback is exhausted. Extracted from ``run_agent.py``; every method resolves through ``AIAgent``'s MRO unchanged. N)ActivityProvenance run_agentceZdZdZdddefdZddddedefdZd efd Zd efd Zd e d e d dfdZ de de d e d dfdZ d efdZ de d dfdZ de d dfdZde d dfdZde deded dfdZdeded dfdZd+dZd+dZde d dfd Zd!e d dfd"Zd!e d dfd#Zde de d dfd$Zde d dfd%Zde d dfd&Zde d dfd'Zd+d(Zd+d)Zd+d*Zy),StatusOutputMixinzRStatus/warning/notice emission and retry-chatter buffering (see module docstring).F) diagnosticrct|ddry|r|jsy |jxst|i|y#tt f$rYywxYw)zPrint that swallows broken pipes / closed stdout (headless stdout can vanish mid-session); routes through ``self._print_fn`` so the CLI can inject an ANSI-aware renderer._mute_notification_replyFN)getattr_warning_presentation_enabled _print_fnprintOSError ValueError)selfrargskwargss 8/home/ubuntu/.hermes/hermes-agent/agent/status_output.py _safe_printzStatusOutputMixin._safe_printsY 43U ;  d@@B   $T^^ $ut 6v 6$   s>AA)forcerrct|ddry|r|jsy|s)t|dds0|jr |jr|j|i|yyy)uVerbose print — suppressed while tokens are streaming (allowed during tool execution) and after the main response; ``force=True`` bypasses both. ``suppress_status_output`` (``hermes chat -q``) wins.suppress_status_outputFN_mute_post_response)r r _has_stream_consumers_executing_toolsr)rrrrrs r_vprintzStatusOutputMixin._vprintso 415 9  d@@B  '> %  ))+, , G4  s&6A  A cxt|ddry|jxr|j xrt|dddk(S)a.True when quiet-mode tool summaries should print directly (CLI, no callback owns rendering); ``suppress_status_output`` always wins so ``[tool]``/``[done]`` never land in captured stdout. ``suppress_status_output`` (the strict machine-readable mode used by ``hermes chat -Q``) always wins: those flows neutralize the rendering callbacks, and without this gate the "no callback owns rendering" fallback would print ``[tool]``/``[done]`` spinner lines into the captured stdout it exists to keep clean (#93220). rFplatformcli)r quiet_modetool_progress_callbackr$s r _should_emit_quiet_tool_messagesz2StatusOutputMixin._should_emit_quiet_tool_messages3sB 415 9mt'B'B#BmwtU_acGdhmGmmrnameoriginNct||d}|r ||yy#t$rtjd||dYywxYw)uhInvoke ``self.(*args)`` if set, swallowing errors — a driver callback must never break the loop.Nz%s error in %sT)exc_info)r Exceptionloggerdebug)rr-r.rcbs r_call_callbackz StatusOutputMixin._call_callback@sM T4 &  LD   L -tVd K Ls "==kindmessagecddlm} |||r|jr!|j|j|d|j d|||y#t $rY!wxYw)zkPrint to the CLI (``_vprint(force=True)``) and forward to ``status_callback(kind, message)``. Never raises.r)is_warning_statusTrstatus_callbackr.N)gateway.warning_notificationsr9r r log_prefixr1r5)rr6r7r.r9s r_emit_status_kindz#StatusOutputMixin._emit_status_kindIskC $T73t7Y7Y7[ 0 :$ G -tWVL   s:A A$#A$c ddlm} |t|dt|ddt|ddS#t$rYywxYw)Nr)warning_notifications_enabled_notification_platformr'r)_notification_configT)r=rAr r1)rrAs rr z/StatusOutputMixin._warning_presentation_enabledSsOO 06jRW8XY4d;   s )2 >>c>ddlm}|j||y)zGA diagnostic on the lifecycle rail, without changing legacy formatting.rDiagnosticTextN)r=rF _emit_statusrr7rFs r_emit_diagnostic_statusz)StatusOutputMixin._emit_diagnostic_status^s@ .12rc,|jd|dy)zDEmit a lifecycle status message (CLI + gateway ``status_callback``). lifecyclerGr<Nr?rr7s rrGzStatusOutputMixin._emit_statuscs {GNKrc,|jd|dy)zdEmit a user-visible warning for degraded side paths where the turn continues but the user must know.warn _emit_warningr<NrLrMs rrPzStatusOutputMixin._emit_warninggs vwGrreasonpreflight_tokensthreshold_tokensc|xsdjddd}d|f}t|dd|k(ry||_ddlm}|d vr%|j d |d t j |j|j||| y)uWarn (deduped on the block *kind* — ``cooldown`` / ``ineffective`` — not the countdown string; cleared by ``_clear_context_overflow_warn``) when context is over the threshold but compression is blocked.unknown:rctx_overflow_blocked_last_ctx_overflow_warnN))CONTEXT_OVERFLOW_BLOCKED_WARNING_TEMPLATE)cooldown ineffectivezcompression blocked ()) provenance)tokens thresholdrQ) splitr rYagent.conversation_compressionrZ_touch_activityrAGENT_COMPRESSION_COOLDOWNrPformat)rrQrRrS _warn_kind _warn_keyrZs r_warn_context_overflow_blockedz0StatusOutputMixin._warn_context_overflow_blockedks) 00a8; +Z8 42D 9Y F '0$\ 4 4  #8!BOaO|O| } DKK#/?L  rcontext_lengthcpd|f}t|dd|k7r"||_|jd|dd|ddyy)aDeduped warning when uncompressed context exceeds the model limit; points the user at /compact. When compression is explicitly disabled (compression.enabled: false), long sessions can grow past the model context window with no compression to shrink them (#89297). Surface an actionable warning so the user knows to run /compact or enable compression. uncompressed_ctx_overflowrYNu⚠️ Session context (~,z, tokens) exceeds the model context window (~z tokens) with compression disabled (compression.enabled: false). Use /compact to compress history or enable compression in config.yaml.)r rYrP)rrRrirgs r#_warn_uncompressed_context_overflowz5StatusOutputMixin._warn_uncompressed_context_overflow|s_1.A 42D 9Y F+4D (   +,QRrc>ddlm}|j||yNrrE)r=rFr|)rryrFs r_emit_diagnostic_waitz'StatusOutputMixin._emit_diagnostic_waits@ ~d34rcZt|dd}| gx}|_|j||fy)zBuffer a retry/fallback line as ``(kind, text)`` until we know whether the turn recovered. ``kind`` is ``"status"`` (replays via ``_emit_status``), ``"vprint"`` (``_vprint(force=True)``) or ``"warn"`` (``_emit_warning``). _retry_status_bufferN)r rappend)rr6r7bufs r_buffer_retry_messagez'StatusOutputMixin._buffer_retry_messages5 d2D9 ;.0 0C$+ D'?#rc(|jd|y)NstatusrrMs r_buffer_statusz StatusOutputMixin._buffer_status ""8W5rc>ddlm}|j||yr~)r=rFrrHs r_buffer_diagnostic_statusz+StatusOutputMixin._buffer_diagnostic_statuss@ N734rc(|jd|y)NvprintrrMs r_buffer_vprintz StatusOutputMixin._buffer_vprintrrcDt|dd}|r|jyy)u=Drop buffered retry messages — call on successful recovery.rN)r clear)rrs r_clear_status_bufferz&StatusOutputMixin._clear_status_buffers"d2D9  IIK rct|dd}|syd|_t|tr|n|gD]} |j |y#t $rY#wxYw)a;Surface the one-shot fallback-switch notice on successful recovery: a provider switch is durable state operators must see, unlike the retry chatter ``_clear_status_buffer`` drops. Emitted once, then cleared; on terminal failure the buffered switch line is flushed instead (``_flush_status_buffer``)._pending_fallback_noticeN)r r isinstancelistrIr1)rrtitems r_emit_pending_fallback_noticez/StatusOutputMixin._emit_pending_fallback_noticesd94@ (,%(6FVH D ,,T2   sA AAcPd|_t|dd}|syt|}|j|j|j d}|D]G\}} ||vr |||n1|j r!|j|j|dIy#t$rYVwxYw)uZEmit buffered retry messages — call on terminal failure so the user sees what was tried.Nr)rrOTr:) rr rrrGrPr rr>r1)rrmessagesreplayr6msgs r_flush_status_bufferz&StatusOutputMixin._flush_status_buffers)-%d2D9 9  --t7I7IJ! ID# 6> F4L%99; '8%>d K    sAB B%$B%)rN)__name__ __module__ __qualname____doc__rrrr%r,strr5r?r rIrGrPintrhrmrorrrxr|rrrrrrrrrrrrs\49 T ,1U.D.d.T n$ nL3LsLtLMcMCMCMDM t 3s3t3 LCLDLHSHTH S C cf ko "CY\ae",NWcWdWScSdS 5#5$5 $# $ $ $6c6d65556c6d6  rr)rloggingr agent.session_activityr getLoggerr2rrrrrs5  5   ; 'TTr