const { updateUser, getUserById } = require('~/models'); const MAX_FAVORITES = 50; const MAX_STRING_LENGTH = 256; const updateFavoritesController = async (req, res) => { try { const { favorites } = req.body; const userId = req.user.id; if (!favorites) { return res.status(400).json({ message: 'Favorites data is required' }); } if (!Array.isArray(favorites)) { return res.status(400).json({ message: 'Favorites must be an array' }); } if (favorites.length > MAX_FAVORITES) { return res.status(400).json({ code: 'MAX_FAVORITES_EXCEEDED', message: `Maximum ${MAX_FAVORITES} favorites allowed`, limit: MAX_FAVORITES, }); } for (const fav of favorites) { const hasAgent = !!fav.agentId; const hasModel = !!(fav.model && fav.endpoint); const hasSpec = !!fav.spec; if (fav.agentId && fav.agentId.length > MAX_STRING_LENGTH) { return res .status(400) .json({ message: `agentId exceeds maximum length of ${MAX_STRING_LENGTH}` }); } if (fav.model && fav.model.length > MAX_STRING_LENGTH) { return res .status(400) .json({ message: `model exceeds maximum length of ${MAX_STRING_LENGTH}` }); } if (fav.endpoint && fav.endpoint.length > MAX_STRING_LENGTH) { return res .status(400) .json({ message: `endpoint exceeds maximum length of ${MAX_STRING_LENGTH}` }); } if (fav.spec !== undefined && fav.spec !== null) { if (typeof fav.spec !== 'string' || fav.spec.length === 0) { return res.status(400).json({ message: 'spec must be a non-empty string' }); } if (fav.spec.length > MAX_STRING_LENGTH) { return res .status(400) .json({ message: `spec exceeds maximum length of ${MAX_STRING_LENGTH}` }); } } const hasPartialModel = !hasModel && !!(fav.model || fav.endpoint); if (hasPartialModel && !hasAgent && !hasSpec) { return res.status(400).json({ message: 'model and endpoint must be provided together' }); } const typeCount = [hasAgent, hasModel, hasSpec].filter(Boolean).length; if (typeCount === 0) { return res.status(400).json({ message: 'Each favorite must have either agentId, model+endpoint, or spec', }); } if (typeCount > 1) { return res.status(400).json({ message: 'Favorite cannot have multiple types (agentId, model/endpoint, or spec)', }); } if (hasSpec && (fav.agentId || fav.model || fav.endpoint)) { return res .status(400) .json({ message: 'spec cannot be combined with agentId, model, or endpoint' }); } if (hasAgent && (fav.model || fav.endpoint)) { return res .status(400) .json({ message: 'agentId cannot be combined with model or endpoint' }); } } const user = await updateUser(userId, { favorites }); if (!user) { return res.status(404).json({ message: 'User not found' }); } return res.status(200).json(user.favorites); } catch (error) { console.error('Error updating favorites:', error); return res.status(500).json({ message: 'Internal server error' }); } }; const getFavoritesController = async (req, res) => { try { const userId = req.user.id; const user = await getUserById(userId, 'favorites'); if (!user) { return res.status(404).json({ message: 'User not found' }); } let favorites = user.favorites || []; if (!Array.isArray(favorites)) { favorites = []; await updateUser(userId, { favorites: [] }); } return res.status(200).json(favorites); } catch (error) { console.error('Error fetching favorites:', error); return res.status(500).json({ message: 'Internal server error' }); } }; module.exports = { updateFavoritesController, getFavoritesController, };