Initial commit

Author: asyncmax

.gitignore

@@ -0,0 +1,5 @@
+.DS_Store
+*.log
+node_modules
+_build
+_test

osx/mongod

@@ -0,0 +1,12 @@
+{
+  "private": true,
+  "scripts": {
+    "test": "node start_db.js& node test.js",
+    "test:win32": "start /b node start_db.js && node test.js"
+  },
+  "dependencies": {
+    "mkdirp": "^0.5.1",
+    "mongodb": "^2.2.31",
+    "tape": "^4.8.0"
+  }
+}

package.json

@@ -0,0 +1,50 @@
+"use strict";
+
+const npath = require("path");
+const spawn = require("child_process").spawn;
+const mkdirp = require("mkdirp");
+
+const MONGO_DBPATH = npath.join(__dirname, "_test/mongo/db");
+const MONGO_LOGPATH = npath.join(__dirname, "_test/mongo/log/mongod.log");
+const MONGO_PORT = 27777;
+
+function startMongoDB({dbpath, logpath, port=27777}) {
+  let mongod;
+
+  if (process.platform === "win32")
+    mongod = npath.join(__dirname, "./win32/mongod.exe");
+  else if (process.platform === "darwin")
+    mongod = npath.join(__dirname, "./osx/mongod");
+  else
+    throw Error("Unsupported platform: " + process.platform);
+
+  mkdirp.sync(dbpath);
+
+  let args = [
+    "--dbpath", dbpath,
+    "--port", port
+  ];
+
+  if (logpath) {
+    mkdirp.sync(npath.dirname(logpath));
+    args = args.concat(["--logpath", logpath]);
+  }
+
+  const child = spawn(mongod, args, {
+    stdio: "inherit"
+  });
+
+  child.on("exit", code => {
+    console.log("MongoDB terminated with exit code: %d", code);
+  });
+
+  return child;
+}
+
+const mongodb = startMongoDB({
+  dbpath: MONGO_DBPATH,
+  logpath: MONGO_LOGPATH,
+  port: MONGO_PORT
+});
+
+console.log("Running MongoDB as a child process, pid = %d", mongodb.pid);

start_db.js

@@ -0,0 +1,47 @@
+"use strict";
+
+const MongoClient = require("mongodb").MongoClient;
+const test = require("tape");
+
+const MONGO_PORT = 27777;
+
+let db, docs;
+
+test("connecting to mongod", t => {
+  MongoClient.connect(`mongodb://localhost:${MONGO_PORT}/hello`).then(_db => {
+    t.pass("MongoDB connection");
+    db = _db;
+  }).then(t.end, t.end);
+});
+
+test("prepare", t => {
+  docs = db.collection("documents");
+  docs.remove({}).then(res => {
+    t.ok(res.result.ok);
+  }).then(t.end, t.end);
+});
+
+test("create", t => {
+  docs.insertMany([
+    {_id: 1, a: 111},
+    {_id: 2, a: 222},
+    {_id: 3, a: 333}
+  ]).then(res => {
+    t.equal(res.insertedCount, 3);
+  }).then(t.end, t.end);
+});
+
+test("read", t => {
+  docs.find({_id: {$in: [1, 2, 3]}}).toArray().then(res => {
+    t.deepEqual(res, [
+      {_id: 1, a: 111},
+      {_id: 2, a: 222},
+      {_id: 3, a: 333}
+    ]);
+  }).then(t.end, t.end);
+});
+
+test("shutting down mongod", t => {
+  db.close();
+  t.end();
+});