From 43a175e7100589cba393c335b5289b151982350f Mon Sep 17 00:00:00 2001
From: Wu Cheng-Han <jacky_cute0808@hotmail.com>
Date: Thu, 24 Sep 2015 11:38:55 +0800
Subject: [PATCH] Added cleaner in realtime.js, to clean up users which aren't
 in any rooms in a interval

---
 lib/realtime.js | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/lib/realtime.js b/lib/realtime.js
index b5a3b1828..1e1f0107a 100644
--- a/lib/realtime.js
+++ b/lib/realtime.js
@@ -80,6 +80,7 @@ function emitCheck(note) {
 //actions
 var users = {};
 var notes = {};
+//update when the note is dirty
 var updater = setInterval(function () {
     async.each(Object.keys(notes), function (key, callback) {
         var note = notes[key];
@@ -102,6 +103,21 @@ var updater = setInterval(function () {
         if (err) return logger.error('updater error', err);
     });
 }, 1000);
+//clean when user not in any rooms
+var cleaner = setInterval(function () {
+    async.each(Object.keys(users), function (key, callback) {
+        var socket = realtime.io.sockets.connected[key];
+        if (!socket || !socket.rooms || socket.rooms.length <= 0) {
+            if (config.debug)
+                logger.info("cleaner found redundant user: " + key);
+            disconnectSocketQueue.push(socket);
+            disconnect(socket);
+        }
+        callback();
+    }, function (err) {
+        if (err) return logger.error('cleaner error', err);
+    });
+}, 60000);
 
 function getStatus(callback) {
     db.countFromDB(function (err, data) {