Struct Notifier 

pub struct Notifier { /* private fields */ }

Per-turn completion notifier.

Holds a shared reqwest::Client and the resolved config. Construct once at agent startup via Notifier::new and call Notifier::fire after each turn.

All I/O is routed through the agent’s BackgroundSupervisor so it is visible in TUI status and bounded by the Telemetry class concurrency limit. fire returns immediately without blocking the agent loop.

Cloning is cheap — reqwest::Client is an Arc-backed handle.

Implementations

impl Notifier

pub fn new(cfg: NotificationsConfig) -> Self

Create a notifier from a NotificationsConfig.

Constructs a shared HTTP client with a 5-second connect timeout. The client is reused across all webhook calls for the agent session.

If webhook_url is set but fails URL validation (unparseable or non-HTTP(S) scheme), it is cleared to None and a warning is logged. This prevents SSRF via malformed URLs (e.g. file://, ftp://).

pub fn should_fire(&self, summary: &TurnSummary) -> bool

Evaluate all gate conditions and return true when the notification should fire.

Gates applied in order (all must pass):

1. enabled is true
2. summary.llm_requests > 0 (zero-LLM turns are never notified)
3. If only_on_error: turn must have errored
4. For successful turns: duration_ms >= min_turn_duration_ms (error turns bypass the duration gate)

pub async fn fire_test(&self) -> Result<(), NotifyTestError>

Fire a test notification with a fixed message.

Used by the zeph notify test CLI subcommand. Returns an error if all channels are disabled or if every channel failed.

Errors

• NotifyTestError::AllDisabled — no channel is enabled
• NotifyTestError::MacOsFailed — macOS notification failed (macOS only)
• NotifyTestError::WebhookFailed — webhook POST failed

Trait Implementations

impl Clone for Notifier

fn clone(&self) -> Notifier

Returns a duplicate of the value.

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

Performs copy-assignment from source.