Merge pull request #219 from agco/remove-mongojs-from-eventsreader

Use mongoose in events reader

lib/events-reader.js

@@ -4,11 +4,12 @@ let _ = require('lodash'),
   Promise = require('bluebird'),
   debug = require('debug')('events-reader'),
   BSON = require('mongodb').BSONPure,
-  mongojs = require('mongojs'),
   hl = require('highland'),
   checkpointWriter = require('./events-reader-checkpoint-writer'),
   Joi = require('joi');
 
+const mongoose = require('mongoose');
+
 module.exports = function(harvesterApp) {
 
   return function(oplogMongodbUri) {
@@ -21,7 +22,9 @@ module.exports = function(harvesterApp) {
       "d": 'delete'
     };
 
-    var db = mongojs(oplogMongodbUri, ['oplog.rs'], {poolSize: 10, socketOptions: {keepAlive: 250}});
+    mongoose.connect(oplogMongodbUri, {poolSize: 10, socketOptions: {keepAlive: 250}})
+      .then(() => console.log('EventsReader connected to oplog'))
+      .catch((err) => console.log(err));
 
     var docStream = hl();
 
@@ -99,9 +102,7 @@ module.exports = function(harvesterApp) {
 
       time = {$gt: since};
       query.ts = time;
-
-      return db.oplog.rs.find(query, options);
-
+      return mongoose.connection.db.collection('oplog.rs').find(query,options);
     };
 
     EventsReader.prototype.processDocHandlers = function(doc) {