ignoring duplicate message

Adhidarma Hadiwinoto
1 parent 6c639636fe
Showing 1 changed file with 9 additions and 1 deletions Side-by-side Diff
index.js
@@ -11,7 +11,7 @@ var ini = require(&#39;ini&#39;);
 var config = ini.parse(fs.readFileSync(__dirname + '/config.ini', 'utf-8'));
  
 var keepalive_interval = 2 * 60 * 1000;
-
+var last_message_hash = '';
 var log_level = 'info';
  
 if (config.globals.log_level) {
@@ -56,6 +56,14 @@ function onPm(data) {
     logger.verbose('onPM()', {data: data});
  
     var message = striptags(data.message);
+    
+    var message_hash = data.sender + ': ' + data.message;
+    if (message_hash == last_message_hash) {
+        logger.verbose('Ignoring duplicate message');
+        return;
+    }
+    last_message_hash = message_hash;
+    
     var greeting_prefix = "Pesan anda telah diterima dan akan segera diproses:";
     if (config.globals.greeting_prefix) {
         greeting_prefix = config.globals.greeting_prefix;
...	...	@@ -11,7 +11,7 @@ var ini = require('ini');
11	11	var config = ini.parse(fs.readFileSync(__dirname + '/config.ini', 'utf-8'));
12	12
13	13	var keepalive_interval = 2 * 60 * 1000;
14		-
	14	+var last_message_hash = '';
15	15	var log_level = 'info';
16	16
17	17	if (config.globals.log_level) {
...	...	@@ -56,6 +56,14 @@ function onPm(data) {
56	56	logger.verbose('onPM()', {data: data});
57	57
58	58	var message = striptags(data.message);
	59	+
	60	+ var message_hash = data.sender + ': ' + data.message;
	61	+ if (message_hash == last_message_hash) {
	62	+ logger.verbose('Ignoring duplicate message');
	63	+ return;
	64	+ }
	65	+ last_message_hash = message_hash;
	66	+
59	67	var greeting_prefix = "Pesan anda telah diterima dan akan segera diproses:";
60	68	if (config.globals.greeting_prefix) {
61	69	greeting_prefix = config.globals.greeting_prefix;