src/error.js

@@ -1,4 +1,4 @@
-import { wrap } from 'boom';
+import Boom from 'boom';
 
 export default (target, key, descriptor) => {
   const fn = descriptor.value;
@@ -7,21 +7,44 @@ export default (target, key, descriptor) => {
     try {
       await fn(request, reply);
     } catch (e) {
-      const { code, detail } = e.original;
+      if (e.original) {
+        const { code, detail } = e.original;
 
-      // pg error codes https://www.postgresql.org/docs/9.5/static/errcodes-appendix.html
+        // pg error codes https://www.postgresql.org/docs/9.5/static/errcodes-appendix.html
-      if (code && (code.startsWith('22') || code.startsWith('23'))) {
+        if (code && (code.startsWith('22') || code.startsWith('23'))) {
-        const error = wrap(e, 406);
+          const error = Boom.wrap(e, 406);
 
-        // detail tends to be more specific information. So, if we have it, use.
+          // detail tends to be more specific information. So, if we have it, use.
-        if (detail) {
+          if (detail) {
-          error.message += `: ${detail}`;
+            error.message += `: ${detail}`;
-          error.reformat();
+            error.reformat();
+          }
+
+          reply(error);
         }
+      } else if (!e.isBoom) {
+        const { message } = e;
+        let err;
 
-        reply(error);
+        if (e.name === 'SequelizeValidationError')
+          err = Boom.badData(message);
+        else if (e.name === 'SequelizeConnectionTimedOutError')
+          err = Boom.gatewayTimeout(message);
+        else if (e.name === 'SequelizeHostNotReachableError')
+          err = Boom.serverUnavailable(message);
+        else if (e.name === 'SequelizeUniqueConstraintError')
+          err = Boom.conflict(message);
+        else if (e.name === 'SequelizeForeignKeyConstraintError')
+          err = Boom.expectationFailed(message);
+        else if (e.name === 'SequelizeExclusionConstraintError')
+          err = Boom.expectationFailed(message);
+        else if (e.name === 'SequelizeConnectionError')
+          err = Boom.badGateway(message);
+        else err = Boom.badImplementation(message);
+
+        reply(err);
       } else {
-        reply(wrap(e));
+        reply(e);
       }
     }
   };