@terascope/job-components/dist/operation-loader.js

"use strict";
var __importDefault = (this && this.__importDefault) || function (mod) {
    return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
/* tslint:disable:variable-name */
const fs_1 = __importDefault(require("fs"));
const path_1 = __importDefault(require("path"));
const utils_1 = require("@terascope/utils");
const shims_1 = require("./operations/shims");
class OperationLoader {
    constructor(options = {}) {
        this.options = utils_1.cloneDeep(options);
        this.availableExtensions = availableExtensions();
    }
    find(name, assetIds) {
        let filePath = null;
        const findCodeFn = this.findCode(name);
        const findCodeByConvention = (basePath, subfolders) => {
            if (!basePath)
                return;
            if (!fs_1.default.existsSync(basePath))
                return;
            if (!subfolders || !subfolders.length)
                return;
            subfolders.forEach((folder) => {
                const folderPath = path_1.default.join(basePath, folder);
                if (!filePath && fs_1.default.existsSync(folderPath)) {
                    filePath = findCodeFn(folderPath);
                }
            });
        };
        findCodeByConvention(this.options.assetPath, assetIds);
        if (!filePath) {
            findCodeByConvention(this.getBuiltinDir(), ['.']);
        }
        if (!filePath) {
            findCodeByConvention(this.options.terasliceOpPath, ['readers', 'processors']);
        }
        if (!filePath) {
            filePath = this.resolvePath(name);
        }
        return filePath;
    }
    /**
     * Load any LegacyOperation
     * DEPRECATED to accommadate for new Job APIs,
     * use loadReader, or loadProcessor
    */
    load(name, assetIds) {
        const codePath = this.findOrThrow(name, assetIds);
        try {
            return this.require(codePath);
        }
        catch (err) {
            throw new Error(`Failure loading module: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
    }
    loadProcessor(name, assetIds) {
        const codePath = this.findOrThrow(name, assetIds);
        if (this.isLegacyProcessor(codePath)) {
            return this.shimLegacyProcessor(name, codePath);
        }
        let Processor;
        let Schema;
        let API;
        try {
            Processor = this.require(codePath, 'processor');
        }
        catch (err) {
            throw new Error(`Failure loading processor from module: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
        try {
            Schema = this.require(codePath, 'schema');
        }
        catch (err) {
            throw new Error(`Failure loading schema from module: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
        try {
            API = this.require(codePath, 'api');
        }
        catch (err) {
        }
        return {
            // @ts-ignore
            Processor,
            // @ts-ignore
            Schema,
            API,
        };
    }
    loadReader(name, assetIds) {
        const codePath = this.findOrThrow(name, assetIds);
        if (this.isLegacyReader(codePath)) {
            return this.shimLegacyReader(name, codePath);
        }
        let Fetcher;
        let Slicer;
        let Schema;
        let API;
        try {
            Slicer = this.require(codePath, 'slicer');
        }
        catch (err) {
            throw new Error(`Failure loading slicer from module: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
        try {
            Fetcher = this.require(codePath, 'fetcher');
        }
        catch (err) {
            throw new Error(`Failure loading fetcher from module: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
        try {
            Schema = this.require(codePath, 'schema');
        }
        catch (err) {
            throw new Error(`Failure loading schema from module: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
        try {
            API = this.require(codePath, 'api');
        }
        catch (err) {
        }
        return {
            // @ts-ignore
            Slicer,
            // @ts-ignore
            Fetcher,
            // @ts-ignore
            Schema,
            API,
        };
    }
    loadAPI(name, assetIds) {
        const [apiName] = name.split(':');
        const codePath = this.findOrThrow(apiName, assetIds);
        let API;
        try {
            API = this.require(codePath, 'api');
        }
        catch (err) {
        }
        let Observer;
        try {
            Observer = this.require(codePath, 'observer');
        }
        catch (err) {
        }
        let Schema;
        try {
            Schema = this.require(codePath, 'schema');
        }
        catch (err) {
            throw new Error(`Failure loading schema from module: ${apiName}, error: ${utils_1.parseError(err, true)}`);
        }
        if (Observer == null && API == null) {
            throw new Error(`Failure to load api module: ${apiName}, requires at least an api.js or observer.js`);
        }
        else if (Observer != null && API != null) {
            throw new Error(`Failure to load api module: ${apiName}, required only one api.js or observer.js`);
        }
        const type = API != null ? 'api' : 'observer';
        return {
            // @ts-ignore
            API: API || Observer,
            // @ts-ignore
            Schema,
            type,
        };
    }
    findOrThrow(name, assetIds) {
        this.verifyOpName(name);
        const codePath = this.find(name, assetIds);
        if (!codePath) {
            throw new Error(`Unable to find module for operation: ${name}`);
        }
        return codePath;
    }
    isLegacyReader(codePath) {
        return !this.fileExists(codePath, 'fetcher') && !this.fileExists(codePath, 'slicer');
    }
    shimLegacyReader(name, codePath) {
        try {
            return shims_1.readerShim(this.require(codePath));
        }
        catch (err) {
            throw new Error(`Failure loading reader: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
    }
    isLegacyProcessor(codePath) {
        return !this.fileExists(codePath, 'processor');
    }
    shimLegacyProcessor(name, codePath) {
        try {
            return shims_1.processorShim(this.require(codePath));
        }
        catch (err) {
            throw new Error(`Failure loading processor: ${name}, error: ${utils_1.parseError(err, true)}`);
        }
    }
    fileExists(dir, name) {
        const filePaths = this.availableExtensions.map((ext) => {
            return path_1.default.format({
                dir,
                name,
                ext,
            });
        });
        return filePaths.some((filePath) => fs_1.default.existsSync(filePath));
    }
    require(dir, name) {
        const filePaths = name ? this.availableExtensions.map((ext) => {
            return path_1.default.format({
                dir,
                name,
                ext,
            });
        }) : [dir];
        let err;
        for (const filePath of filePaths) {
            try {
                const mod = require(filePath);
                return mod.default || mod;
            }
            catch (_err) {
                err = _err;
            }
        }
        if (err) {
            throw err;
        }
        else {
            throw new Error(`Unable to find module at paths: ${filePaths.join(', ')}`);
        }
    }
    resolvePath(filePath) {
        if (fs_1.default.existsSync(filePath))
            return filePath;
        try {
            return require.resolve(filePath);
        }
        catch (err) {
            return null;
        }
    }
    verifyOpName(name) {
        if (!utils_1.isString(name)) {
            throw new TypeError('Please verify that the "_op" name exists for each operation');
        }
    }
    findCode(name) {
        let filePath = null;
        const codeNames = this.availableExtensions.map((ext) => {
            return path_1.default.format({
                name,
                ext,
            });
        });
        const allowedNames = utils_1.uniq([name, ...codeNames]);
        const invalid = [
            'node_modules',
            ...ignoreDirectories(),
        ];
        const findCode = (rootDir) => {
            const fileNames = fs_1.default.readdirSync(rootDir)
                .filter((fileName) => !invalid.includes(fileName));
            for (const fileName of fileNames) {
                if (filePath)
                    break;
                const nextPath = path_1.default.join(rootDir, fileName);
                // if name is same as fileName/dir then we found it
                if (allowedNames.includes(fileName)) {
                    filePath = this.resolvePath(nextPath);
                }
                if (!filePath && this.isDir(nextPath)) {
                    filePath = findCode(nextPath);
                }
            }
            return filePath;
        };
        return findCode;
    }
    isDir(filePath) {
        return fs_1.default.statSync(filePath).isDirectory();
    }
    getBuiltinDir() {
        if (this.availableExtensions.includes('.ts')) {
            return path_1.default.join(__dirname, 'builtin');
        }
        return path_1.default.join(__dirname, '..', 'dist', 'builtin');
    }
}
exports.OperationLoader = OperationLoader;
function availableExtensions() {
    // populated by teraslice Jest configuration
    // @ts-ignore
    return global.availableExtensions ? global.availableExtensions : ['.js'];
}
function ignoreDirectories() {
    // populated by teraslice Jest configuration
    // @ts-ignore
    return global.ignoreDirectories || [];
}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoib3BlcmF0aW9uLWxvYWRlci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3NyYy9vcGVyYXRpb24tbG9hZGVyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7O0FBQUEsa0NBQWtDO0FBQ2xDLDRDQUFvQjtBQUNwQixnREFBd0I7QUFDeEIsNENBQXlFO0FBYXpFLDhDQUErRDtBQVMvRCxNQUFhLGVBQWU7SUFJeEIsWUFBWSxVQUF5QixFQUFFO1FBQ25DLElBQUksQ0FBQyxPQUFPLEdBQUcsaUJBQVMsQ0FBQyxPQUFPLENBQUMsQ0FBQztRQUNsQyxJQUFJLENBQUMsbUJBQW1CLEdBQUcsbUJBQW1CLEVBQUUsQ0FBQztJQUNyRCxDQUFDO0lBRUQsSUFBSSxDQUFDLElBQVksRUFBRSxRQUFtQjtRQUNsQyxJQUFJLFFBQVEsR0FBa0IsSUFBSSxDQUFDO1FBQ25DLE1BQU0sVUFBVSxHQUFHLElBQUksQ0FBQyxRQUFRLENBQUMsSUFBSSxDQUFDLENBQUM7UUFFdkMsTUFBTSxvQkFBb0IsR0FBRyxDQUFDLFFBQWlCLEVBQUUsVUFBcUIsRUFBRSxFQUFFO1lBQ3RFLElBQUksQ0FBQyxRQUFRO2dCQUFFLE9BQU87WUFDdEIsSUFBSSxDQUFDLFlBQUUsQ0FBQyxVQUFVLENBQUMsUUFBUSxDQUFDO2dCQUFFLE9BQU87WUFDckMsSUFBSSxDQUFDLFVBQVUsSUFBSSxDQUFDLFVBQVUsQ0FBQyxNQUFNO2dCQUFFLE9BQU87WUFFOUMsVUFBVSxDQUFDLE9BQU8sQ0FBQyxDQUFDLE1BQWMsRUFBRSxFQUFFO2dCQUNsQyxNQUFNLFVBQVUsR0FBRyxjQUFJLENBQUMsSUFBSSxDQUFDLFFBQVEsRUFBRSxNQUFNLENBQUMsQ0FBQztnQkFDL0MsSUFBSSxDQUFDLFFBQVEsSUFBSSxZQUFFLENBQUMsVUFBVSxDQUFDLFVBQVUsQ0FBQyxFQUFFO29CQUN4QyxRQUFRLEdBQUcsVUFBVSxDQUFDLFVBQVUsQ0FBQyxDQUFDO2lCQUNyQztZQUNMLENBQUMsQ0FBQyxDQUFDO1FBQ1AsQ0FBQyxDQUFDO1FBRUYsb0JBQW9CLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxTQUFTLEVBQUUsUUFBUSxDQUFDLENBQUM7UUFFdkQsSUFBSSxDQUFDLFFBQVEsRUFBRTtZQUNYLG9CQUFvQixDQUFDLElBQUksQ0FBQyxhQUFhLEVBQUUsRUFBRSxDQUFDLEdBQUcsQ0FBQyxDQUFDLENBQUM7U0FDckQ7UUFFRCxJQUFJLENBQUMsUUFBUSxFQUFFO1lBQ1gsb0JBQW9CLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxlQUFlLEVBQUUsQ0FBQyxTQUFTLEVBQUUsWUFBWSxDQUFDLENBQUMsQ0FBQztTQUNqRjtRQUVELElBQUksQ0FBQyxRQUFRLEVBQUU7WUFDWCxRQUFRLEdBQUcsSUFBSSxDQUFDLFdBQVcsQ0FBQyxJQUFJLENBQUMsQ0FBQztTQUNyQztRQUVELE9BQU8sUUFBUSxDQUFDO0lBQ3BCLENBQUM7SUFFRDs7OztNQUlFO0lBQ0YsSUFBSSxDQUFDLElBQVksRUFBRSxRQUFtQjtRQUNsQyxNQUFNLFFBQVEsR0FBRyxJQUFJLENBQUMsV0FBVyxDQUFDLElBQUksRUFBRSxRQUFRLENBQUMsQ0FBQztRQUVsRCxJQUFJO1lBQ0EsT0FBTyxJQUFJLENBQUMsT0FBTyxDQUFDLFFBQVEsQ0FBQyxDQUFDO1NBQ2pDO1FBQUMsT0FBTyxHQUFHLEVBQUU7WUFDVixNQUFNLElBQUksS0FBSyxDQUFDLDJCQUEyQixJQUFJLFlBQVksa0JBQVUsQ0FBQyxHQUFHLEVBQUUsSUFBSSxDQUFDLEVBQUUsQ0FBQyxDQUFDO1NBQ3ZGO0lBQ0wsQ0FBQztJQUVELGFBQWEsQ0FBQyxJQUFZLEVBQUUsUUFBbUI7UUFDM0MsTUFBTSxRQUFRLEdBQUcsSUFBSSxDQUFDLFdBQVcsQ0FBQyxJQUFJLEVBQUUsUUFBUSxDQUFDLENBQUM7UUFFbEQsSUFBSSxJQUFJLENBQUMsaUJBQWlCLENBQUMsUUFBUSxDQUFDLEVBQUU7WUFDbEMsT0FBTyxJQUFJLENBQUMsbUJBQW1CLENBQUMsSUFBSSxFQUFFLFFBQVEsQ0FBQyxDQUFDO1NBQ25EO1FBRUQsSUFBSSxTQUF5QyxDQUFDO1FBQzlDLElBQUksTUFBbUMsQ0FBQztRQUN4QyxJQUFJLEdBQXNDLENBQUM7UUFFM0MsSUFBSTtZQUNBLFNBQVMsR0FBRyxJQUFJLENBQUMsT0FBTyxDQUFDLFFBQVEsRUFBRSxXQUFXLENBQUMsQ0FBQztTQUNuRDtRQUFDLE9BQU8sR0FBRyxFQUFFO1lBQ1YsTUFBTSxJQUFJLEtBQUssQ0FBQywwQ0FBMEMsSUFBSSxZQUFZLGtCQUFVLENBQUMsR0FBRyxFQUFFLElBQUksQ0FBQyxFQUFFLENBQUMsQ0FBQztTQUN0RztRQUVELElBQUk7WUFDQSxNQUFNLEdBQUcsSUFBSSxDQUFDLE9BQU8sQ0FBQyxRQUFRLEVBQUUsUUFBUSxDQUFDLENBQUM7U0FDN0M7UUFBQyxPQUFPLEdBQUcsRUFBRTtZQUNWLE1BQU0sSUFBSSxLQUFLLENBQUMsdUNBQXVDLElBQUksWUFBWSxrQkFBVSxDQUFDLEdBQUcsRUFBRSxJQUFJLENBQUMsRUFBRSxDQUFDLENBQUM7U0FDbkc7UUFFRCxJQUFJO1lBQ0EsR0FBRyxHQUFHLElBQUksQ0FBQyxPQUFPLENBQUMsUUFBUSxFQUFFLEtBQUssQ0FBQyxDQUFDO1NBQ3ZDO1FBQUMsT0FBTyxHQUFHLEVBQUU7U0FDYjtRQUVELE9BQU87WUFDSCxhQUFhO1lBQ2IsU0FBUztZQUNULGFBQWE7WUFDYixNQUFNO1lBQ04sR0FBRztTQUNOLENBQUM7SUFDTixDQUFDO0lBRUQsVUFBVSxDQUFDLElBQVksRUFBRSxRQUFtQjtRQUN4QyxNQUFNLFFBQVEsR0FBRyxJQUFJLENBQUMsV0FBVyxDQUFDLElBQUksRUFBRSxRQUFRLENBQUMsQ0FBQztRQUVsRCxJQUFJLElBQUksQ0FBQyxjQUFjLENBQUMsUUFBUSxDQUFDLEVBQUU7WUFDL0IsT0FBTyxJQUFJLENBQUMsZ0JBQWdCLENBQUMsSUFBSSxFQUFFLFFBQVEsQ0FBQyxDQUFDO1NBQ2hEO1FBRUQsSUFBSSxPQUFxQyxDQUFDO1FBQzFDLElBQUksTUFBbUMsQ0FBQztRQUN4QyxJQUFJLE1BQW1DLENBQUM7UUFDeEMsSUFBSSxHQUFzQyxDQUFDO1FBRTNDLElBQUk7WUFDQSxNQUFNLEdBQUcsSUFBSSxDQUFDLE9BQU8sQ0FBQyxRQUFRLEVBQUUsUUFBUSxDQUFDLENBQUM7U0FDN0M7UUFBQyxPQUFPLEdBQUcsRUFBRTtZQUNWLE1BQU0sSUFBSSxLQUFLLENBQUMsdUNBQXVDLElBQUksWUFBWSxrQkFBVSxDQUFDLEdBQUcsRUFBRSxJQUFJLENBQUMsRUFBRSxDQUFDLENBQUM7U0FDbkc7UUFFRCxJQUFJO1lBQ0EsT0FBTyxHQUFHLElBQUksQ0FBQyxPQUFPLENBQUMsUUFBUSxFQUFFLFNBQVMsQ0FBQyxDQUFDO1NBQy9DO1FBQUMsT0FBTyxHQUFHLEVBQUU7WUFDVixNQUFNLElBQUksS0FBSyxDQUFDLHdDQUF3QyxJQUFJLFlBQVksa0JBQVUsQ0FBQyxHQUFHLEVBQUUsSUFBSSxDQUFDLEVBQUUsQ0FBQyxDQUFDO1NBQ3BHO1FBRUQsSUFBSTtZQUNBLE1BQU0sR0FBRyxJQUFJLENBQUMsT0FBTyxDQUFDLFFBQVEsRUFBRSxRQUFRLENBQUMsQ0FBQztTQUM3QztRQUFDLE9BQU8sR0FBRyxFQUFFO1lBQ1YsTUFBTSxJQUFJLEtBQUssQ0FBQyx1Q0FBdUMsSUFBSSxZQUFZLGtCQUFVLENBQUMsR0FBRyxFQUFFLElBQUksQ0FBQyxFQUFFLENBQUMsQ0FBQztTQUNuRztRQUVELElBQUk7WUFDQSxHQUFHLEdBQUcsSUFBSSxDQUFDLE9BQU8sQ0FBQyxRQUFRLEVBQUUsS0FBSyxDQUFDLENBQUM7U0FDdkM7UUFBQyxPQUFPLEdBQUcsRUFBRTtTQUNiO1FBRUQsT0FBTztZQUNILGFBQWE7WUFDYixNQUFNO1lBQ04sYUFBYTtZQUNiLE9BQU87WUFDUCxhQUFhO1lBQ2IsTUFBTTtZQUNOLEdBQUc7U0FDTixDQUFDO0lBQ04sQ0FBQztJQUVELE9BQU8sQ0FBQyxJQUFZLEVBQUUsUUFBbUI7UUFDckMsTUFBTSxDQUFDLE9BQU8sQ0FBQyxHQUFHLElBQUksQ0FBQyxLQUFLLENBQUMsR0FBRyxDQUFDLENBQUM7UUFDbEMsTUFBTSxRQUFRLEdBQUcsSUFBSSxDQUFDLFdBQVcsQ0FBQyxPQUFPLEVBQUUsUUFBUSxDQUFDLENBQUM7UUFFckQsSUFBSSxHQUFzQyxDQUFDO1FBRTNDLElBQUk7WUFDQSxHQUFHLEdBQUcsSUFBSSxDQUFDLE9BQU8sQ0FBQyxRQUFRLEVBQUUsS0FBSyxDQUFDLENBQUM7U0FDdkM7UUFBQyxPQUFPLEdBQUcsRUFBRTtTQUNiO1FBRUQsSUFBSSxRQUF1QyxDQUFDO1FBRTVDLElBQUk7WUFDQSxRQUFRLEdBQUcsSUFBSSxDQUFDLE9BQU8sQ0FBQyxRQUFRLEVBQUUsVUFBVSxDQUFDLENBQUM7U0FDakQ7UUFBQyxPQUFPLEdBQUcsRUFBRTtTQUNiO1FBRUQsSUFBSSxNQUFtQyxDQUFDO1FBRXhDLElBQUk7WUFDQSxNQUFNLEdBQUcsSUFBSSxDQUFDLE9BQU8sQ0FBQyxRQUFRLEVBQUUsUUFBUSxDQUFDLENBQUM7U0FDN0M7UUFBQyxPQUFPLEdBQUcsRUFBRTtZQUNWLE1BQU0sSUFBSSxLQUFLLENBQUMsdUNBQXVDLE9BQU8sWUFBWSxrQkFBVSxDQUFDLEdBQUcsRUFBRSxJQUFJLENBQUMsRUFBRSxDQUFDLENBQUM7U0FDdEc7UUFFRCxJQUFJLFFBQVEsSUFBSSxJQUFJLElBQUksR0FBRyxJQUFJLElBQUksRUFBRTtZQUNqQyxNQUFNLElBQUksS0FBSyxDQUFDLCtCQUErQixPQUFPLDhDQUE4QyxDQUFDLENBQUM7U0FDekc7YUFBTSxJQUFJLFFBQVEsSUFBSSxJQUFJLElBQUksR0FBRyxJQUFJLElBQUksRUFBRTtZQUN4QyxNQUFNLElBQUksS0FBSyxDQUFDLCtCQUErQixPQUFPLDJDQUEyQyxDQUFDLENBQUM7U0FDdEc7UUFFRCxNQUFNLElBQUksR0FBRyxHQUFHLElBQUksSUFBSSxDQUFDLENBQUMsQ0FBQyxLQUFLLENBQUMsQ0FBQyxDQUFDLFVBQVUsQ0FBQztRQUU5QyxPQUFPO1lBQ0gsYUFBYTtZQUNiLEdBQUcsRUFBRSxHQUFHLElBQUksUUFBUTtZQUNwQixhQUFhO1lBQ2IsTUFBTTtZQUNOLElBQUk7U0FDUCxDQUFDO0lBQ04sQ0FBQztJQUVPLFdBQVcsQ0FBQyxJQUFZLEVBQUUsUUFBbUI7UUFDakQsSUFBSSxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsQ0FBQztRQUV4QixNQUFNLFFBQVEsR0FBRyxJQUFJLENBQUMsSUFBSSxDQUFDLElBQUksRUFBRSxRQUFRLENBQUMsQ0FBQztRQUMzQyxJQUFJLENBQUMsUUFBUSxFQUFFO1lBQ1gsTUFBTSxJQUFJLEtBQUssQ0FBQyx3Q0FBd0MsSUFBSSxFQUFFLENBQUMsQ0FBQztTQUNuRTtRQUVELE9BQU8sUUFBUSxDQUFDO0lBQ3BCLENBQUM7SUFFTyxjQUFjLENBQUMsUUFBZ0I7UUFDbkMsT0FBTyxDQUFDLElBQUksQ0FBQyxVQUFVLENBQUMsUUFBUSxFQUFFLFNBQVMsQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDLFVBQVUsQ0FBQyxRQUFRLEVBQUUsUUFBUSxDQUFDLENBQUM7SUFDekYsQ0FBQztJQUVPLGdCQUFnQixDQUFDLElBQVksRUFBRSxRQUFnQjtRQUNuRCxJQUFJO1lBQ0EsT0FBTyxrQkFBVSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztTQUM3QztRQUFDLE9BQU8sR0FBRyxFQUFFO1lBQ1YsTUFBTSxJQUFJLEtBQUssQ0FBQywyQkFBMkIsSUFBSSxZQUFZLGtCQUFVLENBQUMsR0FBRyxFQUFFLElBQUksQ0FBQyxFQUFFLENBQUMsQ0FBQztTQUN2RjtJQUNMLENBQUM7SUFFTyxpQkFBaUIsQ0FBQyxRQUFnQjtRQUN0QyxPQUFPLENBQUMsSUFBSSxDQUFDLFVBQVUsQ0FBQyxRQUFRLEVBQUUsV0FBVyxDQUFDLENBQUM7SUFDbkQsQ0FBQztJQUVPLG1CQUFtQixDQUFDLElBQVksRUFBRSxRQUFnQjtRQUN0RCxJQUFJO1lBQ0EsT0FBTyxxQkFBYSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsUUFBUSxDQUFDLENBQUMsQ0FBQztTQUNoRDtRQUFDLE9BQU8sR0FBRyxFQUFFO1lBQ1YsTUFBTSxJQUFJLEtBQUssQ0FBQyw4QkFBOEIsSUFBSSxZQUFZLGtCQUFVLENBQUMsR0FBRyxFQUFFLElBQUksQ0FBQyxFQUFFLENBQUMsQ0FBQztTQUMxRjtJQUNMLENBQUM7SUFFTyxVQUFVLENBQUMsR0FBVyxFQUFFLElBQVk7UUFDeEMsTUFBTSxTQUFTLEdBQUcsSUFBSSxDQUFDLG1CQUFtQixDQUFDLEdBQUcsQ0FBQyxDQUFDLEdBQUcsRUFBRSxFQUFFO1lBQ25ELE9BQU8sY0FBSSxDQUFDLE1BQU0sQ0FBQztnQkFDZixHQUFHO2dCQUNILElBQUk7Z0JBQ0osR0FBRzthQUNOLENBQUMsQ0FBQztRQUNQLENBQUMsQ0FBQyxDQUFDO1FBQ0gsT0FBTyxTQUFTLENBQUMsSUFBSSxDQUFDLENBQUMsUUFBUSxFQUFFLEVBQUUsQ0FBQyxZQUFFLENBQUMsVUFBVSxDQUFDLFFBQVEsQ0FBQyxDQUFDLENBQUM7SUFDakUsQ0FBQztJQUVPLE9BQU8sQ0FBSSxHQUFXLEVBQUUsSUFBYTtRQUN6QyxNQUFNLFNBQVMsR0FBRyxJQUFJLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxtQkFBbUIsQ0FBQyxHQUFHLENBQUMsQ0FBQyxHQUFHLEVBQUUsRUFBRTtZQUMxRCxPQUFPLGNBQUksQ0FBQyxNQUFNLENBQUM7Z0JBQ2YsR0FBRztnQkFDSCxJQUFJO2dCQUNKLEdBQUc7YUFDTixDQUFDLENBQUM7UUFDUCxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQyxHQUFHLENBQUMsQ0FBQztRQUVYLElBQUksR0FBb0IsQ0FBQztRQUV6QixLQUFLLE1BQU0sUUFBUSxJQUFJLFNBQVMsRUFBRTtZQUM5QixJQUFJO2dCQUNBLE1BQU0sR0FBRyxHQUFHLE9BQU8sQ0FBQyxRQUFRLENBQUMsQ0FBQztnQkFDOUIsT0FBTyxHQUFHLENBQUMsT0FBTyxJQUFJLEdBQUcsQ0FBQzthQUM3QjtZQUFDLE9BQU8sSUFBSSxFQUFFO2dCQUNYLEdBQUcsR0FBRyxJQUFJLENBQUM7YUFDZDtTQUNKO1FBRUQsSUFBSSxHQUFHLEVBQUU7WUFDTCxNQUFNLEdBQUcsQ0FBQztTQUNiO2FBQU07WUFDSCxNQUFNLElBQUksS0FBSyxDQUFDLG1DQUFtQyxTQUFTLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxFQUFFLENBQUMsQ0FBQztTQUM5RTtJQUNMLENBQUM7SUFFTyxXQUFXLENBQUMsUUFBZ0I7UUFDaEMsSUFBSSxZQUFFLENBQUMsVUFBVSxDQUFDLFFBQVEsQ0FBQztZQUFFLE9BQU8sUUFBUSxDQUFDO1FBRTdDLElBQUk7WUFDQSxPQUFPLE9BQU8sQ0FBQyxPQUFPLENBQUMsUUFBUSxDQUFDLENBQUM7U0FDcEM7UUFBQyxPQUFPLEdBQUcsRUFBRTtZQUNWLE9BQU8sSUFBSSxDQUFDO1NBQ2Y7SUFDTCxDQUFDO0lBRU8sWUFBWSxDQUFDLElBQVk7UUFDN0IsSUFBSSxDQUFDLGdCQUFRLENBQUMsSUFBSSxDQUFDLEVBQUU7WUFDakIsTUFBTSxJQUFJLFNBQVMsQ0FBQyw2REFBNkQsQ0FBQyxDQUFDO1NBQ3RGO0lBQ0wsQ0FBQztJQUVPLFFBQVEsQ0FBQyxJQUFZO1FBQ3pCLElBQUksUUFBUSxHQUFrQixJQUFJLENBQUM7UUFFbkMsTUFBTSxTQUFTLEdBQUcsSUFBSSxDQUFDLG1CQUFtQixDQUFDLEdBQUcsQ0FBQyxDQUFDLEdBQUcsRUFBRSxFQUFFO1lBQ25ELE9BQU8sY0FBSSxDQUFDLE1BQU0sQ0FBQztnQkFDZixJQUFJO2dCQUNKLEdBQUc7YUFDTixDQUFDLENBQUM7UUFDUCxDQUFDLENBQUMsQ0FBQztRQUVILE1BQU0sWUFBWSxHQUFHLFlBQUksQ0FBQyxDQUFDLElBQUksRUFBRSxHQUFHLFNBQVMsQ0FBQyxDQUFDLENBQUM7UUFFaEQsTUFBTSxPQUFPLEdBQUc7WUFDWixjQUFjO1lBQ2QsR0FBRyxpQkFBaUIsRUFBRTtTQUN6QixDQUFDO1FBRUYsTUFBTSxRQUFRLEdBQUcsQ0FBQyxPQUFlLEVBQWUsRUFBRTtZQUM5QyxNQUFNLFNBQVMsR0FBRyxZQUFFLENBQUMsV0FBVyxDQUFDLE9BQU8sQ0FBQztpQkFDcEMsTUFBTSxDQUFDLENBQUMsUUFBZ0IsRUFBRSxFQUFFLENBQUMsQ0FBQyxPQUFPLENBQUMsUUFBUSxDQUFDLFFBQVEsQ0FBQyxDQUFDLENBQUM7WUFFL0QsS0FBSyxNQUFNLFFBQVEsSUFBSSxTQUFTLEVBQUU7Z0JBQzlCLElBQUksUUFBUTtvQkFBRSxNQUFNO2dCQUVwQixNQUFNLFFBQVEsR0FBRyxjQUFJLENBQUMsSUFBSSxDQUFDLE9BQU8sRUFBRSxRQUFRLENBQUMsQ0FBQztnQkFFOUMsbURBQW1EO2dCQUNuRCxJQUFJLFlBQVksQ0FBQyxRQUFRLENBQUMsUUFBUSxDQUFDLEVBQUU7b0JBQ2pDLFFBQVEsR0FBRyxJQUFJLENBQUMsV0FBVyxDQUFDLFFBQVEsQ0FBQyxDQUFDO2lCQUN6QztnQkFFRCxJQUFJLENBQUMsUUFBUSxJQUFJLElBQUksQ0FBQyxLQUFLLENBQUMsUUFBUSxDQUFDLEVBQUU7b0JBQ25DLFFBQVEsR0FBRyxRQUFRLENBQUMsUUFBUSxDQUFDLENBQUM7aUJBQ2pDO2FBQ0o7WUFFRCxPQUFPLFFBQVEsQ0FBQztRQUNwQixDQUFDLENBQUM7UUFFRixPQUFPLFFBQVEsQ0FBQztJQUNwQixDQUFDO0lBRU8sS0FBSyxDQUFDLFFBQWdCO1FBQzFCLE9BQU8sWUFBRSxDQUFDLFFBQVEsQ0FBQyxRQUFRLENBQUMsQ0FBQyxXQUFXLEVBQUUsQ0FBQztJQUMvQyxDQUFDO0lBRU8sYUFBYTtRQUNqQixJQUFJLElBQUksQ0FBQyxtQkFBbUIsQ0FBQyxRQUFRLENBQUMsS0FBSyxDQUFDLEVBQUU7WUFDMUMsT0FBTyxjQUFJLENBQUMsSUFBSSxDQUFDLFNBQVMsRUFBRSxTQUFTLENBQUMsQ0FBQztTQUMxQztRQUNELE9BQU8sY0FBSSxDQUFDLElBQUksQ0FBQyxTQUFTLEVBQUUsSUFBSSxFQUFFLE1BQU0sRUFBRSxTQUFTLENBQUMsQ0FBQztJQUN6RCxDQUFDO0NBQ0o7QUFyVUQsMENBcVVDO0FBRUQsU0FBUyxtQkFBbUI7SUFDeEIsNENBQTRDO0lBQzVDLGFBQWE7SUFDYixPQUFPLE1BQU0sQ0FBQyxtQkFBbUIsQ0FBQyxDQUFDLENBQUMsTUFBTSxDQUFDLG1CQUFtQixDQUFDLENBQUMsQ0FBQyxDQUFDLEtBQUssQ0FBQyxDQUFDO0FBQzdFLENBQUM7QUFFRCxTQUFTLGlCQUFpQjtJQUN0Qiw0Q0FBNEM7SUFDNUMsYUFBYTtJQUNiLE9BQU8sTUFBTSxDQUFDLGlCQUFpQixJQUFJLEVBQUUsQ0FBQztBQUMxQyxDQUFDIn0=