CRUD Operations

// Create (C)
const createUser = async (userData) => {
    try {
        const user = new User(userData);
        const savedUser = await user.save();
        return savedUser;
    } catch (error) {
        throw error;
    }
};

// Read (R)
const getAllUsers = async () => {
    try {
        const users = await User.find();
        return users;
    } catch (error) {
        throw error;
    }
};

const getUserById = async (id) => {
    try {
        const user = await User.findById(id);
        return user;
    } catch (error) {
        throw error;
    }
};

const getUserByEmail = async (email) => {
    try {
        const user = await User.findOne({ email });
        return user;
    } catch (error) {
        throw error;
    }
};

// Update (U)
const updateUser = async (id, updateData) => {
    try {
        const user = await User.findByIdAndUpdate(id, updateData, { new: true });
        return user;
    } catch (error) {
        throw error;
    }
};

// Delete (D)
const deleteUser = async (id) => {
    try {
        const user = await User.findByIdAndDelete(id);
        return user;
    } catch (error) {
        throw error;
    }
};

// Advanced queries
const getUsersByAge = async (minAge, maxAge) => {
    try {
        const users = await User.find({
            age: { $gte: minAge, $lte: maxAge }
        });
        return users;
    } catch (error) {
        throw error;
    }
};

const searchUsers = async (searchTerm) => {
    try {
        const users = await User.find({
            $or: [
                { name: { $regex: searchTerm, $options: 'i' } },
                { email: { $regex: searchTerm, $options: 'i' } }
            ]
        });
        return users;
    } catch (error) {
        throw error;
    }
};

// Create (C)
const createUser = async (userData) => {
    try {
        const user = await User.create(userData);
        return user;
    } catch (error) {
        throw error;
    }
};

// Read (R)
const getAllUsers = async () => {
    try {
        const users = await User.findAll();
        return users;
    } catch (error) {
        throw error;
    }
};

const getUserById = async (id) => {
    try {
        const user = await User.findByPk(id);
        return user;
    } catch (error) {
        throw error;
    }
};

const getUserByEmail = async (email) => {
    try {
        const user = await User.findOne({ where: { email } });
        return user;
    } catch (error) {
        throw error;
    }
};

// Update (U)
const updateUser = async (id, updateData) => {
    try {
        const user = await User.findByPk(id);
        if (user) {
            await user.update(updateData);
            return user;
        }
        return null;
    } catch (error) {
        throw error;
    }
};

// Delete (D)
const deleteUser = async (id) => {
    try {
        const user = await User.findByPk(id);
        if (user) {
            await user.destroy();
            return user;
        }
        return null;
    } catch (error) {
        throw error;
    }
};

// Advanced queries
const { Op } = require('sequelize');

const getUsersByAge = async (minAge, maxAge) => {
    try {
        const users = await User.findAll({
            where: {
                age: {
                    [Op.between]: [minAge, maxAge]
                }
            }
        });
        return users;
    } catch (error) {
        throw error;
    }
};

const searchUsers = async (searchTerm) => {
    try {
        const users = await User.findAll({
            where: {
                [Op.or]: [
                    { name: { [Op.iLike]: `%${searchTerm}%` } },
                    { email: { [Op.iLike]: `%${searchTerm}%` } }
                ]
            }
        });
        return users;
    } catch (error) {
        throw error;
    }
};