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

Let join node auto re-assemble buffers

Browse Source 
and add test
This commit is contained in:
Dave Conway-Jones 2017-06-26 23:10:08 +01:00
parent 1733c38b5c
commit 2482d122b8
No known key found for this signature in database
GPG Key ID: 81B04231572A9A2D
2 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
nodes/core/logic/17-split.js
View File

@ -394,6 +394,7 @@ module.exports = function(RED) {
inflight[partId].arrayLen = arrayLen;
} else if (payloadType === 'buffer') {
inflight[partId].bufferLen = 0;
inflight[partId].joinChar = joinChar;
}
}
if (node.timer > 0) {

22
test/nodes/core/logic/17-split_spec.js
View File

@ -297,6 +297,28 @@ describe('JOIN node', function() {
});
});
it('should join bits of buffer back together automatically', function(done) {
var flow = [{id:"n1", type:"join", wires:[["n2"]], joiner:",", build:"buffer", mode:"auto"},
{id:"n2", type:"helper"}];
helper.load(joinNode, flow, function() {
var n1 = helper.getNode("n1");
var n2 = helper.getNode("n2");
n2.on("input", function(msg) {
try {
msg.should.have.property("payload");
msg.should.be.a.Buffer;
msg.payload.toString().should.equal("A-B-C-D");
done();
}
catch(e) {done(e);}
});
n1.receive({payload:Buffer.from("A"), parts:{id:1, type:"buffer", ch:Buffer.from("-"), index:0, count:4}});
n1.receive({payload:Buffer.from("B"), parts:{id:1, type:"buffer", ch:Buffer.from("-"), index:1, count:4}});
n1.receive({payload:Buffer.from("C"), parts:{id:1, type:"buffer", ch:Buffer.from("-"), index:2, count:4}});
n1.receive({payload:Buffer.from("D"), parts:{id:1, type:"buffer", ch:Buffer.from("-"), index:3, count:4}});
});
});
it('should join things into an array after a count', function(done) {
var flow = [{id:"n1", type:"join", wires:[["n2"]], count:3, joiner:",",mode:"custom"},
{id:"n2", type:"helper"}];