bcgov/common-object-management-service

const Problem = require('api-problem');

/**
 * @function validator
 * Performs express request validation against a specified `schema`
 * @param {object} schema An object containing Joi validation schema definitions
 * @returns {function} Express middleware function
 * @throws The error encountered upon failure
 */
const validate = (schema) => {
  return (req, _res, next) => {
    const validationErrors = Object.entries(schema)
      .map(([prop, def]) => {
        const result = def.validate(req[prop], { abortEarly: false })?.error;
        return result ? [prop, result?.details] : undefined;
      })
      .filter(error => !!error);

    if (Object.keys(validationErrors).length) {
      throw new Problem(422, {
        detail: validationErrors
          .flatMap(groups => groups[1]?.map(error => error?.message))
          .join('; '),
        instance: req.originalUrl,
        errors: Object.fromEntries(validationErrors)
      });
    }
    else next();
  };
};

module.exports = {
  validate
};