use redis expire event to delete stored data immediately

rohankrishnadev · Nov 15, 2017 · 58840e2 · 58840e2
1 parent 490a1e8
commit 58840e2
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 0 deletions.
diff --git a/server/config.js b/server/config.js
@@ -14,6 +14,11 @@ const conf = convict({
     default: 'localhost',
     env: 'REDIS_HOST'
   },
+  redis_event_expire: {
+    format: Boolean,
+    default: false,
+    env: 'REDIS_EVENT_EXPIRE'
+  },
   listen_port: {
     format: 'port',
     default: 1443,

diff --git a/server/storage.js b/server/storage.js
@@ -61,6 +61,20 @@ if (config.s3_bucket) {
   };
 }
 
+if (config.redis_event_expire) {
+  const forceDelete = config.s3_bucket ? awsForceDelete : localForceDelete;
+  const redis_sub = redis_client.duplicate();
+  const subKey = '__keyevent@0__:expired';
+  redis_sub.psubscribe(subKey, function() {
+    log.info('Redis:', 'subscribed to expired key events');
+  });
+
+  redis_sub.on('pmessage', function(channel, message, id) {
+    log.info('RedisExpired:', id);
+    forceDelete(id);
+  });
+}
+
 function flushall() {
   redis_client.flushdb();
 }