Expire values in RedisCacheAdapter

Author: TylerBrock

src/Adapters/Cache/RedisCacheAdapter.js

@@ -1,6 +1,8 @@
 import redis from 'redis';
 import logger from '../../logger';
 
+const DEFAULT_REDIS_TTL = 30 * 1000; // 30 seconds
+
 function debug() {
   logger.debug.apply(logger, ['RedisCacheAdapter', ...arguments]);
 }
@@ -29,11 +31,14 @@ export class RedisCacheAdapter {
   }
 
   put(key, value, ttl) {
+    if (!ttl || isNaN(ttl)) {
+      ttl = DEFAULT_CACHE_TTL;
+    }
     value = JSON.stringify(value);
     debug('put', key, value, ttl);
     this.p = this.p.then(() => {
       return new Promise((resolve, _) => {
-        this.client.set(key, value, function(err, res) {
+        this.client.psetex(key, ttl, value, function(err, res) {
           resolve();
         });
       });