@stoplight/graphite/plugins/stoplight-config/index.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const tslib_1 = require("tslib");
const path_1 = require("@stoplight/path");
const types_1 = require("@stoplight/types");
const eol = require("eol");
const lodash_1 = require("lodash");
const filesystem_1 = require("../../backends/filesystem");
const graph_1 = require("../../graph");
const utils_1 = require("../../graph/utils");
const notifier_1 = require("../../notifier");
const scheduler_1 = require("../../scheduler");
const taskHandler_1 = require("../../scheduler/taskHandler");
const pathsMatcher_1 = require("../../utils/pathsMatcher");
const abstract_lifecycle_1 = require("../abstract-lifecycle");
const consts_1 = require("./consts");
const deserialize_1 = require("./handlers/deserialize");
const serialize_1 = require("./handlers/serialize");
const parse_1 = require("./parse");
const types_2 = require("./types");
const addNode_1 = require("./utils/addNode");
const createFilter_1 = require("./utils/createFilter");
const groupReadableByFormat_1 = require("./utils/groupReadableByFormat");
const mergeConfig_1 = require("./utils/mergeConfig");
exports.mergeConfig = mergeConfig_1.mergeConfig;
const toGraphitePaths_1 = require("./utils/toGraphitePaths");
const validator_1 = require("./validator");
var consts_2 = require("./consts");
exports.DEFAULT_CONFIG = consts_2.DEFAULT_CONFIG;
exports.DEFAULT_PATHS = consts_2.DEFAULT_PATHS;
exports.STOPLIGHT_CONFIG_PATH = consts_2.STOPLIGHT_CONFIG_PATH;
exports.STOPLIGHT_CONFIG_PLUGIN_ID = consts_2.STOPLIGHT_CONFIG_PLUGIN_ID;
var mergeFormats_1 = require("./utils/mergeFormats");
exports.mergeFormats = mergeFormats_1.mergeFormats;
tslib_1.__exportStar(require("./types"), exports);
exports.createStoplightConfigPlugin = (props) => new StoplightConfigPlugin(props);
class StoplightConfigPlugin extends abstract_lifecycle_1.AbstractLifecyclePlugin {
    constructor({ cwd, readFile, defaultConfig = consts_1.DEFAULT_CONFIG }) {
        super();
        this.id = consts_1.STOPLIGHT_CONFIG_PLUGIN_ID;
        this.specProvider = {
            path: consts_1.STOPLIGHT_CONFIG_PATH_REGEXP,
            spec: graph_1.Specs.Stoplight,
        };
        this.tasks = [
            {
                operation: scheduler_1.GraphTaskOp.DeserializeSourceNode,
                handler: taskHandler_1.createTaskHandler({
                    selector: node => this.selector(node),
                    run: deserialize_1.deserialize,
                }, `${consts_1.STOPLIGHT_CONFIG_PLUGIN_ID}-deserializer`),
            },
            {
                operation: scheduler_1.GraphTaskOp.SerializeSourceNode,
                handler: taskHandler_1.createTaskHandler({
                    selector: node => this.selector(node),
                    run: serialize_1.serialize,
                }, `${consts_1.STOPLIGHT_CONFIG_PLUGIN_ID}-serializer`),
            },
        ];
        this.events = [
            {
                name: notifier_1.GraphiteEvent.DidPatch,
                handler({ operations }) {
                    if (operations.length > 0 && operations[0].op === graph_1.GraphOp.AddNode && operations[0].node.path === this.cwd) {
                        if (typeof this.fileContents === 'string') {
                            const stoplightConfigNode = addNode_1.addNode(this.graphite.graph, operations[0].node.id);
                            this.graphite.graph.setSourceNodeProp(stoplightConfigNode.id, 'data.original', eol.lf(this.fileContents));
                            if (/\r\n/.test(this.fileContents)) {
                                this.graphite.graph.setSourceNodeProp(stoplightConfigNode.id, 'data.eol', filesystem_1.EOL.CRLF);
                            }
                            deserialize_1.populateNodeData(this.graphite.graph, stoplightConfigNode);
                        }
                        else if (this.fileError && this.fileError.code !== 'ENOENT') {
                            const stoplightConfigNode = addNode_1.addNode(this.graphite.graph, operations[0].node.id);
                            this.graphite.graph.setSourceNodeDiagnostics(stoplightConfigNode.id, types_2.StoplightConfigError.IO, [
                                {
                                    severity: types_1.DiagnosticSeverity.Error,
                                    message: this.fileError.message,
                                    range: Object.assign({}, validator_1.DEFAULT_RANGE),
                                },
                            ]);
                        }
                    }
                },
            },
        ];
        this.cwd = cwd;
        this.readFile = readFile;
        this.defaultConfig = defaultConfig;
        this.uri = path_1.join(cwd, consts_1.STOPLIGHT_CONFIG_PATH);
        this.selector = (node) => utils_1.isSourceNode(node) && node.uri === this.uri;
    }
    async doActivate() {
        super.doActivate();
        try {
            this.fileContents = await this.readFile(this.uri, 'utf8');
            this.fileError = null;
        }
        catch (ex) {
            this.fileContents = null;
            this.fileError = ex;
            this.config = this.defaultConfig;
            this.graphite.paths = toGraphitePaths_1.toGraphitePaths(this.config);
            this.paths = groupReadableByFormat_1.groupReadableByFormat(this.config);
            return;
        }
        try {
            const config = parse_1.parseConfig(this.fileContents);
            validator_1.assertValidConfig(config);
            this.config = mergeConfig_1.mergeConfig(lodash_1.cloneDeep(this.defaultConfig), config.data);
        }
        catch (_a) {
            this.config = this.defaultConfig;
        }
        this.graphite.paths = toGraphitePaths_1.toGraphitePaths(this.config);
        this.paths = groupReadableByFormat_1.groupReadableByFormat(this.config);
    }
    async doDeactivate() {
        await super.doDeactivate();
        this.fileContents = void 0;
        this.fileError = void 0;
        this.config = void 0;
        this.paths = void 0;
    }
    getNodes() {
        return this.graphite.graph.nodeValues.filter(this.createFilter(this.getPaths(), new WeakMap()));
    }
    createFilter(paths = this.getPaths(), cache = null) {
        return createFilter_1.createFilter(paths, pathsMatcher_1.createPathsMatcher(this.graphite, this.cwd), cache);
    }
    getPaths() {
        if (!this.paths) {
            throw new Error('Config plugin not initialized');
        }
        return this.paths;
    }
    getConfig() {
        if (!this.config) {
            throw new Error('Config plugin not initialized');
        }
        return this.config;
    }
}
exports.StoplightConfigPlugin = StoplightConfigPlugin;
//# sourceMappingURL=index.js.map