Use JSON responses in API route handlers

Author: dex-the-ai

pages/api/user.js

@@ -10,7 +10,7 @@ async function handler(req, res) {
       try {
         body = JSON.parse(req.body);
       } catch {
-        return res.status(400).send({
+        return res.status(400).json({
           message: 'Invalid JSON body',
         });
       }
@@ -24,8 +24,8 @@ async function handler(req, res) {
      *  POST HANDLER
      */
     if (!body.email) {
-      return res.status(400).send({
-        "message": 'email is required'
+      return res.status(400).json({
+        message: 'email is required',
       });
     }
 
@@ -36,17 +36,17 @@ async function handler(req, res) {
     };
     await profileCollection.insert(profile.pid, profile)
         .then((result) => {
-          res.status(201).send({...profile, ...result});
+          res.status(201).json({ ...profile, ...result });
         })
         .catch((error) => {
           if (error.message === 'authentication failure') {
-            return res.status(401).send({
-              "message": error.message,
+            return res.status(401).json({
+              message: error.message,
             });
           }
 
-          res.status(500).send({
-            "message": `Profile Insert Failed: ${error.message}`
+          res.status(500).json({
+            message: `Profile Insert Failed: ${error.message}`,
           });
         });
   } else if (req.method === 'PUT') {
@@ -67,19 +67,21 @@ async function handler(req, res) {
 
             /* Persist updates with new doc */
             await profileCollection.upsert(req.query.pid, newDoc)
-                .then((result) => res.send({ ...newDoc, ...result }))
+                .then((result) => res.json({ ...newDoc, ...result }))
                 .catch((error) => {
                   if (error.message === 'authentication failure') {
-                    return res.status(401).send({
-                      "message": error.message,
+                    return res.status(401).json({
+                      message: error.message,
                     });
                   }
 
-                  res.status(500).send(error);
+                  res.status(500).json({
+                    message: error.message,
+                  });
                 });
           })
-          .catch((e) => res.status(500).send({
-            "message": `Profile Not Found, cannot update: ${e.message}`
+          .catch((e) => res.status(500).json({
+            message: `Profile Not Found, cannot update: ${e.message}`,
           }));
     } catch (e) {
       console.error(e);
@@ -111,9 +113,9 @@ async function handler(req, res) {
         LIMIT $LIMIT OFFSET $SKIP;
       `;
       await cluster.query(query, options)
-          .then((result) => res.send(result.rows))
-          .catch((error) => res.status(500).send({
-            "message": `Query failed: ${error.message}`
+          .then((result) => res.json(result.rows))
+          .catch((error) => res.status(500).json({
+            message: `Query failed: ${error.message}`,
           }));
     } catch (e) {
       console.error(e);
@@ -125,17 +127,17 @@ async function handler(req, res) {
     try {
       await profileCollection.remove(req.query.pid)
           .then(() => {
-            res.status(200).send({message: "Successfully Deleted: " + req.query.pid});
+            res.status(200).json({ message: `Successfully Deleted: ${req.query.pid}` });
           })
           .catch((error) => {
             if (error.message === 'authentication failure') {
-              return res.status(401).send({
-                "message": error.message,
+              return res.status(401).json({
+                message: error.message,
               });
             }
 
-            res.status(500).send({
-              "message": `Profile Not Found, cannot delete: ${error.message}`
+            res.status(500).json({
+              message: `Profile Not Found, cannot delete: ${error.message}`,
             });
           });
     } catch (e) {