req.db connected to parsed db_name

.gitignore

@@ -1,2 +1 @@
-node_modules
-.nyc_output
+node_modules/

README.md

@@ -1,12 +1,10 @@
-# mongo-express-req [![Build Status](https://travis-ci.org/floatdrop/mongo-express-req.svg?branch=master)](https://travis-ci.org/floatdrop/mongo-express-req)
-
 > Get db connection in request
 
 
 ## Install
 
 ```
-$ npm install --save mongo-express-req
+$ npm install mongodb-express-req
 ```
 
 
@@ -15,11 +13,12 @@ $ npm install --save mongo-express-req
 ```js
 var app = require('express')();
 
-var expressMongoDb = require('mongo-express-req');
-app.use(expressMongoDb('mongodb://localhost/test'));
+var expressMongoDb = require('mongodb-express-req');
+app.use(expressMongoDb('mongodb://localhost/db_name'));
 
 app.get('/', function (req, res, next) {
-	req.db // => Db object
+  req.db // => Db object
+  req.db.collection('collection_name').insertOne({ email, password })
 });
 ```
 
@@ -46,7 +45,10 @@ Default: `db`
 
 Property on `request` object in which db connection will be stored.
 
+## Credentials
+
+Fork of [titanscouting/mongo-express-req](https://github.com/titanscouting/mongo-express-req)
 
 ## License
 
-MIT © [Vsevolod Strukchinsky](http://github.com/floatdrop) and [Dev Singh](http://github.com/devksingh4)
+MIT © [Roman Shmigelsky](http://github.com/roman-sh)

index.js

@@ -1,31 +1,35 @@
-'use strict';
+import whatwgUrl from 'whatwg-url'
+import { MongoClient } from 'mongodb'
 
-var MongoClient = require('mongodb').MongoClient;
 
-module.exports = (uri, opts) => {
+module.exports = (uri, opts = {}) => {
 	if (typeof uri !== 'string') {
-		throw new TypeError('Expected uri to be a string');
+		throw new TypeError('Expected uri to be a string')
 	}
 
-	opts = opts || {};
-	var property = opts.property || 'db';
-	delete opts.property;
+  const dbName = whatwgUrl.basicURLParse(uri).path.toString()
+  if (!dbName) {
+		throw new Error('Database name not found in connection string')
+	}
+
+	const property = opts.property || 'db'
+	delete opts.property
 
-	var connection;
+	let connection
 
-	return function expressMongoDb(req, res, next) {
+	return async function expressMongoDb(req, res, next) {
+    console.log(`mongodb_connection: ${!!connection}`)
 		if (!connection) {
-			connection = MongoClient.connect(uri, opts);
+      try {
+        const res = await MongoClient.connect(uri, opts)
+        connection = true
+        req[property] = res.db(dbName)
+				next()
+      }
+      catch (e) {
+        connection = false
+				next(e)
+      }
 		}
-
-		connection
-			.then(function (db) {
-				req[property] = db;
-				next();
-			})
-			.catch(function (err) {
-				connection = undefined;
-				next(err);
-			});
-	};
-};
+	}
+}