@gabliam/core/src/value-extractor.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const expression_1 = require("@gabliam/expression");
const _ = require("lodash");
const constants_1 = require("./constants");
const errors_1 = require("./errors");
const joi_1 = require("./joi");
/**
 * Validate a value
 * @param  {string} path
 * @param  {any} value
 * @param  {ValueValidator} validator
 */
function valueValidator(path, value, validator) {
    const options = Object.assign({ abortEarly: false }, (validator.options || {}));
    const validate = joi_1.Joi.validate(value, validator.schema, options);
    if (validate.error) {
        if (validator.throwError) {
            const msg = validator.customErrorMsg || `Error for '${path}' value`;
            throw new errors_1.ValueValidationError(msg, validate.error);
        }
        else {
            return null;
        }
    }
    return validate.value;
}
/**
 * Create value extractor
 * @param  {Container} container
 */
function configureValueExtractor(container) {
    /**
     * Get value in configuration
     * @param  {string} path
     * @param  {any} defaultValue
     * @param  {ValueValidator|null} validator?
     * @returns any
     */
    return (path, defaultValue, validator) => {
        let value = undefined;
        const config = container.get(constants_1.APP_CONFIG);
        try {
            const expression = new expression_1.ExpressionParser(config).parseExpression(path);
            value = expression.getValue();
        }
        catch (_a) { }
        if (value === undefined) {
            value = _.get(config, path, defaultValue);
        }
        try {
            if (validator) {
                value = valueValidator(path, value, validator);
            }
            return value;
        }
        catch (err) {
            if (err instanceof errors_1.ValueValidationError) {
                throw err;
            }
        }
    };
}
exports.configureValueExtractor = configureValueExtractor;