11var CoreObject = require ( 'core-object' ) ;
2- var Promise = require ( 'ember-cli/lib/ext/promise ' ) ;
2+ var RSVP = require ( 'rsvp ' ) ;
33
44module . exports = CoreObject . extend ( {
55
@@ -47,13 +47,13 @@ module.exports = CoreObject.extend({
4747 var maxEntries = this . _maxRecentUploads ;
4848 var _this = this ;
4949
50- return Promise . resolve ( )
50+ return RSVP . resolve ( )
5151 . then ( this . _uploadIfKeyDoesNotExist . bind ( this , redisKey , value ) )
5252 . then ( function ( ) {
5353 if ( revisionData ) {
5454 return _this . _uploadRevisionData ( keyPrefix , revisionKey , revisionData ) ;
5555 } else {
56- return Promise . resolve ( ) ;
56+ return RSVP . resolve ( ) ;
5757 }
5858 } )
5959 . then ( this . _updateRecentUploadsList . bind ( this , keyPrefix , revisionKey ) )
@@ -64,7 +64,7 @@ module.exports = CoreObject.extend({
6464 } ,
6565
6666 activate : function ( keyPrefix , revisionKey , activationSuffix , activeContentSuffix ) {
67- return Promise . resolve ( )
67+ return RSVP . resolve ( )
6868 . then ( this . _listRevisions . bind ( this , keyPrefix ) )
6969 . then ( this . _validateRevisionKey . bind ( this , revisionKey ) )
7070 . then ( this . _activateRevision . bind ( this , keyPrefix , revisionKey , activationSuffix , activeContentSuffix ) ) ;
@@ -73,8 +73,8 @@ module.exports = CoreObject.extend({
7373 fetchRevisions : function ( keyPrefix ) {
7474 var _this = this ;
7575 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 ) ,
7878 current : _this . activeRevision ( keyPrefix ) ,
7979 revisionData : _this . _revisionData ( keyPrefix , revisions )
8080 } ) ;
@@ -99,15 +99,15 @@ module.exports = CoreObject.extend({
9999
100100 _revisionData : function ( keyPrefix , revisions ) {
101101 if ( revisions . length === 0 ) {
102- return Promise . resolve ( ) ;
102+ return RSVP . resolve ( ) ;
103103 }
104104 var dataKeys = revisions . map ( function ( revision ) {
105105 return keyPrefix + ':revision-data:' + revision ;
106106 } ) ;
107107
108108 return this . _client . mget ( dataKeys ) . then ( function ( data ) {
109109 if ( ! data ) {
110- return Promise . resolve ( ) ;
110+ return RSVP . resolve ( ) ;
111111 }
112112 return data . map ( function ( d ) {
113113 return JSON . parse ( d ) ;
@@ -122,7 +122,7 @@ module.exports = CoreObject.extend({
122122 } ,
123123
124124 _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' ) ;
126126 } ,
127127
128128 _activateRevisionKey : function ( keyPrefix , revisionKey , activationSuffix ) {
@@ -145,7 +145,7 @@ module.exports = CoreObject.extend({
145145 var activeContentKey = keyPrefix + ':' + activeContentSuffix ;
146146 var revisionContentKey = keyPrefix + ':' + revisionKey ;
147147
148- return new Promise ( function ( resolve , reject ) {
148+ return new RSVP . Promise ( function ( resolve , reject ) {
149149 client . get ( revisionContentKey ) . then (
150150 function ( value ) {
151151 client . set ( activeContentKey , value ) . then ( function ( ) {
@@ -161,13 +161,13 @@ module.exports = CoreObject.extend({
161161 var client = this . _client ;
162162 var allowOverwrite = ! ! this . _allowOverwrite ;
163163
164- return Promise . resolve ( )
164+ return RSVP . resolve ( )
165165 . then ( function ( ) {
166166 return client . get ( redisKey ) ;
167167 } )
168168 . then ( function ( value ) {
169169 if ( value && ! allowOverwrite ) {
170- return Promise . reject ( 'Value already exists for key: ' + redisKey ) ;
170+ return RSVP . reject ( 'Value already exists for key: ' + redisKey ) ;
171171 }
172172 } )
173173 . then ( function ( ) {
@@ -178,7 +178,7 @@ module.exports = CoreObject.extend({
178178 _uploadRevisionData : function ( keyPrefix , revisionKey , revisionData ) {
179179 var client = this . _client ;
180180 var redisKey = keyPrefix + ':revision-data:' + revisionKey ;
181- return Promise . resolve ( )
181+ return RSVP . resolve ( )
182182 . then ( function ( ) {
183183 return client . set ( redisKey , JSON . stringify ( revisionData ) ) ;
184184 } ) ;
@@ -195,7 +195,7 @@ module.exports = CoreObject.extend({
195195 var client = this . _client ;
196196 var listKey = keyPrefix + ':revisions' ;
197197
198- return Promise . hash ( {
198+ return RSVP . hash ( {
199199 revisionsToBeRemoved : client . zrange ( listKey , 0 , - ( maxEntries + 1 ) ) ,
200200 current : this . activeRevision ( keyPrefix )
201201 } ) . then ( function ( results ) {
0 commit comments