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

Start making non-red-nodes tolerant to missing payloads

Browse Source
This commit is contained in:
dceejay 2015-03-31 13:18:25 +01:00
parent 32f6dc0346
commit 3896a82bd8
13 changed files with 210 additions and 122 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Gruntfile.js
View File

@ -14,7 +14,7 @@
* limitations under the License. * limitations under the License.
**/ **/
// Project configuration for Node-RED-nodes // Configuration for Node-RED-nodes project
module.exports = function(grunt) { module.exports = function(grunt) {
grunt.initConfig({ grunt.initConfig({
simplemocha: { simplemocha: {

52
function/smooth/17-smooth.js
View File

@ -29,32 +29,34 @@ module.exports = function(RED) {
var old = null; var old = null;
this.on('input', function (msg) { this.on('input', function (msg) {
var n = Number(msg.payload); if msg.hasOwnProperty("payload")) {
if (!isNaN(n)) { var n = Number(msg.payload);
if ((node.action === "low") || (node.action === "high")) { if (!isNaN(n)) {
if (old == null) { old = n; } if ((node.action === "low") || (node.action === "high")) {
old = old + (n - old) / node.count; if (old == null) { old = n; }
if (node.action === "low") { msg.payload = old; } old = old + (n - old) / node.count;
else { msg.payload = n - old; } if (node.action === "low") { msg.payload = old; }
else { msg.payload = n - old; }
}
else {
a.push(n);
if (a.length > node.count) { pop = a.shift(); }
if (node.action === "max") {
msg.payload = Math.max.apply(Math, a);
}
if (node.action === "min") {
msg.payload = Math.min.apply(Math, a);
}
if (node.action === "mean") {
tot = tot + n - pop;
msg.payload = tot / a.length;
}
}
if (node.round) { msg.payload = Math.round(msg.payload); }
node.send(msg);
} }
else { else { node.log("Not a number: "+msg.payload); }
a.push(n); } // ignore msg with no payload property.
if (a.length > node.count) { pop = a.shift(); }
if (node.action === "max") {
msg.payload = Math.max.apply(Math, a);
}
if (node.action === "min") {
msg.payload = Math.min.apply(Math, a);
}
if (node.action === "mean") {
tot = tot + n - pop;
msg.payload = tot / a.length;
}
}
if (node.round) { msg.payload = Math.round(msg.payload); }
node.send(msg);
}
else { node.log("Not a number: "+msg.payload); }
}); });
} }
RED.nodes.registerType("smooth", SmoothNode); RED.nodes.registerType("smooth", SmoothNode);

36
parsers/base64/70-base64.js
View File

@ -21,27 +21,29 @@ module.exports = function(RED) {
RED.nodes.createNode(this,n); RED.nodes.createNode(this,n);
var node = this; var node = this;
this.on("input", function(msg) { this.on("input", function(msg) {
if (Buffer.isBuffer(msg.payload)) { if (msg.hasOwnProperty("payload")) {
// Take binary buffer and make into a base64 string if (Buffer.isBuffer(msg.payload)) {
msg.payload = msg.payload.toString('base64'); // Take binary buffer and make into a base64 string
node.send(msg); msg.payload = msg.payload.toString('base64');
}
else if (typeof msg.payload === "string") {
// Take base64 string and make into binary buffer
var regexp = new RegExp('^[A-Za-z0-9+\/=]*$');
if ( regexp.test(msg.payload) && (msg.payload.length % 4 === 0) ) {
msg.payload = new Buffer(msg.payload,'base64');
node.send(msg); node.send(msg);
} }
else if (typeof msg.payload === "string") {
// Take base64 string and make into binary buffer
var regexp = new RegExp('^[A-Za-z0-9+\/=]*$');
if ( regexp.test(msg.payload) && (msg.payload.length % 4 === 0) ) {
msg.payload = new Buffer(msg.payload,'base64');
node.send(msg);
}
else {
node.log("Not a Base64 string - maybe we should encode it...");
msg.payload = (new Buffer(msg.payload,"binary")).toString('base64');
node.send(msg);
}
}
else { else {
node.log("Not a Base64 string - maybe we should encode it..."); node.warn("This node only handles strings or buffers.");
msg.payload = (new Buffer(msg.payload,"binary")).toString('base64');
node.send(msg);
} }
} } else { node.warn("No payload found to process"); }
else {
node.warn("This node only handles strings or buffers.");
}
}); });
} }
RED.nodes.registerType("base64",Base64Node); RED.nodes.registerType("base64",Base64Node);

34
parsers/msgpack/70-msgpack.js
View File

@ -22,24 +22,26 @@ module.exports = function(RED) {
RED.nodes.createNode(this,n); RED.nodes.createNode(this,n);
var node = this; var node = this;
this.on("input", function(msg) { this.on("input", function(msg) {
if (Buffer.isBuffer(msg.payload)) { if (msg.hasOwnProperty("payload")) {
var l = msg.payload.length; if (Buffer.isBuffer(msg.payload)) {
try { var l = msg.payload.length;
msg.payload = msgpack.decode(msg.payload); try {
msg.payload = msgpack.decode(msg.payload);
node.send(msg);
node.status({text:l +" b->o "+ JSON.stringify(msg.payload).length});
}
catch (e) {
node.warn("Bad decode: "+e);
node.status({text:"not a msgpack buffer"});
}
}
else {
var le = JSON.stringify(msg.payload).length;
msg.payload = msgpack.encode(msg.payload);
node.send(msg); node.send(msg);
node.status({text:l +" b->o "+ JSON.stringify(msg.payload).length}); node.status({text:le +" o->b "+ msg.payload.length});
} }
catch (e) { } else { node.warn("No payload found to process");
node.warn("Bad decode: "+e);
node.status({text:"not a msgpack buffer"});
}
}
else {
var le = JSON.stringify(msg.payload).length;
msg.payload = msgpack.encode(msg.payload);
node.send(msg);
node.status({text:le +" o->b "+ msg.payload.length});
}
}); });
} }
RED.nodes.registerType("msgpack",MsgPackNode); RED.nodes.registerType("msgpack",MsgPackNode);

149
test/utility/exif/94-exif_spec.js
View File

@ -35,40 +35,131 @@ describe('exif node', function() {
it('extracts location data from Exif data of JPEG', function(done) { it('extracts location data from Exif data of JPEG', function(done) {
var exif = require('exif'); var exif = require('exif');
var ExifImage = exif.ExifImage; var ExifImage = exif.ExifImage;
// the jpg file is a single black dot but it was originally a photo taken at IBM Hursley // the jpg file is a single black dot but it was originally a photo taken at IBM Hursley
//console.log(process.cwd());
var data = fs.readFileSync("test/utility/exif/exif_test_image.jpg", null); // extracting genuine exif data to be fed back as the result of the stubbed ExifImage constructor var data = fs.readFileSync("test/utility/exif/exif_test_image.jpg", null); // extracting genuine exif data to be fed back as the result of the stubbed ExifImage constructor
//var data = fs.readFileSync("exif_test_image.jpg", null); // extracting genuine exif data to be fed back as the result of the stubbed ExifImage constructor
var flow = [{id:"exifNode1", type:"exif", wires:[["helperNode1"]]},
{id:"helperNode1", type:"helper"}];
var eD; helper.load(exifNode, flow, function() {
var exifNode1 = helper.getNode("exifNode1");
var helperNode1 = helper.getNode("helperNode1");
new ExifImage({ image : data }, function (error, exifData) { helperNode1.on("input", function(msg) {
if (error) { msg.location.lat.should.equal(50.95624); // this data is stored in the jpg file
done(error); msg.location.lon.should.equal(-1.36701);
} else { done();
eD = exifData;
}
var flow = [{id:"exifNode1", type:"exif", wires:[["helperNode1"]]},
{id:"helperNode1", type:"helper"}];
helper.load(exifNode, flow, function() {
var exifNode1 = helper.getNode("exifNode1");
var helperNode1 = helper.getNode("helperNode1");
helperNode1.on("input", function(msg) {
msg.location.lat.should.equal(50.95624); // this data is stored in the jpg file
msg.location.lon.should.equal(-1.36701);
done();
});
var stub = sinon.stub(ExifImage.prototype, 'loadImage', function(error, callback) {
stub.restore();
callback(null, eD);
});
exifNode1.receive({payload:data});
}); });
});
exifNode1.receive({payload:data});
});
});
it('should report if no data found', function(done) {
var exif = require('exif');
var ExifImage = exif.ExifImage;
// the jpg file is a single black dot but it was originally a photo taken at IBM Hursley
//console.log(process.cwd());
var data = fs.readFileSync("test/utility/exif/exif_test_image2.jpg", null); // extracting genuine exif data to be fed back as the result of the stubbed ExifImage constructor
//var data = fs.readFileSync("exif_test_image2.jpg", null); // extracting genuine exif data to be fed back as the result of the stubbed ExifImage constructor
var flow = [{id:"exifNode1", type:"exif", wires:[["helperNode1"]]},
{id:"helperNode1", type:"helper"}];
helper.load(exifNode, flow, function() {
var exifNode1 = helper.getNode("exifNode1");
var helperNode1 = helper.getNode("helperNode1");
setTimeout(function() {
var logEvents = helper.log().args.filter(function(evt) {
return evt[0].type == "exif";
});
logEvents.should.have.length(1);
logEvents[0][0].should.have.a.property('msg');
logEvents[0][0].msg.toString().should.startWith("The incoming image did not contain Exif GPS");
done();
},150);
exifNode1.receive({payload:data});
});
});
it('should report if not a jpeg', function(done) {
var exif = require('exif');
var ExifImage = exif.ExifImage;
// the jpg file is a single black dot but it was originally a photo taken at IBM Hursley
var data = new Buffer("hello");
var eD;
var flow = [{id:"exifNode1", type:"exif", wires:[["helperNode1"]]},
{id:"helperNode1", type:"helper"}];
helper.load(exifNode, flow, function() {
var exifNode1 = helper.getNode("exifNode1");
var helperNode1 = helper.getNode("helperNode1");
setTimeout(function() {
var logEvents = helper.log().args.filter(function(evt) {
return evt[0].type == "exif";
});
logEvents.should.have.length(1);
logEvents[0][0].should.have.a.property('msg');
logEvents[0][0].msg.toString().should.startWith("Error: The given image is not a JPEG");
done();
},150);
exifNode1.receive({payload:data});
});
});
it('should report if bad payload', function(done) {
var exif = require('exif');
var ExifImage = exif.ExifImage;
var data = "hello";
var eD;
var flow = [{id:"exifNode1", type:"exif", wires:[["helperNode1"]]},
{id:"helperNode1", type:"helper"}];
helper.load(exifNode, flow, function() {
var exifNode1 = helper.getNode("exifNode1");
var helperNode1 = helper.getNode("helperNode1");
setTimeout(function() {
var logEvents = helper.log().args.filter(function(evt) {
return evt[0].type == "exif";
});
logEvents.should.have.length(1);
logEvents[0][0].should.have.a.property('msg');
logEvents[0][0].msg.toString().should.startWith("Invalid payload received, ");
done();
},150);
exifNode1.receive({payload:data});
});
});
it('should report if no payload', function(done) {
var exif = require('exif');
var ExifImage = exif.ExifImage;
var data = new Buffer("hello");
var eD;
var flow = [{id:"exifNode1", type:"exif", wires:[["helperNode1"]]},
{id:"helperNode1", type:"helper"}];
helper.load(exifNode, flow, function() {
var exifNode1 = helper.getNode("exifNode1");
var helperNode1 = helper.getNode("helperNode1");
setTimeout(function() {
var logEvents = helper.log().args.filter(function(evt) {
return evt[0].type == "exif";
});
logEvents.should.have.length(1);
logEvents[0][0].should.have.a.property('msg');
logEvents[0][0].msg.toString().should.startWith("No payload received, ");
done();
},150);
exifNode1.receive({topic:data});
});
}); });
}); });

BIN
test/utility/exif/exif_test_image2.jpg Normal file
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 285 B

0
time/79-suncalc.html → time/suncalc/79-suncalc.html
View File

0
time/79-suncalc.js → time/suncalc/79-suncalc.js
View File

0
time/LICENSE → time/suncalc/LICENSE
View File

0
time/README.md → time/suncalc/README.md
View File

0
time/icons/sun.png → time/suncalc/icons/sun.png
View File

Side by Side Swipe Overlay

Before

Width:  |  Height:  |  Size: 581 B

After

Width:  |  Height:  |  Size: 581 B

0
time/package.json → time/suncalc/package.json
View File

59
utility/exif/94-exif.js
View File

@ -1,5 +1,5 @@
/** /**
* Copyright 2014 IBM Corp. * Copyright 2014, 2015 IBM Corp.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -24,15 +24,18 @@ module.exports = function(RED) {
return result; return result;
} }
/*** function ExifNode(n) {
* Extracts GPS location information from Exif data. If enough information is RED.nodes.createNode(this,n);
* provided, convert the Exif data into a pair of single floating point number var node = this;
* latitude/longitude data pairs. Populates msg.location with these.
* Assumes that the msg object will always have exifData available as msg.exif. /***
* Assume that the GPS data saved into Exif provides a valid value * Extracts GPS location information from Exif data. If enough information is
*/ * provided, convert the Exif data into a pair of single floating point number
function addMsgLocationDataFromExifGPSData(msg) { * latitude/longitude data pairs. Populates msg.location with these.
if(msg.exif.gps) { * Assumes that the msg object will always have exifData available as msg.exif.
* Assume that the GPS data saved into Exif provides a valid value
*/
function addMsgLocationDataFromExifGPSData(msg) {
var gpsData = msg.exif.gps; // declaring variable purely to make checks more readable var gpsData = msg.exif.gps; // declaring variable purely to make checks more readable
if(gpsData.GPSAltitude) { if(gpsData.GPSAltitude) {
if(!msg.location) { if(!msg.location) {
@ -44,26 +47,22 @@ module.exports = function(RED) {
// The data provided in Exif is in degrees, minutes, seconds, this is to be converted into a single floating point degree // The data provided in Exif is in degrees, minutes, seconds, this is to be converted into a single floating point degree
if(gpsData.GPSLatitude.length === 3) { // OK to convert latitude if(gpsData.GPSLatitude.length === 3) { // OK to convert latitude
if(gpsData.GPSLongitude.length === 3) { // OK to convert longitude if(gpsData.GPSLongitude.length === 3) { // OK to convert longitude
var latitude = convertDegreesMinutesSecondsToDecimals(gpsData.GPSLatitude[0], gpsData.GPSLatitude[1], gpsData.GPSLatitude[2]);
latitude = Math.round(latitude * 100000)/100000;
// (N)orth means positive latitude var latitude = convertDegreesMinutesSecondsToDecimals(gpsData.GPSLatitude[0], gpsData.GPSLatitude[1], gpsData.GPSLatitude[2]);
// (S)outh means negative latitude latitude = Math.round(latitude * 100000)/100000; // 5dp is approx 1m resolution...
// (E)ast means positive longitude // (N)orth means positive latitude, (S)outh means negative latitude
// (W)est means negative longitude if (gpsData.GPSLatitudeRef.toString() === 'S' || gpsData.GPSLatitudeRef.toString() === 's') {
if(gpsData.GPSLatitudeRef.toString() === 'S' || gpsData.GPSLatitudeRef.toString() === 's') {
latitude = latitude * -1; latitude = latitude * -1;
} }
var longitude = convertDegreesMinutesSecondsToDecimals(gpsData.GPSLongitude[0], gpsData.GPSLongitude[1], gpsData.GPSLongitude[2]); var longitude = convertDegreesMinutesSecondsToDecimals(gpsData.GPSLongitude[0], gpsData.GPSLongitude[1], gpsData.GPSLongitude[2]);
longitude = Math.round(longitude * 100000)/100000; longitude = Math.round(longitude * 100000)/100000; // 5dp is approx 1m resolution...
// (E)ast means positive longitude, (W)est means negative longitude
if(gpsData.GPSLongitudeRef.toString() === 'W' || gpsData.GPSLongitudeRef.toString() === 'w') { if (gpsData.GPSLongitudeRef.toString() === 'W' || gpsData.GPSLongitudeRef.toString() === 'w') {
longitude = longitude * -1; longitude = longitude * -1;
} }
if(!msg.location) { // Create location property if not exists
msg.location = {}; if (!msg.location) { msg.location = {}; }
}
msg.location.lat = latitude; msg.location.lat = latitude;
msg.location.lon = longitude; msg.location.lon = longitude;
return; return;
@ -76,30 +75,22 @@ module.exports = function(RED) {
} else { } else {
node.log("The location of this image cannot be determined safely so no location information has been added to the message."); node.log("The location of this image cannot be determined safely so no location information has been added to the message.");
} }
} else {
node.log("No location info found in this image.");
} }
}
function ExifNode(n) {
RED.nodes.createNode(this,n);
var node = this;
this.on("input", function(msg) { this.on("input", function(msg) {
try { try {
if (msg.payload) { if (msg.payload) {
if (Buffer.isBuffer(msg.payload)) { if (Buffer.isBuffer(msg.payload)) {
new ExifImage({ image : msg.payload }, function (error, exifData) { new ExifImage({ image : msg.payload }, function (error, exifData) {
if (error) { if (error) {
//node.error('Failed to extract Exif data from image.'); node.log(error.toString());
//node.log('Failed to extract Exif data from image. '+ error);
node.log(error);
} else { } else {
//msg.payload remains the same buffer //msg.payload remains the same buffer
if(exifData) { if ((exifData) && (exifData.hasOwnProperty("gps")) && (Object.keys(exifData.gps).length !== 0)) {
msg.exif = exifData; msg.exif = exifData;
addMsgLocationDataFromExifGPSData(msg); addMsgLocationDataFromExifGPSData(msg);
} else { } else {
node.warn("The incoming buffer did not contain Exif data, nothing to do. "); node.warn("The incoming image did not contain Exif GPS data, nothing to do. ");
} }
} }
node.send(msg); node.send(msg);