Switching to __dirname and adding some extra logging

Author: Danial Knox

src/app.js

@@ -24,6 +24,8 @@ function prepareApp(config) {
   var options = extend(defaults, config);
   var worker = new QueueBuildRequests(options.redis, options.queue);
 
+  options.redis.on('error', function(err) { console.error(err); });
+
   app.use(bodyParser.json());
 
   app.post(

src/main.js

@@ -16,7 +16,18 @@ if (cluster.isMaster) {
   });
 
   for (var i = 0, ii = workerCount; i < ii; i += 1) {
-    cluster.fork();
+    var clusterWorker = cluster.fork();
+    clusterWorker.on('exit', function(code, signal) {
+      if (signal) {
+        console.log(`worker was killed by signal: ${signal}`);
+      } else if (code !== 0) {
+        console.error(`worker exited with error code: ${code}`);
+      } else {
+        console.log('worker success!');
+      }
+    });
+
+    clusterWorker.on('error', function(err) { console.error(err) });
   }
 } else {
   workers.start();

src/processors/cssProcessor.js

@@ -4,6 +4,7 @@ var redis = require('redis');
 var generator = require('../generator.js');
 
 var redisClient = redis.createClient({ url: process.env.REDIS_URL });
+redisClient.on('error', function (err) { console.error(err) });
 var worker = new BuildCss(generator(), redisClient);
 
 
@@ -16,7 +17,7 @@ module.exports = function (job, done) {
         done(null, data);
       })
       .catch(function (err) {
-        console.log('bull: process catch', job.data.page.key);
+        console.error('bull: process catch', job.data.page.key);
         done(err);
       });
 };

src/redisOpts.js

@@ -1,5 +1,5 @@
 // @format
-var url = process.env.REDIS_URL || 'redis://127.0.0.1/';
+var url = process.env.REDIS_URL || 'redis://127.0.0.1:6379/';
 var redisOpts = require('redis-url').parse(url);
 
 module.exports = {

src/workers.js

@@ -13,22 +13,22 @@ module.exports = function(queue) {
       });
 
       queue.on('error', function(job) {
-        console.log('bull: job error! ', job);
+        console.error('bull: job error! ', job);
       });
 
       queue.on('stalled', function(job) {
-        console.log('bull: job stalled', job);
+        console.error('bull: job stalled', job);
       })
 
       queue.on('exit', function(worker, code, signal) {
-        console.log('bull: worker died', worker, code, signal);
+        console.error('bull: worker died', worker, code, signal);
       });
 
       queue.on('failed', function(job) {
-        console.log('bull: job failed! ', job);
+        console.error('bull: job failed! ', job);
       });
 
-      queue.process(path.join(process.cwd(),'src', 'processors', 'cssProcessor.js'));
+      queue.process(path.join(__dirname, 'processors', 'cssProcessor.js'));
     },
   };
 };