1
0
mirror of https://github.com/node-red/node-red-nodes.git synced 2023-10-10 13:36:58 +02:00
node-red-nodes/hardware/neopixel/neopixel.js

160 lines
6.7 KiB
JavaScript
Raw Normal View History

2016-01-11 22:22:30 +01:00
module.exports = function(RED) {
"use strict";
var spawn = require('child_process').spawn;
var fs = require('fs');
2016-01-11 22:22:30 +01:00
var colors = require('./colours.js');
var piCommand = __dirname+'/neopix';
try {
var cpuinfo = fs.readFileSync("/proc/cpuinfo").toString();
if (cpuinfo.indexOf(": BCM") === -1) { throw "Info : "+RED._("rpi-gpio.errors.ignorenode"); }
2017-01-29 18:45:44 +01:00
}
catch(err) {
2016-01-11 22:22:30 +01:00
throw "Info : "+RED._("rpi-gpio.errors.ignorenode");
}
if (!fs.existsSync('/usr/local/lib/python2.7/dist-packages/neopixel.py')) {
RED.log.warn("Can't find neopixel.py python library");
throw "Warning : Can't find neopixel.py python library";
}
if ( !(1 & parseInt ((fs.statSync(piCommand).mode & parseInt ("777", 8)).toString (8)[0]) )) {
RED.log.error(piCommand + " command is not executable");
throw "Error : "+RED._("rpi-gpio.errors.mustbeexecutable");
}
// the magic to make python print stuff immediately
process.env.PYTHONUNBUFFERED = 1;
2016-03-01 22:10:58 +01:00
function PiNeopixelNode(n) {
2016-01-11 22:22:30 +01:00
RED.nodes.createNode(this,n);
this.pixels = n.pixels || 1;
this.bgnd = n.bgnd || "0,0,0";
this.fgnd = n.fgnd || "128,128,128";
this.mode = n.mode || "pcent";
this.rgb = n.rgb || "rgb";
2016-01-11 22:22:30 +01:00
this.wipe = Number(n.wipe || 40);
if (this.wipe < 0) { this.wipe = 0; }
var node = this;
2016-01-13 20:59:30 +01:00
var needle = "255,255,255";
//var p1 = /^\#[A-Fa-f0-9]{6}$/
2016-01-11 22:22:30 +01:00
var p2 = /^[0-9]+,[0-9]+,[0-9]+$/
var p3 = /^[0-9]+,[0-9]+,[0-9]+,[0-9]+$/
var p4 = /^[0-9]+,[0-9]+,[0-9]+,[0-9]+,[0-9]+$/
function inputlistener(msg) {
if (msg.hasOwnProperty("payload")) {
var pay = msg.payload.toString().toUpperCase();
var parts = pay.split(",");
if (parts.length <= 2) {
if (parts.length === 2) { // it's a colour and length
if (isNaN(parseInt(parts[1]))) { parts = parts.reverse(); }
if (colors.getRGB(parts[0],node.rgb)) {
2016-01-11 22:22:30 +01:00
var l = parts[1];
2016-01-13 20:59:30 +01:00
if (node.mode.indexOf("pcent") >= 0) { l = parseInt(l / 100 * node.pixels + 0.5); }
2016-01-11 22:22:30 +01:00
l = l - 1;
2016-01-13 20:59:30 +01:00
if (node.mode.indexOf("need") >= 0) {
needle = colors.getRGB(parts[0],node.rgb);
2016-01-13 20:59:30 +01:00
pay = "0,"+(l-1)+","+node.fgnd+"\n"+l+","+needle+"\n"+(l+1)+","+(node.pixels-1)+","+node.bgnd;
2017-01-29 18:45:44 +01:00
}
else {
node.fgnd = colors.getRGB(parts[0],node.rgb);
2016-01-13 20:59:30 +01:00
pay = "0,"+l+","+node.fgnd+"\n"+(l+1)+","+(node.pixels-1)+","+node.bgnd;
}
2016-01-11 22:22:30 +01:00
}
else { node.warn("Invalid colour : "+pay); return; }
2016-01-11 22:22:30 +01:00
}
else {
if (isNaN(pay)) { // it's a single colour word so set background
if (colors.getRGB(pay,node.rgb)) {
node.bgnd = colors.getRGB(pay,node.rgb);
2016-01-11 22:22:30 +01:00
pay = node.bgnd;
}
else { node.warn("Invalid payload : "+pay); return; }
}
else { // it's a single number so just draw bar
2016-03-01 22:10:58 +01:00
var ll = pay;
if (node.mode.indexOf("pcent") >= 0) { ll = parseInt(ll / 100 * node.pixels + 0.5); }
ll = ll - 1;
2016-01-13 20:59:30 +01:00
if (node.mode.indexOf("need") >= 0) {
2016-03-01 22:10:58 +01:00
pay = "0,"+(ll-1)+","+node.fgnd+"\n"+ll+","+needle+"\n"+(ll+1)+","+(node.pixels-1)+","+node.bgnd;
2017-01-29 18:45:44 +01:00
}
else {
2016-03-01 22:10:58 +01:00
pay = "0,"+ll+","+node.fgnd+"\n"+(ll+1)+","+(node.pixels-1)+","+node.bgnd;
2016-01-13 20:59:30 +01:00
}
2016-01-11 22:22:30 +01:00
}
}
node.child.stdin.write(pay+"\n");
return;
2016-01-11 22:22:30 +01:00
}
if ( p2.test(pay) || p3.test(pay) || p4.test(pay) ) {
if ((parts.length > 2) && (node.rgb === "grb")) { // swap r and g values
var tmp = parts[parts.length-3];
parts[parts.length-3] = parts[parts.length-2];
parts[parts.length-2] = tmp;
}
if (parts.length === 3) { node.bgnd = parts.join(","); }
node.child.stdin.write(parts.join(",")+"\n"); // handle 3 parts, 4 part and 5 parts in the python
2016-01-11 22:22:30 +01:00
}
else { node.warn("Invalid payload : "+pay); }
}
}
2016-01-12 23:53:43 +01:00
node.child = spawn(piCommand, [node.pixels, node.wipe, node.mode]);
2016-01-11 22:22:30 +01:00
node.status({fill:"green",shape:"dot",text:"ok"});
node.on("input", inputlistener);
node.child.stdout.on('data', function (data) {
if (RED.settings.verbose) { node.log("out: "+data+" :"); }
});
node.child.stderr.on('data', function (data) {
if (RED.settings.verbose) { node.log("err: "+data+" :"); }
});
node.child.on('close', function () {
2016-01-11 22:22:30 +01:00
node.child = null;
if (RED.settings.verbose) { node.log(RED._("rpi-gpio.status.closed")); }
if (node.done) {
node.status({fill:"grey",shape:"ring",text:"closed"});
node.done();
}
else { node.status({fill:"red",shape:"ring",text:"stopped"}); }
});
node.child.on('error', function (err) {
if (err.errno === "ENOENT") { node.error(RED._("rpi-gpio.errors.commandnotfound")); }
else if (err.errno === "EACCES") { node.error(RED._("rpi-gpio.errors.commandnotexecutable")); }
else { node.error(RED._("rpi-gpio.errors.error")+': ' + err.errno); }
});
node.on("close", function(done) {
node.status({fill:"grey",shape:"ring",text:"closed"});
if (node.child != null) {
node.done = done;
node.child.kill('SIGKILL');
}
else { done(); }
});
if (node.bgnd) {
if (node.bgnd.split(',').length === 1) {
node.bgnd = colors.getRGB(node.bgnd,node.rgb);
2016-01-11 22:22:30 +01:00
}
2016-01-13 20:59:30 +01:00
if (node.mode.indexOf("shift") === -1) {
node.child.stdin.write(node.bgnd+"\n");
}
2016-01-11 22:22:30 +01:00
}
if (node.fgnd) {
if (node.fgnd.split(',').length === 1) {
node.fgnd = colors.getRGB(node.fgnd,node.rgb);
2016-01-11 22:22:30 +01:00
}
}
}
2016-03-01 22:10:58 +01:00
RED.nodes.registerType("rpi-neopixels",PiNeopixelNode);
2016-01-11 22:22:30 +01:00
}