publish on MQTT

.env.example

@@ -26,4 +26,7 @@ ENABLE_BUTTONS=
 TELEGRAM_TOKEN=
 TELEGRAM_CHATS=
 OPENAI_API_KEY=
-TRIGGER_SENSOR_HOST=
+TRIGGER_SENSOR_HOST=
+MQTT_HOST=
+MQTT_USERNAME=
+MQTT_PASSWORD=

README.md

@@ -58,7 +58,16 @@ sudo yarn collect &
 sudo yarn manager &
 ```
 
-### Output generated example
+## Outputs
+
+Developed to provide updated data in 4 different stacks:
+
+- Publish to external REST/HTTP
+- Publish to MQTT
+- Expose with a REST/HTTP
+- Send with Socket.IO
+
+### Output managed example
 
 #### Realtime data
 
@@ -131,4 +140,4 @@ https://api.giona.tech/domotica/battery
 
 <img src="res/img/dashboard.png" alt="web app" width="100%" />
 
-https://sacconazzo.altervista.org/#battery
+https://app.giona.tech/#battery

package.json

@@ -1,6 +1,6 @@
 {
   "name": "gpio",
-  "version": "1.1.3",
+  "version": "1.2.0",
   "description": "rpi battery signals",
   "scripts": {
     "db:prepare": "npx knex migrate:latest",
@@ -18,6 +18,7 @@
     "dotenv": "^16.4.5",
     "express": "^4.19.2",
     "knex": "0.15.2",
+    "mqtt": "^5.10.1",
     "mysql": "^2.18.1",
     "node-cron": "^3.0.3",
     "openai": "^4.49.0",

src/manager.js

@@ -7,6 +7,7 @@ const Gpio = require("pigpio").Gpio;
 const http = require("http");
 const app = require("express")();
 const { Server } = require("socket.io");
+const mqtt = require("mqtt");
 const { exec, execSync } = require("child_process");
 const db = require("./db");
 const telegram = require("./telegram");
@@ -56,6 +57,10 @@ const buttonShutDown = new Gpio(pinShutDown, {
 const server = http.createServer(app);
 const io = new Server(server);
 server.listen(3000);
+const mqttClient = mqtt.connect(process.env.MQTT_HOST, {
+  username: process.env.MQTT_USERNAME,
+  password: process.env.MQTT_PASSWORD,
+});
 
 const share = async () => {
   pwmShare.hardwarePwmWrite(frequency, 20000);
@@ -90,6 +95,11 @@ const share = async () => {
 
     io.emit("data", app._data);
 
+    mqttClient.publish("data", JSON.stringify(app._data), {
+      qos: 1,
+      retain: true,
+    });
+
     console.log("stored data");
 
     pulseConnection.servoWrite(pulseWidth);