|
|
@ -1519,7 +1519,7 @@ const sendNotification = async (fcmTokens, title, body) => {
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// };
|
|
|
|
// };
|
|
|
|
|
|
|
|
|
|
|
|
exports.publishMotorStopStatus = async (motor_id, motor_stop_status) => {
|
|
|
|
exports. publishMotorStopStatus = async (motor_id, motor_stop_status) => {
|
|
|
|
const payload = {
|
|
|
|
const payload = {
|
|
|
|
topic: 'operation',
|
|
|
|
topic: 'operation',
|
|
|
|
object: {
|
|
|
|
object: {
|
|
|
@ -4370,7 +4370,7 @@ exports.getBlockData = async (req, reply) => {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const mqtt = require('mqtt');
|
|
|
|
const mqtt = require('mqtt');
|
|
|
|
const client = mqtt.connect('mqtt://35.207.198.4:1884'); // Connect to MQTT broker
|
|
|
|
const client = mqtt.connect('mqtt://35.207.198.4:1883'); // Connect to MQTT broker
|
|
|
|
|
|
|
|
|
|
|
|
client.on('connect', () => {
|
|
|
|
client.on('connect', () => {
|
|
|
|
console.log('Connected to MQTT broker');
|
|
|
|
console.log('Connected to MQTT broker');
|
|
|
|