feat(queue): some clean ups for queue feature

Author: iolufemi

app.js

@@ -2,11 +2,11 @@
 var cluster = require('cluster');
 var config = require('./config');
 var log = require('./services/logger');
-var kue = require('kue');
 var basicAuth = require('basic-auth-connect');
 var express = require('express');
 
 if (cluster.isMaster && config.env === 'production') {
+    var kue = require('./services/queue').kue;
     var app = express();
     app.use(basicAuth(config.queueUIUsername, config.queueUIPassword));
     app.use(kue.app);

models/RequestLogs.js

@@ -78,8 +78,7 @@ schemaObject.developer = {
 
 schemaObject.tags = {
     type: [String],
-    index: 'text',
-    default:[]
+    index: 'text'
 };
 
 // Let us define our schema
@@ -118,7 +117,6 @@ Schema.pre('save', function(next) {
 
     // Dump it in the queue
     queue.create('searchIndex', ourDoc)
-    .priority('high')
     .save();
 
     next();
@@ -177,7 +175,6 @@ Schema.pre('update', function(next) {
     }else{
         // Dump it in the queue
         queue.create('searchIndex', ourDoc)
-        .priority('high')
         .save();
     }
 

models/Trash.js

@@ -91,7 +91,6 @@ Schema.pre('save', function(next) {
 
     // Dump it in the queue
     queue.create('searchIndex', ourDoc)
-    .priority('high')
     .save();
 
     next();
@@ -147,7 +146,6 @@ Schema.pre('update', function(next) {
     }else{
         // Dump it in the queue
         queue.create('searchIndex', ourDoc)
-        .priority('high')
         .save();
     }
 

models/Users.js

@@ -88,7 +88,6 @@ Schema.pre('save', function(next) {
 
     // Dump it in the queue
     queue.create('searchIndex', ourDoc)
-    .priority('high')
     .save();
 
     next();
@@ -143,7 +142,6 @@ Schema.pre('update', function(next) {
     }else{
         // Dump it in the queue
         queue.create('searchIndex', ourDoc)
-        .priority('high')
         .save();
     }
 

services/queue/index.js

@@ -15,7 +15,7 @@ queue
 .on('job complete', function(id, result){
   kue.Job.get(id, function(err, job){
     if (err) {
-        throw new Error(err.message);
+        return false;
     }else{
         job.remove(function(err){
           if (err) {
@@ -55,3 +55,4 @@ queue.watchStuckJobs(1000);
 
 // Process Jobs Here
 module.exports = queue;
+module.exports.kue = kue;

services/queue/jobs.js

@@ -36,9 +36,9 @@ jobs.updateRequestLog = function(response, done){
 
 // Creates search tags for all db records
 jobs.createSearchTags = function(data, done){
- var model = data.model;
- var update = data.update ? true : false;
- if(data.update){
+   var model = data.model;
+   var update = data.update ? true : false;
+   if(data.update){
     delete data.update;
 }
 delete data.model;