feat(cluster)

Author: redgeoff

package.json

@@ -55,6 +55,8 @@
     ]
   },
   "dependencies": {
-    "sporks": "0.0.1"
+    "couch-slouch": "0.0.3",
+    "sporks": "0.0.1",
+    "squadron": "0.0.3"
   }
 }

scripts/cluster.js

@@ -0,0 +1,37 @@
+'use strict';
+
+var Slouch = require('couch-slouch'),
+  squadron = require('squadron');
+
+// params
+//   source
+//   target
+//   concurrency
+//   skip
+var Cluster = function (params) {
+  this._params = params;
+
+  this._slouch = new Slouch(params.source);
+
+  if (this._params.concurrency === 1) {
+    // Don't use a throttler
+    this._throttler = null;
+  } else {
+    // Create a throttler with the specified or default concurrency
+    var concurrency = this._params.concurrency ? this._params.concurrency : null;
+    this._throttler = new squadron.Throttler(concurrency);
+  }
+};
+
+Cluster.prototype.replicate = function () {
+  var self = this;
+  return self._slouch.db.all().each(function (db) {
+    return self._replicateDB(db);
+  }, self._throttler);
+};
+
+Cluster.prototype._replicateDB = function (db) {
+  console.log(db);
+};
+
+module.exports = Cluster;

scripts/foo.js

@@ -0,0 +1,3 @@
+'use strict';
+
+module.exports = require('./cluster');

scripts/index.js

@@ -4,18 +4,4 @@ var chai = require('chai');
 chai.use(require('chai-as-promised'));
 chai.should();
 
-var Foo = require('../scripts/foo');
-
 require('./node-and-browser');
-
-describe('browser', function () {
-
-  it('should test in only the browser', function () {
-    // TODO: insert tests that can only be tested in the browser
-    var foo = new Foo();
-    return foo.bar().then(function (thing) {
-      thing.should.eql('yar');
-    });
-  });
-
-});

test/browser.js

@@ -1,15 +1,99 @@
 'use strict';
 
-var Foo = require('../scripts/foo');
+var Promise = require('sporks/scripts/promise'),
+  Cluster = require('../scripts'),
+  sporks = require('sporks'),
+  Slouch = require('couch-slouch');
 
 describe('node and browser', function () {
 
-  it('should test in both node and the browser', function () {
-    // TODO: insert tests that can be tested in both node and the browser
-    var foo = new Foo();
-    return foo.bar().then(function (thing) {
-      thing.should.eql('yar');
+  var slouch = null,
+    id = 0,
+    cluster = null;
+
+  var data = {
+    test_db1: [{
+        _id: '1',
+        foo: 'bar'
+      },
+      {
+        _id: '2',
+        yar: 'nar'
+      },
+    ],
+    test_db2: [{
+        _id: '3',
+        foo: 'star'
+      },
+      {
+        _id: '4',
+        yar: 'raar'
+      },
+    ]
+  };
+
+  var createDocs = function (db, docs) {
+    var promises = [];
+    docs.forEach(function (doc) {
+      promises.push(slouch.doc.create(db, doc));
+    });
+    return Promise.all(promises);
+  };
+
+  var createDatabase = function (db, docs) {
+    return slouch.db.create(db).then(function () {
+      return createDocs(db, docs);
+    });
+  };
+
+  var createData = function () {
+    var promises = [];
+    sporks.each(data, function (docs, db) {
+      promises.push(createDatabase(db + '_' + id, docs));
+    });
+    return Promise.all(promises);
+  };
+
+  var destroyData = function () {
+    var promises = [];
+    sporks.each(data, function (docs, db) {
+      promises.push(slouch.db.destroy(db + '_' + id));
+    });
+    return Promise.all(promises);
+  };
+
+  beforeEach(function () {
+    slouch = new Slouch('http://admin:admin@localhost:5984');
+
+    // Use a unique id as back to back creation/deletion of the same DBs can lead to problems
+    id++;
+
+    return createData();
+  });
+
+  afterEach(function () {
+    return destroyData();
+  });
+
+  it('should replicate', function () {
+    var cluster = new Cluster({
+      source: 'http://admin:admin@localhost:5984',
+      target: 'http://admin:admin@localhost:5984'
     });
+    return cluster.replicate();
   });
 
+  // it('should skip when replicating', function () {
+  //   var cluster = new Cluster({
+  //     source: 'http://admin:admin@localhost:5984',
+  //     target: 'http://admin:admin@localhost:5984',
+  //     skip: ['_global_changes', '_replicator', '_users']
+  //   });
+  //   return cluster.replicate();
+  // });
+
+  // it('should support custom concurrency when replicating', function () {
+  //
+  // });
+
 });

test/node-and-browser.js

@@ -4,18 +4,4 @@ var chai = require('chai');
 chai.use(require('chai-as-promised'));
 chai.should();
 
-var Foo = require('../scripts/foo');
-
 require('./node-and-browser');
-
-describe('node', function () {
-
-  it('should test only in node', function () {
-    // TODO: insert tests that can only be tested in node
-    var foo = new Foo();
-    return foo.bar().then(function (thing) {
-      thing.should.eql('yar');
-    });
-  });
-
-});