timer-rs 0.0.6

A simple timer used to schedule execution of closures at a given timestamp.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

use anyhow::Result;
use axum::routing::post;
use axum::Router;
use timer_rs::Timer;
use tokio::signal;

#[tokio::main]
async fn main() -> Result<()> {
    // Initialize tracing.
    tracing_subscriber::fmt::init();

    let timer = Timer::new(|| {
        tracing::info!("task was executed");
        None
    })
    .with_graceful_shutdown(signal::ctrl_c());

    let scheduler = timer.scheduler();
    tokio::spawn(async move {
        let addr = "0.0.0.0:3000".parse().unwrap();

        // Build a application with a route.
        let app = Router::new()
            // `GET /` goes to `root`.
            .route("/", post(http::root))
            .with_state(http::AppState { scheduler });

        tracing::info!("listening on {}", addr);

        axum::Server::bind(&addr)
            .serve(app.into_make_service())
            .await
            .unwrap();
    });

    tokio::spawn(async move { timer.await }).await?;

    Ok(())
}

mod http {
    use axum::{extract::State, response::IntoResponse, Json};
    use chrono::NaiveDateTime;
    use timer_rs::Scheduler;

    #[derive(Clone)]
    pub struct AppState {
        pub scheduler: Scheduler,
    }

    #[derive(serde::Deserialize, serde::Serialize)]
    pub struct Payload {
        date: NaiveDateTime,
    }

    #[axum::debug_handler]
    pub async fn root(
        State(state): State<AppState>,
        Json(payload): Json<Payload>,
    ) -> impl IntoResponse {
        tracing::info!("received scheduling for {}", payload.date);
        state.scheduler.schedule(payload.date).await.unwrap();
    }
}