philipp/oe1-player
1
0
Fork 0
Code Issues 3 Pull Requests Actions Packages Projects Releases Wiki Activity

be lazy and just return mp3 of orf
All checks were successful
CI/CD Pipeline / test (push) Successful in 4m27s
Details
CI/CD Pipeline / deploy (push) Successful in 5m55s
Details

Browse Source
This commit is contained in:
Philipp Hofer
2025-08-21 22:29:53 +02:00
parent eebea71fca
commit 34811c15af
2 changed files with 41 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/main.rs
View File

@@ -15,24 +15,24 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
.route("/", get(streamer::stream_handler)) .route("/", get(streamer::stream_handler))
.with_state(state.clone()); .with_state(state.clone());
let scheduler = JobScheduler::new().await.unwrap(); //let scheduler = JobScheduler::new().await.unwrap();
scheduler //scheduler
.add( // .add(
Job::new_async( // Job::new_async(
"30 0 7 * * Mon,Tue,Wed,Thu,Fri,Sat", // "30 0 7 * * Mon,Tue,Wed,Thu,Fri,Sat",
move |_uuid, _locked| { // move |_uuid, _locked| {
let state_for_task = state.clone(); // let state_for_task = state.clone();
Box::pin(async move { // Box::pin(async move {
state_for_task.check_update().await; // state_for_task.check_update().await;
println!("Task executed at: {}", Utc::now()); // println!("Task executed at: {}", Utc::now());
}) // })
}, // },
) // )
.unwrap(), // .unwrap(),
) // )
.await // .await
.unwrap(); // .unwrap();
scheduler.start().await.unwrap(); //scheduler.start().await.unwrap();
println!("Streaming server running on http://localhost:3029"); println!("Streaming server running on http://localhost:3029");

38
src/streamer.rs
View File

@@ -1,24 +1,32 @@
use crate::state::AppState; use crate::state::AppState;
use axum::{body::Body, extract::State, response::Response}; use axum::{
body::Body,
extract::State,
response::{Redirect, Response},
};
use player::newest_morning_journal_streaming_url;
use std::sync::Arc; use std::sync::Arc;
use tokio_stream::Stream; use tokio_stream::Stream;
pub async fn stream_handler(State(state): State<Arc<AppState>>) -> Response { pub async fn stream_handler(State(state): State<Arc<AppState>>) -> Redirect {
state.clone().check_update().await; let url = newest_morning_journal_streaming_url().await.unwrap();
Redirect::to(&url)
let stream = create_chunk_stream(state); //state.clone().check_update().await;
let body = Body::from_stream(stream);
Response::builder() //let stream = create_chunk_stream(state);
.header("Content-Type", "audio/mpeg") //let body = Body::from_stream(stream);
.header("Cache-Control", "no-cache, no-store, must-revalidate")
.header("Pragma", "no-cache") //Response::builder()
.header("Expires", "0") // .header("Content-Type", "audio/mpeg")
.header("Accept-Ranges", "none") // .header("Cache-Control", "no-cache, no-store, must-revalidate")
.header("Transfer-Encoding", "chunked") // .header("Pragma", "no-cache")
.header("X-Content-Duration", "infinity") // .header("Expires", "0")
.body(body) // .header("Accept-Ranges", "none")
.unwrap() // .header("Transfer-Encoding", "chunked")
// .header("X-Content-Duration", "infinity")
// .body(body)
// .unwrap()
} }
fn create_chunk_stream( fn create_chunk_stream(