pipestream --> streaming and added chunk2msg node

gorenje · Jan 15, 2024 · 962e021 · 962e021
1 parent 4b133dd
commit 962e021
Show file tree

Hide file tree

Showing 16 changed files with 6,205 additions and 6,159 deletions.
diff --git a/icons.json b/icons.json
@@ -28,10 +28,10 @@
     "@gregoriusrippenstein/node-red-contrib-nodedev": [
         "nodedevsubflow.svg"
     ],
-    "@gregoriusrippenstein/node-red-contrib-pipestream": [],
     "@gregoriusrippenstein/node-red-contrib-tarball": [],
     "@gregoriusrippenstein/node-red-contrib-uglifyjs": [],
     "@gregoriusrippenstein/node-red-contrib-validation-and-documentation": [],
+    "@gregoriusrippenstein/node-red-streaming": [],
     "@martip/node-red-xlsx": [
         "xlsx.svg"
     ],

diff --git a/nodes/messages b/nodes/messages
@@ -80,7 +80,26 @@
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmpublish": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmtarball": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/pkgfile": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/archivestream": {
+    "@gregoriusrippenstein/node-red-contrib-tarball/tarball": {
+        "tarball": {
+            "error": {
+                "compressfailed": "tar creation failed",
+                "formatnotsupported": "format not supported",
+                "general": "error occurred",
+                "nopayload": "no payload set on msg",
+                "unknownpayload": "type of msg.payload is not supported",
+                "untar": "error while untarring file",
+                "xzcorrupt": "Lzma/Xz data corrupt"
+            },
+            "info": {
+                "complete_archive": "archive complete",
+                "complete_extraction": "extraction complete"
+            }
+        }
+    },
+    "@gregoriusrippenstein/node-red-contrib-uglifyjs/uglifyjs": {},
+    "@gregoriusrippenstein/node-red-contrib-validation-and-documentation/json-schema": {},
+    "@gregoriusrippenstein/node-red-streaming/archivestream": {
         "archivestream": {
             "error": {
                 "dirname_not_defined": "Directory destination not specified",
@@ -98,7 +117,20 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/csvstream": {
+    "@gregoriusrippenstein/node-red-streaming/chunk2msg": {
+        "chunk2msg": {
+            "error": {},
+            "label": {
+                "hello": "world"
+            },
+            "status": {
+                "timeout": "No more time to waiting",
+                "waiting": "Waiting for Godot"
+            },
+            "tip": {}
+        }
+    },
+    "@gregoriusrippenstein/node-red-streaming/csvstream": {
         "csvstream": {
             "errors": {},
             "label": {
@@ -111,7 +143,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/decompstream": {
+    "@gregoriusrippenstein/node-red-streaming/decompstream": {
         "decompstream": {
             "error": {
                 "unknown_direction": "Action '__direction__' is not supported",
@@ -127,7 +159,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/filestream": {
+    "@gregoriusrippenstein/node-red-streaming/filestream": {
         "filestream": {
             "errors": {},
             "label": {
@@ -142,7 +174,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/httprequest": {
+    "@gregoriusrippenstein/node-red-streaming/httprequest": {
         "httprequeststream": {
             "error": {},
             "label": {
@@ -162,7 +194,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/iconvstream": {
+    "@gregoriusrippenstein/node-red-streaming/iconvstream": {
         "iconvstream": {
             "errors": {},
             "label": {
@@ -180,7 +212,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/jsonlstream": {
+    "@gregoriusrippenstein/node-red-streaming/jsonlstream": {
         "jsonlstream": {
             "errors": {},
             "label": {
@@ -193,7 +225,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/linestream": {
+    "@gregoriusrippenstein/node-red-streaming/linestream": {
         "linestream": {
             "errors": {},
             "label": {
@@ -206,7 +238,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipeend": {
+    "@gregoriusrippenstein/node-red-streaming/pipeend": {
         "pipeend": {
             "errors": {},
             "label": {
@@ -219,7 +251,7 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipestart": {
+    "@gregoriusrippenstein/node-red-streaming/pipestart": {
         "pipestart": {
             "errors": {},
             "label": {
@@ -232,25 +264,6 @@
             "tip": {}
         }
     },
-    "@gregoriusrippenstein/node-red-contrib-tarball/tarball": {
-        "tarball": {
-            "error": {
-                "compressfailed": "tar creation failed",
-                "formatnotsupported": "format not supported",
-                "general": "error occurred",
-                "nopayload": "no payload set on msg",
-                "unknownpayload": "type of msg.payload is not supported",
-                "untar": "error while untarring file",
-                "xzcorrupt": "Lzma/Xz data corrupt"
-            },
-            "info": {
-                "complete_archive": "archive complete",
-                "complete_extraction": "extraction complete"
-            }
-        }
-    },
-    "@gregoriusrippenstein/node-red-contrib-uglifyjs/uglifyjs": {},
-    "@gregoriusrippenstein/node-red-contrib-validation-and-documentation/json-schema": {},
     "@martip/node-red-xlsx/xlsx": {},
     "node-red-contrib-aedes/aedes-mqtt-broker": {
         "aedes-mqtt-broker": {

diff --git a/nodes/messages.de b/nodes/messages.de
@@ -47,19 +47,20 @@
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmpublish": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmtarball": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/pkgfile": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/archivestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/csvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/decompstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/filestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/httprequest": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/iconvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/jsonlstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/linestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipeend": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipestart": {},
     "@gregoriusrippenstein/node-red-contrib-tarball/tarball": {},
     "@gregoriusrippenstein/node-red-contrib-uglifyjs/uglifyjs": {},
     "@gregoriusrippenstein/node-red-contrib-validation-and-documentation/json-schema": {},
+    "@gregoriusrippenstein/node-red-streaming/archivestream": {},
+    "@gregoriusrippenstein/node-red-streaming/chunk2msg": {},
+    "@gregoriusrippenstein/node-red-streaming/csvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/decompstream": {},
+    "@gregoriusrippenstein/node-red-streaming/filestream": {},
+    "@gregoriusrippenstein/node-red-streaming/httprequest": {},
+    "@gregoriusrippenstein/node-red-streaming/iconvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/jsonlstream": {},
+    "@gregoriusrippenstein/node-red-streaming/linestream": {},
+    "@gregoriusrippenstein/node-red-streaming/pipeend": {},
+    "@gregoriusrippenstein/node-red-streaming/pipestart": {},
     "@martip/node-red-xlsx/xlsx": {},
     "node-red-contrib-aedes/aedes-mqtt-broker": {},
     "node-red-contrib-blockly/blockly": {},

diff --git a/nodes/messages.de-DE b/nodes/messages.de-DE
@@ -47,19 +47,20 @@
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmpublish": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmtarball": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/pkgfile": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/archivestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/csvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/decompstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/filestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/httprequest": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/iconvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/jsonlstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/linestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipeend": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipestart": {},
     "@gregoriusrippenstein/node-red-contrib-tarball/tarball": {},
     "@gregoriusrippenstein/node-red-contrib-uglifyjs/uglifyjs": {},
     "@gregoriusrippenstein/node-red-contrib-validation-and-documentation/json-schema": {},
+    "@gregoriusrippenstein/node-red-streaming/archivestream": {},
+    "@gregoriusrippenstein/node-red-streaming/chunk2msg": {},
+    "@gregoriusrippenstein/node-red-streaming/csvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/decompstream": {},
+    "@gregoriusrippenstein/node-red-streaming/filestream": {},
+    "@gregoriusrippenstein/node-red-streaming/httprequest": {},
+    "@gregoriusrippenstein/node-red-streaming/iconvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/jsonlstream": {},
+    "@gregoriusrippenstein/node-red-streaming/linestream": {},
+    "@gregoriusrippenstein/node-red-streaming/pipeend": {},
+    "@gregoriusrippenstein/node-red-streaming/pipestart": {},
     "@martip/node-red-xlsx/xlsx": {},
     "node-red-contrib-aedes/aedes-mqtt-broker": {},
     "node-red-contrib-blockly/blockly": {},

diff --git a/nodes/messages.en b/nodes/messages.en
@@ -47,19 +47,20 @@
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmpublish": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmtarball": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/pkgfile": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/archivestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/csvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/decompstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/filestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/httprequest": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/iconvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/jsonlstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/linestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipeend": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipestart": {},
     "@gregoriusrippenstein/node-red-contrib-tarball/tarball": {},
     "@gregoriusrippenstein/node-red-contrib-uglifyjs/uglifyjs": {},
     "@gregoriusrippenstein/node-red-contrib-validation-and-documentation/json-schema": {},
+    "@gregoriusrippenstein/node-red-streaming/archivestream": {},
+    "@gregoriusrippenstein/node-red-streaming/chunk2msg": {},
+    "@gregoriusrippenstein/node-red-streaming/csvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/decompstream": {},
+    "@gregoriusrippenstein/node-red-streaming/filestream": {},
+    "@gregoriusrippenstein/node-red-streaming/httprequest": {},
+    "@gregoriusrippenstein/node-red-streaming/iconvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/jsonlstream": {},
+    "@gregoriusrippenstein/node-red-streaming/linestream": {},
+    "@gregoriusrippenstein/node-red-streaming/pipeend": {},
+    "@gregoriusrippenstein/node-red-streaming/pipestart": {},
     "@martip/node-red-xlsx/xlsx": {},
     "node-red-contrib-aedes/aedes-mqtt-broker": {},
     "node-red-contrib-blockly/blockly": {},

diff --git a/nodes/messages.en-GB b/nodes/messages.en-GB
@@ -47,19 +47,20 @@
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmpublish": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/npmtarball": {},
     "@gregoriusrippenstein/node-red-contrib-nodedev/pkgfile": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/archivestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/csvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/decompstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/filestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/httprequest": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/iconvstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/jsonlstream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/linestream": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipeend": {},
-    "@gregoriusrippenstein/node-red-contrib-pipestream/pipestart": {},
     "@gregoriusrippenstein/node-red-contrib-tarball/tarball": {},
     "@gregoriusrippenstein/node-red-contrib-uglifyjs/uglifyjs": {},
     "@gregoriusrippenstein/node-red-contrib-validation-and-documentation/json-schema": {},
+    "@gregoriusrippenstein/node-red-streaming/archivestream": {},
+    "@gregoriusrippenstein/node-red-streaming/chunk2msg": {},
+    "@gregoriusrippenstein/node-red-streaming/csvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/decompstream": {},
+    "@gregoriusrippenstein/node-red-streaming/filestream": {},
+    "@gregoriusrippenstein/node-red-streaming/httprequest": {},
+    "@gregoriusrippenstein/node-red-streaming/iconvstream": {},
+    "@gregoriusrippenstein/node-red-streaming/jsonlstream": {},
+    "@gregoriusrippenstein/node-red-streaming/linestream": {},
+    "@gregoriusrippenstein/node-red-streaming/pipeend": {},
+    "@gregoriusrippenstein/node-red-streaming/pipestart": {},
     "@martip/node-red-xlsx/xlsx": {},
     "node-red-contrib-aedes/aedes-mqtt-broker": {},
     "node-red-contrib-blockly/blockly": {},