@terascope/job-components/dist/config-validators.js

"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
const convict_1 = __importDefault(require("convict"));
const job_schemas_1 = require("./job-schemas");
// @ts-ignore
const validateOptions = { allowed: true };
/**
 * Merges the provided inputSchema with commonSchema and then validates the
 * provided opConfig against the resulting schema.
 */
function validateOpConfig(inputSchema, inputConfig) {
    const schema = Object.assign({}, job_schemas_1.opSchema, inputSchema);
    const config = convict_1.default(schema);
    try {
        config.load(inputConfig);
        config.validate(validateOptions);
    }
    catch (err) {
        throw new Error(`Validation failed for opConfig: ${inputConfig._op} - ${err.message}`);
    }
    return config.getProperties();
}
exports.validateOpConfig = validateOpConfig;
/**
 * Merges the provided inputSchema with commonSchema and then validates the
 * provided apiConfig against the resulting schema.
 */
function validateAPIConfig(inputSchema, inputConfig) {
    const schema = Object.assign({}, job_schemas_1.apiSchema, inputSchema);
    const config = convict_1.default(schema);
    try {
        config.load(inputConfig);
        config.validate(validateOptions);
    }
    catch (err) {
        throw new Error(`Validation failed for apiConfig: ${inputConfig._name} - ${err.message}`);
    }
    return config.getProperties();
}
exports.validateAPIConfig = validateAPIConfig;
/**
 * Merges the provided inputSchema with commonSchema and then validates the
 * provided jobConfig against the resulting schema.
 */
function validateJobConfig(inputSchema, inputConfig) {
    const config = convict_1.default(inputSchema);
    try {
        config.load(inputConfig);
        config.validate(validateOptions);
    }
    catch (err) {
        throw new Error(`Validation failed for jobConfig: ${inputConfig.name} - ${err.stack}`);
    }
    return config.getProperties();
}
exports.validateJobConfig = validateJobConfig;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY29uZmlnLXZhbGlkYXRvcnMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi9zcmMvY29uZmlnLXZhbGlkYXRvcnMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7QUFBQSxzREFBOEI7QUFFOUIsK0NBQW9EO0FBRXBELGFBQWE7QUFDYixNQUFNLGVBQWUsR0FBNEIsRUFBRSxPQUFPLEVBQUUsSUFBSSxFQUFFLENBQUM7QUFFbkU7OztHQUdHO0FBQ0gsU0FBZ0IsZ0JBQWdCLENBQUksV0FBZ0MsRUFBRSxXQUFnQjtJQUNsRixNQUFNLE1BQU0sR0FBRyxNQUFNLENBQUMsTUFBTSxDQUFDLEVBQUUsRUFBRSxzQkFBUSxFQUFFLFdBQVcsQ0FBaUMsQ0FBQztJQUN4RixNQUFNLE1BQU0sR0FBRyxpQkFBTyxDQUFDLE1BQU0sQ0FBQyxDQUFDO0lBRS9CLElBQUk7UUFDQSxNQUFNLENBQUMsSUFBSSxDQUFDLFdBQVcsQ0FBQyxDQUFDO1FBQ3pCLE1BQU0sQ0FBQyxRQUFRLENBQUMsZUFBZSxDQUFDLENBQUM7S0FDcEM7SUFBQyxPQUFPLEdBQUcsRUFBRTtRQUNWLE1BQU0sSUFBSSxLQUFLLENBQUMsbUNBQW1DLFdBQVcsQ0FBQyxHQUFHLE1BQU0sR0FBRyxDQUFDLE9BQU8sRUFBRSxDQUFDLENBQUM7S0FDMUY7SUFFRCxPQUFPLE1BQU0sQ0FBQyxhQUFhLEVBQUUsQ0FBQztBQUNsQyxDQUFDO0FBWkQsNENBWUM7QUFFRDs7O0dBR0c7QUFDSCxTQUFnQixpQkFBaUIsQ0FBSSxXQUFnQyxFQUFFLFdBQWdCO0lBQ25GLE1BQU0sTUFBTSxHQUFHLE1BQU0sQ0FBQyxNQUFNLENBQUMsRUFBRSxFQUFFLHVCQUFTLEVBQUUsV0FBVyxDQUFrQyxDQUFDO0lBQzFGLE1BQU0sTUFBTSxHQUFHLGlCQUFPLENBQUMsTUFBTSxDQUFDLENBQUM7SUFFL0IsSUFBSTtRQUNBLE1BQU0sQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUM7UUFDekIsTUFBTSxDQUFDLFFBQVEsQ0FBQyxlQUFlLENBQUMsQ0FBQztLQUNwQztJQUFDLE9BQU8sR0FBRyxFQUFFO1FBQ1YsTUFBTSxJQUFJLEtBQUssQ0FBQyxvQ0FBb0MsV0FBVyxDQUFDLEtBQUssTUFBTSxHQUFHLENBQUMsT0FBTyxFQUFFLENBQUMsQ0FBQztLQUM3RjtJQUVELE9BQU8sTUFBTSxDQUFDLGFBQWEsRUFBRSxDQUFDO0FBQ2xDLENBQUM7QUFaRCw4Q0FZQztBQUVEOzs7R0FHRztBQUNILFNBQWdCLGlCQUFpQixDQUFJLFdBQWdDLEVBQUUsV0FBZ0I7SUFDbkYsTUFBTSxNQUFNLEdBQUcsaUJBQU8sQ0FBQyxXQUFxRCxDQUFDLENBQUM7SUFFOUUsSUFBSTtRQUNBLE1BQU0sQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUM7UUFDekIsTUFBTSxDQUFDLFFBQVEsQ0FBQyxlQUFlLENBQUMsQ0FBQztLQUNwQztJQUFDLE9BQU8sR0FBRyxFQUFFO1FBQ1YsTUFBTSxJQUFJLEtBQUssQ0FBQyxvQ0FBb0MsV0FBVyxDQUFDLElBQUksTUFBTSxHQUFHLENBQUMsS0FBSyxFQUFFLENBQUMsQ0FBQztLQUMxRjtJQUVELE9BQU8sTUFBTSxDQUFDLGFBQWEsRUFBRSxDQUFDO0FBQ2xDLENBQUM7QUFYRCw4Q0FXQyJ9