Added additional tests, removed unnecessary messages in logs

Author: Henry Mollman

lib/models/mongo/mongoose-control.js

@@ -73,14 +73,15 @@ mongooseControl.stop = function (cb) {
 }
 
 mongooseControl._exitIfFailedToOpen = function () {
-  log.fatal({message: 'Failed to connect to ' + process.env.MONGO}, 'failed to establish a connection to mongodb')
+  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})
+  log.error({message: 'Failed to connect to ' + process.env.MONGO + ' failed to establish a connection to mongodb'})
   setTimeout(function () {
     if (!mongoose.connection.readyState) {
+      log.fatal({message: 'Exiting nodejs process due to mongodb connection failure'})
       process.exit(1)
     }
   }, 10000)

unit/models/mongo/mongoose-control.js

@@ -11,6 +11,7 @@ var Code = require('code')
 var fs = require('fs')
 var mongoose = require('mongoose')
 var sinon = require('sinon')
+var clock
 
 var mongooseControl = require('models/mongo/mongoose-control')
 
@@ -108,11 +109,20 @@ describe('mongoose-control', function () {
 
       beforeEach(function (done) {
         sinon.stub(mongoose.connection, 'on').yields()
+        sinon.stub(process, 'exit')
         sinon.stub(mongooseControl, '_exitIfFailedToReconnect')
         sinon.stub(mongooseControl, '_exitIfFailedToOpen')
         done()
       })
 
+      afterEach(function (done) {
+        mongooseControl._exitIfFailedToReconnect.restore()
+        mongooseControl._exitIfFailedToOpen.restore()
+        mongoose.connection.on.restore()
+        process.exit.restore()
+        done()
+      })
+
       it('should exit if it cannot connect', function (done) {
         mongooseControl.start(function (err) {
           expect(err).to.not.exist()
@@ -124,13 +134,45 @@ describe('mongoose-control', function () {
 
       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()
-          })
+        mongooseControl.start(function (err) {
+          expect(err).to.not.exist()
+          sinon.assert.notCalled(mongooseControl._exitIfFailedToOpen)
+          sinon.assert.calledOnce(mongooseControl._exitIfFailedToReconnect)
+          done()
         })
+      })
+    })
+
+    describe('exiting node process when db disconnects', function () {
+
+      beforeEach(function (done) {
+        clock = sinon.useFakeTimers()
+        sinon.stub(mongoose.connection, 'on').yields()
+        sinon.stub(process, 'exit')
+        done()
+      })
+
+      afterEach(function (done) {
+        mongoose.connection.on.restore()
+        process.exit.restore()
+        clock.restore()
+        done()
+      })
+
+      it('should exit immediately if it cannot connect', function (done) {
+        mongooseControl._exitIfFailedToOpen()
+        sinon.assert.calledOnce(process.exit)
+        done()
+      })
+
+      it('should attempt to reconnect when it was connected once', function (done) {
+        mongooseControl._exitIfFailedToReconnect()
+        clock.tick(1000)
+        sinon.assert.notCalled(process.exit)
+        clock.tick(10000)
+        sinon.assert.calledOnce(process.exit)
+        done()
+      })
     })
   })
 })