Telefonsuz Request Hatasi Cozumu vs Post Requetlerde Save'den Once Modellere Validation Eklendi

routes/controllers/iletisim.js

@@ -1,4 +1,4 @@
-const { checkConnection } = require("../utils");
+const { checkConnection, validateModel} = require("../utils");
 const Iletisim = require("../../models/iletisimModel");
 const check = new (require("../../lib/Check"))();
 
@@ -53,6 +53,15 @@ module.exports = async function (fastifyInstance) {
         ip: req.ip,
       });
 
+      try {
+        await validateModel(newIletisim);
+      } catch (e) {
+        res.statusCode = 400;
+        return {
+          error: e.message,
+        };
+      }
+
       await newIletisim.save();
       return { message: "İletişim talebiniz başarıyla alındı" };
     },

routes/controllers/yardim.js

@@ -1,5 +1,5 @@
 const check = new (require("../../lib/Check"))();
-const { checkConnection } = require("../utils");
+const { checkConnection, validateModel} = require("../utils");
 const Yardim = require("../../models/yardimModel");
 const YardimKaydi = require("../../models/yardimKaydiModel");
 
@@ -190,6 +190,15 @@ module.exports = async function (fastifyInstance) {
         fields: fields || {},
       });
 
+      try {
+        await validateModel(newYardim);
+      } catch (e) {
+        res.statusCode = 400;
+        return {
+          error: e.message,
+        };
+      }
+
       fastifyInstance.selectiveFlush(LIST_PREFIX);
 
       await newYardim.save();

routes/controllers/yardimEt.js

@@ -1,5 +1,5 @@
 const check = new (require("../../lib/Check"))();
-const { checkConnection } = require("../utils");
+const { checkConnection, validateModel } = require("../utils");
 const YardimEt = require("../../models/yardimEtModel");
 const YardimKaydi = require("../../models/yardimKaydiModel");
 
@@ -91,6 +91,15 @@ module.exports = async function (fastifyInstance) {
         ip: req.ip,
       });
 
+      try {
+        await validateModel(newYardim);
+      } catch (e) {
+        res.statusCode = 400;
+        return {
+          error: e.message,
+        };
+      }
+
       await fastifyInstance.flush();
       await newYardim.save();
       return { message: "Yardım talebiniz başarıyla alındı" };

routes/controllers/yardimEtKaydi.js

@@ -1,4 +1,4 @@
-const { checkConnection } = require("../utils");
+const { checkConnection, validateModel} = require("../utils");
 const YardimEt = require("../../models/yardimEtModel");
 const check = new (require("../../lib/Check"))();
 const YardimKaydi = require("../../models/yardimKaydiModel");
@@ -51,6 +51,16 @@ module.exports = async function (fastifyInstance) {
           email: req.body.email || "",
           aciklama: req.body.aciklama || "",
         });
+
+        try {
+          await validateModel(newYardimKaydi);
+        } catch (e) {
+          res.statusCode = 400;
+          return {
+            error: e.message,
+          };
+        }
+
         await fastifyInstance.flush();
         await newYardimKaydi.save();
       } else {

routes/controllers/yardimKaydi.js

@@ -1,4 +1,4 @@
-const { checkConnection } = require("../utils");
+const { checkConnection, validateModel} = require("../utils");
 const Yardim = require("../../models/yardimModel");
 const check = new (require("../../lib/Check"))();
 const YardimKaydi = require("../../models/yardimKaydiModel");
@@ -51,6 +51,16 @@ module.exports = async function (fastifyInstance) {
           email: req.body.email || "",
           aciklama: req.body.aciklama || "",
         });
+
+        try {
+          await validateModel(newYardimKaydi);
+        } catch (e) {
+          res.statusCode = 400;
+          return {
+            error: e.message,
+          };
+        }
+
         await fastifyInstance.flush();
         await newYardimKaydi.save();
       } else {

routes/utils.js

@@ -8,6 +8,14 @@ async function checkConnection(fastifyInstance) {
   }
 }
 
+async function validateModel(model) {
+  let validationSonuc = await model.validate()
+  if (validationSonuc?.errors) {
+    throw new Error(validationSonuc.message);
+  }
+}
+
 module.exports = {
   checkConnection,
+  validateModel
 };