feat(js): handle internal server errors and avoid failing a whole app

Part of #48

Author: php-coder

examples/js/express/mysql/routes.js

@@ -1,11 +1,11 @@
 const register = (app, pool) => {
 
-    app.get('/v1/categories/count', (req, res) => {
+    app.get('/v1/categories/count', (req, res, next) => {
         pool.query(
             'SELECT COUNT(*) AS counter FROM categories',
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 if (rows.length === 0) {
                     res.status(404).end()
@@ -16,13 +16,13 @@ const register = (app, pool) => {
         )
     })
 
-    app.get('/v1/collections/:collectionId/categories/count', (req, res) => {
+    app.get('/v1/collections/:collectionId/categories/count', (req, res, next) => {
         pool.query(
             'SELECT COUNT(DISTINCT s.category_id) AS counter FROM collections_series cs JOIN series s ON s.id = cs.series_id WHERE cs.collection_id = :collectionId',
             { "collectionId": req.params.collectionId },
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 if (rows.length === 0) {
                     res.status(404).end()
@@ -33,39 +33,39 @@ const register = (app, pool) => {
         )
     })
 
-    app.get('/v1/categories', (req, res) => {
+    app.get('/v1/categories', (req, res, next) => {
         pool.query(
             'SELECT id , name , name_ru , slug FROM categories LIMIT :limit',
             { "limit": req.query.limit },
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 res.json(rows)
             }
         )
     })
 
-    app.post('/v1/categories', (req, res) => {
+    app.post('/v1/categories', (req, res, next) => {
         pool.query(
             'INSERT INTO categories ( name , name_ru , slug , created_at , created_by , updated_at , updated_by ) VALUES ( :name , :name_ru , :slug , NOW() , :user_id , NOW() , :user_id )',
             { "name": req.body.name, "name_ru": req.body.name_ru, "slug": req.body.slug, "user_id": req.body.user_id },
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 res.sendStatus(204)
             }
         )
     })
 
-    app.get('/v1/categories/:categoryId', (req, res) => {
+    app.get('/v1/categories/:categoryId', (req, res, next) => {
         pool.query(
             'SELECT id , name , name_ru , slug FROM categories WHERE id = :categoryId',
             { "categoryId": req.params.categoryId },
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 if (rows.length === 0) {
                     res.status(404).end()
@@ -76,32 +76,36 @@ const register = (app, pool) => {
         )
     })
 
-    app.put('/v1/categories/:categoryId', (req, res) => {
+    app.put('/v1/categories/:categoryId', (req, res, next) => {
         pool.query(
             'UPDATE categories SET name = :name , name_ru = :name_ru , slug = :slug , updated_at = NOW() , updated_by = :user_id WHERE id = :categoryId',
             { "name": req.body.name, "name_ru": req.body.name_ru, "slug": req.body.slug, "user_id": req.body.user_id, "categoryId": req.params.categoryId },
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 res.sendStatus(204)
             }
         )
     })
 
-    app.delete('/v1/categories/:categoryId', (req, res) => {
+    app.delete('/v1/categories/:categoryId', (req, res, next) => {
         pool.query(
             'DELETE FROM categories WHERE id = :categoryId',
             { "categoryId": req.params.categoryId },
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 res.sendStatus(204)
             }
         )
     })
 
+    app.use((error, req, res, next) => {
+        console.error(error)
+        res.status(500).json({ "error": "Internal Server Error" })
+    })
 }
 
 exports.register = register;

src/templates/routes.js.ejs

@@ -18,12 +18,12 @@ endpoints.forEach(function(endpoint) {
 
         if (hasGetOne || hasGetMany) {
 %>
-    app.get('<%- path %>', (req, res) => {
+    app.get('<%- path %>', (req, res, next) => {
         pool.query(
             '<%- sql %>',<%- formattedParams %>
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
 <%          if (hasGetMany) { -%>
                 res.json(rows)
@@ -41,12 +41,12 @@ endpoints.forEach(function(endpoint) {
         }
         if (method.name === 'post') {
 %>
-    app.post('<%- path %>', (req, res) => {
+    app.post('<%- path %>', (req, res, next) => {
         pool.query(
             '<%- sql %>',<%- formattedParams %>
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 res.sendStatus(204)
             }
@@ -56,12 +56,12 @@ endpoints.forEach(function(endpoint) {
         }
         if (method.name === 'put') {
 %>
-    app.put('<%- path %>', (req, res) => {
+    app.put('<%- path %>', (req, res, next) => {
         pool.query(
             '<%- sql %>',<%- formattedParams %>
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 res.sendStatus(204)
             }
@@ -71,12 +71,12 @@ endpoints.forEach(function(endpoint) {
         }
         if (method.name === 'delete') {
 %>
-    app.delete('<%- path %>', (req, res) => {
+    app.delete('<%- path %>', (req, res, next) => {
         pool.query(
             '<%- sql %>',<%- formattedParams %>
             (err, rows, fields) => {
                 if (err) {
-                    throw err
+                    return next(err)
                 }
                 res.sendStatus(204)
             }
@@ -87,6 +87,10 @@ endpoints.forEach(function(endpoint) {
     });
 });
 %>
+    app.use((error, req, res, next) => {
+        console.error(error)
+        res.status(500).json({ "error": "Internal Server Error" })
+    })
 }
 
 exports.register = register;