60fps frame streaming examples

.gitignore

@@ -1,2 +1,4 @@
 .DS_Store
-node_modules/
+node_modules/
+/.settings/
+/.project

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>blinkstick-node</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.wst.validation.validationbuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.wst.jsdt.core.jsNature</nature>
+	</natures>
+</projectDescription>

.settings/.jsdtscope

@@ -0,0 +1,16 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry excluding="**/bower_components/*|**/node_modules/*|**/*.min.js" kind="src" path="">
+		<attributes>
+			<attribute name="provider" value="org.eclipse.wst.jsdt.web.core.internal.project.ModuleSourcePathProvider"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.JRE_CONTAINER"/>
+	<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.baseBrowserLibrary"/>
+	<classpathentry kind="con" path="org.eclipse.wst.jsdt.launching.WebProject">
+		<attributes>
+			<attribute name="hide" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path=""/>
+</classpath>

.settings/org.eclipse.wst.jsdt.ui.superType.container

@@ -0,0 +1 @@
+org.eclipse.wst.jsdt.launching.baseBrowserLibrary

.settings/org.eclipse.wst.jsdt.ui.superType.name

@@ -0,0 +1 @@
+Window

examples/connect/connect.js

@@ -7,7 +7,7 @@
 
 if (process.argv[2] == null) {
     console.log("Please supply access code as an argument");
-    return;
+    process.exit(1);
 }
 
 var faye = require('faye'),

examples/flex_stream/TODO.txt

@@ -0,0 +1,14 @@
+TODO
+Add audio to notifiers
+Multi-channel support
+- Might require firmware changes to setColors() to send all channels in one call.
+RGBA layers
+Refactor as npm project
+RGB Emulator Matrix REM (websockets - standalone or in parallel with BlinkStick)
+
+Make web UI prettier
+
+ DONE
+ Specify width and height for matrices, setSize(W,H) getSize()==>WxH
+ - Sharp package's rasterized buffers already compatible with rasterized matrices
+ Add more notification images (s3d, vrip, twitter, etc)

examples/flex_stream/ambilight.js

@@ -0,0 +1,39 @@
+//Ambient display (ambilight) based on flex_stream.js     
+//Real-time streaming of desktop to BlinkStick Flex and Pro
+//User defined OnFrame() samples the desktop, and morphs scaled frames to BlinkStick
+//Minimum Requirements: 
+//- Latest version of nodejs (tested with v8.9.3)
+//- Latest blinkstick, screenshot-desktop and sharp npm packages (all cross-platform)
+//For Windows, Linux and Mac
+
+module.exports = {
+		init: function() {
+			init(); 
+		}
+}
+
+const  flex_stream = require("./flex_stream.js");                                                                                                                                                                     
+const  screenshot  = require('screenshot-desktop'); //Available at npmjs.com                                                                                                                                       
+const  sharp       = require('sharp');              //Available at npmjs.com                                                                                                                                             
+
+
+//Stream scaled desktop (size x 1) to BlinkStick via async futures pipeline
+function ambilight(){
+	screenshot().then((img) => {
+		sharp(img).resize(flex_stream.getWidth(),flex_stream.getHeight()).ignoreAspectRatio().raw().toBuffer().then(data => {
+			flex_stream.setAlpha(0.1);
+			flex_stream.produceFrame(data);
+		})
+	});
+}
+
+//Configure stream
+
+function init(){
+	flex_stream.setSize(8,1);
+	flex_stream.setProducerFramerate(5);
+	flex_stream.setConsumerFramerate(60);
+	flex_stream.setOnFrame(ambilight);
+}
+
+init();

examples/flex_stream/aurora.js

@@ -0,0 +1,54 @@
+//Aurora Borealis ambience based on flex_stream.js
+//For Windows, Linux and Mac
+
+module.exports = {
+		init: function() {
+			init(); 
+		}
+}
+
+const os          = require("os");
+const flex_stream = require("./flex_stream.js");
+
+
+var frame = flex_stream.newFrame();
+function aurora() {       
+	//Aurora
+	a = Math.random();
+	flex_stream.setProducerFramerate(a*4+4);
+	flex_stream.setAlpha(.01+(a/200));
+
+	//Borealis
+	for (i=0; i<flex_stream.getSize(); i++)
+	{    	
+
+		var r = Math.random()*150;
+		var g = (1-Math.random()*.85)*150;
+		var b = (1-Math.random()*.85)*200;   
+
+		if (Math.random()>.75)
+		{
+			r=0; g=0; b=0;
+		}
+
+		if (Math.random()>.5)
+		{
+			frame[i*3+0] = Math.floor(r);  //R
+			frame[i*3+1] = Math.floor(g);  //G
+			frame[i*3+2] = Math.floor(b);  //B
+		}
+	}
+	flex_stream.produceFrame(frame);     
+}
+
+//Configure stream
+
+function init(){
+	flex_stream.setSize(8,1);
+	flex_stream.setProducerFramerate(60);
+	flex_stream.setConsumerFramerate(60);
+	flex_stream.setOnFrame(aurora);
+}
+
+init();
+

examples/flex_stream/cpu_meter.js

@@ -0,0 +1,79 @@
+//CPU load meter based on flex_stream.js
+//User defined OnFrame() is a particle trail emitter to indicate CPU load. 
+//For Windows, Linux and Mac
+
+module.exports = {
+		init: function() {
+			init(); 
+		}
+}
+
+const os          = require("os");
+const flex_stream = require("./flex_stream.js");
+
+var framerate = 30;  // Varies with CPU load   
+
+var startMeasure  = cpuLoad();
+var percentageCPU = 0;
+var cpu_avg       = 0;
+var pos           = 1;
+var speed         = 1;
+
+function cpuMeter() {       
+	var endMeasure      = cpuLoad(); 
+	var idleDifference  = endMeasure.idle - startMeasure.idle;
+	var totalDifference = endMeasure.total - startMeasure.total;
+
+	startMeasure = endMeasure;
+
+	if (totalDifference != 0)
+		percentageCPU = 100 - (100 * idleDifference / totalDifference);
+
+	cpu_avg = (cpu_avg+percentageCPU)/2;
+
+	//Vary the producer framerate by percentage CPU load (15 to 60 fps)
+	framerate = cpu_avg*0.45+15;
+
+	//Bounce particle off edges of LED strip
+	if (pos<=0 || pos>=flex_stream.getSize()-1)
+		speed =-speed;         
+	pos += speed;
+
+	var frame = flex_stream.newFrame();
+	//Vary particle colour by CPU load (green to amber to red)        
+	frame[pos*3+0] = Math.floor(cpu_avg*2.5)+5; //R
+	frame[pos*3+1] = 100-Math.floor(cpu_avg);   //G
+	frame[pos*3+2] = 2;                         //B
+
+	flex_stream.setProducerFramerate(framerate);
+	flex_stream.setAlpha(0.25);
+	flex_stream.produceFrame(frame);     
+}
+
+//CPU load 
+function cpuLoad() {
+	var totalIdle = 0;
+	var totalTick = 0;
+	var cpus      = os.cpus();
+
+	for(var i = 0, len = cpus.length; i < len; i++) {
+		var cpu = cpus[i];
+		for(type in cpu.times) {
+			totalTick += cpu.times[type];
+		}     
+		totalIdle += cpu.times.idle;
+	}
+	return {idle: totalIdle / cpus.length,  total: totalTick / cpus.length};
+}
+
+//Configure stream
+
+function init(){
+	flex_stream.setSize(8,1);
+	flex_stream.setProducerFramerate(30);
+	flex_stream.setConsumerFramerate(60);
+	flex_stream.setOnFrame(cpuMeter);
+}
+
+init();
+

examples/flex_stream/fireplace.js

@@ -0,0 +1,47 @@
+//Fireplace ambience based on flex_stream.js
+//For Windows, Linux and Mac
+
+const os          = require("os");
+const flex_stream = require("./flex_stream.js");
+
+module.exports = {
+		init: function() {
+			init(); 
+		}
+}
+
+var frame = flex_stream.newFrame();
+
+function fireplace() {   
+
+	for (i=0; i<flex_stream.getSize(); i++)
+	{
+		if (Math.random()<.5)
+		{
+			//Red to yellow spectrum
+			var r = Math.random()*230+25;
+			var g = r*Math.random()*.75;
+			frame[i*3+0] = Math.floor(r);  //R
+			frame[i*3+1] = Math.floor(g);  //G
+			frame[i*3+2] = 0;              //B
+		}
+
+
+	}
+	//Flickering flames
+	f = Math.random();
+	flex_stream.setProducerFramerate(f*10+2);
+	flex_stream.setAlpha(.05+(f/20));
+	flex_stream.produceFrame(frame);     
+}
+
+//Configure stream
+
+function init(){
+	flex_stream.setSize(8,1);
+	flex_stream.setProducerFramerate(15);
+	flex_stream.setConsumerFramerate(60);
+	flex_stream.setOnFrame(fireplace);
+}
+
+init();