[BREAKING] add fetchInitialRevisions and move to revisionData key

this implements ember-cli-deploy/ember-cli-deploy#338

Author: ghedamat

index.js

@@ -128,14 +128,33 @@ module.exports = {
         }
       },
 
+      fetchInitialRevisions: function(/* context */) {
+        var redisDeployClient = this.readConfig('redisDeployClient');
+        var keyPrefix = this.readConfig('keyPrefix');
+        this.log('Listing initial revisions for key: `' + keyPrefix + '`', { verbose: true });
+        return Promise.resolve(redisDeployClient.fetchRevisions(keyPrefix))
+          .then(function(revisions) {
+            return {
+              revisionData: {
+                initial: revisions
+              }
+            };
+          })
+          .catch(this._errorMessage.bind(this));
+      },
+
       fetchRevisions: function(context) {
         var redisDeployClient = this.readConfig('redisDeployClient');
         var keyPrefix = this.readConfig('keyPrefix');
 
         this.log('Listing revisions for key: `' + keyPrefix + '`');
+        var data = context.revisionData || {};
         return Promise.resolve(redisDeployClient.fetchRevisions(keyPrefix))
-          .then(function(revisions){
-            return { revisions: revisions };
+          .then(function(revisions) {
+            data.revisions = revisions;
+            return {
+              revisionData: data
+            };
           })
           .catch(this._errorMessage.bind(this));
       },

tests/unit/index-nodetest.js

@@ -575,6 +575,54 @@ describe('redis plugin', function() {
     });
   });
 
+  describe('fetchInitialRevisions hook', function() {
+    it('fills the revisionsData.initial variable on context', function() {
+      var plugin;
+      var context;
+
+      plugin = subject.createDeployPlugin({
+        name: 'redis'
+      });
+
+      context = {
+        ui: mockUi,
+        project: stubProject,
+        config: {
+          redis: {
+            keyPrefix: 'test-prefix',
+            filePattern: 'index.html',
+            distDir: 'tests',
+            revisionKey: '123abc',
+            redisDeployClient: function(context) {
+              return {
+                fetchRevisions: function(keyPrefix, revisionKey) {
+                  return Promise.resolve([{
+                    revision: 'a',
+                    active: false
+                  }]);
+                }
+              };
+            }
+          }
+        }
+      };
+      plugin.beforeHook(context);
+      plugin.configure(context);
+
+      return assert.isFulfilled(plugin.fetchInitialRevisions(context))
+      .then(function(result) {
+        assert.deepEqual(result, {
+          revisionData: {
+            initial: [{
+              "active": false,
+              "revision": "a"
+            }]
+          }
+        });
+      });
+    });
+  });
+
   describe('fetchRevisions hook', function() {
     it('fills the revisions variable on context', function() {
       var plugin;
@@ -610,14 +658,72 @@ describe('redis plugin', function() {
       plugin.configure(context);
 
       return assert.isFulfilled(plugin.fetchRevisions(context))
-        .then(function(result) {
-          assert.deepEqual(result, {
+      .then(function(result) {
+        assert.deepEqual(result, {
+          revisionData: {
+            revisions: [{
+              "active": false,
+              "revision": "a"
+            }]
+          }
+        });
+      });
+    });
+
+    it('merges with the initialData', function() {
+      var plugin;
+      var context;
+
+      plugin = subject.createDeployPlugin({
+        name: 'redis'
+      });
+
+      context = {
+        ui: mockUi,
+        project: stubProject,
+        config: {
+          redis: {
+            keyPrefix: 'test-prefix',
+            filePattern: 'index.html',
+            distDir: 'tests',
+            revisionKey: '123abc',
+            redisDeployClient: function(context) {
+              return {
+                fetchRevisions: function(keyPrefix, revisionKey) {
+                  return Promise.resolve([{
+                    revision: 'a',
+                    active: false
+                  }]);
+                }
+              };
+            }
+          }
+        },
+        revisionData: {
+          initial: [{
+            "active": false,
+            "revision": "old"
+          }]
+        }
+      };
+      plugin.beforeHook(context);
+      plugin.configure(context);
+
+      return assert.isFulfilled(plugin.fetchRevisions(context))
+      .then(function(result) {
+        assert.deepEqual(result, {
+          revisionData: {
+            initial: [{
+              "active": false,
+              "revision": "old"
+            }],
             revisions: [{
               "active": false,
               "revision": "a"
             }]
-          });
+          }
         });
+      });
     });
   });
 });