@terascope/job-components/dist/src/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");
const validateOptions = {
    // IMPORTANT: changing this will break things
    // @ts-ignore because this is deprecated and will be removed in ^5.0.0
    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 operation config: ${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 api config: ${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 job config: ${inputConfig.name} - ${err.message}`);
    }
    return config.getProperties();
}
exports.validateJobConfig = validateJobConfig;
//# sourceMappingURL=config-validators.js.map