Function initialize_librespot

src-tauri/src/librespot/mod.rs:35–111

#[cfg(desktop)]

(app: AppHandle, access_token: String)

#[tauri::command()]
// #[cfg(desktop)]
pub fn initialize_librespot(app: AppHandle, access_token: String) -> Result<()> {
    tracing::debug!("Initializing librespot with {:?}", access_token);
    let credentials = Credentials::with_access_token(access_token);

    let player_config = PlayerConfig::default();

    let connect_config = ConnectConfig {
        name: "Moosync".into(),
        device_type: DeviceType::Computer,
        initial_volume: 0,
        is_group: false,
        ..Default::default()
    };

    let credentials_path = app.path().app_config_dir()?;
    let audio_path = app.path().app_cache_dir()?;
    let cache_config = Cache::new(
        Some(credentials_path.clone()),
        Some(credentials_path),
        Some(audio_path),
        None,
    )?;

    let librespot: State<LibrespotHolder> = app.state();
    librespot.initialize(
        credentials,
        player_config,
        connect_config,
        cache_config,
        "".to_string(),
        "".to_string(),
    )?;

    // TODO: Check if event loop ends on closing librespot
    let events_channel = librespot.get_events_channel()?;
    tauri::async_runtime::spawn(async move {
        let events_channel = events_channel.lock().unwrap();
        loop {
            tracing::trace!("Waiting for librespot player events");
            let event = events_channel.recv();
            match event {
                Ok(event) => {
                    if let PlayerEvent::Unavailable {
                        play_request_id: _,
                        track_id: _,
                    } = event
                    {
                        tracing::error!("Got track unavailable {:?}", event);
                        continue;
                    }

                    let parsed_event = event_to_map(event.clone());

                    let registered_events = REGISTERED_EVENTS.lock().unwrap();
                    if registered_events.contains(&format!(
                        "librespot_event_{}",
                        parsed_event.get("event").unwrap(),
                    )) {