Add mqtt service readiness logging

.pre-commit-config.yaml

@@ -10,7 +10,7 @@ repos:
       - id: check-added-large-files
 
   - repo: https://github.com/Lucas-C/pre-commit-hooks
-    rev: v1.5.4
+    rev: v1.5.5
     hooks:
       - id: insert-license
         files: '\.(js.?|ts.?)$'

backend/index.ts

@@ -28,7 +28,7 @@ const mqttPort: number = process.env.MQTT_ENDPOINT_PORT
 const mqttOptions: IClientOptions = {
   reconnectPeriod: 1000,
   port: mqttPort,
-  clientId: `zigbee-backend-${Math.random().toString(16).substring(2, 8)}`,
+  clientId: `starlight-backend-${Math.random().toString(16).substring(2, 8)}`,
   connectTimeout: 10000,
 };
 
@@ -63,4 +63,12 @@ app.use(
 
 app.listen(port, () => {
   logger(logLevel, "Express", `Server listening on ${port}.`);
+
+  if (!mqttService.ready) {
+    logger(
+      logLevel,
+      "MQTT",
+      "Can't establish a connection to MQTT endpoint. Maybe the server is offline?",
+    );
+  }
 });

backend/zigbee2mqttService.ts

@@ -176,7 +176,8 @@ export class Zigbee2MqttService {
     this.#baseTopic = baseTopic;
     this.#client = mqtt.connect(endpoint, options);
 
-    this.#mqttClientConnected = new Promise((resolve) => {
+    this.#mqttClientConnected = new Promise((resolve, reject) => {
+      this.#client.once("error", (error) => reject({ success: false, error }));
       this.#client.once("connect", () => {
         this.#client.on("message", (topic, payload) =>
           this.#handleMessage(topic, payload),
@@ -191,8 +192,6 @@ export class Zigbee2MqttService {
         this.#ready = true;
         resolve(SUCCESS);
       });
-
-      this.#client.once("error", (error) => resolve({ success: false, error }));
     });
   }