moosicbox_server 0.2.0

MoosicBox server package
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! Audio zone event handling and WebSocket broadcasting.
//!
//! This module initializes event listeners for audio zone updates and broadcasts zone configuration
//! changes to connected WebSocket clients across all profiles.

use moosicbox_audio_zone::events::BoxErrorSend;
use switchy_database::{config::ConfigDatabase, profiles::PROFILES};

use crate::WS_SERVER_HANDLE;

/// Initializes audio zone event listeners.
///
/// Sets up an event handler that broadcasts audio zone updates to all connected WebSocket clients
/// whenever audio zone configurations change (players added/removed, volume changes, etc.).
pub async fn init(config_db: &ConfigDatabase) {
    let config_db = config_db.to_owned();
    moosicbox_audio_zone::events::on_audio_zones_updated_event({
        let config_db = config_db.clone();
        move || {
            let config_db = config_db.clone();
            async move {
                log::debug!("on_audio_zones_updated_event: Audio zones updated");
                let connection_id = "self";
                let context = moosicbox_ws::WebsocketContext {
                    connection_id: connection_id.to_string(),
                    ..Default::default()
                };
                let handle = WS_SERVER_HANDLE
                    .read()
                    .await
                    .clone()
                    .ok_or_else(|| {
                        moosicbox_ws::WebsocketSendError::Unknown("No ws server handle".into())
                    })
                    .map_err(|e| Box::new(e) as BoxErrorSend)?;
                for profile in PROFILES.names() {
                    if let Some(library_db) = PROFILES.get(&profile) {
                        moosicbox_ws::broadcast_audio_zones(
                            &config_db,
                            &library_db,
                            &handle,
                            &context,
                            true,
                        )
                        .await
                        .map_err(|e| Box::new(e) as BoxErrorSend)?;
                    } else {
                        log::error!("Failed to get database for profile '{profile}'");
                    }
                }
                Ok(())
            }
        }
    })
    .await;
}