-
Notifications
You must be signed in to change notification settings - Fork 0
/
arduino.js
54 lines (44 loc) · 1.13 KB
/
arduino.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
const SerialPort = require('serialport');
const EventEmitter = require('events');
class Arduino extends EventEmitter {
constructor(serialPort){
super();
this.port=new SerialPort(serialPort,{baudRate:9600},function(err){
if(err){
console.log("Error opening SerialPort");
}else{
console.log("Serial port is opened!");
}
});
this.port.on('readable',()=>{
const data = this.port.read().toString();
//console.log(`Arduino::readable:${data}:${JSON.stringify(data)}`);
if(data.startsWith('s:')){
this.emit('status',data);
}else if(data.startsWith('c:')){
this.emit('calibrate',data);
}else if(data.startsWith('PONG')){
this.emit('ping');
}else{
this.emit('pH',data);
}
});
this.send=function(msg){
if(!msg.endsWith('\r')) msg+='\r';
//console.log('Arduino::send:'+msg);
this.port.write(msg);
}
this.streamCount=0;
this.enableStream=function(){
if(this.streamCount<1)
this.send('read_data');
this.streamCount++;
}
this.disableStream=function(){
this.streamCount--;
if(this.streamCount<1)
this.send('stop_data');
}
}
}
module.exports={Arduino};