pin pong

Eric Fernandez
1 parent 34f662087e
Showing 2 changed files with 28 additions and 3 deletions Show diff stats
index.js
package.json
@@ -5,11 +5,13 @@ module.exports =
   knex = require('knex')(config.bo),
   moment = require('moment');
  
-
 const client = new WebSocketClient(config.urlHO);
+var pingTimeout;
+var tiempoVivo = new Date();
  
 client.on('open', function open() {
   console.log('conection to socket ho is open');
+  tiempoVivo = new Date();
  
   client.send(JSON.stringify({ gln: config.gln, action: 'gln'}));
  
@@ -19,7 +21,7 @@ client.on(&#39;open&#39;, function open() {
  
     switch (message.action) {
       case 'getEntity':
-
+  
         data.getEntity(message).then(function(message) {
  
           client.send(JSON.stringify(message));
@@ -44,10 +46,32 @@ client.on(&#39;open&#39;, function open() {
         break;
     }
   });
+
+  heartbeat();
 });
  
 client.on('error', function(e) {
   console.log(e);
-})
+});
+
+client.on('ping', heartbeat);
+
+client.on('close', function clear() {
+  clearTimeout(pingTimeout);
+});
+
+function heartbeat() {
+  console.log('recibiendo ping');
+  console.log(`tiempo vivo desde ${tiempoVivo}`);
+
+  clearTimeout(pingTimeout);
  
+  // Use `WebSocket#terminate()`, which immediately destroys the connection,
+  // instead of `WebSocket#close()`, which waits for the close timer.
+  // Delay should be equal to the interval at which your server
+  // sends out pings plus a conservative assumption of the latency.
+    pingTimeout = setTimeout(() => {
+    client.terminate();
+  }, 10000 + 1000);
+}
 console.log('Sevice connected to wsServer: ' + config.urlHO);
@@ -11,6 +11,7 @@
   "dependencies": {
     "express": "^4.16.4",
     "knex": "^0.16.5",
+    "moment": "^2.24.0",
     "mssql": "^5.1.0",
     "ws": "^7.0.0"
   }
...	...	@@ -5,11 +5,13 @@ module.exports =
5	5	knex = require('knex')(config.bo),
6	6	moment = require('moment');
7	7
8		-
9	8	const client = new WebSocketClient(config.urlHO);
	9	+var pingTimeout;
	10	+var tiempoVivo = new Date();
10	11
11	12	client.on('open', function open() {
12	13	console.log('conection to socket ho is open');
	14	+ tiempoVivo = new Date();
13	15
14	16	client.send(JSON.stringify({ gln: config.gln, action: 'gln'}));
15	17
...	...	@@ -19,7 +21,7 @@ client.on('open', function open() {
19	21
20	22	switch (message.action) {
21	23	case 'getEntity':
22		-
	24	+
23	25	data.getEntity(message).then(function(message) {
24	26
25	27	client.send(JSON.stringify(message));
...	...	@@ -44,10 +46,32 @@ client.on('open', function open() {
44	46	break;
45	47	}
46	48	});
	49	+
	50	+ heartbeat();
47	51	});
48	52
49	53	client.on('error', function(e) {
50	54	console.log(e);
51		-})
	55	+});
	56	+
	57	+client.on('ping', heartbeat);
	58	+
	59	+client.on('close', function clear() {
	60	+ clearTimeout(pingTimeout);
	61	+});
	62	+
	63	+function heartbeat() {
	64	+ console.log('recibiendo ping');
	65	+ console.log(`tiempo vivo desde ${tiempoVivo}`);
	66	+
	67	+ clearTimeout(pingTimeout);
52	68
	69	+ // Use `WebSocket#terminate()`, which immediately destroys the connection,
	70	+ // instead of `WebSocket#close()`, which waits for the close timer.
	71	+ // Delay should be equal to the interval at which your server
	72	+ // sends out pings plus a conservative assumption of the latency.
	73	+ pingTimeout = setTimeout(() => {
	74	+ client.terminate();
	75	+ }, 10000 + 1000);
	76	+}
53	77	console.log('Sevice connected to wsServer: ' + config.urlHO);
...	...	@@ -11,6 +11,7 @@
11	11	"dependencies": {
12	12	"express": "^4.16.4",
13	13	"knex": "^0.16.5",
	14	+ "moment": "^2.24.0",
14	15	"mssql": "^5.1.0",
15	16	"ws": "^7.0.0"
16	17	}