From 23f8b2b4df76f6ca6e693036e8b1c08501d779af Mon Sep 17 00:00:00 2001
From: Jan Oberhauser <jan.oberhauser@gmail.com>
Date: Tue, 1 Sep 2020 17:46:32 +0200
Subject: [PATCH] :zap: Minor improvements to MQTT Trigger-Node

---
 packages/nodes-base/nodes/MQTT/MqttTrigger.node.ts | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/packages/nodes-base/nodes/MQTT/MqttTrigger.node.ts b/packages/nodes-base/nodes/MQTT/MqttTrigger.node.ts
index 0344f290b3..3a40941662 100644
--- a/packages/nodes-base/nodes/MQTT/MqttTrigger.node.ts
+++ b/packages/nodes-base/nodes/MQTT/MqttTrigger.node.ts
@@ -3,10 +3,10 @@ import {
 } from 'n8n-core';
 
 import {
+	IDataObject,
 	INodeType,
 	INodeTypeDescription,
 	ITriggerResponse,
-	IDataObject,
 } from 'n8n-workflow';
 
 import * as mqtt from 'mqtt';
@@ -75,7 +75,7 @@ export class MqttTrigger implements INodeType {
 		const credentials = this.getCredentials('mqtt');
 
 		if (!credentials) {
-		  throw new Error('Credentials are mandatory!');
+			throw new Error('Credentials are mandatory!');
 		}
 
 		const topics = (this.getNodeParameter('topics') as string).split(',');
@@ -105,7 +105,7 @@ export class MqttTrigger implements INodeType {
 		const self = this;
 
 		async function manualTriggerFunction() {
-			await new Promise(( resolve, reject ) => {
+			await new Promise((resolve, reject) => {
 				client.on('connect', () => {
 					client.subscribe(topics, (err, granted) => {
 						if (err) {
@@ -120,7 +120,7 @@ export class MqttTrigger implements INodeType {
 							if (options.jsonParseMessage) {
 								try {
 									message = JSON.parse(message.toString());
-								} catch (err) {}
+								} catch (err) { }
 							}
 
 							result.message = message;
@@ -131,8 +131,7 @@ export class MqttTrigger implements INodeType {
 								result = message;
 							}
 
-							self.emit([self.helpers.returnJsonArray([result],
-							)]);
+							self.emit([self.helpers.returnJsonArray([result])]);
 							resolve(true);
 						});
 					});