heartbeat

Adhidarma Hadiwinoto
1 parent 567a7231c5
Showing 2 changed files with 29 additions and 0 deletions Side-by-side Diff
gateway/heartbeat.js
gateway/pull.js
@@ -0,0 +1,28 @@
+"use strict";
+
+const request = require('request');
+
+const config = require('../config');
+const logger = require('../logger');
+const matrix = require('../matrix');
+
+function sendHeartbeat() {
+    if (!config || !config.core_url) { return; }
+
+    const requestOptions =  {
+        url: config.core_url + '/heartbeat/gateway'
+        form: {
+            name: config.handler_name,
+            config: JSON.stringify(config),
+            matrix: JSON.stringify(matrix)
+        }
+    }
+
+    request.post(requestOptions);
+}
+
+sendHeartbeat();
+setInterval(
+    sendHeartbeat,
+    60 * 1000
+)
@@ -6,6 +6,7 @@ const config = require(&#39;../config&#39;);
 const logger = require('../logger');
 const matrix = require('../matrix');
 const controlPanel = require('../control-panel');
+const heartbeat = require('../heartbeat');
  
 var partner;
...	...	@@ -0,0 +1,28 @@
	1	+"use strict";
	2	+
	3	+const request = require('request');
	4	+
	5	+const config = require('../config');
	6	+const logger = require('../logger');
	7	+const matrix = require('../matrix');
	8	+
	9	+function sendHeartbeat() {
	10	+ if (!config \|\| !config.core_url) { return; }
	11	+
	12	+ const requestOptions = {
	13	+ url: config.core_url + '/heartbeat/gateway'
	14	+ form: {
	15	+ name: config.handler_name,
	16	+ config: JSON.stringify(config),
	17	+ matrix: JSON.stringify(matrix)
	18	+ }
	19	+ }
	20	+
	21	+ request.post(requestOptions);
	22	+}
	23	+
	24	+sendHeartbeat();
	25	+setInterval(
	26	+ sendHeartbeat,
	27	+ 60 * 1000
	28	+)
...	...	@@ -6,6 +6,7 @@ const config = require('../config');
6	6	const logger = require('../logger');
7	7	const matrix = require('../matrix');
8	8	const controlPanel = require('../control-panel');
	9	+const heartbeat = require('../heartbeat');
9	10
10	11	var partner;
11	12