config.max_message_age_in_secs

Adhidarma Hadiwinoto
1 parent 2328b1e513
Showing 1 changed file with 7 additions and 3 deletions Side-by-side Diff
lib/apiserver/handler/on-received.js
+const DEFAULT_MAX_MESSAGE_AGE_IN_SECS = 300;
+
 const moment = require('moment');
 const config = require('komodo-sdk/config');
 const logger = require('komodo-sdk/logger');
@@ -14,13 +16,15 @@ module.exports = (req, res) =&gt; {
  
     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) {
+    const maxMessageAgeInSeconds = config.max_message_age_in_secs
+        || DEFAULT_MAX_MESSAGE_AGE_IN_SECS;
+
+    if (messageAgeInSeconds > maxMessageAgeInSeconds) {
         logger.warn('ON-RECEIVED: Got expired message from EVO-CP', {
             qs: req.query,
             messageAgeInSeconds,
-            maxAgeInSeconds,
+            maxMessageAgeInSeconds,
         });
  
         return;
	1	+const DEFAULT_MAX_MESSAGE_AGE_IN_SECS = 300;
	2	+
1	3	const moment = require('moment');
2	4	const config = require('komodo-sdk/config');
3	5	const logger = require('komodo-sdk/logger');
...	...	@@ -14,13 +16,15 @@ module.exports = (req, res) => {
14	16
15	17	const sentTime = moment(ts, 'YYYY-MM-DD HH:mm:ss');
16	18	const messageAgeInSeconds = Math.round(Number(new Date() - sentTime) / 1000);
17		- const maxAgeInSeconds = 300;
18	19
19		- if (messageAgeInSeconds > maxAgeInSeconds) {
	20	+ const maxMessageAgeInSeconds = config.max_message_age_in_secs
	21	+ \|\| DEFAULT_MAX_MESSAGE_AGE_IN_SECS;
	22	+
	23	+ if (messageAgeInSeconds > maxMessageAgeInSeconds) {
20	24	logger.warn('ON-RECEIVED: Got expired message from EVO-CP', {
21	25	qs: req.query,
22	26	messageAgeInSeconds,
23		- maxAgeInSeconds,
	27	+ maxMessageAgeInSeconds,
24	28	});
25	29
26	30	return;