Support allowOverwrite config options.

Author: lukemelia

lib/redis.js

@@ -20,6 +20,7 @@ module.exports = CoreObject.extend({
       this._client = require('then-redis').createClient(redisOptions);
     }
     this._maxNumberOfRecentUploads = 10;
+    this._allowOverwrite = options.allowOverwrite;
   },
 
   upload: function(/*key, tag, value*/) {
@@ -43,13 +44,14 @@ module.exports = CoreObject.extend({
 
   _uploadIfKeyDoesNotExist: function(redisKey, value) {
     var client = this._client;
+    var allowOverwrite = !!this._allowOverwrite;
 
     return Promise.resolve()
       .then(function() {
         return client.get(redisKey);
       })
       .then(function(value) {
-        if (value) {
+        if (value && !allowOverwrite) {
           return Promise.reject('Value already exists for key: ' + redisKey);
         }
       })

tests/unit/lib/redis-nodetest.js

@@ -50,6 +50,30 @@ describe('redis', function() {
         });
     });
 
+    it('uploads the contents if the key already exists but allowOverwrite is true', function() {
+      var fileUploaded = false;
+
+      var redis = new Redis({
+        allowOverwrite: true,
+        redisClient: {
+          get: function(key) {
+            return Promise.resolve('some-other-value');
+          },
+          set: function(key, value) {
+            fileUploaded = true;
+          },
+          lpush: function() { },
+          ltrim: function() { }
+        }
+      });
+
+      var promise = redis.upload('key', 'value');
+      return assert.isFulfilled(promise)
+        .then(function() {
+          assert.ok(fileUploaded);
+        });
+    });
+
     it('updates the list of recent uploads once upload is successful', function() {
       var recentUploads = [];