diff --git a/VNode/services/game/quizz-collector.js b/VNode/services/game/quizz-collector.js index 63300539..c8f7a144 100644 --- a/VNode/services/game/quizz-collector.js +++ b/VNode/services/game/quizz-collector.js @@ -15,19 +15,19 @@ const folderPath = 'quizz'; // Remplace par le chemin de ton dossier const client = mqtt.connect(mqttHost); client.on('connect', () => { - console.log('Connecté au broker MQTT'); + console.log('[INFO] Connecté au broker MQTT'); client.subscribe(mqttQuizzCollectorCmdTopic, (err) => { if (err) { - console.error("Erreur lors de l'abonnement au topic de commande:", err); + console.error("[ERREUR] Erreur lors de l'abonnement au topic de commande:", err); } else { - console.log(`Abonné au topic ${mqttQuizzCollectorCmdTopic}`); + console.log(`[INFO] Abonné au topic ${mqttQuizzCollectorCmdTopic}`); } }); }); client.on('message', (topic, message) => { if (topic === mqttQuizzCollectorCmdTopic) { - console.log('Commande reçue, lecture du dossier en cours...'); + console.log('[INFO] Commande reçue, lecture du dossier en cours...'); Collect(); } }); @@ -36,17 +36,17 @@ client.on('message', (topic, message) => { function Collect() { fs.readdir(folderPath, (err, files) => { if (err) { - console.error('Erreur lors de la lecture du dossier:', err); + console.error('[ERREUR] Erreur lors de la lecture du dossier:', err); return; } - console.log('Dossiers trouvés:', files); + console.log('[INFO] Dossiers trouvés:', files); const message = JSON.stringify(files); client.publish(mqttQuizzCollectorListTopic, message, { qos: 1 }, (err) => { if (err) { - console.error('Erreur lors de la publication MQTT:', err); + console.error('[ERREUR] Erreur lors de la publication MQTT:', err); } else { - console.log('Liste des fichiers publiée sur MQTT'); + console.log('[INFO] Liste des fichiers publiée sur MQTT'); } }); });