G2/dmp-core
1
0
Fork 0
mirror of https://github.com/Dangoware/dmp-core.git synced 2025-04-19 13:22:54 -05:00
Code Issues Projects Releases Packages Wiki Activity

added Controller Handle and Input structs

Browse source
This commit is contained in:
MrDulfin 2024-09-29 23:19:03 -04:00
parent 15988ae808
commit ab5c65d64d
1 changed files with 30 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
src/music_controller/controller.rs
View file

@ -108,16 +108,31 @@ pub enum QueueResponse {
Item(QueueItem<QueueSong, QueueAlbum>), Item(QueueItem<QueueSong, QueueAlbum>),
} }
pub struct ControllerInput<'a> {
player_mail: (
MailMan<PlayerCommand, PlayerResponse>,
MailMan<PlayerResponse, PlayerCommand>,
),
lib_mail: MailMan<LibraryResponse, LibraryCommand>,
library: &'a mut MusicLibrary,
config: Arc<RwLock<Config>>,
}
pub struct ControllerHandle {
lib_mail: MailMan<LibraryCommand, LibraryResponse>,
player_mail: MailMan<PlayerCommand, PlayerResponse>,
}
#[allow(unused_variables)] #[allow(unused_variables)]
impl<'c, P: Player + Send + Sync> Controller<'c, P> { impl<'c, P: Player + Send + Sync> Controller<'c, P> {
pub async fn start( pub async fn start(
player_mail: ( ControllerInput {
MailMan<PlayerCommand, PlayerResponse>, player_mail,
MailMan<PlayerResponse, PlayerCommand>, lib_mail,
), library,
lib_mail: MailMan<LibraryResponse, LibraryCommand>, config
mut library: MusicLibrary, }: ControllerInput<'c>
config: Arc<RwLock<Config>>,
) -> Result<(), Box<dyn Error>> ) -> Result<(), Box<dyn Error>>
where where
P: Player, P: Player,
@ -171,7 +186,7 @@ impl<'c, P: Player + Send + Sync> Controller<'c, P> {
.await; .await;
scope scope
.spawn(async { .spawn(async {
Controller::<P>::inner_library_loop(inner_lib_mail.1, &mut library) Controller::<P>::inner_library_loop(inner_lib_mail.1, library)
.await .await
.unwrap() .unwrap()
}) })
@ -420,7 +435,7 @@ mod test_super {
let a = spawn(move || { let a = spawn(move || {
futures::executor::block_on(async { futures::executor::block_on(async {
let config = Config::read_file(PathBuf::from(std::env!("CONFIG-PATH"))).unwrap(); let config = Config::read_file(PathBuf::from(std::env!("CONFIG-PATH"))).unwrap();
let library = { let mut library = {
MusicLibrary::init( MusicLibrary::init(
config.libraries.get_default().unwrap().path.clone(), config.libraries.get_default().unwrap().path.clone(),
config.libraries.get_default().unwrap().uuid, config.libraries.get_default().unwrap().uuid,
@ -429,10 +444,12 @@ mod test_super {
}; };
Controller::<GStreamer>::start( Controller::<GStreamer>::start(
player_mail, crate::music_controller::controller::ControllerInput {
lib_mail.1, player_mail,
library, lib_mail: lib_mail.1,
Arc::new(RwLock::new(config)), library: &mut library,
config: Arc::new(RwLock::new(config)),
}
) )
.await .await
.unwrap(); .unwrap();