Beagle Bone Green and Grove IoT Starter Kit Powered by AWS

var exec = require('child_process').exec; 
var value = 0;
 
exports.initpins = function(){
	exec("echo 3 > /sys/class/gpio/export",function(error,stdout,stderr){
		if(error) 
        		console.info('stderr : '+stderr);
	});
	exec("echo out > /sys/class/gpio/gpio3/direction",function(error,stdout,stderr){
                if(error) 
                        console.info('stderr : '+stderr);
        });
 
	exec("echo 2 > /sys/class/gpio/export",function(error,stdout,stderr){
                if(error) 
                        console.info('stderr : '+stderr);
        });
 
	exec("echo out > /sys/class/gpio/gpio2/direction",function(error,stdout,stderr){
                if(error) 
                        console.info('stderr : '+stderr);
        });
 
}
digitalwrite = function(pin,state){
	exec("echo "+state.toString()+" > /sys/class/gpio/gpio"+pin.toString()+"/value",
		function(error,stdout,stderr){
                	if(error) 
                        	console.log('stderr : '+stderr);
        });
 
}
sleep = function(sleepTime) {
    for(var start = +new Date; +new Date - start <= sleepTime; ) { }
}
clk = function(){
		digitalwrite(2,0);
		sleep(2);
                digitalwrite(2,1);
		sleep(2);
}
sendByte = function(b){
	for(var i = 0 ; i < 8 ;i++){
		if((b & 0x80) != 0)
			digitalwrite(3,1);
		else
			digitalwrite(3,0);
		clk();
		b = b << 1; 
	}
}
setColor = function(red,green,blue){
	var prefix = 0xc0;
	if((blue & 0x80) == 0)
		prefix |= 0x20;
	if((blue & 0x40) == 0)
		prefix |= 0x10;
	if((green & 0x80) == 0)
		prefix |= 0x08;
	if((green & 0x40) == 0)
		prefix |= 0x04;
	if((red & 0x80) == 0)
		prefix |= 0x02;
	if((red & 0x40) == 0)
		prefix |= 0x01;
	sendByte(prefix);
	sendByte(blue);
	sendByte(green);
	sendByte(red);
}
exports.setColorRGB = function(led,red,green,blue){
	sendByte(0x00);
	sendByte(0x00);
	sendByte(0x00);
	sendByte(0x00);
	for(var i = 0; i < led; i++ ){
		setColor(red,green,blue);
	}
	sendByte(0x00);
	sendByte(0x00);
	sendByte(0x00);
	sendByte(0x00);
	console.log("set rgb");
}
test = function(){
	initpins();
    while(1){
	console.log("loop");
        setColorRGB(1, 255, 0, 0)
        setColorRGB(1, 0, 255, 0)
        setColorRGB(1, 0, 0, 255)
        setColorRGB(1, 0, 255, 255)
        setColorRGB(1, 255, 0, 255)
        setColorRGB(1, 255, 255, 0)
        setColorRGB(1, 255, 255, 255)
	}
}

var awsIot = require('..');
var net = require('net');
var rgbled = require('./rgbled.js');
var exec = require('child_process').exec;	
var myThingName = 'temperature';
var thingShadows = awsIot.thingShadow({
   keyPath: '/var/lib/cloud9/examples/aws-iot-device-sdk-js/awsCerts/private.pem.key',
  certPath: '/var/lib/cloud9/examples/aws-iot-device-sdk-js/awsCerts/certificate.pem.crt',
    caPath: '/var/lib/cloud9/examples/aws-iot-device-sdk-js/awsCerts/root-CA.crt',
  clientId: 'myAwsClientId',
    region: 'us-west-2'
});
var HOST = '127.0.0.1';
var PORT = 7000;
var temperature = 25;
var red = 0;
var green = 0;
var blue = 0;
// Create a server instance, and chain the listen function to it
net.createServer(function(socket) {
    console.log('CONNECTED: ' + socket.remoteAddress +':'+ socket.remotePort);
            // Add a 'data' event handler to this instance of socket
    socket.on('data', function(data) {
        console.log('DATA ' + socket.remoteAddress + ': ' + data);
        temperature = data.toString().substr(0,5);
        socket.write('This is your request: "' + data + '"');
    });
    // Add a 'close' event handler to this instance of socket
    socket.on('close', function(data) {
        console.log('Socket connection closed... ');
    });
}).listen(PORT, HOST);
//
// Thing shadow state
//
var rgbLedLampState = {"state":{"desired":{"red":187,"green":114,"blue":222,value:25}}};
 
//
// Client token value returned from thingShadows.update() operation
//
var clientTokenUpdate;
 
thingShadows.on('connect', function() {
//
// After connecting to the AWS IoT platform, register interest in the
// Thing Shadow named 'RGBLedLamp'.
//
    thingShadows.register( myThingName );
//
// 2 seconds after registering, update the Thing Shadow named 
// 'RGBLedLamp' with the latest device state and save the clientToken
// so that we can correlate it with status or timeout events.
//
// Note that the delay is not required for subsequent updates; only
// the first update after a Thing Shadow registration using default
// parameters requires a delay.  See API documentation for the update
// method for more details.
//
	exec('python python_sensor.py',function(error,stdout,stderr){
    		if(stdout.length >1){
        		console.log('you offer args:',stdout);
    		}else {
        		console.log('you don\'t offer args');
    		}
    		if(error) {
        		console.info('stderr : '+stderr);
    		}});
	rgbled.initpins();
    setTimeout( function() {
       clientTokenUpdate = thingShadows.update(myThingName, rgbLedLampState );
       }, 2000 );
    });
setInterval(function(){
        new_data = {"state":{"desired":{"red":187,"green":114,"blue":222,value:temperature.toString()}}};
        //new_data = {"state":{"desired":{"value":temperature.toString()}}};
        console.log(new_data);
       clientTokenUpdate = thingShadows.update(myThingName, new_data )
},2000);
thingShadows.on('status', 
    function(thingName, stat, clientToken, stateObject) {
       console.log('received '+stat+' on '+thingName+': '+
                   JSON.stringify(stateObject));
    });
 
thingShadows.on('delta', 
    function(thingName, stateObject) {
       console.log('received delta '+' on '+thingName+': '+
                   JSON.stringify(stateObject));
        //console.log(stateObject["state"]);
	if(stateObject["state"]["red"]		!= red ||
	   stateObject["state"]["green"] 	!= green||
	  stateObject["state"]["blue"]   	!= blue)
        	rgbled.setColorRGB(1,stateObject["state"]["red"],
                        stateObject["state"]["green"],
                        stateObject["state"]["blue"]);
 
	red = stateObject["state"]["red"];
	green = stateObject["state"]["green"];
	blue = stateObject["state"]["blue"];
    });
 
thingShadows.on('timeout',
    function(thingName, clientToken) {
       console.log('received timeout '+' on '+thingName+': '+
                   clientToken);
    });