diff --git a/src/main.ts b/src/main.ts index 76cfb9e..aea9ab3 100644 --- a/src/main.ts +++ b/src/main.ts @@ -42,6 +42,9 @@ class MqttMongo { if (topic == "MqttMongo/Command" && message == "shutdown") { this.mqttClient.end() + } else { + // verify JSON format of message + // insert into database } }) }