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;
};