-
Notifications
You must be signed in to change notification settings - Fork 0
/
node_server_start.js
35 lines (34 loc) · 1.09 KB
/
node_server_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
const mysql = require('mysql');
var fs = require('fs');
var shell = require('shelljs');
const connection = mysql.createConnection({
host: 'uopinstance.cisutjhhzfjh.us-west-2.rds.amazonaws.com',
user: 'uopAdmin123',
password: 'pandu123',
database: 'voterdb'
});
connection.connect((err) => {
if (err) throw err;
console.log('Connected!');
});
function nodeCreate(){
connection.query('SELECT * FROM event_details WHERE node_server=1', (err,rows) => {
if(err) throw err;
// console.log('Data received from Db:\n');
// console.log(rows);
for(var each = 0; each < rows.length; each++)
{
fs.createReadStream('nodesetup.js').pipe(fs.createWriteStream('nodesetup_'+rows[each]['event_id']+'.js'));
// console.log(rows[each]['event_id']);
shell.exec('pm2 start nodesetup_'+rows[each]['event_id']+'.js -- '+rows[each]['event_id'], function(code, output) {
console.log('Exit code:', code);
console.log('Program output:', output);
});
}
});
connection.query('update event_details set node_server=0', (err,rows) => {
if(err) throw err;
});
setTimeout(nodeCreate,5*1000);
}
nodeCreate();