@@ -5,24 +5,21 @@ function _interopDefault (ex) { return (ex && (typeof ex === 'object') && 'defau
5
5
var Redis = _interopDefault ( require ( 'redis' ) ) ;
6
6
7
7
var redisStore = function redisStore ( ) {
8
- for ( var _len = arguments . length , args = Array ( _len ) , _key = 0 ; _key < _len ; _key ++ ) {
9
- args [ _key ] = arguments [ _key ] ;
10
- }
11
-
12
- var redisCache = Redis . createClient . apply ( Redis , args ) ;
8
+ var redisCache = Redis . createClient . apply ( Redis , arguments ) ;
13
9
var storeArgs = redisCache . options ;
14
-
15
10
return {
16
11
name : 'redis' ,
17
12
getClient : function getClient ( ) {
18
13
return redisCache ;
19
14
} ,
20
15
set : function set ( key , value , options , cb ) {
16
+ var self = this ;
21
17
return new Promise ( function ( resolve , reject ) {
22
18
if ( typeof options === 'function' ) {
23
19
cb = options ;
24
20
options = { } ;
25
21
}
22
+
26
23
options = options || { } ;
27
24
28
25
if ( ! cb ) {
@@ -31,6 +28,10 @@ var redisStore = function redisStore() {
31
28
} ;
32
29
}
33
30
31
+ if ( ! self . isCacheableValue ( value ) ) {
32
+ return cb ( new Error ( "\"" . concat ( value , "\" is not a cacheable value" ) ) ) ;
33
+ }
34
+
34
35
var ttl = options . ttl || options . ttl === 0 ? options . ttl : storeArgs . ttl ;
35
36
var val = JSON . stringify ( value ) || '"undefined"' ;
36
37
@@ -42,14 +43,13 @@ var redisStore = function redisStore() {
42
43
} ) ;
43
44
} ,
44
45
mset : function mset ( ) {
45
- for ( var _len2 = arguments . length , args = Array ( _len2 ) , _key2 = 0 ; _key2 < _len2 ; _key2 ++ ) {
46
- args [ _key2 ] = arguments [ _key2 ] ;
46
+ for ( var _len = arguments . length , args = new Array ( _len ) , _key = 0 ; _key < _len ; _key ++ ) {
47
+ args [ _key ] = arguments [ _key ] ;
47
48
}
48
49
49
- var _this = this ;
50
-
50
+ var self = this ;
51
51
return new Promise ( function ( resolve , reject ) {
52
- var cb = void 0 ;
52
+ var cb ;
53
53
var options = { } ;
54
54
55
55
if ( typeof args [ args . length - 1 ] === 'function' ) {
@@ -67,24 +67,25 @@ var redisStore = function redisStore() {
67
67
}
68
68
69
69
var ttl = options . ttl || options . ttl === 0 ? options . ttl : storeArgs . ttl ;
70
+ var multi ;
70
71
71
- var multi = void 0 ;
72
72
if ( ttl ) {
73
73
multi = redisCache . multi ( ) ;
74
74
}
75
75
76
- var key = void 0 ;
77
- var value = void 0 ;
76
+ var key ;
77
+ var value ;
78
78
var parsed = [ ] ;
79
+
79
80
for ( var i = 0 ; i < args . length ; i += 2 ) {
80
81
key = args [ i ] ;
81
82
value = args [ i + 1 ] ;
82
-
83
83
/**
84
84
* Make sure the value is cacheable
85
85
*/
86
- if ( ! _this . isCacheableValue ( value ) ) {
87
- return cb ( new Error ( 'value cannot be ' + value ) ) ;
86
+
87
+ if ( ! self . isCacheableValue ( value ) ) {
88
+ return cb ( new Error ( "\"" . concat ( value , "\" is not a cacheable value" ) ) ) ;
88
89
}
89
90
90
91
value = JSON . stringify ( value ) || '"undefined"' ;
@@ -114,16 +115,18 @@ var redisStore = function redisStore() {
114
115
} ;
115
116
}
116
117
117
- redisCache . get ( key , handleResponse ( cb , { parse : true } ) ) ;
118
+ redisCache . get ( key , handleResponse ( cb , {
119
+ parse : true
120
+ } ) ) ;
118
121
} ) ;
119
122
} ,
120
123
mget : function mget ( ) {
121
- for ( var _len3 = arguments . length , args = Array ( _len3 ) , _key3 = 0 ; _key3 < _len3 ; _key3 ++ ) {
122
- args [ _key3 ] = arguments [ _key3 ] ;
124
+ for ( var _len2 = arguments . length , args = new Array ( _len2 ) , _key2 = 0 ; _key2 < _len2 ; _key2 ++ ) {
125
+ args [ _key2 ] = arguments [ _key2 ] ;
123
126
}
124
127
125
128
return new Promise ( function ( resolve , reject ) {
126
- var cb = void 0 ;
129
+ var cb ;
127
130
var options = { } ;
128
131
129
132
if ( typeof args [ args . length - 1 ] === 'function' ) {
@@ -140,16 +143,18 @@ var redisStore = function redisStore() {
140
143
} ;
141
144
}
142
145
143
- redisCache . mget . apply ( redisCache , [ ] . concat ( args , [ handleResponse ( cb , { parse : true } ) ] ) ) ;
146
+ redisCache . mget . apply ( redisCache , [ ] . concat ( args , [ handleResponse ( cb , {
147
+ parse : true
148
+ } ) ] ) ) ;
144
149
} ) ;
145
150
} ,
146
151
del : function del ( ) {
147
- for ( var _len4 = arguments . length , args = Array ( _len4 ) , _key4 = 0 ; _key4 < _len4 ; _key4 ++ ) {
148
- args [ _key4 ] = arguments [ _key4 ] ;
152
+ for ( var _len3 = arguments . length , args = new Array ( _len3 ) , _key3 = 0 ; _key3 < _len3 ; _key3 ++ ) {
153
+ args [ _key3 ] = arguments [ _key3 ] ;
149
154
}
150
155
151
156
return new Promise ( function ( resolve , reject ) {
152
- var cb = void 0 ;
157
+ var cb ;
153
158
var options = { } ;
154
159
155
160
if ( typeof args [ args . length - 1 ] === 'function' ) {
@@ -182,7 +187,7 @@ var redisStore = function redisStore() {
182
187
} ,
183
188
keys : function keys ( ) {
184
189
var pattern = arguments . length > 0 && arguments [ 0 ] !== undefined ? arguments [ 0 ] : '*' ;
185
- var cb = arguments [ 1 ] ;
190
+ var cb = arguments . length > 1 ? arguments [ 1 ] : undefined ;
186
191
return new Promise ( function ( resolve , reject ) {
187
192
if ( typeof pattern === 'function' ) {
188
193
cb = pattern ;
@@ -217,14 +222,14 @@ var redisStore = function redisStore() {
217
222
218
223
function handleResponse ( cb ) {
219
224
var opts = arguments . length > 1 && arguments [ 1 ] !== undefined ? arguments [ 1 ] : { } ;
220
-
221
225
return function ( err , result ) {
222
226
if ( err ) {
223
227
return cb && cb ( err ) ;
224
228
}
225
229
226
230
if ( opts . parse ) {
227
231
var isMultiple = Array . isArray ( result ) ;
232
+
228
233
if ( ! isMultiple ) {
229
234
result = [ result ] ;
230
235
}
@@ -235,9 +240,9 @@ function handleResponse(cb) {
235
240
} catch ( e ) {
236
241
return cb && cb ( e ) ;
237
242
}
243
+
238
244
return _result ;
239
245
} ) ;
240
-
241
246
result = isMultiple ? result : result [ 0 ] ;
242
247
}
243
248
@@ -247,7 +252,7 @@ function handleResponse(cb) {
247
252
248
253
var methods = {
249
254
create : function create ( ) {
250
- return redisStore . apply ( undefined , arguments ) ;
255
+ return redisStore . apply ( void 0 , arguments ) ;
251
256
}
252
257
} ;
253
258
0 commit comments