frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

Merge pull request #4246 from kazuhitoyokoi/dev-fixfilenode

Browse Source 
Fix JSONata in file nodes
This commit is contained in:
Nick O'Leary 2023-07-26 11:55:32 +01:00 committed by GitHub
commit d21c0758b1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 55 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
packages/node_modules/@node-red/nodes/core/storage/10-file.js vendored
View File

@ -68,9 +68,12 @@ module.exports = function(RED) {
node.error(err,msg); node.error(err,msg);
return done(); return done();
} else { } else {
filename = value; processMsg2(msg,nodeSend,value,done);
} }
}); });
}
function processMsg2(msg,nodeSend,filename,done) {
filename = filename || ""; filename = filename || "";
msg.filename = filename; msg.filename = filename;
var fullFilename = filename; var fullFilename = filename;
@ -311,9 +314,12 @@ module.exports = function(RED) {
node.error(err,msg); node.error(err,msg);
return done(); return done();
} else { } else {
filename = (value || "").replace(/\t|\r|\n/g,''); processMsg2(msg, nodeSend, (value || "").replace(/\t|\r|\n/g,''), nodeDone);
} }
}); });
});
function processMsg2(msg, nodeSend, filename, nodeDone) {
filename = filename || ""; filename = filename || "";
var fullFilename = filename; var fullFilename = filename;
if (filename && RED.settings.fileWorkingDirectory && !path.isAbsolute(filename)) { if (filename && RED.settings.fileWorkingDirectory && !path.isAbsolute(filename)) {
@ -434,7 +440,8 @@ module.exports = function(RED) {
nodeDone(); nodeDone();
}); });
} }
}); }
this.on('close', function() { this.on('close', function() {
node.status({}); node.status({});
}); });

45
test/nodes/core/storage/10-file_spec.js
View File

@ -98,6 +98,30 @@ describe('file Nodes', function() {
}); });
}); });
it('should write to a file using JSONata', function(done) {
var fileToTest4jsonata = "'" + resourcesDir + "/'&(20+30)&'-file-test-file.txt'";
var flow = [{id:"fileNode1", type:"file", name: "fileNode", "filename": fileToTest4jsonata, "filenameType": "jsonata", "appendNewline":false, "overwriteFile":true, wires: [["helperNode1"]]},
{id:"helperNode1", type:"helper"}];
helper.load(fileNode, flow, function() {
var n1 = helper.getNode("fileNode1");
var n2 = helper.getNode("helperNode1");
n2.on("input", function(msg) {
try {
var f = fs.readFileSync(fileToTest);
f.should.have.length(4);
fs.unlinkSync(fileToTest);
msg.should.have.property("payload", "test");
done();
}
catch (e) {
done(e);
}
});
n1.receive({payload:"test"});
});
});
it('should write to a file using RED.settings.fileWorkingDirectory', function(done) { it('should write to a file using RED.settings.fileWorkingDirectory', function(done) {
var flow = [{id:"fileNode1", type:"file", name: "fileNode", "filename":relativePathToFile, "appendNewline":false, "overwriteFile":true, wires: [["helperNode1"]]}, var flow = [{id:"fileNode1", type:"file", name: "fileNode", "filename":relativePathToFile, "appendNewline":false, "overwriteFile":true, wires: [["helperNode1"]]},
{id:"helperNode1", type:"helper"}]; {id:"helperNode1", type:"helper"}];
@ -1237,6 +1261,27 @@ describe('file Nodes', function() {
}); });
}); });
it('should read in a file using JSONata and output a utf8 string', function(done) {
var fileToTest4jsonata = "'" + resourcesDir + "/'&(20+30)&'-file-test-file.txt'";
var flow = [{id:"fileInNode1", type:"file in", name: "fileInNode", "filename":fileToTest4jsonata, "filenameType": "jsonata", "format":"utf8", wires:[["n2"]]},
{id:"n2", type:"helper"}];
helper.load(fileNode, flow, function() {
var n1 = helper.getNode("fileInNode1");
var n2 = helper.getNode("n2");
n2.on("input", function(msg) {
try {
msg.should.have.property('payload');
msg.payload.should.be.a.String();
msg.payload.should.have.length(40)
msg.payload.should.equal("File message line 1\nFile message line 2\n");
done();
} catch(err) {
done(err);
}
});
n1.receive({payload:""});
});
});
it('should read in a file using fileWorkingDirectory to set cwd', function(done) { it('should read in a file using fileWorkingDirectory to set cwd', function(done) {
var flow = [{id:"fileInNode1", type:"file in", name: "fileInNode", "filename":relativePathToFile, "format":"utf8", wires:[["n2"]]}, var flow = [{id:"fileInNode1", type:"file in", name: "fileInNode", "filename":relativePathToFile, "format":"utf8", wires:[["n2"]]},