Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
helper.load(sentimentNode, flow, () => {
// At this point the flow is "running". We now need to send in some data.
const n1 = helper.getNode("n1");
const n2 = helper.getNode("n2");
n2.on('input', (msg) => {
msg.sentiment.score.should.be.above(0.5);
done();
});
n1.receive({payload: "This is great!"});
});
});
helper.load(sentimentNode, flow, () => {
// At this point the flow is "running". We now need to send in some data.
const n1 = helper.getNode("n1");
const n2 = helper.getNode("n2");
n2.on('input', (msg) => {
msg.sentiment.score.should.be.above(0.5);
done();
});
n1.receive({payload: "This is great!"});
});
});
helper.load(pubsubInNode, flow, () => {
// At this point the flow is "running". We now need to send in some data.
const n1 = helper.getNode("n1");
const n2 = helper.getNode("n2");
const text = "Hello World!"; // The message we publish which should be received by the flow.
n2.on('input', (msg) => {
msg.should.have.property('payload'); // Check that we have msg.payload
msg.should.have.property('message'); // Check that we have msg.message
msg.payload.toString().should.be.equal(text);
done();
});
// Publish a message using the API which should now wake us up.
const topic = pubsub.topic('node-red-topic');
topic.publish(Buffer.from(text));
});
});
helper.load(testNode, flow, function() {
var n1 = helper.getNode("n1");
var n2 = helper.getNode("n2");
n2.on("input", function(msg) {
msg.should.have.a.property("payload");
msg.payload.should.be.a.Object;
msg.payload.should.have.length(43);
buf = msg.payload;
done();
});
n1.emit("input", {payload:{A:1, B:"string", C:true, D:[1,true,"string"], E:{Y:9,Z:"string"}}});
});
});
helper.load(testNode, flow, function() {
var n1 = helper.getNode("n1");
var n2 = helper.getNode("n2");
var c = 0;
n2.on("input", function(msg) {
if (c === 0) {
msg.should.have.a.property("payload");
msg.payload.should.be.approximately(0,3);
msg.payload.toString().indexOf(".").should.equal(-1);
done();
}
});
n1.emit("input", {payload:"a"});
});
});
helper.load(xmlNode, flow, function() {
var n1 = helper.getNode("n1");
var n2 = helper.getNode("n2");
n2.on("input", function(msg) {
msg.should.have.property('topic', 'bar');
msg.payload.should.have.property('employees');
msg.payload.employees.should.have.property('firstName');
should.equal(msg.payload.employees.firstName[0], 'John');
msg.payload.employees.should.have.property('lastName');
should.equal(msg.payload.employees.lastName[0], 'Smith');
done();
});
var string = 'JohnSmith';
n1.receive({payload:string,topic: "bar"});
});
});
helper.load([rpiNode,statusNode], flow, function() {
var n1 = helper.getNode("n1");
var n2 = helper.getNode("n2");
var n3 = helper.getNode("n3");
n3.on("input", function(msg) {
try {
msg.should.have.property('status');
msg.status.should.have.property('text', "rpi-gpio.status.na");
done();
} catch(err) {
done(err);
}
});
n1.receive({payload:"1"});
});
});
helper.load(functionNode, flow, function() {
var n1 = helper.getNode("n1");
var n2 = helper.getNode("n2");
n2.on("input", function(msg) {
msg.should.have.property("payload", "foobar");
done();
});
n1.receive({payload:"foo"});
});
});
helper.load(htmlNode, flow, function() {
var n1 = helper.getNode("n1");
var n2 = helper.getNode("n2");
n2.on("input", function(msg) {
msg.should.have.property('topic', 'bar');
should.equal(msg.payload, 'This is a test page for node 70-HTML');
done();
});
n1.receive({payload:data,topic:"bar",select:"h1"});
});
});
helper.load(feedParserNode, flow, () => {
const n2 = helper.getNode("n2");
const n1 = helper.getNode("n1");
let count = 0;
n2.on("input", (msg) => {
msg.topic.should.startWith("https://discourse.nodered.org/");
if(count === 0){
done();
count++;
}
});
});
});