Handle all redis errors

fixes issue mozilla#30

server/bin/email

@@ -2,7 +2,7 @@
 /* -*- Mode: js2; js2-basic-offset: 2; indent-tabs-mode: nil; -*- */
 
 var smtp = require('smtp-protocol'),
-   redis = require("redis"),
+   redis = require("../lib/redis"),
    logEvent = require("../lib/events").logEvent,
    MailParser = require("mailparser").MailParser;
 

server/lib/api.js

@@ -6,7 +6,7 @@ const jwcrypto = require('jwcrypto'),
       path = require('path'),
       bid = require('./bid'),
       unixTime = require('./time').unixTime,
-      redis = require('redis'),
+      redis = require('./redis'),
       logEvent = require('./events').logEvent,
       ALGORITHM = "RS",
       KEYSIZE = 256,

server/lib/bid.js

@@ -4,7 +4,7 @@
 
 const util = require('util'),
       events = require('events'),
-      redis = require('redis'),
+      redis = require('./redis'),
       redisConf = require('./config'),
       wsapi = require('./wsapi_client'),
       logEvent = require('./events').logEvent,

server/lib/events.js

@@ -1,4 +1,4 @@
-const redis = require('redis'),
+const redis = require('./redis'),
       db = redis.createClient();
 
 /**
@@ -48,4 +48,4 @@ var fetchEvents = module.exports.fetchEvents = function fetchEvents(email, start
     }
     return callback(null, stream);
   });
-};
+};

server/lib/redis.js

@@ -0,0 +1,20 @@
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+const redis    = require('redis');
+
+var redisErrorCount = 0;
+
+exports.createClient = function() {
+  var client = redis.createClient();
+
+  client.on('error', function(err) {
+    // The error has to be handled or else node restarts the server. Not ideal.
+    console.log("REDIS error", redisErrorCount, err);
+    redisErrorCount++;
+  });
+
+  return client;
+};
+