From bda5dffa347ef58b288590dbd90dac7e5c79340a Mon Sep 17 00:00:00 2001 From: Dave Conway-Jones Date: Fri, 25 Feb 2022 16:19:20 +0000 Subject: [PATCH] Add tests --- test/nodes/core/network/31-tcpin_spec.js | 13 +++++++++++++ test/nodes/core/network/31-tcprequest_spec.js | 15 +++++++++++++++ 2 files changed, 28 insertions(+) diff --git a/test/nodes/core/network/31-tcpin_spec.js b/test/nodes/core/network/31-tcpin_spec.js index cbe7ced2a..a694991ff 100644 --- a/test/nodes/core/network/31-tcpin_spec.js +++ b/test/nodes/core/network/31-tcpin_spec.js @@ -121,6 +121,19 @@ describe('TCP in Node', function() { testTCP0(flow, ["foo\nbar"], ["foo", "bar"], done); }); + it('should recv data (Stream/String/Delimiter:o\\n)', function(done) { + var flow = [{id:"n1", type:"tcp in", server:"server", host:"localhost", port:port, datamode:"stream", datatype:"utf8", newline:"o\n", topic:"", base64:false, wires:[["n2"]] }, + {id:"n2", type:"helper"}]; + testTCP0(flow, ["foo\nbar"], ["fo", "bar"], done); + }); + + it('should recv data (Stream/String/Delimiter:o\\n) and reattach o', function(done) { + var flow = [{id:"n1", type:"tcp in", server:"server", host:"localhost", port:port, datamode:"stream", datatype:"utf8", newline:"o\n", trim:true, topic:"", base64:false, wires:[["n2"]] }, + {id:"n2", type:"helper"}]; + testTCP0(flow, ["foo\nbar"], ["foo", "bar"], done); + }); + + it('should recv data (Stream/String/No delimiter)', function(done) { var flow = [{id:"n1", type:"tcp in", server:"server", host:"localhost", port:port, datamode:"stream", datatype:"utf8", newline:"", topic:"", base64:false, wires:[["n2"]] }, {id:"n2", type:"helper"}]; diff --git a/test/nodes/core/network/31-tcprequest_spec.js b/test/nodes/core/network/31-tcprequest_spec.js index dce73d858..e61e4f7d7 100644 --- a/test/nodes/core/network/31-tcprequest_spec.js +++ b/test/nodes/core/network/31-tcprequest_spec.js @@ -277,6 +277,21 @@ describe('TCP Request Node', function() { }, { payload: "bar\nfoo", topic: 'boo' + }], { + payload: "ACK:foobar", + topic: 'boo' + }, done); + }); + + it('should send & receive, then keep connection, and split return strings and reattach delimiter', function(done) { + var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"sit", ret:"string", newline:"\\n", trim:true, wires:[["n2"]] }, + {id:"n2", type:"helper"}]; + testTCPMany(flow, [{ + payload: "foo", + topic: 'boo' + }, { + payload: "bar\nfoo", + topic: 'boo' }], { payload: "ACK:foobar", topic: 'boo'