Chamadas Painel - Node.JS app.js

app.js

// CONFIG PACKAGES

var express = require('express');
var app = express.createServer();
var socket = require('socket.io');
var pg      = require('pg');

app.configure(function(){
  app.use(express.static(__dirname + '/'));
});
// CONFIG PORT
var server  = app.listen(3000);
// CONFIG LISTEN
var io      = socket.listen(server);

//CONFIG DB
var conString = "tcp://usuario:senha@servidor/banco";
var client = new pg.Client(conString);
client.connect();

io.sockets.on('connection', function(socket) {

    // PEGA O HISTORICO E ENVIA PARA O PAINEL
    socket.on('send_message', function(data_historico) {
      console.log('SELECT * FROM (SELECT DISTINCT on (num_senha) * FROM painel_senha) painel_senha WHERE id_uni = '+data_historico.message+' ORDER BY contador DESC LIMIT 5 OFFSET 1');      
      var sql = 'SELECT * FROM (SELECT DISTINCT on (num_senha) * FROM painel_senha) painel_senha WHERE id_uni = '+data_historico.message+' ORDER BY contador DESC LIMIT 5 OFFSET 1 ';
      var query = client.query(sql);
      client.query(sql, function(err, result) {
          data_historico.message = result;
          io.sockets.emit('get_message_historico', data_historico);
      });
    
    });


    // PEGA SENHA E ENVIA PARA O PAINEL
    socket.on('send_message', function(data_senha) {
      var sql_senha = 'SELECT DISTINCT contador, id_uni, id_serv, num_senha, sig_senha, msg_senha, nm_local, num_guiche FROM painel_senha ORDER BY contador desc LIMIT 1 ';
      var query_senha = client.query(sql_senha);

      query_senha.on('row', function(linha) {
        data_senha.message = linha;
        io.sockets.emit('get_message_senha', data_senha);
      });
    });
});