WebSocket / websocketHO

Authored by Eric Fernandez 2019-05-22 16:59:21 -0300

1 parent 55c7bcadb1

Exists in master

Showing 1 changed file with 1 additions and 1 deletions Show diff stats

webSocketServer/index.js

 module.exports = function() {
 const webSocketServer = require('ws').Server;
 var clients = [];
 var idsSolicitud = [];
 const objWs = {};
 objWs.wsServer = new webSocketServer({
   port: config.port
 });
 objWs.wsServer.on('connection', function connection(ws) {
   console.log('open socket server');
   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);
     }
   });
 });
 objWs.getEntidad = function(gln, tableName, where) {
   return new Promise(function(resolve, reject) {
     var client = clients.filter(function(client) {
       return client.gln == gln
     })[0];
     var idSolicitud = Math.round(Math.random() * 1000);
     var enviar = {
       action: 'getEntity',
       tableName: tableName,
       where: where || {},
       idSolicitud: idSolicitud
     }
     idsSolicitud.push(idSolicitud);
     client.ws.send(JSON.stringify(enviar));
     client.ws.on('message', function(message) {
       message = JSON.parse(message);
       if (idSolicitud == message.idSolicitud) {
         resolve(message.data);
       }
     });
   });
 }
 return objWs;
-}
+}