From b937dece9d15bc06a131d13ba4dc454b770c2e6f Mon Sep 17 00:00:00 2001
From: Eric Coissac <eric@coissac.eu>
Date: Sun, 11 Jan 2026 15:44:37 +0100
Subject: [PATCH] =?UTF-8?q?Optimisation=20des=20d=C3=A9lais=20de=20rafra?=
 =?UTF-8?q?=C3=AEchissement=20et=20am=C3=A9lioration=20de=20la=20r=C3=A9ac?=
 =?UTF-8?q?tivit=C3=A9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Réduction du délai de rafraîchissement des conteneurs à 2 secondes et ajustement du polling pour une meilleure réactivité de l'interface utilisateur.

- Modification du délai de cooldown de 5 secondes à 2 secondes dans MediaBrowser.vue
- Réduction du délai de polling de 60 secondes à 10 secondes pour la découverte des appareils dans control_point.rs
- Modification du polling de volume et de mute de 3 secondes à 1 seconde (tous les 2 ticks à 500ms) dans control_point.rs
- Réduction du délai de polling de position de 1 seconde à 500ms dans control_point.rs
---
 .../components/pmocontrol/MediaBrowser.vue    | 454 +++++++++---------
 pmocontrol/src/control_point.rs               |  14 +-
 2 files changed, 239 insertions(+), 229 deletions(-)

diff --git a/pmoapp/webapp/src/components/pmocontrol/MediaBrowser.vue b/pmoapp/webapp/src/components/pmocontrol/MediaBrowser.vue
index 10af54c8..5a8dfd85 100644
--- a/pmoapp/webapp/src/components/pmocontrol/MediaBrowser.vue
+++ b/pmoapp/webapp/src/components/pmocontrol/MediaBrowser.vue
@@ -1,62 +1,58 @@
 <script setup lang="ts">
-import { computed, ref, watch } from 'vue'
-import { useMediaServers } from '@/composables/useMediaServers'
-import { useRenderers } from '@/composables/useRenderers'
-import { useUIStore } from '@/stores/ui'
-import Breadcrumb from './Breadcrumb.vue'
-import ContainerItem from './ContainerItem.vue'
-import MediaItem from './MediaItem.vue'
-import { Loader2 } from 'lucide-vue-next'
+import { computed, ref, watch } from "vue";
+import { useMediaServers } from "@/composables/useMediaServers";
+import { useRenderers } from "@/composables/useRenderers";
+import { useUIStore } from "@/stores/ui";
+import Breadcrumb from "./Breadcrumb.vue";
+import ContainerItem from "./ContainerItem.vue";
+import MediaItem from "./MediaItem.vue";
+import { Loader2 } from "lucide-vue-next";
 
 const props = defineProps<{
-  serverId: string
-  containerId: string
-}>()
+    serverId: string;
+    containerId: string;
+}>();
 
 const {
-  getBrowseCached,
-  browseContainer,
-  currentPath: breadcrumbPath,
-  loading,
-  error
-} = useMediaServers()
+    getBrowseCached,
+    browseContainer,
+    currentPath: breadcrumbPath,
+    loading,
+    error,
+} = useMediaServers();
 
-const {
-  playContent,
-  addToQueue,
-  attachAndPlayPlaylist,
-  attachPlaylist,
-} = useRenderers()
-const uiStore = useUIStore()
+const { playContent, addToQueue, attachAndPlayPlaylist, attachPlaylist } =
+    useRenderers();
+const uiStore = useUIStore();
 
 // Flags pour gérer le rechargement automatique avec debounce et cooldown
-const isRefreshing = ref(false)
-const refreshTimeoutId = ref<number | null>(null)
-const lastRefreshTime = ref<number>(0)
-const REFRESH_COOLDOWN_MS = 5000  // Ne pas recharger plus d'une fois toutes les 5 secondes
+const isRefreshing = ref(false);
+const refreshTimeoutId = ref<number | null>(null);
+const lastRefreshTime = ref<number>(0);
+const REFRESH_COOLDOWN_MS = 2000; // Ne pas recharger plus d'une fois toutes les 2 secondes
 
 const browseData = computed(() =>
-  getBrowseCached(props.serverId, props.containerId)
-)
+    getBrowseCached(props.serverId, props.containerId),
+);
 
-const containers = computed(() =>
-  browseData.value?.entries.filter((e) => e.is_container) || []
-)
+const containers = computed(
+    () => browseData.value?.entries.filter((e) => e.is_container) || [],
+);
 
-const items = computed(() =>
-  browseData.value?.entries.filter((e) => !e.is_container) || []
-)
+const items = computed(
+    () => browseData.value?.entries.filter((e) => !e.is_container) || [],
+);
 
 // Charger le container au montage et quand containerId change
 watch(
-  () => props.containerId,
-  async (newContainerId) => {
-    if (newContainerId) {
-      await browseContainer(props.serverId, newContainerId)
-    }
-  },
-  { immediate: true }
-)
+    () => props.containerId,
+    async (newContainerId) => {
+        if (newContainerId) {
+            await browseContainer(props.serverId, newContainerId);
+        }
+    },
+    { immediate: true },
+);
 
 // Recharger automatiquement si le cache est invalidé (ex: après un ContainersUpdated SSE)
 // Cela se produit notamment quand on clique sur "Lire maintenant" sur une playlist,
@@ -64,268 +60,282 @@ watch(
 // Utilise un debounce de 3 secondes pour regrouper les multiples invalidations
 // et un cooldown de 5 secondes pour éviter les rechargements successifs
 watch(
-  () => browseData.value,
-  (data) => {
-    // Si browseData devient undefined alors que containerId est présent,
-    // et qu'on n'est pas déjà en train de charger, planifier un rechargement
-    if (!data && props.containerId && !loading.value) {
-      // Vérifier le cooldown: ignorer si on a rechargé il y a moins de 5 secondes
-      const timeSinceLastRefresh = Date.now() - lastRefreshTime.value
-      if (timeSinceLastRefresh < REFRESH_COOLDOWN_MS) {
-        console.log(
-          `[MediaBrowser] Cache invalidé mais cooldown actif (${Math.round((REFRESH_COOLDOWN_MS - timeSinceLastRefresh) / 1000)}s restantes), rechargement ignoré`
-        )
-        return
-      }
+    () => browseData.value,
+    (data) => {
+        // Si browseData devient undefined alors que containerId est présent,
+        // et qu'on n'est pas déjà en train de charger, planifier un rechargement
+        if (!data && props.containerId && !loading.value) {
+            // Vérifier le cooldown: ignorer si on a rechargé il y a moins de 5 secondes
+            const timeSinceLastRefresh = Date.now() - lastRefreshTime.value;
+            if (timeSinceLastRefresh < REFRESH_COOLDOWN_MS) {
+                console.log(
+                    `[MediaBrowser] Cache invalidé mais cooldown actif (${Math.round((REFRESH_COOLDOWN_MS - timeSinceLastRefresh) / 1000)}s restantes), rechargement ignoré`,
+                );
+                return;
+            }
 
-      // Annuler tout timeout en cours
-      if (refreshTimeoutId.value !== null) {
-        clearTimeout(refreshTimeoutId.value)
-      }
+            // Annuler tout timeout en cours
+            if (refreshTimeoutId.value !== null) {
+                clearTimeout(refreshTimeoutId.value);
+            }
 
-      // Planifier le rechargement après 3 secondes
-      // Cela permet de regrouper plusieurs événements SSE successifs
-      refreshTimeoutId.value = window.setTimeout(async () => {
-        if (!isRefreshing.value) {
-          console.log(
-            `[MediaBrowser] Cache invalidé pour ${props.serverId}/${props.containerId}, rechargement après debounce...`
-          )
-          isRefreshing.value = true
-          await browseContainer(props.serverId, props.containerId, false)
-          lastRefreshTime.value = Date.now()  // Enregistrer le moment du rechargement
-          isRefreshing.value = false
-          refreshTimeoutId.value = null
+            // Planifier le rechargement après 200ms
+            // Cela permet de dédupliquer les événements SSE dans le même batch (polling 500ms)
+            refreshTimeoutId.value = window.setTimeout(async () => {
+                if (!isRefreshing.value) {
+                    console.log(
+                        `[MediaBrowser] Cache invalidé pour ${props.serverId}/${props.containerId}, rechargement après debounce...`,
+                    );
+                    isRefreshing.value = true;
+                    await browseContainer(
+                        props.serverId,
+                        props.containerId,
+                        false,
+                    );
+                    lastRefreshTime.value = Date.now(); // Enregistrer le moment du rechargement
+                    isRefreshing.value = false;
+                    refreshTimeoutId.value = null;
+                }
+            }, 200);
         }
-      }, 3000)
-    }
-  }
-)
+    },
+);
 
 const emit = defineEmits<{
-  navigate: [containerId: string]
-}>()
+    navigate: [containerId: string];
+}>();
 
 function handleNavigate(containerId: string) {
-  emit('navigate', containerId)
+    emit("navigate", containerId);
 }
 
 function handleBrowseContainer(containerId: string) {
-  emit('navigate', containerId)
+    emit("navigate", containerId);
 }
 
 // Actions handlers pour les containers (playlists/albums)
 async function handlePlayContainer(containerId: string, rendererId: string) {
-  try {
-    await attachAndPlayPlaylist(rendererId, props.serverId, containerId)
-    uiStore.notifySuccess('Lecture de la playlist démarrée !')
-  } catch (err) {
-    const message = err instanceof Error ? err.message : 'Erreur inconnue'
-    uiStore.notifyError(`Erreur lors de la lecture de la playlist: ${message}`)
-  }
+    try {
+        await attachAndPlayPlaylist(rendererId, props.serverId, containerId);
+        uiStore.notifySuccess("Lecture de la playlist démarrée !");
+    } catch (err) {
+        const message = err instanceof Error ? err.message : "Erreur inconnue";
+        uiStore.notifyError(
+            `Erreur lors de la lecture de la playlist: ${message}`,
+        );
+    }
 }
 
 async function handleQueueContainer(containerId: string, rendererId: string) {
-  try {
-    await attachPlaylist(rendererId, props.serverId, containerId)
-    uiStore.notifySuccess('Playlist attachée à la queue !')
-  } catch (err) {
-    const message = err instanceof Error ? err.message : 'Erreur inconnue'
-    uiStore.notifyError(`Erreur lors de l'ajout de la playlist: ${message}`)
-  }
+    try {
+        await attachPlaylist(rendererId, props.serverId, containerId);
+        uiStore.notifySuccess("Playlist attachée à la queue !");
+    } catch (err) {
+        const message = err instanceof Error ? err.message : "Erreur inconnue";
+        uiStore.notifyError(
+            `Erreur lors de l'ajout de la playlist: ${message}`,
+        );
+    }
 }
 
 // Actions handlers pour les items (tracks)
 async function handlePlayItem(itemId: string, rendererId: string) {
-  try {
-    await playContent(rendererId, props.serverId, itemId)
-    uiStore.notifySuccess('Lecture démarrée !')
-  } catch (err) {
-    const message = err instanceof Error ? err.message : 'Erreur inconnue'
-    uiStore.notifyError(`Erreur lors de la lecture: ${message}`)
-  }
+    try {
+        await playContent(rendererId, props.serverId, itemId);
+        uiStore.notifySuccess("Lecture démarrée !");
+    } catch (err) {
+        const message = err instanceof Error ? err.message : "Erreur inconnue";
+        uiStore.notifyError(`Erreur lors de la lecture: ${message}`);
+    }
 }
 
 async function handleQueueItem(itemId: string, rendererId: string) {
-  try {
-    await addToQueue(rendererId, props.serverId, itemId)
-    uiStore.notifySuccess('Ajouté à la queue !')
-  } catch (err) {
-    const message = err instanceof Error ? err.message : 'Erreur inconnue'
-    uiStore.notifyError(`Erreur lors de l'ajout à la queue: ${message}`)
-  }
+    try {
+        await addToQueue(rendererId, props.serverId, itemId);
+        uiStore.notifySuccess("Ajouté à la queue !");
+    } catch (err) {
+        const message = err instanceof Error ? err.message : "Erreur inconnue";
+        uiStore.notifyError(`Erreur lors de l'ajout à la queue: ${message}`);
+    }
 }
 </script>
 
 <template>
-  <div class="media-browser">
-    <!-- Breadcrumb -->
-    <Breadcrumb
-      :items="breadcrumbPath"
-      :serverId="serverId"
-      @navigate="handleNavigate"
-    />
+    <div class="media-browser">
+        <!-- Breadcrumb -->
+        <Breadcrumb
+            :items="breadcrumbPath"
+            :serverId="serverId"
+            @navigate="handleNavigate"
+        />
 
-    <!-- Loading state -->
-    <div v-if="loading" class="browser-loading">
-      <Loader2 :size="32" class="spinner" />
-      <p>Chargement...</p>
-    </div>
-
-    <!-- Error state -->
-    <div v-else-if="error" class="browser-error">
-      <p class="error-message">{{ error }}</p>
-      <button class="btn btn-secondary" @click="browseContainer(serverId, containerId, false)">
-        Réessayer
-      </button>
-    </div>
-
-    <!-- Content -->
-    <div v-else class="browser-content">
-      <!-- Containers section -->
-      <div v-if="containers.length" class="browser-section">
-        <h3 class="section-title">Dossiers et playlists</h3>
-        <div class="entries-list">
-          <ContainerItem
-            v-for="container in containers"
-            :key="container.id"
-            :entry="container"
-            :server-id="serverId"
-            @browse="handleBrowseContainer"
-            @play-now="handlePlayContainer"
-            @add-to-queue="handleQueueContainer"
-          />
+        <!-- Loading state -->
+        <div v-if="loading" class="browser-loading">
+            <Loader2 :size="32" class="spinner" />
+            <p>Chargement...</p>
         </div>
-      </div>
 
-      <!-- Items section -->
-      <div v-if="items.length" class="browser-section">
-        <h3 class="section-title">Pistes</h3>
-        <div class="entries-list">
-          <MediaItem
-            v-for="item in items"
-            :key="item.id"
-            :entry="item"
-            :server-id="serverId"
-            @play-now="handlePlayItem"
-            @add-to-queue="handleQueueItem"
-          />
+        <!-- Error state -->
+        <div v-else-if="error" class="browser-error">
+            <p class="error-message">{{ error }}</p>
+            <button
+                class="btn btn-secondary"
+                @click="browseContainer(serverId, containerId, false)"
+            >
+                Réessayer
+            </button>
         </div>
-      </div>
 
-      <!-- Empty state -->
-      <div v-if="!containers.length && !items.length" class="browser-empty">
-        <p>Ce dossier est vide</p>
-      </div>
+        <!-- Content -->
+        <div v-else class="browser-content">
+            <!-- Containers section -->
+            <div v-if="containers.length" class="browser-section">
+                <h3 class="section-title">Dossiers et playlists</h3>
+                <div class="entries-list">
+                    <ContainerItem
+                        v-for="container in containers"
+                        :key="container.id"
+                        :entry="container"
+                        :server-id="serverId"
+                        @browse="handleBrowseContainer"
+                        @play-now="handlePlayContainer"
+                        @add-to-queue="handleQueueContainer"
+                    />
+                </div>
+            </div>
+
+            <!-- Items section -->
+            <div v-if="items.length" class="browser-section">
+                <h3 class="section-title">Pistes</h3>
+                <div class="entries-list">
+                    <MediaItem
+                        v-for="item in items"
+                        :key="item.id"
+                        :entry="item"
+                        :server-id="serverId"
+                        @play-now="handlePlayItem"
+                        @add-to-queue="handleQueueItem"
+                    />
+                </div>
+            </div>
+
+            <!-- Empty state -->
+            <div
+                v-if="!containers.length && !items.length"
+                class="browser-empty"
+            >
+                <p>Ce dossier est vide</p>
+            </div>
+        </div>
     </div>
-  </div>
 </template>
 
 <style scoped>
 .media-browser {
-  display: flex;
-  flex-direction: column;
-  gap: var(--spacing-lg);
-  height: 100%;
+    display: flex;
+    flex-direction: column;
+    gap: var(--spacing-lg);
+    height: 100%;
 }
 
 /* Loading */
 .browser-loading {
-  flex: 1;
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  justify-content: center;
-  gap: var(--spacing-md);
-  color: var(--color-text-secondary);
+    flex: 1;
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    justify-content: center;
+    gap: var(--spacing-md);
+    color: var(--color-text-secondary);
 }
 
 .spinner {
-  animation: spin 1s linear infinite;
+    animation: spin 1s linear infinite;
 }
 
 @keyframes spin {
-  from {
-    transform: rotate(0deg);
-  }
-  to {
-    transform: rotate(360deg);
-  }
+    from {
+        transform: rotate(0deg);
+    }
+    to {
+        transform: rotate(360deg);
+    }
 }
 
 /* Error */
 .browser-error {
-  flex: 1;
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  justify-content: center;
-  gap: var(--spacing-md);
+    flex: 1;
+    display: flex;
+    flex-direction: column;
+    align-items: center;
+    justify-content: center;
+    gap: var(--spacing-md);
 }
 
 .error-message {
-  font-size: var(--text-base);
-  color: var(--status-offline);
-  margin: 0;
+    font-size: var(--text-base);
+    color: var(--status-offline);
+    margin: 0;
 }
 
 /* Content */
 .browser-content {
-  flex: 1;
-  overflow-y: auto;
-  display: flex;
-  flex-direction: column;
-  gap: var(--spacing-xl);
-  padding-right: var(--spacing-xs);
+    flex: 1;
+    overflow-y: auto;
+    display: flex;
+    flex-direction: column;
+    gap: var(--spacing-xl);
+    padding-right: var(--spacing-xs);
 }
 
 .browser-section {
-  display: flex;
-  flex-direction: column;
-  gap: var(--spacing-md);
+    display: flex;
+    flex-direction: column;
+    gap: var(--spacing-md);
 }
 
 .section-title {
-  font-size: var(--text-lg);
-  font-weight: 600;
-  color: var(--color-text);
-  margin: 0;
-  padding-bottom: var(--spacing-sm);
-  border-bottom: 1px solid var(--color-border);
+    font-size: var(--text-lg);
+    font-weight: 600;
+    color: var(--color-text);
+    margin: 0;
+    padding-bottom: var(--spacing-sm);
+    border-bottom: 1px solid var(--color-border);
 }
 
 .entries-list {
-  display: flex;
-  flex-direction: column;
-  gap: var(--spacing-xs);
+    display: flex;
+    flex-direction: column;
+    gap: var(--spacing-xs);
 }
 
 /* Empty state */
 .browser-empty {
-  flex: 1;
-  display: flex;
-  align-items: center;
-  justify-content: center;
-  color: var(--color-text-tertiary);
-  font-size: var(--text-base);
-  padding: var(--spacing-xl);
+    flex: 1;
+    display: flex;
+    align-items: center;
+    justify-content: center;
+    color: var(--color-text-tertiary);
+    font-size: var(--text-base);
+    padding: var(--spacing-xl);
 }
 
 /* Scrollbar styling */
 .browser-content::-webkit-scrollbar {
-  width: 6px;
+    width: 6px;
 }
 
 .browser-content::-webkit-scrollbar-track {
-  background: var(--color-bg-secondary);
-  border-radius: var(--radius-full);
+    background: var(--color-bg-secondary);
+    border-radius: var(--radius-full);
 }
 
 .browser-content::-webkit-scrollbar-thumb {
-  background: var(--color-border);
-  border-radius: var(--radius-full);
+    background: var(--color-border);
+    border-radius: var(--radius-full);
 }
 
 .browser-content::-webkit-scrollbar-thumb:hover {
-  background: var(--color-text-tertiary);
+    background: var(--color-text-tertiary);
 }
 </style>
diff --git a/pmocontrol/src/control_point.rs b/pmocontrol/src/control_point.rs
index 4b2d89e7..560a6628 100644
--- a/pmocontrol/src/control_point.rs
+++ b/pmocontrol/src/control_point.rs
@@ -112,8 +112,8 @@ impl ControlPoint {
             ];
 
             loop {
-                // Attendre 60 secondes avant le prochain cycle
-                thread::sleep(Duration::from_secs(60));
+                // Attendre 10 secondes avant le prochain cycle pour découverte rapide
+                thread::sleep(Duration::from_secs(10));
 
                 debug!("Sending periodic M-SEARCH for device discovery");
 
@@ -303,9 +303,9 @@ impl ControlPoint {
                         new_snapshot.state = Some(logical_state);
                     }
 
-                    // Poll volume and mute less frequently (every 3 seconds)
-                    // to reduce SOAP overhead without impacting UI responsiveness
-                    if tick % 3 == 0 {
+                    // Poll volume and mute every second (every 2 ticks at 500ms)
+                    // for responsive volume control feedback
+                    if tick % 2 == 0 {
                         if let Ok(volume) = renderer.volume() {
                             if prev_snapshot.last_volume != Some(volume) {
                                 polling_cp.emit_renderer_event(RendererEvent::VolumeChanged {
@@ -334,8 +334,8 @@ impl ControlPoint {
                 }
 
                 tick = tick.wrapping_add(1);
-                // Keep 1 second polling for smooth position updates
-                thread::sleep(Duration::from_secs(1));
+                // 500ms polling for smoother position updates and progress bar
+                thread::sleep(Duration::from_millis(500));
             }
         });