diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml index 27b1f683f..0f9cff0a3 100644 --- a/.github/workflows/tests.yml +++ b/.github/workflows/tests.yml @@ -19,9 +19,9 @@ jobs: matrix: node-version: [16, 18] steps: - - uses: actions/checkout@v2 + - uses: actions/checkout@v3 - name: Use Node.js ${{ matrix.node-version }} - uses: actions/setup-node@v2 + uses: actions/setup-node@v3 with: node-version: ${{ matrix.node-version }} - name: Install Dependencies diff --git a/packages/node_modules/@node-red/editor-client/src/js/ui/projects/projects.js b/packages/node_modules/@node-red/editor-client/src/js/ui/projects/projects.js index c198b34db..f32e14c33 100644 --- a/packages/node_modules/@node-red/editor-client/src/js/ui/projects/projects.js +++ b/packages/node_modules/@node-red/editor-client/src/js/ui/projects/projects.js @@ -747,14 +747,14 @@ RED.projects = (function() { var row = $('
').appendTo(body); $('').appendTo(row); var subrow = $('
').appendTo(row); - var defaultFlowFile = (createProjectOptions.files &&createProjectOptions.files.flow) || (RED.settings.files && RED.settings.files.flow)||"flow.json"; + var defaultFlowFile = (createProjectOptions.files &&createProjectOptions.files.flow) || (RED.settings.files && RED.settings.files.flow) || "flows.json"; projectFlowFileInput = $('').val(defaultFlowFile) .on("change keyup paste",validateForm) .appendTo(subrow); $('
').appendTo(subrow); $('').appendTo(row); - var defaultCredentialsFile = (createProjectOptions.files &&createProjectOptions.files.credentials) || (RED.settings.files && RED.settings.files.credentials)||"flow_cred.json"; + var defaultCredentialsFile = (createProjectOptions.files &&createProjectOptions.files.credentials) || (RED.settings.files && RED.settings.files.credentials) || "flows_cred.json"; row = $('
').appendTo(body); $('').appendTo(row); subrow = $('
').appendTo(row); @@ -1257,7 +1257,7 @@ RED.projects = (function() { row = $('
').appendTo(container); $('').appendTo(row); subrow = $('
').appendTo(row); - projectFlowFileInput = $('').val("flow.json") + projectFlowFileInput = $('').val("flows.json") .on("change keyup paste",validateForm) .appendTo(subrow); $('
').appendTo(subrow); diff --git a/packages/node_modules/@node-red/nodes/core/storage/10-file.js b/packages/node_modules/@node-red/nodes/core/storage/10-file.js index d0db89d01..d3b8a0765 100644 --- a/packages/node_modules/@node-red/nodes/core/storage/10-file.js +++ b/packages/node_modules/@node-red/nodes/core/storage/10-file.js @@ -117,7 +117,9 @@ module.exports = function(RED) { } if (typeof data === "boolean") { data = data.toString(); } if (typeof data === "number") { data = data.toString(); } - if ((node.appendNewline) && (!Buffer.isBuffer(data))) { data += os.EOL; } + var aflg = true; + if (msg.hasOwnProperty("parts") && msg.parts.type === "string" && (msg.parts.count === msg.parts.index + 1)) { aflg = false; } + if ((node.appendNewline) && (!Buffer.isBuffer(data)) && aflg) { data += os.EOL; } var buf; if (node.encoding === "setbymsg") { buf = encode(data, msg.encoding || "none"); @@ -314,7 +316,6 @@ module.exports = function(RED) { }); filename = filename || ""; var fullFilename = filename; - var filePath = ""; if (filename && RED.settings.fileWorkingDirectory && !path.isAbsolute(filename)) { fullFilename = path.resolve(path.join(RED.settings.fileWorkingDirectory,filename)); } diff --git a/packages/node_modules/@node-red/runtime/lib/flows/Flow.js b/packages/node_modules/@node-red/runtime/lib/flows/Flow.js index b5685d3ec..b5bedb2d6 100644 --- a/packages/node_modules/@node-red/runtime/lib/flows/Flow.js +++ b/packages/node_modules/@node-red/runtime/lib/flows/Flow.js @@ -818,6 +818,16 @@ function handlePreRoute(flow, sendEvent, reportError) { }) } +function deliverMessageToDestination(sendEvent) { + if (sendEvent?.destination?.node) { + try { + sendEvent.destination.node.receive(sendEvent.msg); + } catch(err) { + Log.error(`Error delivering message to node:${sendEvent.destination.node._path} [${sendEvent.destination.node.type}]`) + Log.error(err.stack) + } + } +} function handlePreDeliver(flow,sendEvent, reportError) { // preDeliver - the local router has identified the node it is going to send to. At this point, the message has been cloned if needed. hooks.trigger("preDeliver",sendEvent,(err) => { @@ -827,15 +837,10 @@ function handlePreDeliver(flow,sendEvent, reportError) { } else if (err !== false) { if (asyncMessageDelivery) { setImmediate(function() { - if (sendEvent.destination.node) { - sendEvent.destination.node.receive(sendEvent.msg); - } + deliverMessageToDestination(sendEvent) }) } else { - if (sendEvent.destination.node) { - sendEvent.destination.node.receive(sendEvent.msg); - - } + deliverMessageToDestination(sendEvent) } // postDeliver - the message has been dispatched to be delivered asynchronously (unless the sync delivery flag is set, in which case it would be continue as synchronous delivery) hooks.trigger("postDeliver", sendEvent, function(err) { diff --git a/packages/node_modules/node-red/red.js b/packages/node_modules/node-red/red.js index 4763fd5a1..2f5ab354c 100755 --- a/packages/node_modules/node-red/red.js +++ b/packages/node_modules/node-red/red.js @@ -458,7 +458,7 @@ httpsPromise.then(function(startupHttps) { RED.start().then(function() { if (settings.httpAdminRoot !== false || settings.httpNodeRoot !== false || settings.httpStatic) { server.on('error', function(err) { - if (err.errno === "EADDRINUSE") { + if (err.code === "EADDRINUSE") { RED.log.error(RED.log._("server.unable-to-listen", {listenpath:getListenPath()})); RED.log.error(RED.log._("server.port-in-use")); } else { diff --git a/packages/node_modules/node-red/settings.js b/packages/node_modules/node-red/settings.js index d6e14f21b..ef76f8680 100644 --- a/packages/node_modules/node-red/settings.js +++ b/packages/node_modules/node-red/settings.js @@ -416,7 +416,7 @@ module.exports = { */ // theme: "vs", /** other overrides can be set e.g. fontSize, fontFamily, fontLigatures etc. - * for the full list, see https://microsoft.github.io/monaco-editor/api/interfaces/monaco.editor.IStandaloneEditorConstructionOptions.html + * for the full list, see https://microsoft.github.io/monaco-editor/docs.html#interfaces/editor.IStandaloneEditorConstructionOptions.html */ //fontSize: 14, //fontFamily: "Cascadia Code, Fira Code, Consolas, 'Courier New', monospace", diff --git a/test/nodes/core/storage/10-file_spec.js b/test/nodes/core/storage/10-file_spec.js index 9d5aa033f..19026d457 100644 --- a/test/nodes/core/storage/10-file_spec.js +++ b/test/nodes/core/storage/10-file_spec.js @@ -194,6 +194,55 @@ describe('file Nodes', function() { }); }); + it('should append to a file and add newline, except last line of multipart input', function(done) { + var flow = [{id:"fileNode1", type:"file", name: "fileNode", "filename":fileToTest, "appendNewline":true, "overwriteFile":false, wires: [["helperNode1"]]}, + {id:"helperNode1", type:"helper"}]; + try { + fs.unlinkSync(fileToTest); + } catch(err) { + } + helper.load(fileNode, flow, function() { + var n1 = helper.getNode("fileNode1"); + var n2 = helper.getNode("helperNode1"); + var count = 0; + //var data = ["Line1", "Line2"]; + + n2.on("input", function (msg) { + try { + msg.should.have.property("payload"); + //data.should.containDeep([msg.payload]); + if (count === 3) { + var f = fs.readFileSync(fileToTest).toString(); + if (os.type() !== "Windows_NT") { + f.should.have.length(23); + f.should.equal("Line1\nLine2\nLine3\nLine4"); + } + else { + f.should.have.length(23); + f.should.equal("Line1\r\nLine2\r\nLine3\r\nLine4"); + } + done(); + } + count++; + } + catch (e) { + done(e); + } + }); + + n1.receive({payload:"Line1",parts:{index:0,type:"string"}}); // string + setTimeout(function() { + n1.receive({payload:"Line2",parts:{index:1,type:"string"}}); // string + },30); + setTimeout(function() { + n1.receive({payload:"Line3",parts:{index:2,type:"string"}}); // string + },60); + setTimeout(function() { + n1.receive({payload:"Line4",parts:{index:3,type:"string",count:4}}); // string + },90); + }); + }); + it('should append to a file after it has been deleted ', function(done) { var flow = [{id:"fileNode1", type:"file", name: "fileNode", "filename":fileToTest, "appendNewline":false, "overwriteFile":false, wires: [["helperNode1"]]}, {id:"helperNode1", type:"helper"}];