Refactoring errHandler() to be in lexical scope with new arity as `…

…utility.error()`

lib/tenso.js

@@ -381,23 +381,6 @@ class Tenso extends HTTPMethods {
 				compression = "",
 				header, compressionMethod;
 
-			const errHandler = e => {
-				try {
-					if (this.config.http2 === false) {
-						res.statusCode = 500;
-						res.writeHead(500, headers || rheaders);
-						res.end(http.STATUS_CODES[500]);
-					} else {
-						req.server.router.http2Send(req, res, http.STATUS_CODES[500], 500, headers || rheaders);
-					}
-				} catch (err) {
-					void 0;
-				}
-
-				this.log(e.stack, "warn");
-				reject(e);
-			};
-
 			if (res.headersSent === false) {
 				res.statusCode = status;
 
@@ -443,11 +426,11 @@ class Tenso extends HTTPMethods {
 							headers["transfer-encoding"] = "chunked";
 							delete headers["content-length"];
 							res.writeHead(status, headers);
-							body.pipe(zlib[compressionMethod]()).on("error", errHandler).on("close", () => resolve(true)).pipe(res);
+							body.pipe(zlib[compressionMethod]()).on("error", e => utility.error(req, res, this, resolve, reject, e, headers || rheaders)).on("close", () => resolve(true)).pipe(res);
 						} else {
 							zlib[compressionMethod.replace("create", "").toLowerCase()](body, (e, data) => {
 								if (e !== null) {
-									errHandler(e);
+									utility.error(req, res, this, resolve, reject, e, headers || rheaders);
 								} else {
 									headers["content-length"] = data.length;
 
@@ -482,7 +465,7 @@ class Tenso extends HTTPMethods {
 							res.writeHead(status, headers);
 
 							if (pipe === true) {
-								body.on("error", errHandler).on("close", () => resolve(true)).pipe(res);
+								body.on("error", e => utility.error(req, res, this, resolve, reject, e, headers || rheaders)).on("close", () => resolve(true)).pipe(res);
 							} else {
 								if (req.range !== void 0) {
 									res.end(Buffer.from(body.toString()).slice(req.range.start, req.range.end + 1).toString());

lib/utility.js

@@ -658,6 +658,24 @@ function bootstrap (obj) {
 	return obj;
 }
 
+function error (req, res, obj, resolve, reject, e, headers) {
+	try {
+		if (obj.config.http2 === false) {
+			res.statusCode = 500;
+			res.writeHead(500, headers);
+			res.end(http.STATUS_CODES[500]);
+		} else {
+			obj.router.http2Send(req, res, http.STATUS_CODES[500], 500, headers);
+		}
+
+		obj.log(e.stack, "warn");
+	} catch (err) {
+		void 0;
+	}
+
+	reject(e);
+}
+
 function hypermedia (server, req, rep, headers) {
 	const collection = req.parsed.pathname,
 		links = [];
@@ -805,6 +823,7 @@ module.exports = {
 	bootstrap: bootstrap,
 	capitalize: capitalize,
 	clone: clone,
+	error: error,
 	explode: explode,
 	hypermedia: hypermedia
 };

package.json

@@ -1,7 +1,7 @@
 {
   "name": "tenso",
   "description": "Tensō is an elastic REST API gateway for node.js",
-  "version": "6.2.4",
+  "version": "6.2.5",
   "homepage": "http://avoidwork.github.io/tenso",
   "author": "Jason Mulligan <[email protected]>",
   "repository": {
@@ -29,7 +29,7 @@
     "express-session": "^1.15.6",
     "keysort": "^1.0.2",
     "lusca": "^1.5.2",
-    "mimetype": "0.0.8",
+    "mimetype": "^0.0.8",
     "passport": "^0.4.0",
     "passport-facebook": "^2.1.1",
     "passport-google": "^0.3.0",
@@ -40,7 +40,7 @@
     "passport-local": "^1.0.0",
     "passport-oauth2": "^1.4.0",
     "passport-saml": "^0.31.0",
-    "passport-slack": "0.0.7",
+    "passport-slack": "^0.0.7",
     "passport-twitter": "^1.0.4",
     "precise": "^1.1.0",
     "retsu": "^3.0.1",