Move handleUncaught into this project

Author: gx0r

package.json

@@ -70,7 +70,6 @@
     "react-with-direction": "^1.3.1",
     "redux": "^4.0.5",
     "redux-logger": "^3.0.6",
-    "rethink-handle-uncaught": "^1.0.0",
     "rethinkdbdash": "^2.3.31",
     "socket.io": "^2.3.0",
     "socket.io-client": "^2.3.1",

src/common/db.js

@@ -2,7 +2,7 @@
 "use strict";
 const options = require("../../config/database.js");
 const r = (module.exports = require("rethinkdbdash")(options));
-require("rethink-handle-uncaught")(r, {
+require("./handleUncaught")(r, {
   filter: function(errorOrException) {
     if (errorOrException.msg === "Malicious Path") {
       return false;

src/common/handleUncaught.js

@@ -0,0 +1,76 @@
+'use strict';
+const os = require('os');
+
+module.exports = function(r, opts) {
+    opts = opts || {
+        table: 'errors'
+    };
+
+	if (!opts.filter) {
+		opts.filter = () => true;
+	}
+
+	if (! typeof opts.filter === 'function') {
+		throw new TypeError('opts.filter must be a function');
+	}
+	if (! typeof opts.table === 'string') {
+		throw new TypeError('opts.table must be a string');
+	}
+
+    function getStack(errOrPromise) {
+        if (errOrPromise == null) {
+            return null;
+        } else if (errOrPromise.stack != null) {
+            return errOrPromise.stack;
+        } else {
+            return errOrPromise;
+        }
+    }
+
+    function insert(errOrPromise, isPromise) {
+		var firstStep;
+
+		if (opts.filter(errOrPromise)) {
+			firstStep = r.table(opts.table).insert({
+	            host: os.hostname(),
+	            pid: process.pid,
+	            date: new Date(),
+	            stack: getStack(errOrPromise),
+	            argv: process.argv,
+	            cwd: process.cwd(),
+	            memory: process.memoryUsage(),
+	            uptime: process.uptime(),
+	            promise: isPromise,
+	            uid: process.getuid(),
+	            groups: process.getgroups(),
+	            load: os.loadavg()
+
+	        }).run()
+		} else {
+			firstStep = Promise.resolve();
+		}
+        firstStep
+        .catch(function (err) {
+            // If the DB is unavailable, we would go in an infinite loop trying to keep inserting exceptions.
+            console.error(getStack(err));
+        })
+
+		return firstStep;
+    }
+
+    function handleUncaughtException(err) {
+        console.error((new Date).toUTCString() + ' uncaughtException:', getStack(err))
+        return insert(err, false)
+            .finally(function() {
+                process.exit(1)
+            })
+    };
+
+    function handleUnhandledRejection(reason, promise) {
+        console.error((new Date).toUTCString() + ' unhandledPromiseRejection:', getStack(reason))
+        return insert(reason, true);
+    };
+
+    process.on('uncaughtException', handleUncaughtException);
+    process.on('unhandledRejection', handleUnhandledRejection);
+}

src/common/systemdb.js

@@ -8,12 +8,3 @@ const db = require("rethinkdbdash")({
   db: 'rethinkdb',
 });
 module.exports.db = db;
-
-// require("rethink-handle-uncaught")(r, {
-//   filter: function(errorOrException) {
-//     if (errorOrException.msg === "Malicious Path") {
-//       return false;
-//     }
-//     return true;
-//   }
-// });