COUNTERS: redis failsafe

Adhidarma Hadiwinoto
1 parent b95fb84155
Showing 1 changed file with 9 additions and 4 deletions Side-by-side Diff
counters.js
@@ -3,26 +3,31 @@
 const redis = require('redis');
 const config = require('./config');
  
-const redisClient = redis.createClient(config.redis || { host: '127.0.0.1' });
+const redisClient = config.redis && redis.createClient(config.redis);
  
 function composeKeyword(name) {
     return `CHONGLEE_COUNTER_${name}}`;
 }
  
 exports.increment = (name) => {
-    redisClient.INCR(composeKeyword(name));
+    redisClient && redisClient.INCR(composeKeyword(name), () => {});
 }
  
 exports.reset = (name) => {
-    redisClient.DEL(composeKeyword(name));
+    redisClient && redisClient.DEL(composeKeyword(name), () => {});
 }
  
 exports.set = (name, value) => {
-    redisClient.SET(composeKeyword(name), Number(value));
+    redisClient && redisClient.SET(composeKeyword(name), Number(value), () => {});
 }
  
 exports.get = (name) => {
     return new Promise((resolve) => {
+        if (!redisClient) {
+            resolve(0);
+            return;
+        }
+
         redisClient.GET(composeKeyword(name), (err, reply) => {
             if (err) {
                 resolve(0);
...	...	@@ -3,26 +3,31 @@
3	3	const redis = require('redis');
4	4	const config = require('./config');
5	5
6		-const redisClient = redis.createClient(config.redis \|\| { host: '127.0.0.1' });
	6	+const redisClient = config.redis && redis.createClient(config.redis);
7	7
8	8	function composeKeyword(name) {
9	9	return `CHONGLEE_COUNTER_${name}}`;
10	10	}
11	11
12	12	exports.increment = (name) => {
13		- redisClient.INCR(composeKeyword(name));
	13	+ redisClient && redisClient.INCR(composeKeyword(name), () => {});
14	14	}
15	15
16	16	exports.reset = (name) => {
17		- redisClient.DEL(composeKeyword(name));
	17	+ redisClient && redisClient.DEL(composeKeyword(name), () => {});
18	18	}
19	19
20	20	exports.set = (name, value) => {
21		- redisClient.SET(composeKeyword(name), Number(value));
	21	+ redisClient && redisClient.SET(composeKeyword(name), Number(value), () => {});
22	22	}
23	23
24	24	exports.get = (name) => {
25	25	return new Promise((resolve) => {
	26	+ if (!redisClient) {
	27	+ resolve(0);
	28	+ return;
	29	+ }
	30	+
26	31	redisClient.GET(composeKeyword(name), (err, reply) => {
27	32	if (err) {
28	33	resolve(0);