added javascript to publish message on mqtt
This commit is contained in:
parent
0450dff98f
commit
78cb196463
29
imports/api/mqttPublish.js
Normal file
29
imports/api/mqttPublish.js
Normal file
@ -0,0 +1,29 @@
|
|||||||
|
var mqtt = require('mqtt')
|
||||||
|
var client = mqtt.connect('mqtt://timovolkmann.de')
|
||||||
|
|
||||||
|
const PUBLISH_PATH = "smartgarden/commands/";
|
||||||
|
const MQTT_DEVICE_ID = "esp-sebastian";
|
||||||
|
|
||||||
|
client.on('connect', function () {
|
||||||
|
client.subscribe('presence', function (err) {
|
||||||
|
if (!err) {
|
||||||
|
//client.publish('presence', 'Hello mqtt')
|
||||||
|
publishMessage("smartgarden/commands/esp-sebastian/light", "on")
|
||||||
|
}
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|
||||||
|
client.on('message', function (topic, message) {
|
||||||
|
// message is Buffer
|
||||||
|
console.log(message.toString())
|
||||||
|
client.end()
|
||||||
|
})
|
||||||
|
|
||||||
|
function publishMessage(topic, message) {
|
||||||
|
client.publish(topic, message)
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = {
|
||||||
|
publishMessage
|
||||||
|
}
|
||||||
|
|
||||||
@ -1,5 +1,7 @@
|
|||||||
import {PlantTypesCollection} from '../../client/main'
|
import {PlantTypesCollection} from '../../client/main'
|
||||||
|
|
||||||
|
const mqttManager = require("./mqttPublish");
|
||||||
|
|
||||||
export function getAllPlantTypes() {
|
export function getAllPlantTypes() {
|
||||||
const plantTypesDocuments = PlantTypesCollection.find();
|
const plantTypesDocuments = PlantTypesCollection.find();
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user