WebSocket / websocketHO

Commit c6822da905f842cc0e72289f38dbab1199b2ac62

Authored by Eric Fernandez 2019-08-26 11:45:08 -0300

Exists in master

Merge branch 'master' into 'master'

Master(efernandez)

See merge request !43

Showing 2 changed files Show diff stats

rutas/comprobantes.js

Diff comments View file @ c6822da

 module.exports = router = express.Router();
 router.get('/comprobantes/:gln*?', function(req, res) {
   var cabecera = knex('PMAEFACT_TEMP')
     .where(function(qb) {
       if (req.params.gln) {
         qb.where({GLN: req.params.gln});
       }
     })
     .select('*');
   var cuerpo = knex('PMOVFACT_TEMP')
     .where(function(qb) {
       if (req.params.gln) {
         qb.where({GLN: req.params.gln});
       }
     })
     .select('*');
     Promise.all([cabecera, cuerpo]).then(function(data) {
       var result = [];
       data[0].forEach((cabecera) => {
         let idCabecera = cabecera.TIP + cabecera.TCO + cabecera.SUC + cabecera.NCO;
         var cuerpos = data[1].filter((cuerpo) => {
           let idCuerpo = cuerpo.TIP + cuerpo.TCO + cuerpo.SUC + cuerpo.NCO;
           return idCuerpo == idCabecera;
         });
         result.push({
           cabecera: cabecera,
           cuerpo: cuerpos
         });
       });
       res.status(200).send(result);
   });
 });
 router.post('/comprobante', function(req, res) {
   // var recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)),
   //   JSON.parse(JSON.stringify(req.body.cuerpo)));
-  var guardar = wsServer.guardarComprobante(req.body, req.body.cabecera.GLN);
+  wsServer.guardarComprobante(req.body, req.body.cabecera.GLN).then(() => {
-  Promise.all([
+    Promise.all([
-      // recadv,
-      guardar,
       knex('PMAEFACT_TEMP').where({
         TIP: req.body.cabecera.TIP,
         TCO: req.body.cabecera.TCO,
         SUC: req.body.cabecera.SUC,
         NCO: req.body.cabecera.NCO,
         COD: req.body.cabecera.COD
       })
       .del(),
       knex('PMOVFACT_TEMP').where({
         TIP: req.body.cabecera.TIP,
         TCO: req.body.cabecera.TCO,
         SUC: req.body.cabecera.SUC,
         NCO: req.body.cabecera.NCO
       })
       .del()
     ])
     .then(() => {
       res.status(200).send({data: 'Comprobante guardado con éxito'});
     })
     .catch(err => {
       console.log(err);
-      console.log({data: 'error al guardar algo ruta comprobantes'});
+      res.status(500).send(err);
-      res.status(500).send(err)
     });
+  })
+  .catch((err) => res.status(500).send(err));

webSocketServer/index.js

Diff comments View file @ c6822da

 module.exports = function() {
   const webSocketServer = require('ws').Server;
   var clients = [];
   const objWs = {};
   objWs.wsServer = new webSocketServer({
     port: config.port
   });
+  function noop() {}
+  function heartbeat() {
+    this.isAlive = true;
+  }
   objWs.wsServer.on('connection', function connection(ws) {
     console.log('open socket server');
+    ws.isAlive = true;
+    ws.on('pong', heartbeat);
     ws.on('message', function incoming(message) {
       message = JSON.parse(message.toString('utf8'));
       switch (message.action) {
         case 'gln':
           clients.push({ws: ws, gln: message.gln});
           break;
         default:
           // console.log(message.action);
       }
     });
   });
+  const interval = setInterval(function ping() {
+    objWs.wsServer.clients.forEach(function each(ws) {
+      if (ws.isAlive === false) return ws.terminate();
+      ws.isAlive = false;
+      ws.ping(noop);
+    });
+  }, 10000);
   objWs.getEntidad = function(gln, tableName, where, queryString) {
     return new Promise(function(resolve, reject) {
       var client = clients.filter(function(client) {
         return client.gln == gln
       })[0];
       if (!client) {
         reject('No se encuentra el webSocket client');
       }
       var idSolicitud = Math.round(Math.random() * 1000);
       var enviar = {
         action: 'getEntity',
         idSolicitud: idSolicitud
       };
       if (queryString) {
         enviar.queryString = queryString;
       } else {
         enviar.tableName = tableName;
         enviar.where = where || {};
       }
       client.ws.send(JSON.stringify(enviar));
       client.ws.on('message', function(message) {
         message = JSON.parse(message);
         if (idSolicitud == message.idSolicitud) {
           resolve(message.data);
         }
       });
     });
   }
   objWs.getClientGln = function(gln) {
     return clients.filter(function(client) {
       return client.gln = gln;
     });
   }
   objWs.guardarComprobante = function (cuerpo, gln) {
     return new Promise((resolve, reject) => {
       var client = clients.filter(function(client) {
         return client.gln == gln
       })[0];
       if (!client) {
         reject('No se encuentra el webSocket client');
         console.log('No se encuentra el webSocket client');
         return;
       }
       var idSolicitud = Math.round(Math.random() * 1000);
       var enviar = {
         action: 'comprobante',
         req: cuerpo,
         idSolicitud: idSolicitud
       };
       console.log(`enviando comprobante a cliente`)
       console.log(cuerpo.cabecera);
       client.ws.send(JSON.stringify(enviar));
       client.ws.on('message', function(message) {
         message = JSON.parse(message);
         console.log(message);
         if (idSolicitud == message.idSolicitud) {
           if (message.ok) {
             console.log('resuelve comprobante en estación')
             resolve();
           } else {
             reject();
           }
         }
       });
     });
   }
   return objWs;
 }