Changes after PR Review

components/polls/index.js

@@ -148,11 +148,11 @@ const addPoll = async (req, response) => {
       return element._id;
     });
 
-    const pollExists = await db_connect
+    const doesPollExists = await db_connect
       .collection("Polls")
       .findOne({ payloadBytes });
 
-    if (pollExists) {
+    if (doesPollExists) {
       throw new Error("Invalid Signature, Poll already exists");
     }
 

package.json

@@ -5,6 +5,7 @@
   "main": "./server.js",
   "scripts": {
     "test": "jest",
+    "start":"node ./server.js",
     "dev": "nodemon ./server.js"
   },
   "jest": {
@@ -33,6 +34,7 @@
     "jest": "^29.7.0",
     "jest-mock": "^29.7.0",
     "mongodb-memory-server": "^9.1.4",
+    "nodemon": "^3.1.0",
     "supertest": "^6.3.3"
   }
 }

routes/tokens.js

@@ -1,4 +1,5 @@
 const express = require("express");
+const {catchAsync} = require("../services/response.util");
 
 // recordRoutes is an instance of the express router.
 // We use it to define our routes.
@@ -87,6 +88,6 @@ tokensRoutes.route("/token/:id").get(getTokenById);
  */
 tokensRoutes
   .route("/network/:network/token/:address/token-id/:tokenID/voting-power")
-  .get(getVotingPowerAtLevel);
+  .get(catchAsync(getVotingPowerAtLevel));
 
 module.exports = tokensRoutes;

services/ipfs.service.js

@@ -4,7 +4,7 @@ const { NFTStorage } = require('nft.storage')
 const NFT_STORAGE_KEY = AppConfig.IPFS.NFT_STORAGE_TOKEN
 
 async function uploadToIPFS(jsonData) {
-    const data = new Blob([jsonData])
+    const data = new Blob([jsonData], { type: 'text/plain' })
     const client = new NFTStorage({ token: NFT_STORAGE_KEY })
     const cid = await client.storeBlob(data)
     return cid

services/response.util.js

@@ -0,0 +1,34 @@
+const catchAsync = (fn) => (req, res, next) => {
+    Promise.resolve(fn(req, res, next)).catch((err) => {
+        const errName = err.name
+        const errMessage = err.message;
+
+        console.error({ errName })
+        if (!errMessage) errMessage = err;
+
+
+        console.error('CaughtError:', err);
+        console.error('ErrorStack:', err.stack)
+        console.error('ErrorPayload:', JSON.stringify(req.body));
+        console.error('ErrorParams:', req.params);
+        console.error('--------------------xxxxxx--------------------');
+        console.error(err.stack)
+
+        let responseStatusCode = 500;
+        if (err.statusCode) responseStatusCode = err.statusCode
+
+        try {
+            errMessage = JSON.parse(errMessage)
+            errMessage = errMessage.map(ex => ex.message).join(",")
+        } catch (e) { }
+
+        return res.status(responseStatusCode).json({
+            success: false,
+            message: errMessage,
+        });
+    });
+};
+
+module.exports = {
+    catchAsync
+}