style(QuizzCollector): Amélioration formatage des logs ([INFO]/[ERREUR])

This commit is contained in:
2026-02-08 16:34:15 +01:00
parent ce8d859126
commit b1b7080fbe

View File

@@ -15,19 +15,19 @@ const folderPath = 'quizz'; // Remplace par le chemin de ton dossier
const client = mqtt.connect(mqttHost); const client = mqtt.connect(mqttHost);
client.on('connect', () => { client.on('connect', () => {
console.log('Connecté au broker MQTT'); console.log('[INFO] Connecté au broker MQTT');
client.subscribe(mqttQuizzCollectorCmdTopic, (err) => { client.subscribe(mqttQuizzCollectorCmdTopic, (err) => {
if (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 { } else {
console.log(`Abonné au topic ${mqttQuizzCollectorCmdTopic}`); console.log(`[INFO] Abonné au topic ${mqttQuizzCollectorCmdTopic}`);
} }
}); });
}); });
client.on('message', (topic, message) => { client.on('message', (topic, message) => {
if (topic === mqttQuizzCollectorCmdTopic) { 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(); Collect();
} }
}); });
@@ -36,17 +36,17 @@ client.on('message', (topic, message) => {
function Collect() { function Collect() {
fs.readdir(folderPath, (err, files) => { fs.readdir(folderPath, (err, files) => {
if (err) { if (err) {
console.error('Erreur lors de la lecture du dossier:', err); console.error('[ERREUR] Erreur lors de la lecture du dossier:', err);
return; return;
} }
console.log('Dossiers trouvés:', files); console.log('[INFO] Dossiers trouvés:', files);
const message = JSON.stringify(files); const message = JSON.stringify(files);
client.publish(mqttQuizzCollectorListTopic, message, { qos: 1 }, (err) => { client.publish(mqttQuizzCollectorListTopic, message, { qos: 1 }, (err) => {
if (err) { if (err) {
console.error('Erreur lors de la publication MQTT:', err); console.error('[ERREUR] Erreur lors de la publication MQTT:', err);
} else { } else {
console.log('Liste des fichiers publiée sur MQTT'); console.log('[INFO] Liste des fichiers publiée sur MQTT');
} }
}); });
}); });