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
|
var io = require('socket.io').listen(app);
var iob = require('socket.io');
var AsteriskAmi = require('asterisk-ami');
var express= require('express');
var http=require('http');
var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var ami = new AsteriskAmi( { port : '5038', host: '127.0.0.1', username: 'test', password: 'test' } );
var pg = require("pg")
socket.on('connection', function(client){
console.log('Le client s\'est connecté au serveur');
socketnavigateur = client; //socketnavigateur est une variable global pour l'envoi des données temps réel.
var connectionString = "pg://postgres:password@localhost:5432/test";
var conn = new pg.Client(connectionString);
conn.connect();
var selectQuery = "SELECT * FROM items";
conn.query(selectQuery, function select(error, rows, fields){
if(error){
console.log(error);
conn.end();
return;
}
//if(rows.length > 0){
// var Result = rows[0];
// client.send('id: ' + Result['Id_depassement']);
// client.send('Date : ' + Result['Date_Dep']);
// client.send('Heure : '+ Result['Heure_Dep']);
// client.send('Puissance: ' + Result['P_reactive']);
//} else{
// console.log(error);
//}
});
//Listener de message
client.on('message', function(event){
console.log('Réception du message du client =',event);
});
client.on('disconnect',function(){
console.log('Le client s\'est déconnecté !');
});
});
app.get('/', function(req, res){
//send the index.html file for all requests
res.sendFile(__dirname + '/index.html');
});
http.listen(3001, function(){
console.log('listening on *:3001');
});
ami.on('ami_data', function(data){
console.log('AMI DATA', data);
io.sockets.emit('ami_data', data);
});
ami.connect(function(response){
console.log('connected to the AMI');
setInterval( function() {
ami.send({action: ''});
}, 10000);
});
process.on('SIGINT', function () {
ami.disconnect();
process.exit(0);
}); |
Partager