Updated MongoAscoltatore to MongoDB driver v2.0.0

lib/mongo_ascoltatore.js

@@ -8,7 +8,7 @@ var SubsCounter = require("./subs_counter");
 var debug = require("debug")("ascoltatori:mongodb");
 var mongo = require('mongodb');
 var MongoClient = require('mongodb').MongoClient;
-var BSON = mongo.BSONPure;
+var ObjectID = require('mongodb').ObjectID;
 var async = require("async");
 
 /**
@@ -46,7 +46,7 @@ var MongoAscoltatore = function(opts) {
   this._closed = false;
 
   this._handlingCursorFailure = false;
-  this._lastSuccessfulHandling = new BSON.ObjectID();
+  this._lastSuccessfulHandling = new ObjectID();
 
   this.wait = this._opts.wait || 100;
 
@@ -76,7 +76,7 @@ var MongoAscoltatore = function(opts) {
         debug('ready');
 
         // create a new object id. We will get all the events from now on
-        that._poll(new BSON.ObjectID());
+        that._poll(new ObjectID());
 
         that.emit('ready');
       }
@@ -146,11 +146,7 @@ MongoAscoltatore.prototype._handle = function(die, callback) {
       err = args.shift();
 
     if (err && !that._closed) {
-      if (that._cursor && that._cursor.isClosed()) {
-        that._handleCursorClosed(that._lastSuccessfulHandling);
-      } else {
-        that.emit('error', err);
-      }
+      that._handleCursorClosed(that._lastSuccessfulHandling);
       return;
     }
 

package.json

@@ -50,7 +50,7 @@
     "sinon": "^1.10.3",
     "sinon-chai": "^2.6.0",
     "optimist": "~0.6.0",
-    "async_bench": "~0.4.0",
+    "async_bench": "~0.5.0",
     "dox-foundation": "0.5.4",
     "mosca": "git://github.com/mcollina/mosca.git",
     "jshint": "~2.5.2",
@@ -62,15 +62,15 @@
     "async": "~0.9.0",
     "debug": "^2.0.0",
     "node-uuid": "~1.4.0",
-    "qlobber": "~0.3.0"
+    "qlobber": "~0.5.0"
   },
   "optionalDependencies": {
     "nan": "~1.8.4",
     "redis": "~0.12.1",
-    "hiredis": "^0.3.0",
+    "hiredis": "^0.4.0",
     "zmq": "~2.11.0",
     "amqp": "~0.2.4",
-    "mqtt": "~1.0.0",
+    "mqtt": "^1.0.0",
     "mongodb": "~2.0.33",
     "eventemitter2": "~0.4.14",
     "qlobber-fsq": "~0.3.0"