const express = require("express");
const router = express.Router();
const defineRunCase = require("../../models/runCases");
const { DataTypes, Op } = require("sequelize");

module.exports = function (sequelize) {
  const RunCase = defineRunCase(sequelize, DataTypes);

  router.post("/bulknew", async (req, res) => {
    const recordsToCreate = req.body;

    try {
      const existingRunCases = await RunCase.findAll({
        where: {
          [Op.or]: recordsToCreate.map((record) => ({
            runId: record.runId,
            caseId: record.caseId,
          })),
        },
      });

      // Filter out records that already exist
      const recordsToCreateFiltered = recordsToCreate.filter((record) => {
        return !existingRunCases.some(
          (existingRecord) =>
            existingRecord.runId === record.runId &&
            existingRecord.caseId === record.caseId
        );
      });
      console.log(recordsToCreateFiltered)
      const newRunCases = await RunCase.bulkCreate(
        recordsToCreateFiltered.map((record) => ({
          runId: record.runId,
          caseId: record.caseId,
          status: 0,
        }))
      );

      res.json(newRunCases);
    } catch (error) {
      console.error(error);
      res.status(500).send("Internal Server Error");
    }
  });

  return router;
};