Initial version

Author: avital

.gitignore

@@ -0,0 +1,2 @@
+*~
+node_modules

index.js

@@ -0,0 +1,82 @@
+var MemoryDB = require('sharedb/lib/db/memory');
+var Mingo = require('mingo');
+
+function ShareDBMingo(options) {
+  if (!(this instanceof ShareDBMingo)) return new ShareDBMingo(options);
+  MemoryDB.call(this, options);
+}
+
+ShareDBMingo.prototype = Object.create(MemoryDB.prototype);
+
+ShareDBMingo.prototype._querySync = function(snapshots, query, options) {
+  var query = shallowCopy(query);
+  var orderby = query.$orderby;
+  delete query.$orderby;
+  var skip = query.$skip;
+  delete query.$skip;
+  var limit = query.$limit;
+  delete query.$limit;
+
+  var filtered = filter(snapshots, query.$query || query);
+  sort(filtered, orderby);
+  if (skip) filtered.splice(0, skip);
+  if (limit) filtered = filtered.slice(0, limit);
+  return filtered;
+};
+
+ShareDBMingo.prototype.queryPollDoc = function(collection, id, query, options, callback) {
+  var mingoQuery = new Mingo.Query(query);
+  this.getSnapshot(collection, id, null, function(err, snapshot) {
+    if (err) return callback(err);
+    if (snapshot.data) {
+      callback(null, mingoQuery.test(snapshot.data));
+    } else {
+      callback(null, false);
+    }
+  });
+};
+
+ShareDBMingo.prototype.canPollDoc = function(collection, query) {
+  return !(
+    query.hasOwnProperty('$orderby') ||
+    query.hasOwnProperty('$limit') ||
+    query.hasOwnProperty('$skip') ||
+    query.hasOwnProperty('$count')
+  );
+};
+
+// Support exact key match filters only
+function filter(snapshots, query) {
+  var mingoQuery = new Mingo.Query(query);
+  return snapshots.filter(function(snapshot) {
+    return snapshot.data && mingoQuery.test(snapshot.data);
+  });
+}
+
+// Support sorting with the Mongo $orderby syntax
+function sort(snapshots, orderby) {
+  if (!orderby) return snapshots;
+  snapshots.sort(function(snapshotA, snapshotB) {
+    for (var key in orderby) {
+      var value = orderby[key];
+      if (value !== 1 && value !== -1) {
+        throw new Error('Invalid $orderby value');
+      }
+      var a = snapshotA.data && snapshotA.data[key];
+      var b = snapshotB.data && snapshotB.data[key];
+      if (a > b) return value;
+      if (b > a) return -value;
+    }
+    return 0;
+  });
+}
+
+function shallowCopy(object) {
+  var out = {};
+  for (var key in object) {
+    out[key] = object[key];
+  }
+  return out;
+}
+
+module.exports = ShareDBMingo;

package.json

@@ -0,0 +1,29 @@
+{
+  "name": "sharedb-mingo-memory",
+  "version": "0.1.0",
+  "description": "In-memory database adapter with MongoDB API for ShareDB",
+  "main": "index.js",
+  "scripts": {
+    "test": "mocha",
+    "test-cover": "node_modules/istanbul/lib/cli.js cover node_modules/mocha/bin/_mocha"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/share/sharedb-mingo-memory.git"
+  },
+  "devDependencies": {
+    "coveralls": "^2.11.8",
+    "expect.js": "^0.3.1",
+    "istanbul": "^0.4.2",
+    "mocha": "^2.3.3"
+  },
+  "author": "Avital Oliver",
+  "license": "MIT",
+  "bugs": {
+    "url": "https://github.com/share/sharedb-mingo-memory/issues"
+  },
+  "homepage": "https://github.com/share/sharedb-mingo-memory#readme",
+  "dependencies": {
+    "sharedb": "^0.11.35"
+  }
+}

test/mocha.opts

@@ -0,0 +1,4 @@
+--reporter spec
+--check-leaks
+--globals Promise
+--timeout 5000

test/test.js

@@ -0,0 +1,10 @@
+var expect = require('expect.js');
+var ShareDBMingo = require('../index');
+
+function create(callback) {
+  var db = ShareDBMingo();
+  callback(null, db);
+}
+
+require('sharedb/test/db')(create);
+