setup and use kue and redis

Author: harsh1206

config/kue.js

@@ -0,0 +1,5 @@
+const kue=require('kue');
+
+const queue=kue.createQueue();
+
+module.exports=queue;

controllers/comments_controller.js

@@ -1,6 +1,10 @@
 const Comment = require('../models/comment');
 const Post = require('../models/posts');
 const commentsMailer=require('../mailers/comments_mailer');
+const kue=require('../config/kue');
+const commentsEmailworker=require('../workers/comment_email');
+const queue = require('../config/kue');
+
 
 module.exports.create = async function(req, res){
 
@@ -17,7 +21,16 @@ module.exports.create = async function(req, res){
             post.comments.push(comment);
             post.save();
             comment = await comment.populate('user', 'name email').execPopulate();
-            commentsMailer.newComment(comment); 
+            // commentsMailer.newComment(comment); 
+           let job = queue.create('emails',comment).save(function(err){
+               
+                if(err){
+                    console.log('error in creating a queue');
+                    return;
+                }
+            
+                console.log('job enqueued',job.id);
+            });
 
             if (req.xhr){
                 // Similar for comments to fetch the user's id!

mailers/comments_mailer.js

@@ -24,7 +24,7 @@ exports.newComment=(comment)=>{
             console.log('error in sending mail',err);
             return;
         }
-        console.log('Message Sent',info);
+        // console.log('Message Sent',info);
         return;
 
     })