update to latest mongodb driver

lib/index.js

@@ -140,7 +140,7 @@ Grid.prototype.findOne = function (options, callback) {
   collection.find(find, function(err, cursor) {
     if (err) { return callback(err); }
     if (!cursor) { return callback(new Error('Collection not found')); }
-    cursor.nextObject(callback);
+    cursor.next(callback);
   });
 }
 

package.json

@@ -1,8 +1,9 @@
 {
-  "author": "Aaron Heckmann <aaron.heckmann+github@gmail.com>",
-  "name": "gridfs-stream",
+  "author": "Lally Elias <lallyelias87@gmail.com>",
+  "name": "@lykmapipo/gridfs-stream",
   "description": "Writable/Readable Nodejs compatible GridFS streams",
-  "version": "1.1.1",
+  "version": "1.2.0",
+  "license": "MIT",
   "keywords": [
     "mongodb",
     "mongoose",
@@ -16,7 +17,7 @@
   },
   "devDependencies": {
     "mocha": "*",
-    "mongodb": "2.0.15",
+    "mongodb": "3.1.1",
     "checksum": "~0.1.1"
   },
   "optionalDependencies": {},
@@ -25,6 +26,6 @@
   },
   "repository": {
     "type": "git",
-    "url": "git://github.com/aheckmann/gridfs-stream.git"
+    "url": "git://github.com/lykmapipo/gridfs-stream.git"
   }
 }

test/index.js

@@ -4,6 +4,7 @@ var assert = require('assert')
   , Stream = require('stream')
   , fs = require('fs')
   , mongo = require('mongodb')
+  , MongoClient = mongo.MongoClient
   , Grid = require('../')
   , crypto = require('crypto')
   , checksum = require('checksum')
@@ -13,23 +14,27 @@ var assert = require('assert')
   , txtReadPath =fixturesDir + 'text.txt'
   , emptyReadPath = fixturesDir + 'emptydoc.txt'
   , largeBlobPath = tmpDir + '1mbBlob'
-  , server
+  , url = 'mongodb://localhost:27017'
+  , dbName = 'gridstream_test'
+  , client
   , db
 
 
 describe('test', function(){
   var id;
   before(function (done) {
-    server = new mongo.Server('localhost', 27017);
-    db = new mongo.Db('gridstream_test', server, {w:1});
     if (!fs.existsSync(tmpDir)) {
       fs.mkdirSync(tmpDir);
     }
     fs.writeFile(largeBlobPath, crypto.randomBytes(1024*1024), function (err) {
       if (err) {
         done(err);
       }
-      db.open(done)
+      MongoClient.connect(url, { useNewUrlParser: true }, function(err, _client) {
+        client = _client;
+        db = _client.db(dbName);
+        done(err);
+      });
     });
   });
 
@@ -784,7 +789,7 @@ describe('test', function(){
       }
       fs.rmdir(tmpDir, function () {
         db.dropDatabase(function () {
-          db.close(true, done);
+          client.close(true, done);
         });
       });
     });