lib: refactor, split into modules

* docs: add docco-style documentation for js code

lib/bplus.js

@@ -1,199 +1,13 @@
-var Buffer = require('buffer').Buffer,
-    binding;
+// Export utils
+exports.utils = require('./bplus/utils');
 
+// Export binding
 try {
-  binding = require('./bplus/bplus');
+  exports.binding = require('./bplus/bplus');
 } catch (e) {
   throw Error('BPlus can\' be loaded without compiled addon');
 }
 
-function BPlus() {
-  this._db = new binding.BPlus();
-};
-exports.BPlus = BPlus;
-
-exports.create = function() {
-  return new BPlus();
-};
-
-BPlus.prototype.open = function open(filename) {
-  this._db.open(filename);
-
-  return this;
-};
-
-BPlus.prototype.close = function close() {
-  this._db.close();
-
-  return this;
-};
-
-BPlus.prototype.set = function set(key, value, callback) {
-  callback || (callback = function() {});
-
-  if (typeof key === 'string') key = new Buffer(key);
-  if (typeof value === 'string') value = new Buffer(value);
-
-  this._db.set(key, value, callback);
-
-  return this;
-};
-
-BPlus.prototype.update = function update(key, value, filter, callback) {
-  callback || (callback = function() {});
-  filter || (filter = function() {});
-
-  if (typeof key === 'string') key = new Buffer(key);
-  if (typeof value === 'string') value = new Buffer(value);
-
-  var res = this._db.update(key, value, function(prev, curr) {
-    return filter(prev.value, curr.value);
-  });
-
-  process.nextTick(function() {
-    if (res === true) {
-      callback(null);
-    } else {
-      callback(true, res);
-    }
-  });
-
-  return this;
-};
-
-BPlus.prototype.bulk = function bulk(keyValues, callback) {
-  callback || (callback = function() {});
-  if (!Array.isArray(keyValues)) {
-    return callback(Error('First argument should be an Array'));
-  }
-
-  var binaryKvs = keyValues.map(function(kv) {
-    return {
-      key: typeof kv.key === 'string' ? new Buffer(kv.key) : kv.key,
-      value: typeof kv.value === 'string' ? new Buffer(kv.value) : kv.value
-    };
-  });
-
-  this._db.bulkSet(binaryKvs, callback);
-
-  return this;
-};
-
-BPlus.prototype.bulkUpdate = function bulkUpdate(keyValues, filter, callback) {
-  filter || (filter = function() {});
-  callback || (callback = function() {});
-  if (!Array.isArray(keyValues)) {
-    return callback(Error('First argument should be an Array'));
-  }
-
-  var binaryKvs = keyValues.map(function(kv) {
-    return {
-      key: typeof kv.key === 'string' ? new Buffer(kv.key) : kv.key,
-      value: typeof kv.value === 'string' ? new Buffer(kv.value) : kv.value
-    };
-  });
-
-  var ret = this._db.bulkUpdate(binaryKvs, function(prev, curr) {
-    return filter(prev.value, curr.value);
-  });
-
-  process.nextTick(function() {
-    if (ret === true) {
-      callback(null);
-    } else {
-      callback(true, ret);
-    }
-  });
-
-  return this;
-};
-
-BPlus.prototype.get = function get(key, callback) {
-  if (typeof key === 'string') key = new Buffer(key);
-
-  this._db.get(key, function(err, result) {
-    if (!callback) return;
-    if (err) return callback(err, result);
-    return callback(err, result.value, result.ref);
-  });
-
-  return this;
-};
-
-BPlus.prototype.getRange = function getRange(start, end, filter) {
-  var promise = new process.EventEmitter;
-
-  if (typeof start === 'string') start = new Buffer(start);
-  if (typeof end === 'string') end = new Buffer(end);
-
-  function callback(err, type, key, value) {
-    if (err) return promise.emit('error', err, type);
-
-    if (type === 'message') {
-      promise.emit('message', key.value, value.value, value.ref);
-    } else {
-      promise.emit('end');
-    }
-  }
-
-  if (filter) {
-    var self = this;
-    process.nextTick(function() {
-      self._db.getFilteredRange(start, end, function(key) {
-        return filter(key.value)
-      }, callback);
-    });
-  } else {
-    this._db.getRange(start, end, callback);
-  }
-
-  return promise;
-};
-
-BPlus.prototype.getPrevious = function getPrevious(ref, callback) {
-  this._db.getPrevious(ref, function(err, result) {
-    if (!callback) return;
-    if (err) return callback(err, result);
-    return callback(err, result.value, result.ref);
-  });
-
-  return this;
-};
-
-BPlus.prototype.remove = function remove(key, callback) {
-  callback || (callback = function() {});
-
-  if (typeof key === 'string') key = new Buffer(key);
-
-  this._db.remove(key, callback);
-
-  return this;
-};
-
-BPlus.prototype.removev = function removev(key, filter, callback) {
-  callback || (callback = function() {});
-  filter || (filter = function() {});
-
-  if (typeof key === 'string') key = new Buffer(key);
-
-  var res = this._db.removev(key, function(value) {
-    return filter(value.value);
-  }, callback);
-
-  process.nextTick(function() {
-    if (res === true) {
-      callback(null);
-    } else {
-      callback(true, res);
-    }
-  });
-
-  return this;
-};
-
-BPlus.prototype.compact = function compact(callback) {
-  callback || (callback = function() {});
-
-  this._db.compact(callback);
-  return this;
-};
+// Export Bplus constructor (core)
+exports.BPlus = require('./bplus/core').BPlus;
+exports.create = require('./bplus/core').create;