Skip to content

Commit 66953ce

Browse files
committed
Expire values in RedisCacheAdapter
1 parent 583887c commit 66953ce

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

src/Adapters/Cache/RedisCacheAdapter.js

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
import redis from 'redis';
22
import logger from '../../logger';
33

4+
const DEFAULT_REDIS_TTL = 30 * 1000; // 30 seconds
5+
46
function debug() {
57
logger.debug.apply(logger, ['RedisCacheAdapter', ...arguments]);
68
}
@@ -33,9 +35,15 @@ export class RedisCacheAdapter {
3335
debug('put', key, value, ttl);
3436
this.p = this.p.then(() => {
3537
return new Promise((resolve, _) => {
36-
this.client.set(key, value, function(err, res) {
37-
resolve();
38-
});
38+
if (ttl) {
39+
this.client.psetex(key, ttl, value, function(err, res) {
40+
resolve();
41+
});
42+
} else {
43+
this.client.set(key, value, function(err, res) {
44+
resolve();
45+
});
46+
}
3947
});
4048
});
4149
return this.p;

0 commit comments

Comments
 (0)