Separated functions, added tests

Author: Henry Mollman

lib/models/mongo/mongoose-control.js

@@ -52,17 +52,12 @@ mongooseControl.start = function (cb) {
   }
 
   mongoose.connect(process.env.MONGO, mongooseOptions, cb)
+
   mongoose.connection.on('disconnected', function () {
     if (!mongoose.connection._hasOpened) {
-      log.fatal({message: 'Failed to connect to ' + process.env.MONGO}, 'failed to establish a connection to mongodb')
-      process.exit(1)
+      mongooseControl._exitIfFailedToOpen()
     } else {
-      log.error({message: 'Lost connection to ' + process.env.MONGO})
-      setTimeout(function () {
-        if (!mongoose.connection.readyState) {
-          process.exit(1)
-        }
-      }, 10000)
+      mongooseControl._exitIfFailedToReconnect()
     }
   })
 }
@@ -76,3 +71,17 @@ mongooseControl.stop = function (cb) {
     })
   })
 }
+
+mongooseControl._exitIfFailedToOpen = function () {
+  log.fatal({message: 'Failed to connect to ' + process.env.MONGO}, 'failed to establish a connection to mongodb')
+  process.exit(1)
+}
+
+mongooseControl._exitIfFailedToReconnect = function() {
+  log.error({message: 'Lost connection to ' + process.env.MONGO})
+  setTimeout(function () {
+    if (!mongoose.connection.readyState) {
+      process.exit(1)
+    }
+  }, 10000)
+}

unit/models/mongo/mongoose-control.js

@@ -103,5 +103,34 @@ describe('mongoose-control', function () {
         done()
       })
     })
+
+    describe('handling mongodb disconnect events', function () {
+
+      beforeEach(function (done) {
+        sinon.stub(mongoose.connection, 'on').yields()
+        sinon.stub(mongooseControl, '_exitIfFailedToReconnect')
+        sinon.stub(mongooseControl, '_exitIfFailedToOpen')
+        done()
+      })
+
+      it('should exit if it cannot connect', function (done) {
+        mongooseControl.start(function (err) {
+          expect(err).to.not.exist()
+          sinon.assert.notCalled(mongooseControl._exitIfFailedToReconnect)
+          sinon.assert.calledOnce(mongooseControl._exitIfFailedToOpen)
+          done()
+        })
+      })
+
+      it('should attempt a retry if connection existed', function (done) {
+        mongoose.connection._hasOpened = true
+          mongooseControl.start(function (err) {
+            expect(err).to.not.exist()
+            sinon.assert.notCalled(mongooseControl._exitIfFailedToOpen)
+            sinon.assert.calledOnce(mongooseControl._exitIfFailedToReconnect)
+            done()
+          })
+        })
+    })
   })
 })