const express = require('express');
const router = express.Router();
const { Schedule } = require('../models');
const { Op } = require("sequelize");
const yup = require("yup");
const dayjs = require('dayjs');

router.post("/", async (req, res) => {
    let data = req.body;
    // Validate request body
    let validationSchema = yup.object().shape({
        dateTime: yup.date().required(),
        location: yup.string().trim().min(15).max(50).required(),
        postalCode: yup.string().matches(/^\d{6}$/, 'Postal code must be exactly 6 digits').required(),
        status: yup.string().trim().required()
    });
    try {
        data = await validationSchema.validate(data, { abortEarly: false });
        // Process valid data
        let result = await Schedule.create(data);
        res.json(result);
    } catch (err) {
        res.status(400).json({ errors: err.errors });
    }
});

router.get("/", async (req, res) => {
    let condition = {};
    let search = req.query.search;
    if (search) {
        condition[Op.or] = [
            { dateTime: { [Op.like]: `%${search}%` } },
            { location: { [Op.like]: `%${search}%` } },
            { postalCode: { [Op.like]: `%${search}%` } },
            { status: { [Op.like]: `%${search}%` } }
        ];
    }
    let list = await Schedule.findAll({
        where: condition,
        order: [['createdAt', 'ASC']]
    });
    res.json(list);
});

router.get("/:id", async (req, res) => {
    let id = req.params.id;
    let schedule = await Schedule.findByPk(id);
    if (!schedule) {
        res.sendStatus(404);
        return;
    }
    res.json(schedule);
});

router.put("/:id", async (req, res) => { //update
    let id = req.params.id;
    let schedule = await Schedule.findByPk(id);
    if (!schedule) {
        res.sendStatus(404);
        return;
    }
    let data = req.body;
    let validationSchema = yup.object().shape({
        dateTime: yup.date().required(),
        location: yup.string().trim().min(15).max(50).required(),
        postalCode: yup.string().matches(/^\d{6}$/, 'Postal code must be exactly 6 digits').required(),
        status: yup.string().trim().required()
    });
    try {
        data = await validationSchema.validate(data,
            { abortEarly: false });
        let num = await Schedule.update(data, {
            where: { id: id }
        });
        if (num == 1) {
            res.json({
                message: "Schedule was updated successfully."
            });
        }
        else {
            res.status(400).json({
                message: `Cannot update schedule with id ${id}.`
            });
        }
    }
    catch (err) {
        res.status(400).json({ errors: err.errors });
    }
});

router.delete("/:id", async (req, res) => {
    let id = req.params.id;
    let num = await Schedule.destroy({
        where: { id: id }
    })
    if (num == 1) {
        res.json({
            message: "Schedule was deleted successfully."
        });
    }
    else {
        res.status(400).json({
            message: `Cannot delete schedule with id ${id}.`
        });
    }
});

router.patch("/:id/status", async (req, res) => {
    try {
        const { id } = req.params;
        const schedule = await Schedule.findByPk(id);

        if (!schedule) {
            return res.status(404).json({ message: 'Schedule not found' });
        }

        const now = dayjs();
        const scheduleDateTime = dayjs(schedule.dateTime);

        const newStatus = scheduleDateTime.isAfter(now) ? "Up coming" : "Ended";
        schedule.status = newStatus;

        await schedule.save();
        res.status(200).json(schedule);
    } catch (error) {
        console.error("Error updating status:", error); // Log the error
        res.status(500).json({ message: error.message });
    }
});

module.exports = router;