feat(queue): completed tests for the queue system

Author: iolufemi

TODO.md

@@ -1,4 +1,9 @@
 ### TODOs
 | Filename | line # | TODO
 |:------|:------:|:------
-| routes/index.js | 208 | Implement API Generator
+| controllers/Initialize.js | 18 | Test initialize controller
+| controllers/Users.js | 49 | Finish users controller
+| controllers/Users.js | 50 | Finish users route
+| routes/index.js | 208 | Implement API Generator
+| routes/initialize.js | 10 | Test initialize route
+| services/queue/index.js | 61 | work on a clock functionality so kue can support scheduled jobs

controllers/Initialize.js

@@ -14,3 +14,5 @@ module.exports = {
         });
     }
 };
+
+// Todo: Test initialize controller

controllers/Users.js

@@ -45,3 +45,6 @@ UsersController.restore = function(query){
 };
 
 module.exports = UsersController;
+
+// Todo: Finish users controller
+// Todo: Finish users route

routes/initialize.js

@@ -7,3 +7,4 @@ var initializeController = require('../controllers/Initialize');
 router.get('/initialize', initializeController.init);
 
 module.exports = router;
+// Todo: Test initialize route

services/queue/index.js

@@ -13,6 +13,7 @@ queue
   log.info( 'Job %s got queued of type %s', id, type );
 })
 .on('job complete', function(id, result){
+    log.info('ID: ',id,' Result: ',result);
   kue.Job.get(id, function(err, job){
     if (err) {
         return false;
@@ -56,3 +57,5 @@ queue.watchStuckJobs(1000);
 // Process Jobs Here
 module.exports = queue;
 module.exports.kue = kue;
+
+// ToDo: work on a clock functionality so kue can support scheduled jobs

services/queue/jobs.js

@@ -11,7 +11,7 @@ jobs.createRequestLog = function(request, done){
     log.info('logging API request: ',request.RequestId);
     models.RequestLogs.create(request)
     .then(function(res){
-      return done();
+      return done(false, res);
   })
     .catch(function(err){
       log.error(err);
@@ -23,10 +23,10 @@ jobs.createRequestLog = function(request, done){
 jobs.updateRequestLog = function(response, done){
     log.info('logging API response: ',response.requestId);
     var requestId = response.requestId;
-    delete response.RequestId;
+    delete response.requestId;
     models.RequestLogs.update({RequestId: requestId},response)
     .then(function(res){
-        return done();
+        return done(false, res);
     })
     .catch(function(err){
         log.error(err);
@@ -36,6 +36,7 @@ jobs.updateRequestLog = function(response, done){
 
 // Creates search tags for all db records
 jobs.createSearchTags = function(data, done){
+    log.info('Creating search index for: ', data._id);
    var model = data.model;
    var update = data.update ? true : false;
    if(data.update){
@@ -63,7 +64,7 @@ if(update){
 
 task
 .then(function(res){
-  return done();
+  return done(false, res);
 })
 .catch(function(err){
   log.error(err);

test/services/queue.js

@@ -0,0 +1,112 @@
+"use strict";
+
+var chai = require('chai');
+chai.should();
+var config = require('../../config');
+var chaiAsPromised = require("chai-as-promised");
+chai.use(chaiAsPromised);
+var queue = require('../../services/queue');
+
+var workers = require('../../services/queue/workers');
+var sinon = require("sinon");
+var sinonChai = require("sinon-chai");
+chai.use(sinonChai);
+
+// Test Index
+var jobs;
+describe('#Queue service', function(){
+    before(function() { /* jslint ignore:line */
+      queue.testMode.enter();
+      jobs = require('../../services/queue/jobs');
+  });
+
+    afterEach(function() { /* jslint ignore:line */
+      queue.testMode.clear();
+  });
+
+    after(function() { /* jslint ignore:line */
+      queue.testMode.exit();
+  });
+
+    it('should return an object', function(done){
+        queue.should.be.an('object');
+        queue.should.be.have.property('kue');
+        jobs.should.be.an('object');
+        workers.should.be.an('object');
+        done();
+    });
+
+    it('should pass basic smoke test', function() {
+      queue.createJob('myJob', 'foo').save();
+      queue.createJob('anotherJob', { baz: 'bip' }).save();
+      queue.testMode.jobs.length.should.equal(2);
+      queue.testMode.jobs[0].type.should.equal('myJob');
+      queue.testMode.jobs[0].data.should.equal('foo');
+  });
+
+    it('should load processes', function() {
+        var process = require('../../services/queue/workers');
+        // We have configured queue to create 2 workers per job making a total of 6 workers for 3 jobs that we currently have
+        process.workers.length.should.equal(6);
+    });
+
+
+
+    // Test Jobs
+    describe('#Testing Jobs', function(){
+        it('should run createRequestLog successfully', function(done){
+          var myrequestlog = {
+            RequestId: 'gdfd6563',
+            ipAddress: '192.168.90.9',
+            url: 'http://google.com',
+            method: 'POST',
+            body: {name: 'femi'},
+            createdAt: new Date()
+        };
+        jobs.createRequestLog(myrequestlog,done);
+    });
+
+        it('should run updateRequestLog successfully', function(done){
+          var myrequestlog = {
+            requestId: 'gdfd6563',
+            response: {
+                ipAddress: '192.168.90.9',
+                url: 'http://google.com',
+                method: 'POST',
+                body: {name: 'femi'},
+                createdAt: new Date()
+            }
+        };
+        jobs.updateRequestLog(myrequestlog,done);
+    });
+        it('should run createSearchTags successfully for saving data', function(done){
+          var myrequestlog = {
+            RequestId: 'gdfd6563',
+            ipAddress: '192.168.90.9',
+            url: 'http://google.com',
+            method: 'POST',
+            body: {name: 'femi'},
+            createdAt: new Date()
+        };
+
+        myrequestlog.model = 'RequestLogs';
+        jobs.createSearchTags(myrequestlog,done);
+    });
+
+        it('should run createSearchTags successfully for updating data', function(done){
+          var myrequestlog = {
+            RequestId: 'gdfd6563',
+            ipAddress: '192.168.90.9',
+            url: 'http://google.com',
+            method: 'POST',
+            body: {name: 'femi'},
+            createdAt: new Date()
+        };
+
+        myrequestlog.model = 'RequestLogs';
+        myrequestlog.update = true;
+        jobs.createSearchTags(myrequestlog,done);
+    });
+
+    });
+});