+
@(Brokers)
+
Topic
+
@(Supports variables, example: \`device/{device-id}\`)
+
Static message(string)
+
@(Supports variables), @(If specified then incoming data are ignored and this message is sent instead. Topic is required if static message is defined.)
+
@(QoS)
+
@(Retain)
+
+
DB collection name
+
@(Method)
+
+
Add unique ID to data before insert
+
+
+
Insert document if it doesn't exist
+
Add unique ID to data before insert (only if it doesn't exist)
+
+
-
-
-
@(Slack channel to receive the alerts)
-
-
-
@(Watch these types, comma separated names)
-
-
-
@(Watch messages that include any of the following strings)
-
-
-
@(Tag people if message includes something)
-
-
-
@@ -198,6 +199,7 @@ exports.install = function(instance) {
TRY(function() {
message = JSON.parse(message);
+console.log("ooooo------x", message);
if (message.hasOwnProperty("device") && message.hasOwnProperty("data") && message.data.hasOwnProperty("id")) {
client.publish(topic, `{"device": ${message.device}, "id": ${message.data.id}, "data": {"success": true}}`, {qos:1});
instance.send(SEND_TO.rpcCall, {"device": message.device, "id": message.data.id, "RPC response": {"success": true}});
@@ -261,8 +263,6 @@ exports.install = function(instance) {
let stringifiedJson = JSON.stringify(data.data);
client.publish("v1/gateway/telemetry", stringifiedJson, {qos: 1});
- instance.send(3, stringifiedJson);
-
//backup telemetry
if(createTelemetryBackup)
{
@@ -450,7 +450,6 @@ exports.install = function(instance) {
let message = JSON.stringify(o);
client.publish("v1/gateway/telemetry", message, {qos:1});
- instance.send(3, message);
//remove from database
await promisifyBuilder(nosql.remove().where("id", id));