@@ -43,7 +43,7 @@ module.exports = CoreObject.extend({
43
43
let value = args . pop ( ) ;
44
44
let revisionKey = args [ 0 ] || 'default' ;
45
45
let revisionData = args [ 1 ] ;
46
- let redisKey = keyPrefix + ':' + revisionKey ;
46
+ let redisKey = ` ${ keyPrefix } : ${ revisionKey } ` ;
47
47
let maxEntries = this . _maxRecentUploads ;
48
48
49
49
await this . _uploadIfKeyDoesNotExist ( redisKey , value ) ;
@@ -89,7 +89,7 @@ module.exports = CoreObject.extend({
89
89
return ;
90
90
}
91
91
let dataKeys = revisions . map ( function ( revision ) {
92
- return keyPrefix + ' :revision-data:' + revision ;
92
+ return ` ${ keyPrefix } :revision-data:${ revision } ` ;
93
93
} ) ;
94
94
95
95
let data = this . _client . mget ( dataKeys ) ;
@@ -102,21 +102,20 @@ module.exports = CoreObject.extend({
102
102
} ,
103
103
104
104
_listRevisions ( keyPrefix ) {
105
- var client = this . _client ;
106
- var listKey = keyPrefix + ' :revisions' ;
105
+ let client = this . _client ;
106
+ let listKey = ` ${ keyPrefix } :revisions` ;
107
107
return client . zrevrange ( listKey , 0 , - 1 ) ;
108
108
} ,
109
109
110
110
_validateRevisionKey ( revisionKey , revisions ) {
111
111
if ( revisions . indexOf ( revisionKey ) === - 1 ) {
112
- throw new Error ( '`' + revisionKey + ' ` is not a valid revision key' ) ;
112
+ throw new Error ( `\` ${ revisionKey } \ ` is not a valid revision key` ) ;
113
113
}
114
114
return ;
115
115
} ,
116
116
117
117
_activateRevisionKey ( keyPrefix , revisionKey , activationSuffix ) {
118
- var currentKey = keyPrefix + ':' + activationSuffix ;
119
-
118
+ let currentKey = `${ keyPrefix } :${ activationSuffix } ` ;
120
119
return this . _client . set ( currentKey , revisionKey ) ;
121
120
} ,
122
121
@@ -128,59 +127,58 @@ module.exports = CoreObject.extend({
128
127
return this . _activateRevisionKey ( keyPrefix , revisionKey , activationSuffix ) ;
129
128
} ,
130
129
131
- async _copyRevisionAndActivateRevisionKey (
132
- keyPrefix , revisionKey , activationSuffix , activeContentSuffix ) {
130
+ async _copyRevisionAndActivateRevisionKey ( keyPrefix , revisionKey , activationSuffix , activeContentSuffix ) {
133
131
let client = this . _client ;
134
- let activeContentKey = keyPrefix + ':' + activeContentSuffix ;
135
- let revisionContentKey = keyPrefix + ':' + revisionKey ;
132
+ let activeContentKey = ` ${ keyPrefix } : ${ activeContentSuffix } ` ;
133
+ let revisionContentKey = ` ${ keyPrefix } : ${ revisionKey } ` ;
136
134
137
135
let value = await client . get ( revisionContentKey ) ;
138
136
await client . set ( activeContentKey , value ) ;
139
137
await this . _activateRevisionKey ( keyPrefix , revisionKey , activationSuffix ) ;
140
138
} ,
141
139
142
140
async _uploadIfKeyDoesNotExist ( redisKey , value ) {
143
- var client = this . _client ;
144
- var allowOverwrite = ! ! this . _allowOverwrite ;
141
+ let client = this . _client ;
142
+ let allowOverwrite = ! ! this . _allowOverwrite ;
145
143
146
144
let existingValue = await client . get ( redisKey ) ;
147
145
if ( existingValue && ! allowOverwrite ) {
148
- throw new Error ( ' Value already exists for key: ' + redisKey ) ;
146
+ throw new Error ( ` Value already exists for key: ${ redisKey } ` ) ;
149
147
}
150
148
return client . set ( redisKey , value ) ;
151
149
} ,
152
150
153
151
async _uploadRevisionData ( keyPrefix , revisionKey , revisionData ) {
154
152
let client = this . _client ;
155
- let redisKey = keyPrefix + ' :revision-data:' + revisionKey ;
153
+ let redisKey = ` ${ keyPrefix } :revision-data:${ revisionKey } ` ;
156
154
await client . set ( redisKey , JSON . stringify ( revisionData ) ) ;
157
155
} ,
158
156
159
157
async _updateRecentUploadsList ( keyPrefix , revisionKey ) {
160
158
let client = this . _client ;
161
159
let score = new Date ( ) . getTime ( ) ;
162
- let listKey = keyPrefix + ' :revisions' ;
160
+ let listKey = ` ${ keyPrefix } :revisions` ;
163
161
await client . zadd ( listKey , score , revisionKey ) ;
164
162
} ,
165
163
166
164
async _trimRecentUploadsList ( keyPrefix , maxEntries ) {
167
165
let client = this . _client ;
168
- let listKey = keyPrefix + ' :revisions' ;
166
+ let listKey = ` ${ keyPrefix } :revisions` ;
169
167
170
168
let results = await RSVP . hash ( {
171
169
revisionsToBeRemoved : client . zrange ( listKey , 0 , - ( maxEntries + 1 ) ) ,
172
170
current : this . activeRevision ( keyPrefix )
173
171
} ) ;
174
- var revisions = results . revisionsToBeRemoved ;
175
- var current = results . current ;
172
+ let revisions = results . revisionsToBeRemoved ;
173
+ let current = results . current ;
176
174
if ( ! revisions ) {
177
175
return ;
178
176
}
179
177
let promises = [ ] ;
180
178
revisions . forEach ( function ( revision ) {
181
179
if ( revision !== current ) {
182
- promises . push ( client . del ( keyPrefix + ":" + revision ) ) ;
183
- promises . push ( client . del ( keyPrefix + " :revision-data:" + revision ) ) ;
180
+ promises . push ( client . del ( ` ${ keyPrefix } : ${ revision } ` ) ) ;
181
+ promises . push ( client . del ( ` ${ keyPrefix } :revision-data:${ revision } ` ) ) ;
184
182
promises . push ( client . zrem ( listKey , revision ) ) ;
185
183
}
186
184
} ) ;
0 commit comments