(update) Mise à jour de buzzer-watcher.js pour mettre en forme le debug de console

VApp/src/components/CardButtonScore.vue

@@ -81,6 +81,9 @@
     client.on('connect', () => {
         console.log('CardButtonScore: Connected to MQTT broker at', config.mqttBrokerUrl);
         client.subscribe('game/score');
+        
+        console.log("CardButtonScore: Requesting scores.");
+        client.publish('game/score/request', '{}');
     });
 
     client.on('error', (err) => {

VApp/src/components/CardScore.vue

@@ -91,7 +91,6 @@
 
 <script setup>
 import { onMounted, ref, reactive } from 'vue';
-import variables from '@/variables.js';
 import mqtt from 'mqtt'
 import config from '@/config.js'
 
@@ -131,24 +130,6 @@ function handleMessage(topic, message) {
   scores.BlueRoundScore = parsedMessage.TEAM.Blue.RoundScore
   scores.YellowRoundScore = parsedMessage.TEAM.Yellow.RoundScore
   scores.GreenRoundScore = parsedMessage.TEAM.Green.RoundScore
-	// Mettre à jour l'état des buzzers en fonction des messages
-  /*
-	switch (buzzer) {
-		case 'redBuzzerIP':
-			redBuzzerState.value = status === "online" ? 1 : 0;
-			break;
-		case 'blueBuzzerIP':
-			blueBuzzerState.value = status === "online" ? 1 : 0;
-			break;
-		case 'yellowBuzzerIP':
-			yellowBuzzerState.value = status === "online" ? 1 : 0;
-			break;
-		case 'greenBuzzerIP':
-			greenBuzzerState.value = status === "online" ? 1 : 0;
-			break;
-	}
-  */
-
 }
 
 
@@ -162,7 +143,9 @@ onMounted(() => {
 	subscribeToTopic('game/score', (topic, message) => {
 		handleMessage(topic, message);
 	});
-  
+
+  // Request score refresh
+  client.publish('game/score/request', '{}');
 });
 
 </script>

VApp/src/components/MqttButton.vue

@@ -16,6 +16,7 @@
 	const disabled = ref(false)
 
 	const _publishMessage = () => { 
+        console.log('MqttButton: Publishing', props.topic, props.message)
 		publishMessage(props.topic, props.message) 
 		disabled.value = true
 	}

VApp/src/views/GameDisplay.vue

@@ -5,20 +5,14 @@
         <v-container class="score_div color-blue">
           <div class="d-flex flex-column align-center">
             <Transition name="score-fade" mode="out-in">
-              <span :key="scores.BlueRoundScore" class="v-label-round-score">Manche : {{ scores.BlueRoundScore }}</span>
-            </Transition>
-            <Transition name="score-fade" mode="out-in">
-              <span :key="scores.BlueTotalScore" class="v-label-score">{{ scores.BlueTotalScore }}</span>
+              <span :key="scores.BlueTotalScore" class="v-label-score">{{ scores.BlueRoundScore }}</span>
             </Transition>
           </div>
         </v-container>
         <v-container class="score_div color-red">
           <div class="d-flex flex-column align-center">
             <Transition name="score-fade" mode="out-in">
-              <span :key="scores.RedRoundScore" class="v-label-round-score">Manche : {{ scores.RedRoundScore }}</span>
-            </Transition>
-            <Transition name="score-fade" mode="out-in">
-              <span :key="scores.RedTotalScore" class="v-label-score">{{ scores.RedTotalScore }}</span>
+              <span :key="scores.RedTotalScore" class="v-label-score">{{ scores.RedRoundScore }}</span>
             </Transition>
           </div>
         </v-container>
@@ -28,20 +22,14 @@
         <v-container class="score_div color-green">
           <div class="d-flex flex-column align-center">
             <Transition name="score-fade" mode="out-in">
-              <span :key="scores.GreenRoundScore" class="v-label-round-score">Manche : {{ scores.GreenRoundScore }}</span>
-            </Transition>
-            <Transition name="score-fade" mode="out-in">
-              <span :key="scores.GreenTotalScore" class="v-label-score">{{ scores.GreenTotalScore }}</span>
+              <span :key="scores.GreenTotalScore" class="v-label-score">{{ scores.GreenRoundScore }}</span>
             </Transition>
           </div>
         </v-container>
         <v-container class="score_div color-yellow">
           <div class="d-flex flex-column align-center">
             <Transition name="score-fade" mode="out-in">
-              <span :key="scores.YellowRoundScore" class="v-label-round-score">Manche : {{ scores.YellowRoundScore }}</span>
-            </Transition>
-            <Transition name="score-fade" mode="out-in">
-              <span :key="scores.YellowTotalScore" class="v-label-score">{{ scores.YellowTotalScore }}</span>
+              <span :key="scores.YellowTotalScore" class="v-label-score">{{ scores.YellowRoundScore }}</span>
             </Transition>
           </div>
         </v-container>
@@ -56,7 +44,6 @@
 </template>
 
 <script setup>
-  //import VideoPlayer from "@/components/VideoPlayer.vue"
   import GameMedia from "@/components/GameMedia.vue"
   import HidingOverlay from "@/components/HidingOverlay.vue"
   import { onMounted, reactive } from 'vue';
@@ -64,9 +51,11 @@
   import config from '@/config.js'
   import quizStore from '@/store/quizStore';
 
+  // Configuration MQTT
   const mqttBrokerUrl = config.mqttBrokerUrl
   const client = mqtt.connect(mqttBrokerUrl)
 
+  // Objet réactif pour stocker les scores des équipes
   const scores = reactive({
     RedTotalScore: 0,
     BlueTotalScore: 0,
@@ -79,14 +68,17 @@
   });
 
   import { ref } from 'vue';
+  // Variable réactive pour l'affichage du timer
   const timerDisplay = ref('00:00');
 
+  // Fonction pour formater le temps en mm:ss
   function formatTime(seconds) {
     const mins = Math.floor(seconds / 60);
     const secs = seconds % 60;
     return `${String(mins).padStart(2, '0')}:${String(secs).padStart(2, '0')}`;
   }
 
+  // Fonction de gestion des messages MQTT reçus
   function handleMessage(topic, message) {
     let parsedMessage;
     try {
@@ -96,6 +88,7 @@
       return;
     }
 
+    // Mise à jour des scores si le message vient du topic 'game/score'
     if (topic === 'game/score' && parsedMessage.TEAM) {
        scores.RedTotalScore = parsedMessage.TEAM.Red.TotalScore
        scores.BlueTotalScore = parsedMessage.TEAM.Blue.TotalScore
@@ -108,11 +101,13 @@
        scores.GreenRoundScore = parsedMessage.TEAM.Green.RoundScore
     }
 
+    // Mise à jour du timer si le message vient du topic 'game/timer'
     if (topic === 'game/timer' && parsedMessage.time !== undefined) {
        timerDisplay.value = formatTime(parsedMessage.time);
     }
   }
 
+  // Fonction utilitaire pour s'abonner à un topic MQTT
   function subscribeToTopic(topic, callback) {
     client.subscribe(topic)
     client.on('message', (receivedTopic, message) => { callback(receivedTopic.toString(), message.toString())
@@ -120,14 +115,20 @@
   }
 
   onMounted(() => {
+    // Initialisation du store du quiz
     quizStore.actions.init();
     
+    // Abonnement aux topics MQTT pour les scores et le timer
     subscribeToTopic('game/score', (topic, message) => {
       handleMessage(topic, message);
     });
     subscribeToTopic('game/timer', (topic, message) => {
       handleMessage(topic, message);
     });
+
+    // Demande de rafraîchissement des scores au chargement
+    // Cela permet de récupérer les scores actuels même après un rechargement de page
+    client.publish('game/score/request', '{}');
   });
 </script>
 

VApp/src/views/ScoreDisplay.vue

@@ -10,14 +10,18 @@
           </div>
         </div>
         <div class="score-main">
-          <div class="team-score main-score">{{ scores.BlueRoundScore }}</div>
+          <Transition name="score-pop" mode="out-in">
+            <div :key="scores.BlueRoundScore" class="team-score main-score">{{ scores.BlueRoundScore }}</div>
+          </Transition>
         </div>
       </div>
     </div>
     <div class="score-cell cell-red color-red">
       <div class="score-content">
         <div class="score-main">
-          <div class="team-score main-score">{{ scores.RedRoundScore }}</div>
+          <Transition name="score-pop" mode="out-in">
+            <div :key="scores.RedRoundScore" class="team-score main-score">{{ scores.RedRoundScore }}</div>
+          </Transition>
         </div>
         <div class="score-info info-right">
           <div class="team-name">Rouge</div>
@@ -38,14 +42,18 @@
           </div>
         </div>
         <div class="score-main">
-          <div class="team-score main-score">{{ scores.GreenRoundScore }}</div>
+          <Transition name="score-pop" mode="out-in">
+            <div :key="scores.GreenRoundScore" class="team-score main-score">{{ scores.GreenRoundScore }}</div>
+          </Transition>
         </div>
       </div>
     </div>
     <div class="score-cell cell-yellow color-yellow">
       <div class="score-content">
         <div class="score-main">
-          <div class="team-score main-score">{{ scores.YellowRoundScore }}</div>
+          <Transition name="score-pop" mode="out-in">
+            <div :key="scores.YellowRoundScore" class="team-score main-score">{{ scores.YellowRoundScore }}</div>
+          </Transition>
         </div>
         <div class="score-info info-right">
           <div class="team-name">Jaune</div>
@@ -132,6 +140,8 @@
     subscribeToTopic('game/timer', (topic, message) => {
       handleMessage(topic, message);
     });
+    // Request score refresh
+    client.publish('game/score/request', '{}');
   });
 
   onUnmounted(() => {
@@ -299,4 +309,34 @@
   .color-yellow {
     background: linear-gradient(135deg, rgb(var(--v-theme-YellowBuzzer)), #5a5a1a);
   }
+
+  /* Score Pop Animation */
+  .score-pop-enter-active {
+    animation: pop-in 0.3s cubic-bezier(0.175, 0.885, 0.32, 1.275);
+  }
+  .score-pop-leave-active {
+    animation: pop-out 0.2s ease-in;
+  }
+
+  @keyframes pop-in {
+    0% {
+      transform: scale(0.5);
+      opacity: 0;
+    }
+    100% {
+      transform: scale(1);
+      opacity: 1;
+    }
+  }
+
+  @keyframes pop-out {
+    0% {
+      transform: scale(1);
+      opacity: 1;
+    }
+    100% {
+      transform: scale(1.5);
+      opacity: 0;
+    }
+  }
 </style>

VNode/services/buzzer/_a retravailler_test-buzzer-manager.js

@@ -1,161 +0,0 @@
-// Import necessary modules
-const mqtt = require('mqtt');
-
-// MQTT broker configuration
-const brokerUrl = 'mqtt://localhost'; // Broker URL (change if needed)
-const options = {
-    clientId: 'test_buzzer_manager',
-    clean: true
-};
-
-// Set up MQTT client
-const client = mqtt.connect(brokerUrl, options);
-
-// Variables for tracking test results
-let testResults = {
-    buzzerActivity: false,
-    confirmationReceived: false,
-    statusBlocked: false,
-    statusUnblocked: false,
-    tiltAddConfirmed: false,
-    tiltRemoveConfirmed: false,
-    tiltIgnored: false,
-    unlockConfirmation: false,
-    tiltUpdateAdd: false,
-    tiltUpdateRemove: false
-};
-
-// Subscribe to topics to capture the responses from the buzzer manager
-client.on('connect', () => {
-    console.log('[INFO] Connected to MQTT broker for testing');
-
-    // Subscribe to all topics related to the buzzer manager
-    client.subscribe('vulture/buzzer/#', (err) => {
-        if (err) console.error('[ERROR] Failed to subscribe to topics for testing');
-        else console.log('[INFO] Subscribed to topics successfully');
-    });
-
-    // Run the test sequence after a short delay
-    setTimeout(runTestSequence, 500);
-});
-
-// Capture and process incoming MQTT messages
-client.on('message', (topic, message) => {
-    const payload = JSON.parse(message.toString());
-    console.log(`[INFO] Message received on ${topic}: ${message.toString()}`);
-
-    // Track the test results based on the topics and payloads
-    if (topic.startsWith('vulture/buzzer/activity') && payload.buzzer_id === 1) {
-        testResults.buzzerActivity = true;
-    }
-
-    if (topic.startsWith(`vulture/buzzer/confirmation/1`) && payload.status === "received") {
-        testResults.confirmationReceived = true;
-    }
-
-    if (topic === 'vulture/buzzer/status' && payload.status === "blocked") {
-        testResults.statusBlocked = true;
-    }
-
-    if (topic === 'vulture/buzzer/status' && payload.status === "unblocked") {
-        testResults.statusUnblocked = true;
-    }
-
-    if (topic.startsWith(`vulture/buzzer/tilt/confirmation/2`) && payload.status === "received" && payload.action === "add") {
-        testResults.tiltAddConfirmed = true;
-    }
-
-    if (topic.startsWith(`vulture/buzzer/tilt/confirmation/2`) && payload.status === "received" && payload.action === "remove") {
-        testResults.tiltRemoveConfirmed = true;
-    }
-
-    if (topic === `vulture/buzzer/tilt/ignored/2` && payload.status === "tilt_ignored") {
-        testResults.tiltIgnored = true;
-    }
-
-    if (topic === 'vulture/buzzer/status' && payload.status === "tilt_update") {
-        // Check for tilt update with added buzzer
-        if (payload.tilt_buzzers.includes(2) && payload.message.includes("added")) {
-            testResults.tiltUpdateAdd = true;
-        }
-
-        // Check for tilt update with removed buzzer
-        if (!payload.tilt_buzzers.includes(2) && payload.message.includes("removed")) {
-            testResults.tiltUpdateRemove = true;
-        }
-    }
-
-    if (topic === 'vulture/buzzer/unlock/confirmation' && payload.status === "received") {
-        testResults.unlockConfirmation = true;
-    }
-});
-
-// Function to run the complete test sequence
-function runTestSequence() {
-    console.log('[INFO] Starting test sequence...');
-
-    // 1. Simulate a buzzer press (buzzer 1, color red)
-    console.log('[TEST] Simulating buzzer press (ID 1, color #FF0000)...');
-    client.publish('vulture/buzzer/pressed/1', JSON.stringify({
-        buzzer_id: 1,
-        color: "#FF0000"
-    }));
-
-    // 2. Simulate a second buzzer press (buzzer 2, color blue) to check blocking
-    setTimeout(() => {
-        console.log('[TEST] Simulating second buzzer press (ID 2, color #0000FF)...');
-        client.publish('vulture/buzzer/pressed/2', JSON.stringify({
-            buzzer_id: 2,
-            color: "#0000FF"
-        }));
-    }, 1000);
-
-    // 3. Simulate adding a buzzer to tilt mode (buzzer 2)
-    setTimeout(() => {
-        console.log('[TEST] Adding buzzer ID 2 to tilt mode...');
-        client.publish('vulture/buzzer/tilt', JSON.stringify({
-            buzzer_id: 2,
-            status: "add"
-        }));
-    }, 1500);
-
-    // 4. Simulate pressing a buzzer in tilt mode (should be ignored)
-    setTimeout(() => {
-        console.log('[TEST] Simulating tilt buzzer press (ID 2, color #0000FF)...');
-        client.publish('vulture/buzzer/pressed/2', JSON.stringify({
-            buzzer_id: 2,
-            color: "#0000FF"
-        }));
-    }, 2000);
-
-    // 5. Remove tilt mode from buzzer 2
-    setTimeout(() => {
-        console.log('[TEST] Removing tilt mode for buzzer ID 2...');
-        client.publish('vulture/buzzer/tilt', JSON.stringify({
-            buzzer_id: 2,
-            status: "remove"
-        }));
-    }, 2500);
-
-    // 6. Unlock buzzers to reset state
-    setTimeout(() => {
-        console.log('[TEST] Unlocking buzzers...');
-        client.publish('vulture/buzzer/unlock', '{}');
-    }, 3000);
-
-    // 7. Display results
-    setTimeout(() => {
-        console.log('[INFO] Test sequence complete. Results:');
-        console.log(`1. Buzzer activity detected for buzzer 1: ${testResults.buzzerActivity ? 'PASSED' : 'FAILED'}`);
-        console.log(`2. Confirmation received for buzzer 1: ${testResults.confirmationReceived ? 'PASSED' : 'FAILED'}`);
-        console.log(`3. Buzzer 1 status set to "blocked": ${testResults.statusBlocked ? 'PASSED' : 'FAILED'}`);
-        console.log(`4. Buzzer status set to "unblocked": ${testResults.statusUnblocked ? 'PASSED' : 'FAILED'}`);
-        console.log(`5. Tilt mode add confirmed for buzzer 2: ${testResults.tiltAddConfirmed ? 'PASSED' : 'FAILED'}`);
-        console.log(`6. Tilted buzzer press ignored: ${testResults.tiltIgnored ? 'PASSED' : 'FAILED'}`);
-        console.log(`7. Tilt status update sent (add): ${testResults.tiltUpdateAdd ? 'PASSED' : 'FAILED'}`);
-        console.log(`8. Tilt mode remove confirmed for buzzer 2: ${testResults.tiltRemoveConfirmed ? 'PASSED' : 'FAILED'}`);
-        console.log(`9. Tilt status update sent (remove): ${testResults.tiltUpdateRemove ? 'PASSED' : 'FAILED'}`);
-        console.log(`10. Unlock confirmation received: ${testResults.unlockConfirmation ? 'PASSED' : 'FAILED'}`);
-        client.end(); // End the MQTT connection
-    }, 4000);
-}

VNode/services/buzzer/buzzer-watcher.js

@@ -13,7 +13,7 @@ const { mqttHost, hosts: { buzzers: { IP: buzzerIPs, MQTTconfig: { mqttTopic } }
 const client = mqtt.connect(mqttHost);
 
 client.on('connect', () => {
-    console.log(`Connecté au broker MQTT à ${mqttHost}`);
+    console.log(`[INFO] Connecté au broker MQTT à ${mqttHost}`);
 
     // Fonction pour pinger les buzzers et publier l'état
     const pingAndPublish = async () => {
@@ -24,9 +24,8 @@ client.on('connect', () => {
 
                 // Publication du statut dans le topic MQTT
                 client.publish(`${mqttTopic}`, JSON.stringify({ buzzer: buzzerName, ip, status }));
-                console.log(`Ping ${buzzerName} (${ip}) - Status: ${status}`);
             } catch (error) {
-                console.error(`Erreur avec le buzzer ${buzzerName} (${ip}):`, error.message);
+                console.error(`[ERREUR] Erreur avec le buzzer ${buzzerName} (${ip}):`, error.message);
             }
         }
     };
@@ -36,5 +35,5 @@ client.on('connect', () => {
 });
 
 client.on('error', (error) => {
-    console.error('Erreur de connexion au broker MQTT:', error.message);
+    console.error('[ERREUR] Erreur de connexion au broker MQTT:', error.message);
 });

VNode/services/config/configuration.json

@@ -4,7 +4,8 @@
         "score": {
             "MQTTconfig": {
                 "mqttScoreTopic": "game/score",
-                "mqttScoreChangeTopic": "game/score/update"
+                "mqttScoreChangeTopic": "game/score/update",
+                "mqttScoreRequestTopic": "game/score/request"
             }
         },
         "quizzcollector": {
@@ -27,4 +28,4 @@
             }
         }
     }
-}
+}

VNode/services/game/score-manager.js

@@ -33,14 +33,14 @@ fs.access(filePath, fs.constants.F_OK, (err) => {
         // Le fichier existe, on le lit et on le parse en JSON
         fs.readFile(filePath, 'utf8', (err, data) => {
             if (err) {
-                console.error("Erreur de lecture du fichier :", err);
+                console.error("[ERREUR] Erreur de lecture du fichier :", err);
                 return;
             }
             try {
                 global.jsonData = JSON.parse(data);
-                console.log("Propriétés importées depuis le fichier JSON :");
+                console.log("[INFO] Propriétés importées depuis le fichier JSON :");
             } catch (parseErr) {
-                console.error("Erreur de parsing JSON :", parseErr);
+                console.error("[ERREUR] Erreur de parsing JSON :", parseErr);
             }
         });
     } else {
@@ -82,10 +82,10 @@ fs.access(filePath, fs.constants.F_OK, (err) => {
 
         fs.writeFile(newFilePath, JSON.stringify(initialContent, null, 2), (err) => {
             if (err) {
-                console.error("Erreur de création du fichier :", err);
+                console.error("[ERREUR] Erreur de création du fichier :", err);
                 return;
             }
-            console.log(`Fichier JSON créé avec succès : ${newFilePath}`);
+            console.log(`[INFO] Fichier JSON créé avec succès : ${newFilePath}`);
             // Mettre à jour ScoreFile et filePath
 
             // Charger les données initiales si nécessaire
@@ -99,14 +99,14 @@ fs.access(filePath, fs.constants.F_OK, (err) => {
 function updateTeamTotalScore(teamColor, points) {
     fs.readFile(filePath, 'utf8', (err, data) => {
         if (err) {
-            console.error("Erreur de lecture du fichier :", err);
+            console.error("[ERREUR] Erreur de lecture du fichier :", err);
             return;
         }
         try {
             const jsonData = JSON.parse(data);
             // Vérifier si l'équipe existe
             if (!jsonData.TEAM.hasOwnProperty(teamColor)) {
-                console.error(`L'équipe ${teamColor} n'existe pas.`);
+                console.error(`[ERREUR] L'équipe ${teamColor} n'existe pas.`);
                 return;
             }
 
@@ -114,18 +114,22 @@ function updateTeamTotalScore(teamColor, points) {
 
             // Mettre à jour le score
             jsonData.TEAM[teamColor].TotalScore += points;
-            console.log(`Le score total pour l'équipe ${teamColor} est de ${jsonData.TEAM[teamColor].TotalScore} points !`)
+
+            // Update global state
+            global.jsonData = jsonData;
+
+            console.log(`[INFO] Le score total pour l'équipe ${teamColor} est de ${jsonData.TEAM[teamColor].TotalScore} points !`)
             // Enregistrer les modifications dans le fichier
             client.publish(mqttScoreTopic, JSON.stringify(jsonData));
             fs.writeFile(filePath, JSON.stringify(jsonData, null, 2), (err) => {
                 if (err) {
-                    console.error("Erreur lors de l'écriture du fichier :", err);
+                    console.error("[ERREUR] Erreur lors de l'écriture du fichier :", err);
                 } else {
-                    console.log(`Le score total de l'équipe ${teamColor} a été mis à jour avec succès dans le fichier json !`);
+                    console.log(`[INFO] Le score total de l'équipe ${teamColor} a été mis à jour avec succès dans le fichier json !`);
                 }
             });
         } catch (parseErr) {
-            console.error("Erreur de parsing JSON :", parseErr);
+            console.error("[ERREUR] Erreur de parsing JSON :", parseErr);
         }
     });
 }
@@ -136,26 +140,45 @@ const configPath = path.join(__dirname, '../config/configuration.json');
 const config = JSON.parse(fs.readFileSync(configPath, 'utf8'));
 
 // Extraction des informations de config
-const { mqttHost, services: { score: { MQTTconfig: { mqttScoreTopic, mqttScoreChangeTopic } } } } = config;
-console.log("DEBUG: Config loaded from:", configPath);
-console.log("DEBUG: MQTT Host:", mqttHost);
-console.log("DEBUG: Topics:", mqttScoreTopic, mqttScoreChangeTopic);
+const { mqttHost, services: { score: { MQTTconfig: { mqttScoreTopic, mqttScoreChangeTopic, mqttScoreRequestTopic } } } } = config;
+console.log("------------------------------------------------------------------------------");
+console.log("[CONFIG] Configuration chargée depuis   :", configPath);
+console.log("[CONFIG] Hôte MQTT                      :", mqttHost);
+console.log("[CONFIG] Topics chargés                 :", mqttScoreTopic, mqttScoreChangeTopic, mqttScoreRequestTopic);
+console.log("------------------------------------------------------------------------------");
 
 // Connexion au broker MQTT
 const client = mqtt.connect(mqttHost);
 
 client.on('connect', () => {
-    console.log(`Connecté au broker MQTT à ${mqttHost}`);
+    console.log(`[INFO] Connecté au broker MQTT à ${mqttHost}`);
 
     client.subscribe(mqttScoreChangeTopic, (err) => {
-        if (err) console.error('[ERROR] impossible de souscrire au topic de gestion du score total');
-        else console.log(`[INFO] Souscription réalisée avec succès au topic ${mqttScoreChangeTopic}]`);
+        if (err) console.error('[ERREUR] impossible de souscrire au topic de gestion du score total');
+        else console.log(`[INFO] Souscription réalisée avec succès au topic ${mqttScoreChangeTopic}`);
+    });
+
+    client.subscribe(mqttScoreRequestTopic, (err) => {
+        if (err) console.error('[ERREUR] impossible de souscrire au topic de demande de score');
+        else console.log(`[INFO] Souscription réalisée avec succès au topic ${mqttScoreRequestTopic}`);
     });
 
 });
 
 // Gestion des messages entrants
 client.on('message', (topic, message) => {
+    // Gestion de la demande de score (REFRESH)
+    if (topic === mqttScoreRequestTopic) {
+        console.log(`[INFO] Demande de rafraîchissement des scores reçue sur ${topic}`);
+        if (global.jsonData) {
+            client.publish(mqttScoreTopic, JSON.stringify(global.jsonData));
+            console.log(`[INFO] Scores envoyés sur ${mqttScoreTopic}`);
+        } else {
+            console.warn("[INFO] Aucune donnée de score disponible pour le rafraîchissement");
+        }
+        return; // Fin du traitement pour ce message
+    }
+
     let payload;
     let process;
     let Team;
@@ -167,7 +190,7 @@ client.on('message', (topic, message) => {
         // Analyse du message reçu
         payload = JSON.parse(message.toString());
     } catch (e) {
-        console.error(`[ERROR] Invalid JSON message received on topic ${topic}: ${message.toString()}`);
+        console.error(`[ERREUR] Invalid JSON message received on topic ${topic}: ${message.toString()}`);
         return;
     }
     // Vérifie que le payload est bien un objet
@@ -202,7 +225,7 @@ client.on('message', (topic, message) => {
             if (!isNaN(change)) {
                 updateTeamTotalScore(Team, change);
             } else {
-                console.error(`Action invalide : ${Action}`);
+                console.error(`[ERREUR] Action invalide : ${Action}`);
             }
         }
     }
@@ -213,7 +236,7 @@ client.on('message', (topic, message) => {
 function updateTeamScoreAbsolute(teamColor, totalScore, roundScore) {
     fs.readFile(filePath, 'utf8', (err, data) => {
         if (err) {
-            console.error("Erreur de lecture du fichier :", err);
+            console.error("[ERREUR] Erreur de lecture du fichier :", err);
             return;
         }
         try {
@@ -232,26 +255,26 @@ function updateTeamScoreAbsolute(teamColor, totalScore, roundScore) {
 
             console.log(`Mise à jour absolue pour ${teamColor} -> Total: ${jsonData.TEAM[teamColor].TotalScore}, Round: ${jsonData.TEAM[teamColor].RoundScore}`);
 
+            // Update global state
+            global.jsonData = jsonData;
+
             client.publish(mqttScoreTopic, JSON.stringify(jsonData));
             fs.writeFile(filePath, JSON.stringify(jsonData, null, 2), (err) => {
-                if (err) console.error("Erreur d'écriture :", err);
+                if (err) console.error("[ERREUR] Erreur d'écriture :", err);
             });
         } catch (parseErr) {
-            console.error("Erreur JSON :", parseErr);
+            console.error("[ERREUR] Erreur JSON :", parseErr);
         }
     });
 }
 
 (async () => {
     while (true) {
-        console.log("Boucle en arrière-plan");
-
         await new Promise((resolve) => setTimeout(resolve, 2000)); // Pause de 2 secondes
         //client.publish(mqttScoreTopic, JSON.stringify(global.jsonData));
     }
 })();
 
 client.on('error', (error) => {
-    console.error('Erreur de connexion au broker MQTT:', error.message);
-});
-
+    console.error("[ERREUR] Erreur de connexion au broker MQTT:", error.message);
+});