diff --git a/.gitignore b/.gitignore index 9e02892..cacc1a2 100644 --- a/.gitignore +++ b/.gitignore @@ -6,7 +6,6 @@ target/ dist/ certificates/ audios/ -configs/ # Remove Cargo.lock from gitignore if creating an executable, leave it for libraries # More information here https://doc.rust-lang.org/cargo/guide/cargo-toml-vs-cargo-lock.html diff --git a/streamer/configs/streamer_configs.txt b/streamer/configs/streamer_configs.txt new file mode 100644 index 0000000..f62f6e0 --- /dev/null +++ b/streamer/configs/streamer_configs.txt @@ -0,0 +1,3 @@ +address: tahinli.com.tr:2525 +quality: 6 +latency: 100 \ No newline at end of file diff --git a/streamer/src/lib.rs b/streamer/src/lib.rs index 1dfe855..0399b4b 100644 --- a/streamer/src/lib.rs +++ b/streamer/src/lib.rs @@ -2,3 +2,10 @@ pub mod recording; pub mod streaming; pub const BUFFER_LENGTH: usize = 1000000; + +pub struct Config { + pub address: String, + pub quality: u8, + pub latency: u16, + pub tls: bool, +} diff --git a/streamer/src/main.rs b/streamer/src/main.rs index 64fee3f..ce307d8 100644 --- a/streamer/src/main.rs +++ b/streamer/src/main.rs @@ -1,16 +1,36 @@ use std::time::Duration; -use streamer::{recording::recording, streaming::start, BUFFER_LENGTH}; -use tokio::sync::broadcast::channel; +use streamer::{recording::recording, streaming::start, Config, BUFFER_LENGTH}; +use tokio::{fs::File, io::AsyncReadExt, sync::broadcast::channel}; #[tokio::main] async fn main() { println!("Hello, world!"); - + let streamer_config = get_config().await; let (sound_stream_producer, sound_stream_consumer) = channel(BUFFER_LENGTH); tokio::spawn(recording(sound_stream_producer)); - tokio::spawn(start(sound_stream_consumer)); + tokio::spawn(start(sound_stream_consumer, streamer_config)); loop { tokio::time::sleep(Duration::from_secs(1000000000)).await; } } + +async fn get_config() -> Config { + let mut config_file = File::open("configs/streamer_configs.txt").await.unwrap(); + let mut configs_unparsed = String::new(); + config_file.read_to_string(&mut configs_unparsed).await.unwrap(); + + let configs_parsed:Vec<&str> = configs_unparsed.split_terminator("\n").collect(); + let mut configs_cleaned: Vec<&str> = vec![]; + + for config in configs_parsed { + let dirty_configs: Vec<&str> = config.split(": ").collect(); + configs_cleaned.push(dirty_configs[1]); + } + Config { + address: configs_cleaned[0].to_string(), + quality: configs_cleaned[1].parse().unwrap(), + latency: configs_cleaned[2].parse().unwrap(), + tls: configs_cleaned[3].parse().unwrap(), + } +}