Add/Insert Step

backend/routes/steps/delete.js

@@ -10,11 +10,15 @@ module.exports = function (sequelize) {
 
   router.delete("/:stepId", async (req, res) => {
     const stepId = req.params.stepId;
+    // TODO The caseId should not be specified from the front end, but should be traced from stepId by association.
     const caseId = req.query.parentCaseId;
 
+    const t = await sequelize.transaction();
+
     try {
       const step = await Step.findByPk(stepId);
       if (!step) {
+        await t.rollback();
         return res.status(404).send("Step not found");
       }
 
@@ -23,6 +27,7 @@ module.exports = function (sequelize) {
         where: {
           StepId: stepId,
         },
+        transaction: t,
       });
 
       // Decrease stepNo for all caseSteps with greater than the caseStep to be deleted.
@@ -35,14 +40,17 @@ module.exports = function (sequelize) {
               [Op.gt]: deletingCaseStep.stepNo,
             },
           },
+          transaction: t,
         }
       );
 
-      await step.destroy();
+      await step.destroy({ transaction: t });
 
+      await t.commit();
       res.status(204).send();
     } catch (error) {
       console.error(error);
+      await t.rollback();
       res.status(500).send("Internal Server Error");
     }
   });

backend/routes/steps/new.js

@@ -0,0 +1,63 @@
+const express = require("express");
+const router = express.Router();
+const defineStep = require("../../models/steps");
+const defineCaseStep = require("../../models/caseSteps");
+const { DataTypes, Op } = require("sequelize");
+
+module.exports = function (sequelize) {
+  const Step = defineStep(sequelize, DataTypes);
+  const CaseStep = defineCaseStep(sequelize, DataTypes);
+
+  router.post("/", async (req, res) => {
+    const newStepNo = req.query.newStepNo;
+    const caseId = req.query.parentCaseId;
+
+    const t = await sequelize.transaction();
+
+    try {
+      // Update existing stepNo for steps with stepNo greater than or equal to newStepNo
+      const maxStepNo = await CaseStep.max("stepNo", {
+        where: { caseId: caseId },
+        transaction: t,
+      });
+      if (maxStepNo >= newStepNo) {
+        await CaseStep.update(
+          { stepNo: sequelize.literal("stepNo + 1") },
+          {
+            where: {
+              caseId: caseId,
+              stepNo: { [Op.gte]: newStepNo },
+            },
+            transaction: t,
+          }
+        );
+      }
+
+      const newStep = await Step.create(
+        {
+          step: "",
+          result: "",
+        },
+        { transaction: t }
+      );
+
+      await CaseStep.create(
+        {
+          caseId: caseId,
+          stepId: newStep.id,
+          stepNo: newStepNo,
+        },
+        { transaction: t }
+      );
+
+      await t.commit();
+      res.json(newStep);
+    } catch (error) {
+      console.error(error);
+      await t.rollback();
+      res.status(500).send("Internal Server Error");
+    }
+  });
+
+  return router;
+};