Function AudioStream

src/components/audiostream.rs:449–540

()

#[tracing::instrument(level = "debug", skip())]
#[component()]
pub fn AudioStream() -> impl IntoView {
    let provider_store = use_context::<Arc<ProviderStore>>().unwrap();
    let player_store = use_context::<RwSignal<PlayerStore>>().unwrap();

    let player_container_ref = NodeRef::<Div>::new();

    let players = PlayerHolder::new(player_container_ref, provider_store.clone());
    let players = Rc::new(Mutex::new(players));
    let players_clone = players.clone();
    spawn_local(async move {
        let players = players_clone.lock().await;
        players.initialize_players().await;
    });

    let current_song_sig =
        create_read_slice(player_store, |player_store| player_store.get_current_song());

    let last_song_sig = create_read_slice(player_store, |player_store| {
        player_store.data.player_details.last_song.clone()
    });

    let force_load_sig =
        create_read_slice(player_store, |player_store| player_store.get_force_load());
    let current_volume = create_read_slice(player_store, |player_store| player_store.get_volume());

    let players_clone = players.clone();
    Effect::new(move || {
        let current_volume = current_volume.get();
        let players = players.clone();
        spawn_local(async move {
            let players = players.lock().await;
            players
                .set_volume(current_volume)
                .await
                .expect("Failed to set volume");
        });
    });

    let last_song_time = RwSignal::new(Instant::now());
    Effect::new(move || {
        let is_providers_initialized = provider_store.is_initialized.get();
        tracing::info!("providers initialized {}", is_providers_initialized);
        if !is_providers_initialized {
            tracing::info!("providers not initialized");
            return;
        }
        let current_song = current_song_sig.get();
        let _ = force_load_sig.get();

        send_extension_event(ExtensionExtraEvent::SongChanged([current_song.clone()]));
        if let Some(current_song) = current_song {
            tracing::info!("Loading song {:?}", current_song.song.title);
            set_metadata(&current_song);

            let last_song_sig = last_song_sig.get_untracked();
            let players = players_clone.clone();
            spawn_local(async move {
                let mut players = players.lock().await;