code cleaning

Author: icsboyx

src/audio_player.rs

@@ -1,5 +1,4 @@
-use std::fs::OpenOptions;
-use std::io::{Cursor, Write};
+use std::io::Cursor;
 use std::sync::{Arc, LazyLock};
 use std::thread::sleep;
 use std::time::Duration;
@@ -19,7 +18,6 @@ use pulse::sample::{Format, Spec};
 use pulse::stream::Direction;
 use rodio::{Decoder, Source};
 use serde::{Deserialize, Serialize};
-use tokio::net::UdpSocket;
 use tokio::sync::RwLock;
 
 use crate::CONFIG_DIR;
@@ -232,153 +230,3 @@ pub async fn play_on_kira(audio: Vec<u8>) -> Result<()> {
     TTS_AUDIO_CONTROL.set_status_ready().await;
     Ok(())
 }
-
-// ############################
-// pub async fn play_on_pipe(audio: Vec<u8>, pipe: impl AsRef<str>) -> Result<()> {
-//     // let cursor = Cursor::new(audio);
-//     // let source = Decoder::new(cursor)?.convert_samples::<u16>();
-//     // let sample_rate = source.sample_rate();
-//     // let channels = source.channels() as u8;
-
-//     let mut pipe = OpenOptions::new().write(true).open("/tmp/audio_pipe.mp3")?;
-//     // log_trace!("Sample rate: {}, channels {}.", sample_rate, channels);
-//     // log_trace!("Playing on pipe: {:?}", pipe.metadata());
-
-//     // let audio_data = source.into_iter().collect::<Vec<_>>();
-
-//     log_debug!("Setting audio player to busy");
-//     let audio_chunks = audio.chunks(1024);
-//     TTS_AUDIO_CONTROL.set_status_busy().await;
-
-//     for chunk in audio_chunks {
-//         match TTS_AUDIO_CONTROL.get_status().await {
-//             PlayerCommands::Busy => {
-//                 pipe.write(&chunk)?;
-//                 sleep(Duration::from_millis(10));
-//             }
-//             PlayerCommands::Stop => {
-//                 log_debug!("Stopping audio playback");
-//                 TTS_AUDIO_CONTROL.set_status_ready().await;
-//                 log_debug!("Setting audio player ready");
-//                 break;
-//             }
-//             _ => {}
-//         }
-//     }
-//     log_debug!("Audio playback finished");
-//     TTS_AUDIO_CONTROL.set_status_ready().await;
-
-//     Ok(())
-// }
-
-// pub async fn play_udp(audio: Vec<u8>, _sink: impl AsRef<str>) -> Result<()> {
-//     let udp_socket = tokio::net::UdpSocket::bind("0.0.0.0:0").await?;
-//     udp_socket.connect("127.0.0.1:12345").await?;
-
-//     let cursor = Cursor::new(audio);
-//     let source = Decoder::new(cursor)?.convert_samples::<f32>();
-//     let sample_rate = source.sample_rate();
-//     let channels = source.channels() as u8;
-
-//     log_trace!("Sample rate: {}, channels {}.", sample_rate, channels);
-
-//     // let (_stream, stream_handle) = OutputStream::try_default().unwrap();
-
-//     let spec = Spec {
-//         format: Format::FLOAT32NE,
-//         channels,
-//         rate: sample_rate,
-//     };
-//     assert!(spec.is_valid());
-//     let audio_data = source.into_iter().collect::<Vec<_>>();
-//     // let audio_chunks = source.chunks(1024);
-
-//     let audio_bytes = audio_data
-//         .iter()
-//         .flat_map(|&x| x.to_le_bytes().to_vec())
-//         .collect::<Vec<_>>();
-
-//     let audio_chunks = audio_bytes.chunks(1024);
-//     // Calculate delay for each chunk (based on sample rate, channels, and chunk size)
-//     let chunk_size = 1024; // Size of each chunk in bytes
-//     let samples_per_chunk = chunk_size / std::mem::size_of::<f32>();
-//     let seconds_per_chunk = samples_per_chunk as f64 / (sample_rate as f64 * channels as f64);
-//     let delay = Duration::from_secs_f64(seconds_per_chunk);
-
-//     TTS_AUDIO_CONTROL.set_status_busy().await;
-//     log_debug!("Setting audio player to busy");
-//     for chunk in audio_chunks {
-//         match TTS_AUDIO_CONTROL.get_status().await {
-//             PlayerCommands::Busy => {
-//                 tokio::time::sleep(delay).await;
-//             }
-//             PlayerCommands::Stop => {
-//                 log_debug!("Stopping audio playback");
-//                 TTS_AUDIO_CONTROL.set_status_ready().await;
-//                 log_debug!("Setting audio player ready");
-//                 break;
-//             }
-//             _ => {}
-//         }
-//     }
-//     log_debug!("Audio playback finished");
-//     TTS_AUDIO_CONTROL.set_status_ready().await;
-//     Ok(())
-// }
-
-// pub async fn play_udp(audio: Vec<u8>, _sink: impl AsRef<str>) -> Result<()> {
-//     let udp_socket = tokio::net::UdpSocket::bind("0.0.0.0:0").await?;
-//     udp_socket.connect("127.0.0.1:12345").await?;
-
-//     udp_socket.send(&audio).await?;
-
-//     return Ok(());
-//     let cursor = Cursor::new(audio);
-//     let source = Decoder::new(cursor)?.convert_samples::<i16>();
-
-//     let sample_rate = source.sample_rate();
-//     let channels = source.channels() as u8;
-
-//     log_debug!("Audio chunks duration: {:?}", source.inner().total_duration());
-
-//     let audio_chunks = source.into_iter().collect::<Vec<_>>();
-//     log_debug!("Sample rate: {}, channels {}.", sample_rate, channels);
-
-//     let audio_duration = audio_chunks.len() as u32 / (sample_rate * channels as u32);
-//     println!("Total chunk count: {}", audio_chunks.len() / channels as usize);
-//     println!("Audio duration: {:?}", audio_duration);
-//     println!(
-//         "duration of single chunk is {:?}",
-//         audio_duration as f32 / audio_chunks.len() as f32
-//     );
-
-//     let spec = Spec {
-//         format: Format::F32le, // You can safely send this as f32le via `to_le_bytes()`
-//         channels,
-//         rate: sample_rate,
-//     };
-
-//     TTS_AUDIO_CONTROL.set_status_busy().await;
-//     for chunk in audio_chunks {
-//         match TTS_AUDIO_CONTROL.get_status().await {
-//             PlayerCommands::Busy => {
-//                 // TODO: send chunk (e.g. over UDP, to pipe, etc.)
-//                 // Convert f32 samples to bytes
-//                 let bytes = chunk.to_le_bytes();
-
-//                 //Example: send via socket or write to pipe
-//                 udp_socket.send(&bytes).await?;
-
-//                 // tokio::time::sleep(chunk_duration).await;
-//             }
-//             PlayerCommands::Stop => {
-//                 TTS_AUDIO_CONTROL.set_status_ready().await;
-//                 break;
-//             }
-//             _ => {}
-//         }
-//     }
-
-//     TTS_AUDIO_CONTROL.set_status_ready().await;
-//     Ok(())
-// }