frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2025-03-01 10:36:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

tcprequest tests: normalize indents

Browse Source
This commit is contained in:
Christopher Hiller 2018-03-19 15:45:52 -07:00
parent 98f7271ac8
commit 9994df9601
No known key found for this signature in database
GPG Key ID: 517E44D4799F10A6
1 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
test/nodes/core/io/31-tcprequest_spec.js
View File

@ -27,12 +27,12 @@ describe('TCP Request Node', function() {
function startServer(done) { function startServer(done) {
port += 1; port += 1;
server = net.createServer(function(c) { server = net.createServer(function(c) {
c.on('data', function(data) { c.on('data', function(data) {
var rdata = "ACK:"+data.toString(); var rdata = "ACK:"+data.toString();
c.write(rdata); c.write(rdata);
}); });
c.on('error', function(err) { c.on('error', function(err) {
startServer(done); startServer(done);
}); });
}).listen(port, "127.0.0.1", function(err) { }).listen(port, "127.0.0.1", function(err) {
done(); done();
@ -63,48 +63,47 @@ describe('TCP Request Node', function() {
done(err); done(err);
} }
}); });
if((typeof val0) === 'object') { if((typeof val0) === 'object') {
n1.receive(val0); n1.receive(val0);
} else { } else {
n1.receive({payload:val0}); n1.receive({payload:val0});
} }
}); });
} }
it('should send & recv data', function(done) { it('should send & recv data', function(done) {
var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"time", splitc: "0", wires:[["n2"]] }, var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"time", splitc: "0", wires:[["n2"]] },
{id:"n2", type:"helper"}]; {id:"n2", type:"helper"}];
testTCP(flow, "foo", "ACK:foo", done) testTCP(flow, "foo", "ACK:foo", done)
}); });
it('should send & recv data when specified character received', function(done) { it('should send & recv data when specified character received', function(done) {
var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"char", splitc: "0", wires:[["n2"]] }, var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"char", splitc: "0", wires:[["n2"]] },
{id:"n2", type:"helper"}]; {id:"n2", type:"helper"}];
testTCP(flow, "foo0bar0", "ACK:foo0", done); testTCP(flow, "foo0bar0", "ACK:foo0", done);
}); });
it('should send & recv data after fixed number of chars received', function(done) { it('should send & recv data after fixed number of chars received', function(done) {
var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"count", splitc: "7", wires:[["n2"]] }, var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"count", splitc: "7", wires:[["n2"]] },
{id:"n2", type:"helper"}]; {id:"n2", type:"helper"}];
testTCP(flow, "foo bar", "ACK:foo", done); testTCP(flow, "foo bar", "ACK:foo", done);
}); });
it('should send & receive, then keep connection', function(done) { it('should send & receive, then keep connection', function(done) {
var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"sit", splitc: "5", wires:[["n2"]] }, var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"sit", splitc: "5", wires:[["n2"]] },
{id:"n2", type:"helper"}]; {id:"n2", type:"helper"}];
testTCP(flow, "foo", "ACK:foo", done); testTCP(flow, "foo", "ACK:foo", done);
}); });
it('should send & close', function(done) { it('should send & close', function(done) {
var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"sit", splitc: "5", wires:[["n2"]] }, var flow = [{id:"n1", type:"tcp request", server:"localhost", port:port, out:"sit", splitc: "5", wires:[["n2"]] },
{id:"n2", type:"helper"}]; {id:"n2", type:"helper"}];
testTCP(flow, "foo", "ACK:foo", done); testTCP(flow, "foo", "ACK:foo", done);
}); });
it('should send & recv data to/from server:port from msg', function(done) { it('should send & recv data to/from server:port from msg', function(done) {
var flow = [{id:"n1", type:"tcp request", server:"", port:"", out:"time", splitc: "0", wires:[["n2"]] }, var flow = [{id:"n1", type:"tcp request", server:"", port:"", out:"time", splitc: "0", wires:[["n2"]] },
{id:"n2", type:"helper"}]; {id:"n2", type:"helper"}];
testTCP(flow, {payload:"foo", host:"localhost", port:port}, "ACK:foo", done) testTCP(flow, {payload:"foo", host:"localhost", port:port}, "ACK:foo", done)
}); });
}); });