feat(cluster): replicate

Author: redgeoff

scripts/cluster.js

@@ -11,7 +11,8 @@ var Slouch = require('couch-slouch'),
 var Cluster = function (params) {
   this._params = params;
 
-  this._slouch = new Slouch(params.source);
+  this._sourceSlouch = new Slouch(params.source);
+  this._targetSlouch = new Slouch(params.target);
 
   if (this._params.concurrency === 1) {
     // Don't use a throttler
@@ -25,13 +26,42 @@ var Cluster = function (params) {
 
 Cluster.prototype.replicate = function () {
   var self = this;
-  return self._slouch.db.all().each(function (db) {
+  return self._sourceSlouch.db.all().each(function (db) {
     return self._replicateDB(db);
   }, self._throttler);
 };
 
+Cluster.prototype._createDBIfMissing = function (db) {
+  var self = this;
+  return self._targetSlouch.db.exists(db).then(function (exists) {
+    if (!exists) {
+      return self._targetSlouch.db.create(db);
+    }
+  });
+};
+
+Cluster.prototype._replicateSecurity = function (db) {
+  var self = this;
+  return self._sourceSlouch.security.get(db).then(function (security) {
+    return self._targetSlouch.security.set(db, security);
+  });
+};
+
+Cluster.prototype._replicateRawDB = function (db) {
+  return this._sourceSlouch.db.replicate({
+    source: this._params.source + '/' + db,
+    target: this._params.target + '/' + db
+  });
+};
+
 Cluster.prototype._replicateDB = function (db) {
-  console.log(db);
+  var self = this;
+  return self._createDBIfMissing(db).then(function () {
+    // Replicate security first so that security is put in place before data is copied over
+    return self._replicateSecurity(db);
+  }).then(function () {
+    return self._replicateRawDB(db);
+  });
 };
 
 module.exports = Cluster;

test/node-and-browser.js

@@ -8,8 +8,9 @@ var Promise = require('sporks/scripts/promise'),
 describe('node and browser', function () {
 
   var slouch = null,
-    id = 0,
-    cluster = null;
+    id = 0;
+
+  // TODO: also need to test security
 
   var data = {
     test_db1: [{

test/node.js

@@ -5,3 +5,5 @@ chai.use(require('chai-as-promised'));
 chai.should();
 
 require('./node-and-browser');
+
+// TODO: use spawn to test CL interface