Ignore expired

Adhidarma Hadiwinoto
1 parent a6ca097772
Showing 1 changed file with 19 additions and 1 deletions Side-by-side Diff
lib/apiserver/handler/on-received.js
+const moment = require('ts');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
  
@@ -7,11 +8,28 @@ const modems = require(&#39;../../modems&#39;);
 module.exports = (req, res) => {
     res.end('OK');
  
+    const {
+        msg, msisdn, smsc, ts,
+    } = req.query;
+
+    const sentTime = moment(ts, 'YYYY-MM-DD HH:mm:ss');
+    const messageAgeInSeconds = Math.round(Number(new Date() - sentTime) / 1000);
+    const maxAgeInSeconds = 300;
+
+    if (messageAgeInSeconds > maxAgeInSeconds) {
+        logger.warn('ON-RECEIVED: Got expired message from EVO-CP', {
+            qs: req.query,
+            messageAgeInSeconds,
+            maxAgeInSeconds,
+        });
+
+        return;
+    }
+
     logger.info('ON-RECEIVED: Got message from EVO-CP', {
         qs: req.query,
     });
  
-    const { msg, msisdn, smsc } = req.query;
     const modem = modems.modemsDictionary[smsc] || {};
  
     const doNotForwardToCore = (msisdn.search(/(\+)*62/) !== 0) || (msisdn.length <= 8);
	1	+const moment = require('ts');
1	2	const config = require('komodo-sdk/config');
2	3	const logger = require('komodo-sdk/logger');
3	4
...	...	@@ -7,11 +8,28 @@ const modems = require('../../modems');
7	8	module.exports = (req, res) => {
8	9	res.end('OK');
9	10
	11	+ const {
	12	+ msg, msisdn, smsc, ts,
	13	+ } = req.query;
	14	+
	15	+ const sentTime = moment(ts, 'YYYY-MM-DD HH:mm:ss');
	16	+ const messageAgeInSeconds = Math.round(Number(new Date() - sentTime) / 1000);
	17	+ const maxAgeInSeconds = 300;
	18	+
	19	+ if (messageAgeInSeconds > maxAgeInSeconds) {
	20	+ logger.warn('ON-RECEIVED: Got expired message from EVO-CP', {
	21	+ qs: req.query,
	22	+ messageAgeInSeconds,
	23	+ maxAgeInSeconds,
	24	+ });
	25	+
	26	+ return;
	27	+ }
	28	+
10	29	logger.info('ON-RECEIVED: Got message from EVO-CP', {
11	30	qs: req.query,
12	31	});
13	32
14		- const { msg, msisdn, smsc } = req.query;
15	33	const modem = modems.modemsDictionary[smsc] \|\| {};
16	34
17	35	const doNotForwardToCore = (msisdn.search(/(\+)*62/) !== 0) \|\| (msisdn.length <= 8);