-
Notifications
You must be signed in to change notification settings - Fork 0
/
start.js
122 lines (107 loc) · 3.68 KB
/
start.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
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
var domainSocket = '/tmp/humix-sense-blinking';
var sensorName = 'humix-sense-blinking';
var natChannel = 'humix.sense.eyelid.command';
var workDir = '/home/liuch/workspace/humix/humix-sense/controls/humix-sense-blinking';
var pythonScript = workDir + '/blinking.py';
var GPIOPin = 26;
var processing = false;
var isClosed = true;
var net = require('net');
var fs = require('fs');
var ps = require('child_process');
var nats = require('nats').connect();//connect immediately
//unlink domainSocket anyway
try {
fs.unlinkSync(domainSocket);
} catch (e) {}
//the following server is only used for shutdown service
//once someone connects to the domain socket and close
//this service will shutdown
var server = net.createServer(function(conn) {
conn.on('end', function () {
nats.close();
fs.unlinkSync(domainSocket);
server.unref();
});
});
server.on('error', function (err) {
console.error('failed to start service,' + err);
nats.close();
fs.unlinkSync(domainSocket);
server.unref();
});
try {
server.listen(domainSocket, function() {
console.log('start to listen on ' + domainSocket);
});
} catch (e) {
console.error('failed to start service,' + err);
nats.close();
fs.unlinkSync(domainSocket);
server.unref();
}
var psOpt = {
'cwd' : workDir,
'stdio' : 'inherit'
// 'stdio' : ['inherit', 'ignore', 'ignore']
// 'stdio' : ['inherit', 'inherit', 'inherit']
};
nats.subscribe('humix.sense.eyelid.status.ping', function(request,replyto){
nats.publish(replyto, 'humix.sense.eyelid.status.pong');
})
//receive and process commands
nats.subscribe(natChannel, function(msg) {
console.error('Received a message: ' + msg);
processing = true;
var jsonObj = JSON.parse(msg);
var action = jsonObj.action;
try {
switch (action) {
case('blink'):
ps.execSync('sudo python ' + pythonScript + ' ' + GPIOPin + ' blink 2', { 'cwd' : workDir, 'stdio': 'inherit'} );
break;
case('open'):
ps.execSync('sudo python ' + pythonScript + ' ' + GPIOPin + ' open', { 'cwd' : workDir, 'stdio': 'inherit'} );
isClosed = false;
break;
case('close'):
ps.execSync('sudo python ' + pythonScript + ' ' + GPIOPin + ' close', { 'cwd' : workDir, 'stdio': 'inherit'} );
isClosed = true;
break;
case('half'):
ps.execSync('sudo python ' + pythonScript + ' ' + GPIOPin + ' half', { 'cwd' : workDir, 'stdio': 'inherit'});
isClosed = true;
break;
default:
break;
}
} catch (e) {
console.error('execution of command:' + msg + ' failed');
}
processing = false;
});
function getRandomInt(min, max) {
return Math.floor(Math.random() * (max - min)) + min;
}
function randomBlink() {
var nextRandom = getRandomInt(8, 12);
if ( processing || isClosed ) {
console.log('skipped random blink');
} else {
try {
ps.execSync('sudo python ' + pythonScript + ' ' + GPIOPin + ' blink 2', { 'cwd' : workDir, 'stdio': 'inherit'});
} catch (e) {
console.error('random blink failed' + e);
}
}
setTimeout(randomBlink, nextRandom*1000);
}
//ok be sure to close the eye and wait for the signal to open
try {
ps.execSync('sudo python ' + pythonScript + ' ' + GPIOPin + ' close', { 'cwd' : workDir, 'stdio': 'inherit'});
isClosed = true;
//still enable the random blink
setTimeout(randomBlink, getRandomInt(8, 12) * 1000);
} catch (e) {
console.error('initial open failed' + e);
}