Struct UpdateCheckHandler 

pub struct UpdateCheckHandler { /* private fields */ }

TaskHandler that polls the GitHub releases API for a newer Zeph version.

On each execution, UpdateCheckHandler fetches the latest release from https://api.github.com/repos/bug-ops/zeph/releases/latest, compares the tag_name field against current_version using semantic versioning, and sends a human-readable notification message on notify_tx when a newer release is found.

Network and parse errors are logged as warnings; execute always returns Ok(()) so a transient failure does not stop the scheduler.

Examples

use tokio::sync::mpsc;
use zeph_scheduler::UpdateCheckHandler;

let (tx, mut rx) = mpsc::channel(1);
let handler = UpdateCheckHandler::new(env!("CARGO_PKG_VERSION"), tx);

use zeph_scheduler::TaskHandler;
handler
    .execute(&serde_json::Value::Null)
    .await
    .expect("update check should not fail");

// A notification is sent only when a newer version exists on GitHub.
if let Ok(msg) = rx.try_recv() {
    println!("{msg}");
}

Implementations

impl UpdateCheckHandler

pub fn new(current_version: &'static str, notify_tx: Sender<String>) -> Self

Create a new handler.

current_version should be env!("CARGO_PKG_VERSION"). Notifications are sent as formatted strings via notify_tx.

Panics

Panics if the underlying reqwest client cannot be constructed (unreachable in practice).

pub fn with_base_url(self, url: impl Into<String>) -> Self

Override the GitHub releases API URL.

Intended for tests only: point the handler at a local mock server so the test does not make real network requests.

Trait Implementations

impl TaskHandler for UpdateCheckHandler

fn execute( &self, _config: &Value, ) -> Pin<Box<dyn Future<Output = Result<(), SchedulerError>> + Send + '_>>

Execute the task with the provided configuration.