37 lines
1.0 KiB
JavaScript
37 lines
1.0 KiB
JavaScript
function validateRequest(schema, source = 'body') {
|
|
return (req, res, next) => {
|
|
const dataToValidate = req[source];
|
|
const { error, value } = schema.validate(dataToValidate, {
|
|
abortEarly: false,
|
|
stripUnknown: true,
|
|
convert: true // Enable type coercion (e.g., '123' -> 123)
|
|
});
|
|
|
|
if (error) {
|
|
const errorDetails = error.details.map(detail => ({
|
|
field: detail.path.join('.'),
|
|
message: detail.message,
|
|
value: detail.context.value
|
|
}));
|
|
|
|
// Create a message that includes the field names
|
|
const fieldNames = errorDetails.map(detail => detail.field);
|
|
const message = `Validation error for field${fieldNames.length > 1 ? 's' : ''}: ${fieldNames.join(', ')}`;
|
|
|
|
return res.status(400).json({
|
|
success: false,
|
|
message: message,
|
|
details: errorDetails
|
|
});
|
|
}
|
|
|
|
// Replace the validated data source with validated and sanitized data
|
|
req[source] = value;
|
|
next();
|
|
};
|
|
}
|
|
|
|
module.exports = {
|
|
validateRequest
|
|
};
|