@node-red/nodes - npm Package Compare versions

Comparing version 1.0.4 to 1.0.5

core/common/lib/debug/debug-utils.js

@@ -460,3 +460,3 @@ /**
         if (sourceNode) {
-            $('<a>',{href:"#",class:"red-ui-debug-msg-name"}).text('node: '+sanitize(o.name||sourceNode.name||sourceNode.id))
+            $('<a>',{href:"#",class:"red-ui-debug-msg-name"}).text('node: '+(o.name||sourceNode.name||sourceNode.id))
             .appendTo(metaRow)
@@ -463,0 +463,0 @@ .on("click", function(evt) {

core/function/90-exec.js

@@ -148,3 +148,3 @@ /**
                             else { node.status({fill:"red",shape:"dot",text:"error:"+error.code}); }
-                            node.log('error:' + error);
+                            if (RED.settings.verbose) { node.log('error:' + error); }
                         }
@@ -151,0 +151,0 @@ else if (node.oldrc === "false") {

core/network/10-mqtt.js

@@ -472,2 +472,3 @@ /**
         var node = this;
+        var chk = /[\+#]/;
 
@@ -491,2 +492,3 @@ if (this.brokerConn) {
                     if (msg.hasOwnProperty("topic") && (typeof msg.topic === "string") && (msg.topic !== "")) { // topic must exist
+                        if (chk.test(msg.topic)) { node.warn(RED._("mqtt.errors.invalid-topic")); }
                         this.brokerConn.publish(msg, done);  // send the message
@@ -493,0 +495,0 @@ } else {

core/sequence/17-split.js

@@ -295,3 +295,2 @@ /**
         });
-
     }
@@ -335,3 +334,3 @@ function reduceAndSendGroup(node, group, done) {
             var count;
-            if(!pending.hasOwnProperty(gid)) {
+            if (!pending.hasOwnProperty(gid)) {
                 if(parts.hasOwnProperty('count')) {
@@ -366,3 +365,2 @@ count = msg.parts.count;
             }
-
             if (msgs.length === group.count) {
@@ -414,3 +412,3 @@ delete pending[gid];
         } else if (this.joinerType === "bin") {
-            var joinArray = JSON.parse(n.joiner)
+            var joinArray = JSON.parse(n.joiner || "[]");
             if (Array.isArray(joinArray)) {
@@ -455,2 +453,5 @@ this.joiner = Buffer.from(joinArray);
                         }
+                        if (!Buffer.isBuffer(group.payload[i])) { 
+                            group.payload[i] = Buffer.from(group.payload[i]);
+                        }
                         buffers.push(group.payload[i]);
@@ -637,3 +638,9 @@ bufferLen += group.payload[i].length;
                     if (property !== undefined) {
-                        inflight[partId].bufferLen += property.length;
+                        if (Buffer.isBuffer(property) || (typeof property === "string") || Array.isArray(property)) {
+                            inflight[partId].bufferLen += property.length;
+                        }
+                        else {
+                            node.error(RED._("join.errors.invalid-type",{error:(typeof property)}),msg);
+                            return;
+                        }
                     }
@@ -640,0 +647,0 @@ }

locales/de/messages.json

@@ -400,3 +400,3 @@ {
       "path1" : "Standardmäßig enthält  <code> Nutzdaten </code>  die Daten, die über einen Websocket gesendet oder von einem Websocket empfangen werden. Der Listener kann so konfiguriert werden, dass er das gesamte Nachrichtenobjekt als eine JSON-formatierte Zeichenfolge sendet oder empfängt.",
-      "path2" : "Dieser Pfad ist relativ zu ",
+      "path2" : "Dieser Pfad ist relativ zu <code>__path__</code>.",
       "url1" : "URL sollte ws: &#47; & #47; oder wss: &#47; & #47; Schema verwenden und auf einen vorhandenen Websocket-Listener verweisen.",
@@ -403,0 +403,0 @@ "url2" : "Standardmäßig enthält  <code> Nutzdaten </code>  die Daten, die über einen Websocket gesendet oder von einem Websocket empfangen werden. Der Client kann so konfiguriert werden, dass er das gesamte Nachrichtenobjekt als eine JSON-formatierte Zeichenfolge sendet oder empfängt."

locales/en-US/messages.json

@@ -458,3 +458,3 @@ {
             "path1": "By default, <code>payload</code> will contain the data to be sent over, or received from a websocket. The listener can be configured to send or receive the entire message object as a JSON formatted string.",
-            "path2": "This path will be relative to ",
+            "path2": "This path will be relative to <code>__path__</code>.",
             "url1": "URL should use ws:&#47;&#47; or wss:&#47;&#47; scheme and point to an existing websocket listener.",
@@ -898,3 +898,4 @@ "url2": "By default, <code>payload</code> will contain the data to be sent over, or received from a websocket. The client can be configured to send or receive the entire message object as a JSON formatted string."
         "errors": {
-            "invalid-expr": "Invalid JSONata expression: __error__"
+            "invalid-expr": "Invalid JSONata expression: __error__",
+            "invalid-type": "Cannot join __error__ to buffer"
         }
@@ -901,0 +902,0 @@ },

locales/ja/messages.json

@@ -458,3 +458,3 @@ {
             "path1": "標準では <code>payload</code> がwebsocketから送信、受信されるデータを持ちます。クライアントはJSON形式の文字列としてメッセージ全体を送信、受信するよう設定できます。",
-            "path2": "This path will be relative to ",
+            "path2": "このパスは <code>__path__</code> の相対パスになります。",
             "url1": "URLには ws:&#47;&#47; または wss:&#47;&#47; スキーマを使用して、存在するwebsocketリスナを設定してください。",
@@ -896,3 +896,4 @@ "url2": "標準では <code>payload</code> がwebsocketから送信、受信されるデータを持ちます。クライアントはJSON形式の文字列としてメッセージ全体を送信、受信するよう設定できます。"
         "errors": {
-            "invalid-expr": "JSONata式が不正: __error__"
+            "invalid-expr": "JSONata式が不正: __error__",
+            "invalid-type": "__error__ をバッファに連結できません"
         }
@@ -899,0 +900,0 @@ },

locales/ko/messages.json

@@ -449,3 +449,3 @@ {
             "path1": "표준으로는 <code>payload</code> 가 websocket에서 송신, 수신된 데이터를 기다립니다. 클라이언트는 JSON형식의 문자열로 메세지전체를 송신, 수신하도록 설정할 수 있습니다.",
-            "path2": "This path will be relative to ",
+            "path2": "This path will be relative to <code>__path__</code>.",
             "url1": "URL에는 ws:&#47;&#47; 또는 wss:&#47;&#47; 스키마를 사용하여, 존재하는 websocket리스너를 설정해 주세요.",
@@ -452,0 +452,0 @@ "url2": "표준으로는 <code>payload</code> 가 websocket에서 송신,수신될 데이터를 기다립니다.클라이언트는 JSON형식의 문자열로 메세지전체를 송신, 수신하도록 설정할 수 있습니다."

locales/zh-CN/messages.json

@@ -458,3 +458,3 @@ {
             "path1": "默认情况下，<code>payload</code>将包含要发送或从Websocket接收的数据。侦听器可以配置为以JSON格式的字符串发送或接收整个消息对象.",
-            "path2": "这条路径将相对于 ",
+            "path2": "这条路径将相对于 <code>__path__</code>.",
             "url1": "URL 应该使用ws:&#47;&#47;或者wss:&#47;&#47;方案并指向现有的websocket侦听器.",
@@ -461,0 +461,0 @@ "url2": "默认情况下，<code>payload</code> 将包含要发送或从Websocket接收的数据。可以将客户端配置为以JSON格式的字符串发送或接收整个消息对象."

locales/zh-TW/messages.json

@@ -458,3 +458,3 @@ {
             "path1": "預設情況下，<code>payload</code>將包含要發送或從Websocket接收的資料。偵聽器可以配置為以JSON格式的字串發送或接收整個消息物件.",
-            "path2": "這條路徑將相對於 ",
+            "path2": "這條路徑將相對於 <code>__path__</code>.",
             "url1": "URL 應該使用ws:&#47;&#47;或者wss:&#47;&#47;方案並指向現有的websocket監聽器.",
@@ -461,0 +461,0 @@ "url2": "預設情況下，<code>payload</code> 將包含要發送或從Websocket接收的資料。可以將使用者端配置為以JSON格式的字串發送或接收整個消息物件."

package.json

 {
     "name": "@node-red/nodes",
-    "version": "1.0.4",
+    "version": "1.0.5",
     "license": "Apache-2.0",
@@ -22,3 +22,3 @@ "repository": {
         "content-type": "1.0.4",
-        "cookie-parser": "1.4.4",
+        "cookie-parser": "1.4.5",
         "cookie": "0.4.0",
@@ -37,3 +37,3 @@ "cors": "2.8.5",
         "multer": "1.4.2",
-        "mustache": "4.0.0",
+        "mustache": "4.0.1",
         "on-headers": "1.0.2",
@@ -40,0 +40,0 @@ "raw-body": "2.4.1",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Lines of code

13564

increased by0.1%

Worsened metrics

Total package byte prevSize

1458610

decreased by-0.06%

Dependency changes

• + Addedcookie-parser@1.4.5(transitive)

• + Addedmustache@4.0.1(transitive)

• - Removedcookie@0.3.1(transitive)

• - Removedcookie-parser@1.4.4(transitive)

• - Removedmustache@4.0.0(transitive)

• Updatedcookie-parser@1.4.5

• Updatedmustache@4.0.1