Initial release

Author: drublic

.editorconfig

@@ -0,0 +1,7 @@
+root = true
+
+[*]
+end_of_line = lf
+insert_final_newline = true
+indent_style = space
+indent_size = 2

__tests__/_database.js

@@ -0,0 +1,62 @@
+import { MongoClient } from 'mongodb'
+
+const state = {
+  db: null,
+  mode: null,
+}
+
+const DATABASE_URI = 'mongodb://127.0.0.1:27017/test'
+
+exports.connect = (mode, done) => {
+  if (state.db) {
+    return done()
+  }
+
+  MongoClient.connect(DATABASE_URI, (err, db) => {
+    if (err) {
+      return done(err)
+    }
+
+    state.db = db
+    state.mode = mode
+
+    done()
+  })
+}
+
+exports.getDB = () => {
+  return state.db
+}
+
+exports.drop = (done) => {
+  if (!state.db) {
+    return done()
+  }
+
+  // This is faster then dropping the database
+  state.db.collections(async (err, collections) => {
+
+    collections.forEach((collection) => {
+      await collection.remove(cb)
+    })
+
+    done()
+  })
+}
+
+exports.fixtures = function (data, done) {
+  var db = state.db
+
+  if (!db) {
+    return done(new Error('Missing database connection.'))
+  }
+
+  const names = Object.keys(data.collections)
+
+  names.forEach(async (name) => {
+    const collection = await db.createCollection(name, function (err, collection) {
+    await collection.insert(data.collections[name], resolve)
+  })
+
+  done()
+}

__tests__/fixtures/database.json

@@ -0,0 +1,18 @@
+{
+  "collections": {
+    "comments": [
+      {
+        "user": "Peter Parker",
+        "text": "I like ice cream."
+      },
+      {
+        "user": "John Doe",
+        "text": "Nodejs is the best."
+      },
+      {
+        "user": "Peter Jones",
+        "text": "Keep your keyboard clean."
+      }
+    ]
+  }
+}

__tests__/index.js

@@ -0,0 +1,7 @@
+import Mongo from '../dist/'
+
+describe('Init Mongo', () => {
+  it('finds single', () => {
+
+  })
+})

dist/index.js

@@ -0,0 +1,74 @@
+import { MongoClient } from 'mongodb'
+
+interface Config {
+  url: string
+}
+
+class InitMongo {
+  private client: MongoClient
+  private collection
+  private config: Config
+
+  constructor(config: Config) {
+    this.client = MongoClient
+    this.config = config
+  }
+
+  private caller(collectionName: string, callee: Function) {
+    return new Promise((resolve, reject) => {
+      this.client.connect(this.config.url, (err, db) => {
+        if (err) {
+          return reject(err)
+        }
+
+        this.collection = db.collection(collectionName)
+
+        return callee()
+          .then((data) => {
+            db.close()
+            resolve(data)
+          })
+          .catch(console.error)
+      })
+    })
+  }
+
+  private insertCallee(elements: object[] | object) {
+    return new Promise((resolve, reject) => {
+      this.collection.insertMany(elements, (error, result) => {
+        if (error) {
+          return reject(error)
+        }
+
+        return resolve(result)
+      })
+    })
+  }
+
+  public insert(collectionName: string, elements: object[] | object) {
+    if (elements.constructor !== Array) {
+      elements = [elements]
+    }
+
+    return this.caller(collectionName, () => this.insertCallee(elements))
+  }
+
+  private findCallee(query: object) {
+    return new Promise((resolve, reject) => {
+      this.collection.find(query).toArray((error, result) => {
+        if (error) {
+          return reject(error)
+        }
+
+        return resolve(result)
+      });
+    })
+  }
+
+  public find(collectionName: string, query: object) {
+    return this.caller(collectionName, () => this.findCallee(query))
+  }
+
+}
+
+export default InitMongo

dist/index.js.map

@@ -0,0 +1,18 @@
+{
+  "name": "init-mongo",
+  "version": "0.1.0",
+  "main": "dist/index.js",
+  "author": "Hans Christian Reinl <[email protected]>",
+  "license": "MIT",
+  "dependencies": {
+    "@types/jest": "^21.1.6",
+    "@types/node": "^8.0.53",
+    "jest": "^21.2.1",
+    "mongodb": "^2.2.33",
+    "tslint": "^5.8.0",
+    "typescript": "^2.6.1"
+  },
+  "scripts": {
+    "compile": "tsc"
+  }
+}

index.ts

@@ -0,0 +1,20 @@
+{
+  "compilerOptions": {
+    "target": "es6",
+    "moduleResolution": "node",
+    "module": "commonjs",
+    "outDir": "dist",
+    "sourceMap": true,
+    "types": [
+      "node",
+      "jest"
+    ]
+  },
+  "include": [
+    "**/*.ts"
+  ],
+  "exclude": [
+    "node_modules",
+    "__tests__"
+  ]
+}

package.json

@@ -0,0 +1,24 @@
+{
+  "rules": {
+    "max-line-length": {
+      "options": [
+        120
+      ]
+    },
+    "new-parens": true,
+    "no-arg": true,
+    "no-bitwise": true,
+    "no-conditional-assignment": true,
+    "no-consecutive-blank-lines": false,
+    "no-console": {
+      "options": [
+        "debug",
+        "info",
+        "log",
+        "time",
+        "timeEnd",
+        "trace"
+      ]
+    }
+  }
+}