Struct SessionStatusNotifier 

pub struct SessionStatusNotifier { /* private fields */ }

Fire-and-forget handle for pushing a client-visible status update outside of the normal prompt-drain path.

Most agent output reaches the client through LoopbackChannel and is only flushed to the IDE as part of a session/prompt response (see helpers::loopback_event_to_updates and drain_agent_events). Some failures are discovered before any prompt is ever sent — e.g. session hydration in spawn_acp_agent (zeph binary crate) hitting SessionError::AlreadyLocked — so a client that never prompts, or whose first prompt is cancelled before the drain, would otherwise never learn persistence degraded (#5519). SessionStatusNotifier reuses the same per-session notification channel that ZephAcpAgentState::send_notification_nowait already drives for other proactive updates (e.g. available_commands_update), so it delivers immediately via the session’s notify drainer instead of waiting on the next prompt.

Implementations

impl SessionStatusNotifier

pub fn new(notify_tx: NotifySender, session_id: SessionId) -> Self

Builds a notifier bound to a session’s notification channel.

notify_tx is normally a SessionEntry’s own notify sender (see build_acp_context), so pushes from this notifier are drained by the same task that delivers this session’s session/update notifications to the client. pub (not pub(crate)) so integration tests outside this crate can bind a notifier to a plain mpsc::channel and assert on the receiving end directly, without constructing a full AcpContext/ACP connection.

Examples

use agent_client_protocol::schema::v1::SessionId;
use tokio::sync::mpsc;
use zeph_acp::SessionStatusNotifier;

let (tx, mut rx) = mpsc::channel(4);
let notifier = SessionStatusNotifier::new(tx, SessionId::new("session-1".to_owned()));
notifier.notify_status_nowait("degraded");
assert!(rx.try_recv().is_ok());

pub fn notify_status_nowait(&self, text: impl Into<String>)

Push a status message to the client immediately, without waiting for an ack.

Mirrors the AgentThoughtChunk shape loopback_event_to_updates already produces for LoopbackEvent::Status, so proactive and prompt-drained status messages render identically on the client. Errors (channel full or closed) are logged and swallowed — same tolerance as ZephAcpAgentState::send_notification_nowait.

Trait Implementations

impl Clone for SessionStatusNotifier

fn clone(&self) -> SessionStatusNotifier

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.