@radial/validation/lib/validator.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var helpers_1 = require("@radial/helpers");
var forEach_1 = require("./rules/forEach");
var setIn = helpers_1.setInMutable;
var ValidationException = /** @class */ (function () {
    function ValidationException(errors) {
        this.errors = errors;
    }
    return ValidationException;
}());
exports.ValidationException = ValidationException;
function only(value, path, validators, data) {
    var result = validators.map(function (validator) {
        var isNil = value === undefined || value === null;
        if (isNil && validator.name !== 'notBlank' && validator.name !== 'notNull')
            return Promise.resolve();
        return Promise.resolve(validator(value, path, data, {}));
    });
    return Promise.all(result).then(function (errors) {
        return errors.filter(function (error) {
            return error !== undefined && error !== null;
        });
    }).then(function (err) {
        return err.length == 0 ? Promise.resolve() : Promise.reject(err);
    });
}
exports.only = only;
function validate(data, rules) {
    if (data === void 0) { data = {}; }
    if (rules === void 0) { rules = {}; }
    var errors = {};
    var results = Object.keys(rules).map(function (key) {
        var val = helpers_1.getIn(data, key);
        var rule = rules[key];
        if (rule instanceof forEach_1.ForEach) {
            if ((helpers_1.isBlank(val) || !Array.isArray(val)) && rule.nullable === false) {
                setIn(errors, key, ['This is required']);
                return Promise.resolve(null);
            }
            if (!Array.isArray(val) && rule.nullable)
                return Promise.resolve(null);
            var promises = val.map(function (data, index) {
                var path = key + '.' + index;
                var promise = Array.isArray(rule.rules) ? only(data, path, rule.rules, val) : validate(data, rule.rules);
                return promise.catch(function (err) {
                    setIn(errors, path, err.errors || err);
                });
            });
            return Promise.all(promises);
        }
        else {
            return new Promise(function (resolve, reject) {
                only(val, key, rules[key], data).then(function () {
                    resolve();
                }, function (e) {
                    setIn(errors, key, e);
                    resolve();
                });
            });
        }
    });
    return new Promise(function (resolve, reject) {
        Promise.all(results).then(function () {
            if (Object.keys(errors).length == 0) {
                return resolve();
            }
            reject(new ValidationException(errors));
        });
    });
}
exports.validate = validate;