From 78cb196463fbecf9be054cd27b3b4c95e718acae Mon Sep 17 00:00:00 2001
From: Sebastian <Sebastian@wherzog.de>
Date: Wed, 15 Jul 2020 00:06:15 +0200
Subject: [PATCH] added javascript to publish message on mqtt

---
 imports/api/mqttPublish.js | 29 +++++++++++++++++++++++++++++
 imports/api/plantTypes.js  |  2 ++
 2 files changed, 31 insertions(+)
 create mode 100644 imports/api/mqttPublish.js

diff --git a/imports/api/mqttPublish.js b/imports/api/mqttPublish.js
new file mode 100644
index 0000000..a4a2678
--- /dev/null
+++ b/imports/api/mqttPublish.js
@@ -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
+}
+
diff --git a/imports/api/plantTypes.js b/imports/api/plantTypes.js
index d8af609..53fd777 100644
--- a/imports/api/plantTypes.js
+++ b/imports/api/plantTypes.js
@@ -1,5 +1,7 @@
 import {PlantTypesCollection} from '../../client/main'
 
+const mqttManager = require("./mqttPublish");
+
 export function getAllPlantTypes() {
     const plantTypesDocuments = PlantTypesCollection.find();