1
1
var CoreObject = require ( 'core-object' ) ;
2
- var Promise = require ( 'ember-cli/lib/ext/promise ' ) ;
2
+ var RSVP = require ( 'rsvp ' ) ;
3
3
4
4
module . exports = CoreObject . extend ( {
5
5
@@ -47,13 +47,13 @@ module.exports = CoreObject.extend({
47
47
var maxEntries = this . _maxRecentUploads ;
48
48
var _this = this ;
49
49
50
- return Promise . resolve ( )
50
+ return RSVP . resolve ( )
51
51
. then ( this . _uploadIfKeyDoesNotExist . bind ( this , redisKey , value ) )
52
52
. then ( function ( ) {
53
53
if ( revisionData ) {
54
54
return _this . _uploadRevisionData ( keyPrefix , revisionKey , revisionData ) ;
55
55
} else {
56
- return Promise . resolve ( ) ;
56
+ return RSVP . resolve ( ) ;
57
57
}
58
58
} )
59
59
. then ( this . _updateRecentUploadsList . bind ( this , keyPrefix , revisionKey ) )
@@ -64,7 +64,7 @@ module.exports = CoreObject.extend({
64
64
} ,
65
65
66
66
activate : function ( keyPrefix , revisionKey , activationSuffix , activeContentSuffix ) {
67
- return Promise . resolve ( )
67
+ return RSVP . resolve ( )
68
68
. then ( this . _listRevisions . bind ( this , keyPrefix ) )
69
69
. then ( this . _validateRevisionKey . bind ( this , revisionKey ) )
70
70
. then ( this . _activateRevision . bind ( this , keyPrefix , revisionKey , activationSuffix , activeContentSuffix ) ) ;
@@ -73,8 +73,8 @@ module.exports = CoreObject.extend({
73
73
fetchRevisions : function ( keyPrefix ) {
74
74
var _this = this ;
75
75
return this . _listRevisions ( keyPrefix ) . then ( function ( revisions ) {
76
- return Promise . hash ( {
77
- revisions : Promise . resolve ( revisions ) ,
76
+ return RSVP . hash ( {
77
+ revisions : RSVP . resolve ( revisions ) ,
78
78
current : _this . activeRevision ( keyPrefix ) ,
79
79
revisionData : _this . _revisionData ( keyPrefix , revisions )
80
80
} ) ;
@@ -99,15 +99,15 @@ module.exports = CoreObject.extend({
99
99
100
100
_revisionData : function ( keyPrefix , revisions ) {
101
101
if ( revisions . length === 0 ) {
102
- return Promise . resolve ( ) ;
102
+ return RSVP . resolve ( ) ;
103
103
}
104
104
var dataKeys = revisions . map ( function ( revision ) {
105
105
return keyPrefix + ':revision-data:' + revision ;
106
106
} ) ;
107
107
108
108
return this . _client . mget ( dataKeys ) . then ( function ( data ) {
109
109
if ( ! data ) {
110
- return Promise . resolve ( ) ;
110
+ return RSVP . resolve ( ) ;
111
111
}
112
112
return data . map ( function ( d ) {
113
113
return JSON . parse ( d ) ;
@@ -122,7 +122,7 @@ module.exports = CoreObject.extend({
122
122
} ,
123
123
124
124
_validateRevisionKey : function ( revisionKey , revisions ) {
125
- return revisions . indexOf ( revisionKey ) > - 1 ? Promise . resolve ( ) : Promise . reject ( '`' + revisionKey + '` is not a valid revision key' ) ;
125
+ return revisions . indexOf ( revisionKey ) > - 1 ? RSVP . resolve ( ) : RSVP . reject ( '`' + revisionKey + '` is not a valid revision key' ) ;
126
126
} ,
127
127
128
128
_activateRevisionKey : function ( keyPrefix , revisionKey , activationSuffix ) {
@@ -145,7 +145,7 @@ module.exports = CoreObject.extend({
145
145
var activeContentKey = keyPrefix + ':' + activeContentSuffix ;
146
146
var revisionContentKey = keyPrefix + ':' + revisionKey ;
147
147
148
- return new Promise ( function ( resolve , reject ) {
148
+ return new RSVP . Promise ( function ( resolve , reject ) {
149
149
client . get ( revisionContentKey ) . then (
150
150
function ( value ) {
151
151
client . set ( activeContentKey , value ) . then ( function ( ) {
@@ -161,13 +161,13 @@ module.exports = CoreObject.extend({
161
161
var client = this . _client ;
162
162
var allowOverwrite = ! ! this . _allowOverwrite ;
163
163
164
- return Promise . resolve ( )
164
+ return RSVP . resolve ( )
165
165
. then ( function ( ) {
166
166
return client . get ( redisKey ) ;
167
167
} )
168
168
. then ( function ( value ) {
169
169
if ( value && ! allowOverwrite ) {
170
- return Promise . reject ( 'Value already exists for key: ' + redisKey ) ;
170
+ return RSVP . reject ( 'Value already exists for key: ' + redisKey ) ;
171
171
}
172
172
} )
173
173
. then ( function ( ) {
@@ -178,7 +178,7 @@ module.exports = CoreObject.extend({
178
178
_uploadRevisionData : function ( keyPrefix , revisionKey , revisionData ) {
179
179
var client = this . _client ;
180
180
var redisKey = keyPrefix + ':revision-data:' + revisionKey ;
181
- return Promise . resolve ( )
181
+ return RSVP . resolve ( )
182
182
. then ( function ( ) {
183
183
return client . set ( redisKey , JSON . stringify ( revisionData ) ) ;
184
184
} ) ;
@@ -195,7 +195,7 @@ module.exports = CoreObject.extend({
195
195
var client = this . _client ;
196
196
var listKey = keyPrefix + ':revisions' ;
197
197
198
- return Promise . hash ( {
198
+ return RSVP . hash ( {
199
199
revisionsToBeRemoved : client . zrange ( listKey , 0 , - ( maxEntries + 1 ) ) ,
200
200
current : this . activeRevision ( keyPrefix )
201
201
} ) . then ( function ( results ) {
0 commit comments