Ajustement de l'interface de console MQTT, couleur appliqués au Topic et Msg pour bien trancher toute la ligne (plus facile à lire)

buzzer/README.md

@@ -0,0 +1,31 @@
+# buzzer
+
+Code arduino du buzzer
+
+## memo arduino-cli
+
+Pour Compilation en ligne de commande.
+
+### Configuration
+
+Après installation d'arduino
+
+```sh
+arduino-cli config init
+arduino-cli config add board_manager.additional_urls http://arduino.esp8266.com/stable/package_esp8266com_index.json
+arduino-cli core update-index
+arduino-cli core install esp8266:esp8266
+arduino-cli lib install PubSubClient
+```
+
+### Compilation
+
+```sh
+arduino-cli compile --fqbn esp8266:esp8266:nodemcuv2 buzzer.ino
+```
+
+### Envoi vers l'ESP
+
+```sh
+ arduino-cli upload -p /dev/ttyUSB0 --fqbn esp8266:esp8266:nodemcuv2 buzzer.ino
+```

buzzer/buzzer.ino

@@ -0,0 +1,68 @@
+#include <ESP8266WiFi.h>
+#include <PubSubClient.h>
+
+// Configurations WiFi et MQTT
+const char* ssid = "Redmi Note 13 Pro 5G";
+const char* password = "1234567890";
+const char* mqtt_server = "192.168.127.208";
+const char* mqtt_topic = "brainblast/buzzer/pressed/1";
+const char* mqtt_message = "{\"buzzer_id\": 1, \"color\": \"#FF7518\"}";
+
+// Déclaration des broches
+#define BUTTON_PIN D8
+
+WiFiClient espClient;
+PubSubClient client(espClient);
+
+void setup_wifi() {
+  delay(10);
+  Serial.println();
+  Serial.print("Connexion au WiFi...");
+  WiFi.begin(ssid, password);
+
+  while (WiFi.status() != WL_CONNECTED) {
+    delay(500);
+    Serial.print(".");
+  }
+
+  Serial.println("");
+  Serial.println("WiFi connecté");
+  Serial.print("Adresse IP: ");
+  Serial.println(WiFi.localIP());
+}
+
+void reconnect() {
+  while (!client.connected()) {
+    Serial.print("Connexion au broker MQTT...");
+    if (client.connect("ESP8266Client")) {
+      Serial.println("connecté");
+    } else {
+      Serial.print("échec, rc=");
+      Serial.print(client.state());
+      Serial.println("; nouvelle tentative dans 5 secondes");
+      delay(5000);
+    }
+  }
+}
+
+void setup() {
+  Serial.begin(115200);
+  pinMode(BUTTON_PIN, INPUT_PULLUP);
+
+  setup_wifi();
+  client.setServer(mqtt_server, 1883);
+}
+
+void loop() {
+  if (!client.connected()) {
+    reconnect();
+  }
+  client.loop();
+
+  // Vérifier si le bouton est pressé
+  if (digitalRead(BUTTON_PIN) == HIGH) {
+    Serial.println("Bouton pressé, envoi du message...");
+    client.publish(mqtt_topic, mqtt_message);
+    delay(200);  // Anti-rebond pour éviter les publications multiples
+  }
+}

services/buzzer-manager.js

@@ -0,0 +1,223 @@
+// Import necessary modules
+const mqtt = require('mqtt');
+
+// MQTT broker configuration
+const brokerUrl = 'mqtt://localhost'; // Broker URL (change if needed)
+const clientId = 'buzzer_manager';
+const options = {
+    clientId,
+    clean: true
+};
+
+// State variables
+let buzzerActive = false; // Indicates if buzzers are blocked
+let buzzerThatPressed = null; // Stores the ID of the buzzer that pressed first
+let tiltBuzzers = new Set(); // List of buzzer IDs currently in "tilt" mode
+
+// Connect to the MQTT broker
+const client = mqtt.connect(brokerUrl, options);
+
+client.on('connect', () => {
+    console.log(`[INFO] Connected to MQTT broker ${brokerUrl} with ID ${clientId}`);
+
+    // Subscribe to topics related to buzzer presses, unlocking, and tilt management
+    client.subscribe('brainblast/buzzer/pressed/#', (err) => {
+        if (err) console.error('[ERROR] Failed to subscribe to buzzer presses');
+        else console.log('[INFO] Successfully subscribed to buzzer presses');
+    });
+
+    client.subscribe('brainblast/buzzer/unlock', (err) => {
+        if (err) console.error('[ERROR] Failed to subscribe to buzzer unlock');
+        else console.log('[INFO] Successfully subscribed to buzzer unlock');
+    });
+
+    client.subscribe('brainblast/buzzer/tilt', (err) => {
+        if (err) console.error('[ERROR] Failed to subscribe to tilt management');
+        else console.log('[INFO] Successfully subscribed to tilt management');
+    });
+});
+
+// Validate buzzer payload
+function validateBuzzerPayload(payload) {
+    const { buzzer_id, color } = payload;
+
+    // Validate buzzer ID (should be a positive integer)
+    if (typeof buzzer_id !== 'number' || buzzer_id <= 0) {
+        console.error(`[ERROR] Invalid buzzer ID: ${buzzer_id}`);
+        return false;
+    }
+
+    // Validate color (should be in the format #RRGGBB)
+    const validColor = /^#[0-9A-F]{6}$/i.test(color);
+    if (!validColor) {
+        console.error(`[ERROR] Invalid color: ${color}`);
+        return false;
+    }
+
+    return true;
+}
+
+// Send updated tilt status
+function sendTiltStatus(action, buzzerId) {
+    const tiltList = Array.from(tiltBuzzers); // Convert Set to Array
+
+    client.publish('brainblast/buzzer/status', JSON.stringify({
+        status: "tilt_update",
+        tilt_buzzers: tiltList,
+        message: `Buzzer ID ${buzzerId} ${action} to tilt mode`,
+        timestamp: new Date().toISOString()
+    }));
+
+    console.log(`[INFO] Tilt status updated: ${tiltList.length} buzzers in tilt mode`);
+}
+
+// Handle incoming messages
+client.on('message', (topic, message) => {
+    let payload;
+
+    // Parse the incoming message
+    try {
+        payload = JSON.parse(message.toString());
+    } catch (e) {
+        console.error(`[ERROR] Invalid JSON message received on topic ${topic}: ${message.toString()}`);
+        return;
+    }
+
+    // Manage tilt mode for buzzers
+    if (topic === 'brainblast/buzzer/tilt') {
+        const { buzzer_id, status } = payload;
+
+        if (typeof buzzer_id !== 'number' || !['add', 'remove'].includes(status)) {
+            console.error('[ERROR] Invalid tilt payload, message ignored.');
+            return;
+        }
+
+        // Update tilt status based on the command
+        if (status === 'add') {
+            tiltBuzzers.add(buzzer_id);
+            console.log(`[INFO] Buzzer ID ${buzzer_id} added to tilt mode`);
+        } else if (status === 'remove') {
+            tiltBuzzers.delete(buzzer_id);
+            console.log(`[INFO] Buzzer ID ${buzzer_id} removed from tilt mode`);
+        }
+
+        // Confirm that the tilt command has been received
+        client.publish(`brainblast/buzzer/tilt/confirmation/${buzzer_id}`, JSON.stringify({
+            status: "received",
+            action: status,
+            buzzer_id: buzzer_id,
+            message: `Tilt command '${status}' received for buzzer ID ${buzzer_id}`,
+            timestamp: new Date().toISOString()
+        }));
+
+        // Send the updated tilt status to all components
+        sendTiltStatus(status === 'add' ? 'added' : 'removed', buzzer_id);
+
+        return;
+    }
+
+    // Detect a buzzer press
+    if (topic.startsWith('brainblast/buzzer/pressed/')) {
+        // Validate buzzer payload
+        if (!validateBuzzerPayload(payload)) {
+            console.error('[ERROR] Invalid buzzer payload, message ignored.');
+            return;
+        }
+
+        const buzzerId = payload.buzzer_id; // Unique buzzer ID
+        const color = payload.color; // Associated hex color
+
+        // Always send a confirmation, even if the buzzer is in tilt mode
+        client.publish(`brainblast/buzzer/confirmation/${buzzerId}`, JSON.stringify({
+            status: "received",
+            buzzer_id: buzzerId,
+            message: `Buzzer ID ${buzzerId} received (Color: ${color})`,
+            timestamp: new Date().toISOString()
+        }));
+
+        // Ignore if the buzzer is in tilt mode, but notify this event
+        if (tiltBuzzers.has(buzzerId)) {
+            console.log(`[INFO] Buzzer ID ${buzzerId} ignored (Tilt mode active)`);
+
+            // Notify that the buzzer is in tilt mode and ignored
+            client.publish(`brainblast/buzzer/tilt/ignored/${buzzerId}`, JSON.stringify({
+                status: "tilt_ignored",
+                buzzer_id: buzzerId,
+                message: `Buzzer ID ${buzzerId} is in tilt mode and ignored.`,
+                timestamp: new Date().toISOString()
+            }));
+            return;
+        }
+
+        // Notify activity even if buzzers are blocked
+        client.publish('brainblast/buzzer/activity', JSON.stringify({
+            buzzer_id: buzzerId,
+            color: color,
+            status: buzzerActive ? "blocked" : "free",
+            message: `Activity detected on buzzer ID ${buzzerId} (Color: ${color})`,
+            timestamp: new Date().toISOString()
+        }));
+
+        if (!buzzerActive) {
+            // Block further buzzers and record the first pressed ID
+            buzzerActive = true;
+            buzzerThatPressed = buzzerId;
+
+            console.log(`[INFO] Buzzer activated by ID: ${buzzerId} (Color: ${color})`);
+
+            // Notify the light manager to change to the team's color
+            client.publish('brainblast/light/change', JSON.stringify({
+                color: color,
+                effect: 'full_color'
+            }));
+
+            // Notify all components of buzzer blocking
+            client.publish('brainblast/buzzer/status', JSON.stringify({
+                status: "blocked",
+                buzzer_id: buzzerId,
+                color: color,
+                message: `Buzzer activated by ID ${buzzerId} (Color: ${color})`,
+                timestamp: new Date().toISOString()
+            }));
+
+            console.log(`[INFO] Buzzers blocked and notification sent`);
+        }
+    }
+
+    // Unlock buzzers
+    if (topic === 'brainblast/buzzer/unlock') {
+        console.log('[INFO] Buzzer unlock requested');
+
+        // Confirm receipt of unlock command
+        client.publish('brainblast/buzzer/unlock/confirmation', JSON.stringify({
+            status: "received",
+            message: "Buzzer unlock command received.",
+            timestamp: new Date().toISOString()
+        }));
+        // Notify the light manager to change to the team's color
+        client.publish('brainblast/light/change', JSON.stringify({
+            color: "#FFFFFF",
+            effect: 'rainbow'
+        }));
+
+
+        // Reset buzzer manager state
+        buzzerActive = false;
+        buzzerThatPressed = null;
+
+        // Notify all components of buzzer unlock
+        client.publish('brainblast/buzzer/status', JSON.stringify({
+            status: "unblocked",
+            message: "Buzzers unblocked and ready for activation.",
+            timestamp: new Date().toISOString()
+        }));
+
+        console.log('[INFO] Buzzers unblocked and notification sent');
+    }
+});
+
+client.on('error', (err) => {
+    console.error(`[ERROR] Error connecting to broker: ${err}`);
+});
+
+console.log('[INFO] Buzzer manager started...');

services/light-manager.js

@@ -0,0 +1,138 @@
+// Import du module MQTT
+const mqtt = require('mqtt');
+
+// Configuration du broker MQTT et de WLED
+const brokerUrl = 'mqtt://localhost';  // Change ce lien si nécessaire
+const clientId = 'light_manager_wled';
+const wledTopicBase = 'wled/all';  // Le topic de base pour ton ruban WLED
+const options = {
+    clientId,
+    clean: true
+};
+
+// État des lumières
+let currentColor = '#FFFFFF';  // Couleur par défaut (blanc)
+let currentEffect = 'none';  // Pas d'effet par défaut
+
+// Connexion au broker MQTT
+const client = mqtt.connect(brokerUrl, options);
+
+client.on('connect', () => {
+    console.log(`[INFO] Connected to MQTT broker ${brokerUrl} as ${clientId}`);
+
+    // Souscription aux topics de gestion de lumière
+    client.subscribe('brainblast/light/#', (err) => {
+        if (err) console.error('[ERROR] Subscription to light topics failed');
+        else console.log('[INFO] Successfully subscribed to light topics');
+    });
+});
+
+// Fonction pour envoyer un message au ruban WLED
+function sendToWLED(topicSuffix, message) {
+    const wledTopic = `${wledTopicBase}/${topicSuffix}`;
+    client.publish(wledTopic, message, { qos: 1 }, (err) => {
+        if (err) console.error(`[ERROR] Failed to send message to WLED topic: ${wledTopic}`);
+        else console.log(`[INFO] Sent to WLED (${wledTopic}): ${message}`);
+    });
+}
+
+// Fonction pour appliquer un changement de lumière
+function applyLightChange(color, effect, intensity) {
+    currentColor = color || currentColor;
+    currentEffect = effect || currentEffect;
+
+    console.log(`[INFO] Applying light change: Color=${currentColor}, Effect=${currentEffect}, Intensity=${intensity}`);
+
+    // Envoyer la couleur au ruban WLED
+    sendToWLED('col', currentColor);
+
+    // Appliquer l'effet si défini
+    if (currentEffect !== 'none') {
+        const effectId = getWLEDEffectId(currentEffect);
+        sendToWLED('api', "FX=" + effectId.toString());
+    }
+
+    // Régler l'intensité si spécifiée
+    if (intensity) {
+        sendToWLED('api', intensity.toString());
+    }
+
+    // Envoi de l'état mis à jour
+    sendLightStatus();
+}
+
+// Fonction pour obtenir l'ID d'effet WLED correspondant à un effet donné
+function getWLEDEffectId(effect) {
+    const effectsMap = {
+        'none': 0,
+        'blink': 1,      // Effet de fondu
+        'fade': 12,     // Clignotement
+        'rainbow': 9    // Effet arc-en-ciel
+    };
+    return effectsMap[effect] || 0;  // Par défaut, aucun effet
+}
+
+// Fonction pour envoyer l'état actuel des lumières sur le topic de réponse
+function sendLightStatus() {
+    const statusMessage = JSON.stringify({
+        status: "updated",
+        color: currentColor,
+        effect: currentEffect,
+        message: `Current light state: Color=${currentColor}, Effect=${currentEffect}`,
+        timestamp: new Date().toISOString()
+    });
+
+    // Envoi de l'état à tous les clients intéressés
+    client.publish('brainblast/light/status/response', statusMessage);
+
+    console.log('[INFO] Light status sent to brainblast/light/status/response');
+}
+
+// Gestion des messages entrants
+client.on('message', (topic, message) => {
+    let payload;
+
+    try {
+        // Analyse du message reçu
+        payload = JSON.parse(message.toString());
+    } catch (e) {
+        console.error(`[ERROR] Invalid JSON message received on topic ${topic}: ${message.toString()}`);
+        return;
+    }
+
+    // Changement de lumière
+    if (topic === 'brainblast/light/change') {
+        const { color, effect, intensity } = payload;
+
+        // Valider la couleur et l'effet
+        if (!/^#[0-9A-F]{6}$/i.test(color)) {
+            console.error('[ERROR] Invalid color format');
+            return;
+        }
+
+        // Appliquer le changement de lumière
+        applyLightChange(color, effect, intensity);
+
+    } else if (topic === 'brainblast/light/reset') {
+        // Réinitialisation des lumières à la couleur et l'effet par défaut
+        console.log('[INFO] Resetting lights to default state');
+        applyLightChange('#FFFFFF', 'reset', 255);
+
+    } else if (topic === 'brainblast/light/status/request') {
+        // Répondre à la requête de statut
+        console.log('[INFO] Light status request received');
+        sendLightStatus();
+    } else if (topic === 'brainblast/light/status/response') {
+        // Répondre à la requête de statut
+        console.log('[INFO] Light status response received');
+    } else {
+        console.error(`[ERROR] Unrecognized topic: ${topic}`);
+    }
+});
+
+// Gestion des erreurs de connexion
+client.on('error', (err) => {
+    console.error(`[ERROR] Error connecting to broker: ${err}`);
+});
+
+console.log('[INFO] Light Manager with WLED support and status handling started...');

services/package-lock.json

@@ -0,0 +1,497 @@
+{
+  "name": "services",
+  "lockfileVersion": 3,
+  "requires": true,
+  "packages": {
+    "": {
+      "dependencies": {
+        "mqtt": "^5.10.1"
+      }
+    },
+    "node_modules/@babel/runtime": {
+      "version": "7.25.7",
+      "resolved": "https://registry.npmjs.org/@babel/runtime/-/runtime-7.25.7.tgz",
+      "integrity": "sha512-FjoyLe754PMiYsFaN5C94ttGiOmBNYTf6pLr4xXHAT5uctHb092PBszndLDR5XA/jghQvn4n7JMHl7dmTgbm9w==",
+      "license": "MIT",
+      "dependencies": {
+        "regenerator-runtime": "^0.14.0"
+      },
+      "engines": {
+        "node": ">=6.9.0"
+      }
+    },
+    "node_modules/@types/node": {
+      "version": "22.7.4",
+      "resolved": "https://registry.npmjs.org/@types/node/-/node-22.7.4.tgz",
+      "integrity": "sha512-y+NPi1rFzDs1NdQHHToqeiX2TIS79SWEAw9GYhkkx8bD0ChpfqC+n2j5OXOCpzfojBEBt6DnEnnG9MY0zk1XLg==",
+      "license": "MIT",
+      "dependencies": {
+        "undici-types": "~6.19.2"
+      }
+    },
+    "node_modules/@types/readable-stream": {
+      "version": "4.0.15",
+      "resolved": "https://registry.npmjs.org/@types/readable-stream/-/readable-stream-4.0.15.tgz",
+      "integrity": "sha512-oAZ3kw+kJFkEqyh7xORZOku1YAKvsFTogRY8kVl4vHpEKiDkfnSA/My8haRE7fvmix5Zyy+1pwzOi7yycGLBJw==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/node": "*",
+        "safe-buffer": "~5.1.1"
+      }
+    },
+    "node_modules/@types/ws": {
+      "version": "8.5.12",
+      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.5.12.tgz",
+      "integrity": "sha512-3tPRkv1EtkDpzlgyKyI8pGsGZAGPEaXeu0DOj5DI25Ja91bdAYddYHbADRYVrZMRbfW+1l5YwXVDKohDJNQxkQ==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/node": "*"
+      }
+    },
+    "node_modules/abort-controller": {
+      "version": "3.0.0",
+      "resolved": "https://registry.npmjs.org/abort-controller/-/abort-controller-3.0.0.tgz",
+      "integrity": "sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg==",
+      "license": "MIT",
+      "dependencies": {
+        "event-target-shim": "^5.0.0"
+      },
+      "engines": {
+        "node": ">=6.5"
+      }
+    },
+    "node_modules/base64-js": {
+      "version": "1.5.1",
+      "resolved": "https://registry.npmjs.org/base64-js/-/base64-js-1.5.1.tgz",
+      "integrity": "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/feross"
+        },
+        {
+          "type": "patreon",
+          "url": "https://www.patreon.com/feross"
+        },
+        {
+          "type": "consulting",
+          "url": "https://feross.org/support"
+        }
+      ],
+      "license": "MIT"
+    },
+    "node_modules/bl": {
+      "version": "6.0.16",
+      "resolved": "https://registry.npmjs.org/bl/-/bl-6.0.16.tgz",
+      "integrity": "sha512-V/kz+z2Mx5/6qDfRCilmrukUXcXuCoXKg3/3hDvzKKoSUx8CJKudfIoT29XZc3UE9xBvxs5qictiHdprwtteEg==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/readable-stream": "^4.0.0",
+        "buffer": "^6.0.3",
+        "inherits": "^2.0.4",
+        "readable-stream": "^4.2.0"
+      }
+    },
+    "node_modules/buffer": {
+      "version": "6.0.3",
+      "resolved": "https://registry.npmjs.org/buffer/-/buffer-6.0.3.tgz",
+      "integrity": "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/feross"
+        },
+        {
+          "type": "patreon",
+          "url": "https://www.patreon.com/feross"
+        },
+        {
+          "type": "consulting",
+          "url": "https://feross.org/support"
+        }
+      ],
+      "license": "MIT",
+      "dependencies": {
+        "base64-js": "^1.3.1",
+        "ieee754": "^1.2.1"
+      }
+    },
+    "node_modules/buffer-from": {
+      "version": "1.1.2",
+      "resolved": "https://registry.npmjs.org/buffer-from/-/buffer-from-1.1.2.tgz",
+      "integrity": "sha512-E+XQCRwSbaaiChtv6k6Dwgc+bx+Bs6vuKJHHl5kox/BaKbhiXzqQOwK4cO22yElGp2OCmjwVhT3HmxgyPGnJfQ==",
+      "license": "MIT"
+    },
+    "node_modules/commist": {
+      "version": "3.2.0",
+      "resolved": "https://registry.npmjs.org/commist/-/commist-3.2.0.tgz",
+      "integrity": "sha512-4PIMoPniho+LqXmpS5d3NuGYncG6XWlkBSVGiWycL22dd42OYdUGil2CWuzklaJoNxyxUSpO4MKIBU94viWNAw==",
+      "license": "MIT"
+    },
+    "node_modules/concat-stream": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/concat-stream/-/concat-stream-2.0.0.tgz",
+      "integrity": "sha512-MWufYdFw53ccGjCA+Ol7XJYpAlW6/prSMzuPOTRnJGcGzuhLn4Scrz7qf6o8bROZ514ltazcIFJZevcfbo0x7A==",
+      "engines": [
+        "node >= 6.0"
+      ],
+      "license": "MIT",
+      "dependencies": {
+        "buffer-from": "^1.0.0",
+        "inherits": "^2.0.3",
+        "readable-stream": "^3.0.2",
+        "typedarray": "^0.0.6"
+      }
+    },
+    "node_modules/concat-stream/node_modules/readable-stream": {
+      "version": "3.6.2",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-3.6.2.tgz",
+      "integrity": "sha512-9u/sniCrY3D5WdsERHzHE4G2YCXqoG5FTHUiCC4SIbr6XcLZBY05ya9EKjYek9O5xOAwjGq+1JdGBAS7Q9ScoA==",
+      "license": "MIT",
+      "dependencies": {
+        "inherits": "^2.0.3",
+        "string_decoder": "^1.1.1",
+        "util-deprecate": "^1.0.1"
+      },
+      "engines": {
+        "node": ">= 6"
+      }
+    },
+    "node_modules/debug": {
+      "version": "4.3.7",
+      "resolved": "https://registry.npmjs.org/debug/-/debug-4.3.7.tgz",
+      "integrity": "sha512-Er2nc/H7RrMXZBFCEim6TCmMk02Z8vLC2Rbi1KEBggpo0fS6l0S1nnapwmIi3yW/+GOJap1Krg4w0Hg80oCqgQ==",
+      "license": "MIT",
+      "dependencies": {
+        "ms": "^2.1.3"
+      },
+      "engines": {
+        "node": ">=6.0"
+      },
+      "peerDependenciesMeta": {
+        "supports-color": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/event-target-shim": {
+      "version": "5.0.1",
+      "resolved": "https://registry.npmjs.org/event-target-shim/-/event-target-shim-5.0.1.tgz",
+      "integrity": "sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=6"
+      }
+    },
+    "node_modules/events": {
+      "version": "3.3.0",
+      "resolved": "https://registry.npmjs.org/events/-/events-3.3.0.tgz",
+      "integrity": "sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=0.8.x"
+      }
+    },
+    "node_modules/fast-unique-numbers": {
+      "version": "8.0.13",
+      "resolved": "https://registry.npmjs.org/fast-unique-numbers/-/fast-unique-numbers-8.0.13.tgz",
+      "integrity": "sha512-7OnTFAVPefgw2eBJ1xj2PGGR9FwYzSUso9decayHgCDX4sJkHLdcsYTytTg+tYv+wKF3U8gJuSBz2jJpQV4u/g==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.23.8",
+        "tslib": "^2.6.2"
+      },
+      "engines": {
+        "node": ">=16.1.0"
+      }
+    },
+    "node_modules/help-me": {
+      "version": "5.0.0",
+      "resolved": "https://registry.npmjs.org/help-me/-/help-me-5.0.0.tgz",
+      "integrity": "sha512-7xgomUX6ADmcYzFik0HzAxh/73YlKR9bmFzf51CZwR+b6YtzU2m0u49hQCqV6SvlqIqsaxovfwdvbnsw3b/zpg==",
+      "license": "MIT"
+    },
+    "node_modules/ieee754": {
+      "version": "1.2.1",
+      "resolved": "https://registry.npmjs.org/ieee754/-/ieee754-1.2.1.tgz",
+      "integrity": "sha512-dcyqhDvX1C46lXZcVqCpK+FtMRQVdIMN6/Df5js2zouUsqG7I6sFxitIC+7KYK29KdXOLHdu9zL4sFnoVQnqaA==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/feross"
+        },
+        {
+          "type": "patreon",
+          "url": "https://www.patreon.com/feross"
+        },
+        {
+          "type": "consulting",
+          "url": "https://feross.org/support"
+        }
+      ],
+      "license": "BSD-3-Clause"
+    },
+    "node_modules/inherits": {
+      "version": "2.0.4",
+      "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.4.tgz",
+      "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ==",
+      "license": "ISC"
+    },
+    "node_modules/js-sdsl": {
+      "version": "4.3.0",
+      "resolved": "https://registry.npmjs.org/js-sdsl/-/js-sdsl-4.3.0.tgz",
+      "integrity": "sha512-mifzlm2+5nZ+lEcLJMoBK0/IH/bDg8XnJfd/Wq6IP+xoCjLZsTOnV2QpxlVbX9bMnkl5PdEjNtBJ9Cj1NjifhQ==",
+      "license": "MIT",
+      "funding": {
+        "type": "opencollective",
+        "url": "https://opencollective.com/js-sdsl"
+      }
+    },
+    "node_modules/lru-cache": {
+      "version": "10.4.3",
+      "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-10.4.3.tgz",
+      "integrity": "sha512-JNAzZcXrCt42VGLuYz0zfAzDfAvJWW6AfYlDBQyDV5DClI2m5sAmK+OIO7s59XfsRsWHp02jAJrRadPRGTt6SQ==",
+      "license": "ISC"
+    },
+    "node_modules/minimist": {
+      "version": "1.2.8",
+      "resolved": "https://registry.npmjs.org/minimist/-/minimist-1.2.8.tgz",
+      "integrity": "sha512-2yyAR8qBkN3YuheJanUpWC5U3bb5osDywNB8RzDVlDwDHbocAJveqqj1u8+SVD7jkWT4yvsHCpWqqWqAxb0zCA==",
+      "license": "MIT",
+      "funding": {
+        "url": "https://github.com/sponsors/ljharb"
+      }
+    },
+    "node_modules/mqtt": {
+      "version": "5.10.1",
+      "resolved": "https://registry.npmjs.org/mqtt/-/mqtt-5.10.1.tgz",
+      "integrity": "sha512-hXCOki8sANoQ7w+2OzJzg6qMBxTtrH9RlnVNV8panLZgnl+Gh0J/t4k6r8Az8+C7y3KAcyXtn0mmLixyUom8Sw==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/readable-stream": "^4.0.5",
+        "@types/ws": "^8.5.9",
+        "commist": "^3.2.0",
+        "concat-stream": "^2.0.0",
+        "debug": "^4.3.4",
+        "help-me": "^5.0.0",
+        "lru-cache": "^10.0.1",
+        "minimist": "^1.2.8",
+        "mqtt-packet": "^9.0.0",
+        "number-allocator": "^1.0.14",
+        "readable-stream": "^4.4.2",
+        "reinterval": "^1.1.0",
+        "rfdc": "^1.3.0",
+        "split2": "^4.2.0",
+        "worker-timers": "^7.1.4",
+        "ws": "^8.17.1"
+      },
+      "bin": {
+        "mqtt": "build/bin/mqtt.js",
+        "mqtt_pub": "build/bin/pub.js",
+        "mqtt_sub": "build/bin/sub.js"
+      },
+      "engines": {
+        "node": ">=16.0.0"
+      }
+    },
+    "node_modules/mqtt-packet": {
+      "version": "9.0.0",
+      "resolved": "https://registry.npmjs.org/mqtt-packet/-/mqtt-packet-9.0.0.tgz",
+      "integrity": "sha512-8v+HkX+fwbodsWAZIZTI074XIoxVBOmPeggQuDFCGg1SqNcC+uoRMWu7J6QlJPqIUIJXmjNYYHxBBLr1Y/Df4w==",
+      "license": "MIT",
+      "dependencies": {
+        "bl": "^6.0.8",
+        "debug": "^4.3.4",
+        "process-nextick-args": "^2.0.1"
+      }
+    },
+    "node_modules/ms": {
+      "version": "2.1.3",
+      "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz",
+      "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==",
+      "license": "MIT"
+    },
+    "node_modules/number-allocator": {
+      "version": "1.0.14",
+      "resolved": "https://registry.npmjs.org/number-allocator/-/number-allocator-1.0.14.tgz",
+      "integrity": "sha512-OrL44UTVAvkKdOdRQZIJpLkAdjXGTRda052sN4sO77bKEzYYqWKMBjQvrJFzqygI99gL6Z4u2xctPW1tB8ErvA==",
+      "license": "MIT",
+      "dependencies": {
+        "debug": "^4.3.1",
+        "js-sdsl": "4.3.0"
+      }
+    },
+    "node_modules/process": {
+      "version": "0.11.10",
+      "resolved": "https://registry.npmjs.org/process/-/process-0.11.10.tgz",
+      "integrity": "sha512-cdGef/drWFoydD1JsMzuFf8100nZl+GT+yacc2bEced5f9Rjk4z+WtFUTBu9PhOi9j/jfmBPu0mMEY4wIdAF8A==",
+      "license": "MIT",
+      "engines": {
+        "node": ">= 0.6.0"
+      }
+    },
+    "node_modules/process-nextick-args": {
+      "version": "2.0.1",
+      "resolved": "https://registry.npmjs.org/process-nextick-args/-/process-nextick-args-2.0.1.tgz",
+      "integrity": "sha512-3ouUOpQhtgrbOa17J7+uxOTpITYWaGP7/AhoR3+A+/1e9skrzelGi/dXzEYyvbxubEF6Wn2ypscTKiKJFFn1ag==",
+      "license": "MIT"
+    },
+    "node_modules/readable-stream": {
+      "version": "4.5.2",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-4.5.2.tgz",
+      "integrity": "sha512-yjavECdqeZ3GLXNgRXgeQEdz9fvDDkNKyHnbHRFtOr7/LcfgBcmct7t/ET+HaCTqfh06OzoAxrkN/IfjJBVe+g==",
+      "license": "MIT",
+      "dependencies": {
+        "abort-controller": "^3.0.0",
+        "buffer": "^6.0.3",
+        "events": "^3.3.0",
+        "process": "^0.11.10",
+        "string_decoder": "^1.3.0"
+      },
+      "engines": {
+        "node": "^12.22.0 || ^14.17.0 || >=16.0.0"
+      }
+    },
+    "node_modules/regenerator-runtime": {
+      "version": "0.14.1",
+      "resolved": "https://registry.npmjs.org/regenerator-runtime/-/regenerator-runtime-0.14.1.tgz",
+      "integrity": "sha512-dYnhHh0nJoMfnkZs6GmmhFknAGRrLznOu5nc9ML+EJxGvrx6H7teuevqVqCuPcPK//3eDrrjQhehXVx9cnkGdw==",
+      "license": "MIT"
+    },
+    "node_modules/reinterval": {
+      "version": "1.1.0",
+      "resolved": "https://registry.npmjs.org/reinterval/-/reinterval-1.1.0.tgz",
+      "integrity": "sha512-QIRet3SYrGp0HUHO88jVskiG6seqUGC5iAG7AwI/BV4ypGcuqk9Du6YQBUOUqm9c8pw1eyLoIaONifRua1lsEQ==",
+      "license": "MIT"
+    },
+    "node_modules/rfdc": {
+      "version": "1.4.1",
+      "resolved": "https://registry.npmjs.org/rfdc/-/rfdc-1.4.1.tgz",
+      "integrity": "sha512-q1b3N5QkRUWUl7iyylaaj3kOpIT0N2i9MqIEQXP73GVsN9cw3fdx8X63cEmWhJGi2PPCF23Ijp7ktmd39rawIA==",
+      "license": "MIT"
+    },
+    "node_modules/safe-buffer": {
+      "version": "5.1.2",
+      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",
+      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g==",
+      "license": "MIT"
+    },
+    "node_modules/split2": {
+      "version": "4.2.0",
+      "resolved": "https://registry.npmjs.org/split2/-/split2-4.2.0.tgz",
+      "integrity": "sha512-UcjcJOWknrNkF6PLX83qcHM6KHgVKNkV62Y8a5uYDVv9ydGQVwAHMKqHdJje1VTWpljG0WYpCDhrCdAOYH4TWg==",
+      "license": "ISC",
+      "engines": {
+        "node": ">= 10.x"
+      }
+    },
+    "node_modules/string_decoder": {
+      "version": "1.3.0",
+      "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
+      "integrity": "sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==",
+      "license": "MIT",
+      "dependencies": {
+        "safe-buffer": "~5.2.0"
+      }
+    },
+    "node_modules/string_decoder/node_modules/safe-buffer": {
+      "version": "5.2.1",
+      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.2.1.tgz",
+      "integrity": "sha512-rp3So07KcdmmKbGvgaNxQSJr7bGVSVk5S9Eq1F+ppbRo70+YeaDxkw5Dd8NPN+GD6bjnYm2VuPuCXmpuYvmCXQ==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/feross"
+        },
+        {
+          "type": "patreon",
+          "url": "https://www.patreon.com/feross"
+        },
+        {
+          "type": "consulting",
+          "url": "https://feross.org/support"
+        }
+      ],
+      "license": "MIT"
+    },
+    "node_modules/tslib": {
+      "version": "2.7.0",
+      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.7.0.tgz",
+      "integrity": "sha512-gLXCKdN1/j47AiHiOkJN69hJmcbGTHI0ImLmbYLHykhgeN0jVGola9yVjFgzCUklsZQMW55o+dW7IXv3RCXDzA==",
+      "license": "0BSD"
+    },
+    "node_modules/typedarray": {
+      "version": "0.0.6",
+      "resolved": "https://registry.npmjs.org/typedarray/-/typedarray-0.0.6.tgz",
+      "integrity": "sha512-/aCDEGatGvZ2BIk+HmLf4ifCJFwvKFNb9/JeZPMulfgFracn9QFcAf5GO8B/mweUjSoblS5In0cWhqpfs/5PQA==",
+      "license": "MIT"
+    },
+    "node_modules/undici-types": {
+      "version": "6.19.8",
+      "resolved": "https://registry.npmjs.org/undici-types/-/undici-types-6.19.8.tgz",
+      "integrity": "sha512-ve2KP6f/JnbPBFyobGHuerC9g1FYGn/F8n1LWTwNxCEzd6IfqTwUQcNXgEtmmQ6DlRrC1hrSrBnCZPokRrDHjw==",
+      "license": "MIT"
+    },
+    "node_modules/util-deprecate": {
+      "version": "1.0.2",
+      "resolved": "https://registry.npmjs.org/util-deprecate/-/util-deprecate-1.0.2.tgz",
+      "integrity": "sha512-EPD5q1uXyFxJpCrLnCc1nHnq3gOa6DZBocAIiI2TaSCA7VCJ1UJDMagCzIkXNsUYfD1daK//LTEQ8xiIbrHtcw==",
+      "license": "MIT"
+    },
+    "node_modules/worker-timers": {
+      "version": "7.1.8",
+      "resolved": "https://registry.npmjs.org/worker-timers/-/worker-timers-7.1.8.tgz",
+      "integrity": "sha512-R54psRKYVLuzff7c1OTFcq/4Hue5Vlz4bFtNEIarpSiCYhpifHU3aIQI29S84o1j87ePCYqbmEJPqwBTf+3sfw==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.24.5",
+        "tslib": "^2.6.2",
+        "worker-timers-broker": "^6.1.8",
+        "worker-timers-worker": "^7.0.71"
+      }
+    },
+    "node_modules/worker-timers-broker": {
+      "version": "6.1.8",
+      "resolved": "https://registry.npmjs.org/worker-timers-broker/-/worker-timers-broker-6.1.8.tgz",
+      "integrity": "sha512-FUCJu9jlK3A8WqLTKXM9E6kAmI/dR1vAJ8dHYLMisLNB/n3GuaFIjJ7pn16ZcD1zCOf7P6H62lWIEBi+yz/zQQ==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.24.5",
+        "fast-unique-numbers": "^8.0.13",
+        "tslib": "^2.6.2",
+        "worker-timers-worker": "^7.0.71"
+      }
+    },
+    "node_modules/worker-timers-worker": {
+      "version": "7.0.71",
+      "resolved": "https://registry.npmjs.org/worker-timers-worker/-/worker-timers-worker-7.0.71.tgz",
+      "integrity": "sha512-ks/5YKwZsto1c2vmljroppOKCivB/ma97g9y77MAAz2TBBjPPgpoOiS1qYQKIgvGTr2QYPT3XhJWIB6Rj2MVPQ==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.24.5",
+        "tslib": "^2.6.2"
+      }
+    },
+    "node_modules/ws": {
+      "version": "8.18.0",
+      "resolved": "https://registry.npmjs.org/ws/-/ws-8.18.0.tgz",
+      "integrity": "sha512-8VbfWfHLbbwu3+N6OKsOMpBdT4kXPDDB9cJk2bJ6mh9ucxdlnNvH1e+roYkKmN9Nxw2yjz7VzeO9oOz2zJ04Pw==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=10.0.0"
+      },
+      "peerDependencies": {
+        "bufferutil": "^4.0.1",
+        "utf-8-validate": ">=5.0.2"
+      },
+      "peerDependenciesMeta": {
+        "bufferutil": {
+          "optional": true
+        },
+        "utf-8-validate": {
+          "optional": true
+        }
+      }
+    }
+  }
+}

services/package.json

@@ -0,0 +1,5 @@
+{
+  "dependencies": {
+    "mqtt": "^5.10.1"
+  }
+}

services/test-buzzer-manager.js

@@ -0,0 +1,161 @@
+// 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('brainblast/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('brainblast/buzzer/activity') && payload.buzzer_id === 1) {
+        testResults.buzzerActivity = true;
+    }
+
+    if (topic.startsWith(`brainblast/buzzer/confirmation/1`) && payload.status === "received") {
+        testResults.confirmationReceived = true;
+    }
+
+    if (topic === 'brainblast/buzzer/status' && payload.status === "blocked") {
+        testResults.statusBlocked = true;
+    }
+
+    if (topic === 'brainblast/buzzer/status' && payload.status === "unblocked") {
+        testResults.statusUnblocked = true;
+    }
+
+    if (topic.startsWith(`brainblast/buzzer/tilt/confirmation/2`) && payload.status === "received" && payload.action === "add") {
+        testResults.tiltAddConfirmed = true;
+    }
+
+    if (topic.startsWith(`brainblast/buzzer/tilt/confirmation/2`) && payload.status === "received" && payload.action === "remove") {
+        testResults.tiltRemoveConfirmed = true;
+    }
+
+    if (topic === `brainblast/buzzer/tilt/ignored/2` && payload.status === "tilt_ignored") {
+        testResults.tiltIgnored = true;
+    }
+
+    if (topic === 'brainblast/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 === 'brainblast/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('brainblast/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('brainblast/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('brainblast/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('brainblast/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('brainblast/buzzer/tilt', JSON.stringify({
+            buzzer_id: 2,
+            status: "remove"
+        }));
+    }, 2500);
+
+    // 6. Unlock buzzers to reset state
+    setTimeout(() => {
+        console.log('[TEST] Unlocking buzzers...');
+        client.publish('brainblast/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);
+}

ui/src/components/MQTTColorPublisher.vue

@@ -0,0 +1,95 @@
+<template>
+  <v-container class="v-container-style">   
+    <v-card tile outlined width="500">     
+      <v-card-title class="card__title primary centered-title">       
+        <v-icon left class="pr-5 pl-2" size="30">mdi-send</v-icon>       
+        Publier une couleur    
+      </v-card-title>     
+      <div class="input-style">       
+        <v-select label="Topic" v-model="selectedTopic" :items="topics" prepend-icon="mdi-target"></v-select>   
+      </div> 
+      <v-row>
+        <v-col cols="6" class="color-picker-style">
+          <div>
+            <v-color-picker mode="hex" v-model="selectedColor" border="md" width="250"></v-color-picker>
+            <v-btn class="v-btn-style-validate" height="35" @click="publisCustomColor">Publier</v-btn>  
+        </div>
+        </v-col>
+        <v-col cols="5.5" class="button-container">
+          <v-btn color="#D42828" class="team-button" @click="publisButtonColor('#D42828')">Team Rouge</v-btn>
+          <v-btn color="#FF7518" class="team-button" @click="publisButtonColor('#FF7518')">Team Orange</v-btn>
+          <v-btn color="#00FF1F" class="team-button" @click="publisButtonColor('#00FF1F')">Team Verte</v-btn>
+          <v-btn color="#007AFF" class="team-button" @click="publisButtonColor('#007AFF')">Team Bleue</v-btn>
+          <v-btn color="#FFFC00" class="team-button" @click="publisButtonColor('#FFFC00')">Team Jaune</v-btn>
+        </v-col>
+      </v-row>
+    </v-card> 
+  </v-container>
+
+</template>
+
+<script>
+import { publishMessage } from '@/services/mqttService'
+
+export default {
+  data() { 
+    return {   
+      message: '', // Initialiser la variable message   
+      selectedTopic: 'Selectionnez un topic',   
+      selectedColor: "#FF0000",   
+      topics: [     
+        '/wled/all',
+        '/wled/1',
+        '/wled/2',
+        '/wled/3',
+        '/wled/4',
+        '/wled/5'
+      ]
+    }
+},
+  methods: { 
+    publisCustomColor() {   
+      publishMessage(this.selectedTopic, this.selectedColor)
+    },
+    publisButtonColor(param) {   
+      publishMessage(this.selectedTopic, param)
+    },
+    
+  }
+}
+</script>
+
+<style>
+  .v-container-style { 
+    align-items: center; 
+    justify-content: center;
+  }
+  .input-style{ 
+    margin: 20px;
+  }
+  .v-btn-style-validate{ 
+    border-top-right-radius: 0%; 
+    border-top-left-radius: 0%;
+  }
+  .centered-title { 
+    text-align: center;
+  }
+  .color-picker-style {
+    margin-left: 5%;
+    margin-bottom: 5%;
+    display: flex;
+  }
+  .button-container {
+  text-align: center;
+  margin-top: 12px;
+  margin-bottom: 27px;
+  margin-left: 15px;
+  margin-right: 13px;
+}
+  .team-button {
+    width: 140px;
+    display: block;
+    margin: 12% auto 0; /* 5% de marge en bas pour espacer les boutons */
+    background-color: #d42828;
+  }
+</style>

ui/src/components/MQTTDebugConsole.vue

@@ -1,5 +1,5 @@
 <template>
-   <v-container class="v-container-style"> 
+   <v-container class="v-container-style-console"> 
       <v-card tile outlined width="500">   
          <v-card-title class="card__title primary centered-title">     
             <v-icon left class="pr-5 pl-2" size="40">mdi-console-line</v-icon>     
@@ -7,8 +7,9 @@
          </v-card-title>   
          <v-container class="text-center">     
             <div v-for="(log, index) in messageLogs" :key="index">       
-               <v-label class="v-label-timestamp">{{ log.timestamp }} </v-label>        -        
-               <v-label>{{ log.message }}</v-label>     
+               <v-label class="v-label-timestamp">{{ log.timestamp }} -&nbsp;</v-label>    
+               <v-label class="v-label-topic-message-title">Topic :&nbsp;</v-label><v-label class="v-label-topic-message">{{ log.topic }}&nbsp;</v-label>     
+               <v-label class="v-label-topic-message-title">Msg :&nbsp;</v-label><v-label class="v-label-topic-message">{{ log.message }}</v-label>     
             </div>   
          </v-container> 
       </v-card>
@@ -32,10 +33,11 @@
       });
       
       // Ajouter le message avec l'horodatage à la liste des messages   
-      this.messageLogs.push({ timestamp, message: `Topic: ${topic}, Message: ${message}` });
+      this.messageLogs.push({ timestamp, topic: `${topic}`, message: `${message}`  });
+      //this.messageLogs.push({ timestamp, message: `${message}` });
       
       // Limiter la liste à 10 messages   
-      if (this.messageLogs.length > 10) {     
+      if (this.messageLogs.length > 26) {     
       this.messageLogs.shift(); // Supprimer le premier élément (le plus ancien)   
       } }) // S'abonner à tous les topics MQTT
    }
@@ -43,16 +45,28 @@
 </script>
 
 <style>
-  .v-container-style { 
+  .v-container-style-console { 
       display: flex; 
       justify-content: center;
+      position: sticky;
+      top: 50px; /* Distance depuis le haut de la fenêtre avant de "coller" */
   }
   .centered-title { 
       text-align: center;
   }
   .v-label-timestamp{ 
+      opacity: 100%; 
+      font-style: oblique;
+      font-weight: 400; 
+      color: #838383;
+  }
+  .v-label-topic-message-title{ 
       opacity: 100%; 
       font-weight: 700; 
       color: #d42828;
   }
+  .v-label-topic-message{ 
+      font-weight: 300; 
+  }
+
 </style>

ui/src/components/MQTTDebugPublish.vue

@@ -8,7 +8,9 @@
       <div class="input-style">       
         <v-select label="Topic" v-model="selectedTopic" :items="topics" prepend-icon="mdi-target"></v-select>       
         <v-text-field label="Message" v-model="message" prepend-icon="mdi-text-box"></v-text-field>     
-      </div>       <v-btn class="v-btn-style" height="50" @click="publishMessage">Publier</v-btn>   
+      </div>       
+      <v-btn class="v-btn-style-standalone" height="40" @click="publishBuzzerUnblock">Déblocage<br>Buzzer</v-btn>
+      <v-btn class="v-btn-style-validate" height="50" @click="publisCustomMessage">Publier</v-btn>   
     </v-card> 
   </v-container>
 
@@ -19,13 +21,22 @@ import { publishMessage } from '@/services/mqttService'
 
 export default {
   data() { return {   message: '', // Initialiser la variable message   
-    selectedTopic: 'topic1',   
-    topics: [     '/display/control',     '/sound/playsound',     'topic3',     'topic4',     'topic5',     'topic6',     'topic7',     'topic8',     'topic9',     'topic10'   ] // Liste des topics 
+    selectedTopic: 'Selectionnez un topic',   
+    topics: [     
+      '/wled/all',     
+      '/display/control',     
+      '/sound/playsound'
+    ] // Liste des topics 
   }
 },
   methods: { 
-    publishMessage() {   
-      publishMessage(this.selectedTopic, this.message) }
+    publisCustomMessage() {   
+      publishMessage(this.selectedTopic, this.message)
+    },
+    publishBuzzerUnblock() {   
+      publishMessage('brainblast/buzzer/unlock', "0")  
+    }
+    
   }
 }
 </script>
@@ -38,7 +49,12 @@ export default {
   .input-style{ 
     margin: 20px;
   }
-  .v-btn-style{ 
+  .v-btn-style-standalone{ 
+    background-color: #d42828; /* Changez la couleur en fonction de votre thème */ 
+    margin-bottom: 5%;
+    margin-left: 5%;
+  }
+  .v-btn-style-validate{ 
     align-items: center; 
     justify-content: center; 
     width: 100%; 

ui/src/views/MQTTDebugView.vue

@@ -1,15 +1,42 @@
 <template>
-  <div> <!-- Zone pour publier sur MQTT --> <PublishMQTTComponent />
- <!-- Zone pour afficher la console MQTT --> <MQTTConsoleComponent />
+  <v-row>
+    
+  </v-row>
+  <div> <!-- Zone pour publier sur MQTT --> 
+ <!-- Zone pour afficher la console MQTT --> 
   </div>
+  <v-container>
+    <v-row>
+      <!-- Colonne gauche avec les deux composants empilés -->
+      <v-col cols="6">
+        <!-- Composant 1 -->
+        <v-row>
+          <v-col>
+            <PublishMQTTComponent />
+            <MQTTColorPublisher />
+
+          </v-col>
+        </v-row>
+      </v-col>
+
+      <!-- Colonne droite avec le composant unique -->
+      <v-col cols="6">
+        <MQTTConsoleComponent />
+      </v-col>
+    </v-row>
+  </v-container>
 </template>
 
 <script>
 import PublishMQTTComponent from '@/components/MQTTDebugPublish.vue' // Importer le composant pour publier sur MQTT
-import MQTTConsoleComponent from '@/components/MQTTDebugConsole.vue' // Importer le composant pour la console MQTT
+import MQTTConsoleComponent from '@/components/MQTTDebugConsole.vue' // Importer le composant pour publier sur MQTT
+import MQTTColorPublisher from '@/components/MQTTColorPublisher.vue' // Importer le composant pour publier sur MQTT
 
 export default {
-  components: { PublishMQTTComponent, // Composant pour publier sur MQTT MQTTConsoleComponent // Composant pour la console MQTT
+  components: { 
+    PublishMQTTComponent, // Composant pour publier sur MQTT MQTTConsoleComponent // Composant pour la console MQTT
+    MQTTConsoleComponent, // Composant pour la console MQTT
+    MQTTColorPublisher, // Composant pour publier une couleur custom dans un topic
   }
 }
 </script>