From 635614598970a5c8860aa0f8729a77a9590ea3be Mon Sep 17 00:00:00 2001
From: Simon Arnell <14029547+simonarnell@users.noreply.github.com>
Date: Sat, 1 Feb 2025 00:08:39 +0200
Subject: [PATCH] removing topic regex

---
 src/core/operations/MQTTPublish.mjs | 13 +++++--------
 1 file changed, 5 insertions(+), 8 deletions(-)

diff --git a/src/core/operations/MQTTPublish.mjs b/src/core/operations/MQTTPublish.mjs
index fdabf119..0eb53eba 100644
--- a/src/core/operations/MQTTPublish.mjs
+++ b/src/core/operations/MQTTPublish.mjs
@@ -50,15 +50,12 @@ class MQTTPublish extends Operation {
     run(input, args) {
         const [broker, topic] = args;
         const mqttUrlRegex = /^(ws|mqtt)s?:\/\/(([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9-]{0,61}[a-zA-Z0-9])(\.([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9-]{0,61}[a-zA-Z0-9]))*|([01]?[0-9][0-9]?|2[0-4][0-9]|25[0-5])(\.([01]?[0-9][0-9]?|2[0-4][0-9]|25[0-5])){3}|(([0-9a-fA-F]{1,4}:){7,7}[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,7}:|([0-9a-fA-F]{1,4}:){1,6}:[0-9a-fA-F]{1,4}|([0-9a-fA-F]{1,4}:){1,5}(:[0-9a-fA-F]{1,4}){1,2}|([0-9a-fA-F]{1,4}:){1,4}(:[0-9a-fA-F]{1,4}){1,3}|([0-9a-fA-F]{1,4}:){1,3}(:[0-9a-fA-F]{1,4}){1,4}|([0-9a-fA-F]{1,4}:){1,2}(:[0-9a-fA-F]{1,4}){1,5}|[0-9a-fA-F]{1,4}:((:[0-9a-fA-F]{1,4}){1,6})|:((:[0-9a-fA-F]{1,4}){1,7}|:)|fe80:(:[0-9a-fA-F]{0,4}){0,4}%[0-9a-zA-Z]{1,}|::(ffff(:0{1,4}){0,1}:){0,1}((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])|([0-9a-fA-F]{1,4}:){1,4}:((25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])\.){3,3}(25[0-5]|(2[0-4]|1{0,1}[0-9]){0,1}[0-9])))(:([1-9][0-9]{0,3}|[1-5][0-9]{4}|6[0-4][0-9]{3}|65[0-4][0-9]{2}|655[0-2][0-9]|6553[0-5]))?/;
-        const mqttTopicRegex = /^[\u0000-\uFFFF]+(\/[\u0000-\uFFFF]+)+$/;
         if (mqttUrlRegex.test(broker)) {
-            if (mqttTopicRegex.test(broker)) {
-                const client = mqtt.connect(broker);
-                client.on("connect", () => {
-                    client.publish(topic, Buffer.from(input));
-                    client.end();
-                });
-            } else throw new OperationError(`Invalid MQTT topic name - ${topic}`);
+            const client = mqtt.connect(broker);
+            client.on("connect", () => {
+                client.publish(topic, Buffer.from(input));
+                client.end();
+            });
         } else throw new OperationError(`Invalid MQTT broker URL - ${broker}`);
         return input;
     }