Merge pull request #10 from luk3Sky/main

More TypeError fixes
Pera-Swarm · Jan 16, 2021 · 8dcefc4 · 8dcefc4
2 parents 05a475f + 035c9d4
commit 8dcefc4
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/src/helper.ts b/src/helper.ts
@@ -28,7 +28,8 @@ export const resolveChannelTopic = (topic: string) => {
     const mergedTopic = channel + topic;
     var result: string;
     if (typeof topic !== 'string') {
-        throw new TypeError('Invalid topic');
+        console.error('Invalid topic');
+        return channel;
     } else {
         const mergedFC = channel + topic[0];
         if (channel.includes('/') && topic[0].includes('/')) {

diff --git a/src/queue.ts b/src/queue.ts
@@ -64,7 +64,7 @@ export class Queue implements AbstractQueue {
      */
     remove = (topic: string) => {
         if (typeof topic !== 'string') {
-            throw new TypeError('Invalid topic');
+            console.error('Invalid topic');
         } else {
             const prevList = this._list;
             prevList.forEach((item, index) => {

diff --git a/src/router.ts b/src/router.ts
@@ -143,7 +143,7 @@ export class MQTTRouter {
                         }
                         try {
                             msg =
-                                this._routes[i].type == 'String'
+                                this._routes[i].type === 'String'
                                     ? message.toString()
                                     : JSON.parse(message.toString());
                             /*msg = message.toString();
@@ -277,7 +277,7 @@ export class MQTTRouter {
      */
     addRoute = (route: Route) => {
         if (route === undefined) {
-            throw new TypeError('Invalid route');
+            console.error('Invalid route');
         } else {
             this._routes.push(route);
             if (route.subscribe !== false) {
@@ -307,7 +307,7 @@ export class MQTTRouter {
      */
     removeRoute = (topic: string) => {
         if (topic === undefined) {
-            throw new TypeError('Invalid topic');
+            console.error('Invalid topic');
         } else {
             const prevList = this._routes;
             prevList.forEach((item, index) => {