Add MQTT topic to create device (#743)

GladysAssistant · Apr 14, 2020 · 8196d4f · 8196d4f
1 parent a3b0e54
commit 8196d4f
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/server/services/mqtt/lib/handler/handleGladysMessage.js b/server/services/mqtt/lib/handler/handleGladysMessage.js
@@ -11,8 +11,10 @@ const logger = require('../../../../utils/logger');
  */
 function handleGladysMessage(topic, message) {
   const parsedTopic = topic.split('/');
-  // Topic = gladys/master/device/:device_external_id/feature/:device_feature_external_id/state
-  if (topic.startsWith('gladys/master/device/')) {
+  if (topic === 'gladys/master/device/create') {
+    this.gladys.event.emit(EVENTS.DEVICE.NEW, JSON.parse(message));
+  } else if (topic.startsWith('gladys/master/device/')) {
+    // Topic = gladys/master/device/:device_external_id/feature/:device_feature_external_id/state
     if (!parsedTopic[5]) {
       throw new BadParameters('Device feature external_id is required');
     }

diff --git a/server/test/services/mqtt/lib/handleNewMessage.test.js b/server/test/services/mqtt/lib/handleNewMessage.test.js
@@ -34,6 +34,12 @@ describe('Mqtt handle message', () => {
     assert.notCalled(gladys.event.emit);
   });
 
+  it('should create device', () => {
+    mqttHandler.handleNewMessage('gladys/master/device/create', '{}');
+
+    assert.calledWith(gladys.event.emit, EVENTS.DEVICE.NEW, {});
+  });
+
   it('should update device state', () => {
     mqttHandler.handleNewMessage(
       'gladys/master/device/my_device_external_id/feature/my_feature_external_id/state',