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 spawned onto the Tokio runtime via tokio::spawn; 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 fn fire(&self, summary: &TurnSummary)

Fire all enabled notification channels for this turn summary.

Returns immediately — all I/O is spawned as a background task. Failures are logged at warn level and never propagated. The spawned task has an internal 5-second per-channel timeout.

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.