auto-call downloader every day

Cargo.lock

@@ -194,6 +194,15 @@ version = "0.8.7"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "773648b94d0e5d620f64f280777445740e61fe701025087ec8b57f45c791888b"
 
+[[package]]
+name = "croner"
+version = "2.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c344b0690c1ad1c7176fe18eb173e0c927008fdaaa256e40dfd43ddd149c0843"
+dependencies = [
+ "chrono",
+]
+
 [[package]]
 name = "displaydoc"
 version = "0.2.5"
@@ -689,30 +698,6 @@ version = "0.8.4"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "47e1ffaa40ddd1f3ed91f717a33c8c0ee23fff369e3aa8772b9605cc1d22f4c3"
 
-[[package]]
-name = "maud"
-version = "0.27.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "8156733e27020ea5c684db5beac5d1d611e1272ab17901a49466294b84fc217e"
-dependencies = [
- "axum-core",
- "http",
- "itoa",
- "maud_macros",
-]
-
-[[package]]
-name = "maud_macros"
-version = "0.27.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "7261b00f3952f617899bc012e3dbd56e4f0110a038175929fa5d18e5a19913ca"
-dependencies = [
- "proc-macro2",
- "proc-macro2-diagnostics",
- "quote",
- "syn",
-]
-
 [[package]]
 name = "mediatype"
 version = "0.20.0"
@@ -751,6 +736,17 @@ dependencies = [
  "windows-sys 0.59.0",
 ]
 
+[[package]]
+name = "num-derive"
+version = "0.4.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ed3955f1a9c7c0c15e092f9c887db08b1fc683305fdf6eb6684f22555355e202"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
 [[package]]
 name = "num-traits"
 version = "0.2.19"
@@ -824,13 +820,12 @@ dependencies = [
  "axum",
  "bytes",
  "chrono",
- "maud",
  "reqwest",
  "serde_json",
  "stream-download",
  "tokio",
+ "tokio-cron-scheduler",
  "tokio-stream",
- "tracing",
 ]
 
 [[package]]
@@ -860,18 +855,6 @@ dependencies = [
  "unicode-ident",
 ]
 
-[[package]]
-name = "proc-macro2-diagnostics"
-version = "0.10.1"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "af066a9c399a26e020ada66a034357a868728e72cd426f3adcd35f80d88d88c8"
-dependencies = [
- "proc-macro2",
- "quote",
- "syn",
- "version_check",
-]
-
 [[package]]
 name = "quinn"
 version = "0.11.8"
@@ -1361,6 +1344,21 @@ dependencies = [
  "windows-sys 0.59.0",
 ]
 
+[[package]]
+name = "tokio-cron-scheduler"
+version = "0.14.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5c71ce8f810abc9fabebccc30302a952f9e89c6cf246fafaf170fef164063141"
+dependencies = [
+ "chrono",
+ "croner",
+ "num-derive",
+ "num-traits",
+ "tokio",
+ "tracing",
+ "uuid",
+]
+
 [[package]]
 name = "tokio-macros"
 version = "2.5.0"
@@ -1520,10 +1518,15 @@ source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "b6c140620e7ffbb22c2dee59cafe6084a59b5ffc27a8859a5f0d494b5d52b6be"
 
 [[package]]
-name = "version_check"
+name = "uuid"
-version = "0.9.5"
+version = "1.18.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0b928f33d975fc6ad9f86c8f283853ad26bdd5b10b7f1542aa2fa15e2289105a"
+checksum = "f33196643e165781c20a5ead5582283a7dacbb87855d867fbc2df3f81eddc1be"
+dependencies = [
+ "getrandom 0.3.3",
+ "js-sys",
+ "wasm-bindgen",
+]
 
 [[package]]
 name = "want"

Cargo.toml

@@ -11,7 +11,6 @@ reqwest = { version = "0.12", features = ["stream", "json", "rustls-tls"], defau
 bytes = "1"
 async-stream = "0.3"
 serde_json = "1"
-tracing = "0.1"
 stream-download = "0.22"
 chrono = "0.4"
-maud = { version = "0.27", features = ["axum"] }
+tokio-cron-scheduler = "0.14.0"

src/lib.rs

@@ -16,11 +16,11 @@ async fn get_newest_morning_journal() -> Result<String, Box<dyn std::error::Erro
         for day in days.iter().rev() {
             if let Some(broadcasts) = day["broadcasts"].as_array() {
                 for broadcast in broadcasts.iter().rev() {
-                    if broadcast["title"] == "Ö1 Morgenjournal" {
+                    //if broadcast["title"] == "Ö1 Morgenjournal" {
-                        if let Some(href) = broadcast["href"].as_str() {
+                    if broadcast["title"] == "Eröffnungskonzert Allegro Vivo"
+                        && let Some(href) = broadcast["href"].as_str() {
                             return Ok(href.into());
                         }
-                    }
                 }
             }
         }

src/main.rs

@@ -1,109 +1,38 @@
 mod state;
 mod streamer;
 
-use axum::{response::IntoResponse, routing::get, Router};
+use axum::{routing::get, Router};
-use maud::{html, Markup, DOCTYPE};
+use chrono::Utc;
-use reqwest::header;
 use state::AppState;
 use std::sync::Arc;
-
+use tokio_cron_scheduler::{Job, JobScheduler};
-async fn index() -> Markup {
-    html! {
-        (DOCTYPE)
-        html lang="en" {
-            head {
-                meta charset="utf-8";
-                meta name="viewport" content="user-scalable=no";
-                title { "Ö1 Morgenjournal" }
-                link rel="stylesheet" href="/styles.css";
-            }
-            body {
-                // Top Info
-                div #title {
-                    span #track {}
-                    div #timer { "0:00" }
-                    div #duration { "0:00" }
-                }
-
-                // Controls
-                div .controlsOuter {
-                    div .controlsInner {
-                        div #loading {}
-                        div .btn #playBtn {}
-                        div .btn #pauseBtn {}
-                        div .btn #prevBtn {}
-                        div .btn #nextBtn {}
-                    }
-                    div .btn #playlistBtn {}
-                    div .btn #volumeBtn {}
-                }
-
-                // Progress
-                div #waveform {}
-                div #bar {}
-                div #progress {}
-
-                // Playlist
-                div #playlist {
-                    div #list {}
-                }
-
-                // Volume
-                div #volume .fadeout {
-                    div #barFull .bar {}
-                    div #barEmpty .bar {}
-                    div #sliderBtn {}
-                }
-
-                // Scripts
-                script src="/howler.core.min.js" {}
-                script src="/siriwave.js" {}
-                script src="/player.js" {}
-            }
-        }
-    }
-}
-
-async fn styles() -> impl IntoResponse {
-    (
-        [(header::CONTENT_TYPE, "text/css")],
-        include_str!("../static/styles.css"),
-    )
-}
-
-async fn howler() -> impl IntoResponse {
-    (
-        [(header::CONTENT_TYPE, "text/javascript")],
-        include_str!("../static/howler.core.min.js").to_string(),
-    )
-}
-
-async fn player() -> impl IntoResponse {
-    (
-        [(header::CONTENT_TYPE, "text/javascript")],
-        include_str!("../static/player.js").to_string(),
-    )
-}
-
-async fn siriwave() -> impl IntoResponse {
-    (
-        [(header::CONTENT_TYPE, "text/javascript")],
-        include_str!("../static/siriwave.js").to_string(),
-    )
-}
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let state = Arc::new(AppState::new());
 
     let app = Router::new()
-        .route("/", get(index))
+        .route("/", get(streamer::stream_handler))
-        .route("/stream", get(streamer::stream_handler))
+        .with_state(state.clone());
-        .route("/howler.core.min.js", get(howler))
+
-        .route("/styles.css", get(styles))
+    let scheduler = JobScheduler::new().await.unwrap();
-        .route("/player.js", get(player))
+    scheduler
-        .route("/siriwave.js", get(siriwave))
+        .add(
-        .with_state(state);
+            Job::new_async(
+                "30 0 7 * * Mon,Tue,Wed,Thu,Fri,Sat",
+                move |_uuid, _locked| {
+                    let state_for_task = state.clone();
+                    Box::pin(async move {
+                        state_for_task.check_update().await;
+                        println!("Task executed at: {}", Utc::now());
+                    })
+                },
+            )
+            .unwrap(),
+        )
+        .await
+        .unwrap();
+    scheduler.start().await.unwrap();
 
     println!("Streaming server running on http://localhost:3029");
 

src/state.rs

@@ -25,11 +25,10 @@ impl AppState {
 
     pub async fn check_update(self: Arc<Self>) {
         let today = Local::now().date_naive();
-        if let Some(downloaded_on_day) = *self.downloaded_on_day.read().await {
+        if let Some(downloaded_on_day) = *self.downloaded_on_day.read().await
-            if today == downloaded_on_day {
+            && today == downloaded_on_day {
                 return;
             }
-        }
 
         self.reset().await;
         *self.downloaded_on_day.write().await = Some(today);