@terascope/job-components/dist/src/job-validator.js

'use strict';
Object.defineProperty(exports, "__esModule", { value: true });
const utils_1 = require("@terascope/utils");
const config_validators_1 = require("./config-validators");
const job_schemas_1 = require("./job-schemas");
const operation_loader_1 = require("./operation-loader");
const register_apis_1 = require("./register-apis");
class JobValidator {
    constructor(context, options = {}) {
        this.context = context;
        this.opLoader = new operation_loader_1.OperationLoader({
            terasliceOpPath: options.terasliceOpPath,
            assetPath: context.sysconfig.teraslice.assets_directory,
        });
        this.schema = job_schemas_1.jobSchema(context);
    }
    /** Validate the job configuration, including the Operations and APIs configuration */
    validateConfig(jobSpec) {
        // top level job validation occurs, but not operations
        const jobConfig = config_validators_1.validateJobConfig(this.schema, utils_1.cloneDeep(jobSpec));
        const assetIds = jobConfig.assets || [];
        const apis = {};
        const validateJobFns = [];
        const handleModule = (opConfig, op) => {
            const { Schema, API } = op;
            if (API != null) {
                apis[opConfig._op] = API;
            }
            const schema = new Schema(this.context);
            validateJobFns.push((job) => {
                if (!schema.validateJob)
                    return;
                schema.validateJob(job);
            });
            return schema.validate(opConfig);
        };
        jobConfig.operations = jobConfig.operations.map((opConfig, index) => {
            if (index === 0) {
                return handleModule(opConfig, this.opLoader.loadReader(opConfig._op, assetIds));
            }
            return handleModule(opConfig, this.opLoader.loadProcessor(opConfig._op, assetIds));
        });
        jobConfig.apis = jobConfig.apis.map((apiConfig) => {
            const { Schema } = this.opLoader.loadAPI(apiConfig._name, assetIds);
            const schema = new Schema(this.context, 'api');
            validateJobFns.push((job) => {
                if (!schema.validateJob)
                    return;
                schema.validateJob(job);
            });
            return schema.validate(apiConfig);
        });
        register_apis_1.registerApis(this.context, jobConfig);
        validateJobFns.forEach((fn) => { fn(jobConfig); });
        Object.keys(apis).forEach((name) => {
            const api = apis[name];
            this.context.apis.executionContext.addToRegistry(name, api);
        });
        return jobConfig;
    }
    hasSchema(obj, name) {
        if (!obj.schema || typeof obj.schema !== 'function') {
            throw new Error(`${name} needs to have a method named "schema"`);
        }
        else if (typeof obj.schema() !== 'object') {
            throw new Error(`${name} schema needs to return an object`);
        }
    }
}
exports.JobValidator = JobValidator;
//# sourceMappingURL=job-validator.js.map