WebSocket / websocketHO

Merge Request #43

← To merge requests efernandez/websocketho: master → master
Merged
Created by Eric Fernandez

Master(efernandez)

Assignee: Eric Fernandez
Milestone: None

Merged by Eric Fernandez

Commits (2)
1 participants
Showing 2 changed files   Show diff stats
rutas/comprobantes.js
Diff comments   Edit   View file @ 6849492
1 module.exports = router = express.Router(); 1 module.exports = router = express.Router();
2 2
3 router.get('/comprobantes/:gln*?', function(req, res) { 3 router.get('/comprobantes/:gln*?', function(req, res) {
4 4
5 var cabecera = knex('PMAEFACT_TEMP') 5 var cabecera = knex('PMAEFACT_TEMP')
6 .where(function(qb) { 6 .where(function(qb) {
7 if (req.params.gln) { 7 if (req.params.gln) {
8 qb.where({GLN: req.params.gln}); 8 qb.where({GLN: req.params.gln});
9 } 9 }
10 }) 10 })
11 .select('*'); 11 .select('*');
12 12
13 var cuerpo = knex('PMOVFACT_TEMP') 13 var cuerpo = knex('PMOVFACT_TEMP')
14 .where(function(qb) { 14 .where(function(qb) {
15 if (req.params.gln) { 15 if (req.params.gln) {
16 qb.where({GLN: req.params.gln}); 16 qb.where({GLN: req.params.gln});
17 } 17 }
18 }) 18 })
19 .select('*'); 19 .select('*');
20 20
21 Promise.all([cabecera, cuerpo]).then(function(data) { 21 Promise.all([cabecera, cuerpo]).then(function(data) {
22 22
23 var result = []; 23 var result = [];
24 data[0].forEach((cabecera) => { 24 data[0].forEach((cabecera) => {
25 25
26 let idCabecera = cabecera.TIP + cabecera.TCO + cabecera.SUC + cabecera.NCO; 26 let idCabecera = cabecera.TIP + cabecera.TCO + cabecera.SUC + cabecera.NCO;
27 27
28 var cuerpos = data[1].filter((cuerpo) => { 28 var cuerpos = data[1].filter((cuerpo) => {
29 let idCuerpo = cuerpo.TIP + cuerpo.TCO + cuerpo.SUC + cuerpo.NCO; 29 let idCuerpo = cuerpo.TIP + cuerpo.TCO + cuerpo.SUC + cuerpo.NCO;
30 return idCuerpo == idCabecera; 30 return idCuerpo == idCabecera;
31 }); 31 });
32 32
33 result.push({ 33 result.push({
34 cabecera: cabecera, 34 cabecera: cabecera,
35 cuerpo: cuerpos 35 cuerpo: cuerpos
36 }); 36 });
37 }); 37 });
38 38
39 res.status(200).send(result); 39 res.status(200).send(result);
40 }); 40 });
41 }); 41 });
42 42
43 router.post('/comprobante', function(req, res) { 43 router.post('/comprobante', function(req, res) {
44 44
45 // var recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)), 45 // var recadv = require('../recadv')(JSON.parse(JSON.stringify(req.body.cabecera)),
46 // JSON.parse(JSON.stringify(req.body.cuerpo))); 46 // JSON.parse(JSON.stringify(req.body.cuerpo)));
47 47
48 var guardar = wsServer.guardarComprobante(req.body, req.body.cabecera.GLN); 48 wsServer.guardarComprobante(req.body, req.body.cabecera.GLN).then(() => {
49 49
50 Promise.all([ 50 Promise.all([
51 // recadv,
52 guardar,
53 knex('PMAEFACT_TEMP').where({ 51 knex('PMAEFACT_TEMP').where({
54 TIP: req.body.cabecera.TIP, 52 TIP: req.body.cabecera.TIP,
55 TCO: req.body.cabecera.TCO, 53 TCO: req.body.cabecera.TCO,
56 SUC: req.body.cabecera.SUC, 54 SUC: req.body.cabecera.SUC,
57 NCO: req.body.cabecera.NCO, 55 NCO: req.body.cabecera.NCO,
58 COD: req.body.cabecera.COD 56 COD: req.body.cabecera.COD
59 }) 57 })
60 .del(), 58 .del(),
61 knex('PMOVFACT_TEMP').where({ 59 knex('PMOVFACT_TEMP').where({
62 TIP: req.body.cabecera.TIP, 60 TIP: req.body.cabecera.TIP,
63 TCO: req.body.cabecera.TCO, 61 TCO: req.body.cabecera.TCO,
64 SUC: req.body.cabecera.SUC, 62 SUC: req.body.cabecera.SUC,
65 NCO: req.body.cabecera.NCO 63 NCO: req.body.cabecera.NCO
66 }) 64 })
67 .del() 65 .del()
68 ]) 66 ])
69 .then(() => { 67 .then(() => {
70 res.status(200).send({data: 'Comprobante guardado con éxito'}); 68 res.status(200).send({data: 'Comprobante guardado con éxito'});
71 }) 69 })
72 .catch(err => { 70 .catch(err => {
73 console.log(err); 71 console.log(err);
74 console.log({data: 'error al guardar algo ruta comprobantes'}); 72 res.status(500).send(err);
75 res.status(500).send(err)
76 }); 73 });
74 })
75 .catch((err) => res.status(500).send(err));
77 76
webSocketServer/index.js
Diff comments   Edit   View file @ 6849492
1 module.exports = function() { 1 module.exports = function() {
2 2
3 const webSocketServer = require('ws').Server; 3 const webSocketServer = require('ws').Server;
4 var clients = []; 4 var clients = [];
5 5
6 const objWs = {}; 6 const objWs = {};
7 7
8 objWs.wsServer = new webSocketServer({ 8 objWs.wsServer = new webSocketServer({
9 port: config.port 9 port: config.port
10 }); 10 });
11 11
12 function noop() {}
13
14 function heartbeat() {
15 this.isAlive = true;
16 }
17
12 function noop() {} 18 objWs.wsServer.on('connection', function connection(ws) {
13 19
14 function heartbeat() { 20 console.log('open socket server');
21 ws.isAlive = true;
22 ws.on('pong', heartbeat);
15 this.isAlive = true; 23
16 } 24 ws.on('message', function incoming(message) {
17 25
18 objWs.wsServer.on('connection', function connection(ws) { 26 message = JSON.parse(message.toString('utf8'));
19 27
20 console.log('open socket server'); 28 switch (message.action) {
21 ws.isAlive = true; 29 case 'gln':
22 ws.on('pong', heartbeat); 30 clients.push({ws: ws, gln: message.gln});
23 31 break;
24 ws.on('message', function incoming(message) { 32 default:
25 33 // console.log(message.action);
26 message = JSON.parse(message.toString('utf8')); 34 }
27 35 });
28 switch (message.action) { 36 });
29 case 'gln': 37
38 const interval = setInterval(function ping() {
39 objWs.wsServer.clients.forEach(function each(ws) {
40 if (ws.isAlive === false) return ws.terminate();
41
42 ws.isAlive = false;
43 ws.ping(noop);
44 });
45 }, 10000);
46
30 clients.push({ws: ws, gln: message.gln}); 47 objWs.getEntidad = function(gln, tableName, where, queryString) {
31 break; 48
32 default: 49 return new Promise(function(resolve, reject) {
33 // console.log(message.action); 50
34 } 51 var client = clients.filter(function(client) {
35 }); 52 return client.gln == gln
36 }); 53 })[0];
37 54
38 const interval = setInterval(function ping() { 55 if (!client) {
39 objWs.wsServer.clients.forEach(function each(ws) { 56 reject('No se encuentra el webSocket client');
40 if (ws.isAlive === false) return ws.terminate(); 57 }
41 58
42 ws.isAlive = false; 59 var idSolicitud = Math.round(Math.random() * 1000);
43 ws.ping(noop); 60
44 }); 61 var enviar = {
45 }, 10000); 62 action: 'getEntity',
46 63 idSolicitud: idSolicitud
47 objWs.getEntidad = function(gln, tableName, where, queryString) { 64 };
48 65
49 return new Promise(function(resolve, reject) { 66 if (queryString) {
50 67
51 var client = clients.filter(function(client) { 68 enviar.queryString = queryString;
52 return client.gln == gln 69 } else {
53 })[0]; 70 enviar.tableName = tableName;
54 71 enviar.where = where || {};
55 if (!client) { 72 }
56 reject('No se encuentra el webSocket client'); 73
57 } 74 client.ws.send(JSON.stringify(enviar));
58 75
59 var idSolicitud = Math.round(Math.random() * 1000); 76 client.ws.on('message', function(message) {
60 77
61 var enviar = { 78 message = JSON.parse(message);
62 action: 'getEntity', 79
63 idSolicitud: idSolicitud 80 if (idSolicitud == message.idSolicitud) {
64 }; 81
65 82 resolve(message.data);
66 if (queryString) { 83 }
67 84
68 enviar.queryString = queryString; 85 });
69 } else { 86 });
70 enviar.tableName = tableName; 87 }
71 enviar.where = where || {}; 88
72 } 89 objWs.getClientGln = function(gln) {
73 90 return clients.filter(function(client) {
74 client.ws.send(JSON.stringify(enviar)); 91 return client.gln = gln;
75 92 });
76 client.ws.on('message', function(message) { 93 }
77 94
78 message = JSON.parse(message); 95 objWs.guardarComprobante = function (cuerpo, gln) {
79 96
80 if (idSolicitud == message.idSolicitud) { 97 return new Promise((resolve, reject) => {
81 98
82 resolve(message.data); 99 var client = clients.filter(function(client) {
83 } 100 return client.gln == gln
84 101 })[0];
85 }); 102
86 }); 103 if (!client) {
87 } 104 reject('No se encuentra el webSocket client');
88 105 console.log('No se encuentra el webSocket client');
89 objWs.getClientGln = function(gln) { 106 return;
90 return clients.filter(function(client) { 107 }
91 return client.gln = gln; 108
92 }); 109 var idSolicitud = Math.round(Math.random() * 1000);
93 } 110
94 111 var enviar = {
95 objWs.guardarComprobante = function (cuerpo, gln) { 112 action: 'comprobante',
96 113 req: cuerpo,
97 return new Promise((resolve, reject) => { 114 idSolicitud: idSolicitud
98 115 };
99 var client = clients.filter(function(client) { 116
100 return client.gln == gln 117 console.log(`enviando comprobante a cliente`)
101 })[0]; 118 console.log(cuerpo.cabecera);
102 119
103 if (!client) { 120 client.ws.send(JSON.stringify(enviar));
104 reject('No se encuentra el webSocket client'); 121
105 console.log('No se encuentra el webSocket client'); 122 client.ws.on('message', function(message) {
106 return; 123
107 } 124 message = JSON.parse(message);
108 125 console.log(message);
109 var idSolicitud = Math.round(Math.random() * 1000); 126 if (idSolicitud == message.idSolicitud) {
110 127
111 var enviar = { 128 if (message.ok) {
112 action: 'comprobante', 129 console.log('resuelve comprobante en estación')
113 req: cuerpo, 130 resolve();
114 idSolicitud: idSolicitud 131 } else {
115 }; 132
116 133 reject();
117 console.log(`enviando comprobante a cliente`) 134 }
118 console.log(cuerpo.cabecera); 135 }
119 136
120 client.ws.send(JSON.stringify(enviar)); 137 });
121 138
122 client.ws.on('message', function(message) { 139 });
123 140 }
124 message = JSON.parse(message); 141
125 console.log(message); 142 return objWs;
126 if (idSolicitud == message.idSolicitud) { 143 }
127 144