init file commit

Author: markmachine

.gitignore

@@ -0,0 +1 @@
+node_modules/

package.json

@@ -0,0 +1,19 @@
+{
+  "name": "arduino",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "bufferutil": "1.2.1",
+    "onoff": "^1.0.3",
+    "plotly": "^1.0.5",
+    "serialport": "^2.0.5",
+    "utf-8-validate": "1.2.1",
+    "ws": "1.1.1"
+  }
+}

sensors.js

@@ -0,0 +1,112 @@
+var GPIO = require('onoff').Gpio;
+var serialport = require('serialport'),
+    plotly = require('plotly')('revmecha','cyuheqx155'),
+    token = '786yfy9ilv';
+
+var pir_sensor = new GPIO(17, 'in', 'both');
+var audio_sensor = new GPIO(27, 'in', 'both');
+
+console.log("running...");
+function exit() {
+  pir_sensor.unexport();
+  console.log("exiting.");
+  audio_sensor.unexport();
+  process.exit();
+}
+
+
+
+
+var portName = '/dev/dev/ttyACM0';
+var sp = new serialport.SerialPort(portName,{
+    baudRate: 9600,
+    dataBits: 8,
+    parity: 'none',
+    stopBits: 1,
+    flowControl: false,
+    parser: serialport.parsers.readline("\r\n")
+});
+
+// helper function to get a nicely formatted date string
+function getDateString() {
+    var time = new Date().getTime();
+    // 32400000 is (GMT+9 Japan)
+    // for your timezone just multiply +/-GMT by 36000000
+    var datestr = new Date(time +32400000).toISOString().replace(/T/, ' ').replace(/Z/, '');
+    return datestr;
+}
+
+var initdata = [{x:[], y:[], stream:{token:token, maxpoints: 500}}];
+var initlayout = {fileopt : "extend", filename : "sensor-test"};
+
+var stream;
+
+function streamData(input) {
+  var streamObject = JSON.stringify({ x : getDateString(), y : input });
+  console.log(streamObject);
+  stream.write(streamObject+'\n');
+}
+
+plotly.plot(initdata, initlayout, function (err, msg) {
+    if (err) return console.log(err)
+
+    console.log(msg);
+    stream = plotly.stream(token, function (err, res) {
+        console.log(err, res);
+    });
+
+    sp.on('data', function(input) {
+        if(isNaN(input) || input > 1023) return;
+
+        streamData(input);
+
+        // var streamObject = JSON.stringify({ x : getDateString(), y : input });
+        // console.log(streamObject);
+        // stream.write(streamObject+'\n');
+    });
+});
+
+
+// define the callback function
+function pirState(err, state) {
+
+  if (err) {
+    console.log("err: " + err);
+    throw err;
+  }
+  if(state == 1) {
+    // turn LED on
+    console.log("PIR detected");
+    streamData(state);
+    //led1.writeSync(1);
+  } else {
+    // turn LED off
+    //console.log("PIR off");
+    //led1.writeSync(0);
+  }
+}
+function audioState(err, state) {
+
+  if (err) {
+    console.log("err: " + err);
+    throw err;
+  }
+  if(state == 1) {
+    // turn LED on
+    console.log("audio detected");
+    //elapsedTime();
+    streamData(state);
+    //led2.writeSync(1);
+  } else {
+    // turn LED off
+    //console.log("audio off");
+    //led2.writeSync(0);
+  }
+}
+
+// pass the callback function to the
+// as the first argument to watch()
+pir_sensor.watch(pirState);
+audio_sensor.watch(audioState);
+process.on('SIGINT', exit);
+

server.js

@@ -0,0 +1,25 @@
+
+var serialport = require('serialport');
+var arduino = {};
+
+arduino.connect = function (e) {
+        var portName = '/dev/ttyACM0';
+        var sp = new serialport.SerialPort(portName, {
+            baudRate: 115200, //9600,
+            dataBits: 8,
+            parity: 'none',
+            stopBits: 1,
+            flowControl: false,
+            parser: serialport.parsers.readline("\r\n")
+        });
+
+        sp.on('data', function(input) {
+		
+		var ttype = input.substr(0,1);
+            	var value = input.substr(1);
+		
+		console.log("input", input);
+	});
+}
+
+module.exports = arduino;

server1.js

@@ -0,0 +1,15 @@
+var serialport = require('serialport');
+var portName = '/dev/ttyACM0';
+var sp = new serialport.SerialPort(portName, {
+    baudRate: 9600,
+    dataBits: 8,
+    parity: 'none',
+    stopBits: 1,
+    flowControl: false,
+    parser: serialport.parsers.readline("\r\n")
+});
+
+sp.on('data', function(input) {
+    console.log(input);
+});
+

server2.js

@@ -0,0 +1,43 @@
+var serialport = require('serialport'),
+    plotly = require('plotly')('revmecha','cyuheqx155'),
+    token = '786yfy9ilv';
+
+var portName = '/dev/ttyACM0';
+var sp = new serialport.SerialPort(portName,{
+    baudRate: 9600,
+    dataBits: 8,
+    parity: 'none',
+    stopBits: 1,
+    flowControl: false,
+    parser: serialport.parsers.readline("\r\n")
+});
+
+// helper function to get a nicely formatted date string
+function getDateString() {
+    var time = new Date().getTime();
+    // 32400000 is (GMT+9 Japan)
+    // for your timezone just multiply +/-GMT by 36000000
+    var datestr = new Date(time +32400000).toISOString().replace(/T/, ' ').replace(/Z/, '');
+    return datestr;
+}
+
+var initdata = [{x:[], y:[], stream:{token:token, maxpoints: 500}}];
+var initlayout = {fileopt : "extend", filename : "sensor-test"};
+
+plotly.plot(initdata, initlayout, function (err, msg) {
+    if (err) return console.log(err)
+
+    console.log(msg);
+    var stream = plotly.stream(token, function (err, res) {
+        console.log(err, res);
+    });
+
+    sp.on('data', function(input) {
+        if(isNaN(input) || input > 1023) return;
+
+    var streamObject = JSON.stringify({ x : getDateString(), y : input });
+    console.log(streamObject);
+    stream.write(streamObject+'\n');
+    });
+});
+

server_stub.js

@@ -0,0 +1,14 @@
+var serialport = require('serialport');
+var portName = '/dev/ttyACM0';
+var sp = new serialport.SerialPort(portName, {
+    baudRate: 115200,//9600,
+    dataBits: 8,
+    parity: 'none',
+    stopBits: 1,
+    flowControl: false,
+    parser: serialport.parsers.readline("\r\n")
+});
+
+sp.on('data', function(input) {
+    console.log(input);
+});

server_stub.js.save

@@ -0,0 +1,25 @@
+var serialport = require('serialport');
+var WebSocket = require('ws')
+  , ws = new WebSocket('ws://www.host.com/path');
+ws.on('open', function() {
+    ws.send('something');
+});
+ws.on('message', function(message) {
+    console.log('received: %s', message);
+});
+
+
+
+var portName = '/dev/ttyACM0';
+var sp = new serialport.SerialPort(portName, {
+    baudRate: 115200,//9600,
+    dataBits: 8,
+    parity: 'none',
+    stopBits: 1,
+    flowControl: false,
+    parser: serialport.parsers.readline("\r\n")
+});
+
+sp.on('data', function(input) {
+    console.log(input);
+});