gpml2pvjson/es5/spinoffs/cxml-xpath.js

"use strict";
var __extends = (this && this.__extends) || (function () {
    var extendStatics = Object.setPrototypeOf ||
        ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
        function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
    return function (d, b) {
        extendStatics(d, b);
        function __() { this.constructor = d; }
        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
    };
})();
Object.defineProperty(exports, "__esModule", { value: true });
require("source-map-support/register");
// TODO should I get rid of source-map-support/register for production build for browser?
// TODO most or all of this should go into the xpath branch of @wikipathways/cxml.
// Decide on an API and then merge most or all this code into there.
//
// TODO why does TS require that we use the Pathway's "constructor.prototype"
// instead of just the Pathway?
// Why does Pathway.Graphics not need that?
// Why do many of the other require using the prototype?
//
//// TODO why do we get an error with this (/Pathway/@* before /Pathway):
//"/Pathway/@*": GPML2013a.document.Pathway.constructor.prototype,
//"/Pathway": GPML2013a.document.Pathway.constructor.prototype,
//// And with this, we don't get an error, but nothing comes out (/Pathway before /Pathway/@*):
//"/Pathway": GPML2013a.document.Pathway.constructor.prototype,
//"/Pathway/@*": GPML2013a.document.Pathway.constructor.prototype,
var fp_1 = require("lodash/fp");
var hl = require("highland");
var cxml = require("@wikipathways/cxml");
// TODO don't use this regex when we are already also using a nice
// xpath expression parser in the xpath branch of cxml
var ATTR_SELECTOR_REGEX = /\/@(\*|([:A-Za-z_][:\w\-\.]*))$/;
function getSelectorLevel(selector) {
    return selector.replace(ATTR_SELECTOR_REGEX, "").split("/").length - 1;
}
var nestedElementsToSelector = fp_1.curry(function (commonLevel, nestedElements) {
    return nestedElements.slice(0, commonLevel).join("/");
});
function getSelectorNestedElements(selector) {
    return selector.replace(ATTR_SELECTOR_REGEX, "").split("/");
}
var CXMLXPath = /** @class */ (function () {
    function CXMLXPath(inputStream, schema, xpathNamespaceTbl) {
        if (xpathNamespaceTbl === void 0) { xpathNamespaceTbl = { "": "" }; }
        this._parser = new cxml.Parser(xpathNamespaceTbl);
        this._schema = schema;
        this._inputStream = inputStream;
    }
    CXMLXPath.prototype.parse = function (selectorToCXML) {
        var inputStream = this._inputStream;
        var parser = this._parser;
        var schema = this._schema;
        var result = fp_1.toPairs(selectorToCXML).reduce(function (_a, _b) {
            var output = _a.output, runningSelectors = _a.runningSelectors;
            var selector = _b[0], schemaElement = _b[1];
            var outputStream = hl();
            var useBefore = selector.match(ATTR_SELECTOR_REGEX);
            parser.attach(/** @class */ (function (_super) {
                __extends(CustomHandler, _super);
                function CustomHandler() {
                    return _super !== null && _super.apply(this, arguments) || this;
                }
                CustomHandler.prototype._before = function () {
                    if (useBefore) {
                        outputStream.write(fp_1.cloneDeep(this));
                    }
                };
                CustomHandler.prototype._after = function () {
                    if (!useBefore) {
                        outputStream.write(fp_1.cloneDeep(this));
                    }
                };
                return CustomHandler;
            }(schemaElement.constructor)), selector);
            output[selector] = outputStream;
            var level = getSelectorLevel(selector);
            var selectorNestedElements = getSelectorNestedElements(selector);
            var _c = fp_1.partition(function (runningSelector) {
                var runningSelectorNestedElements = getSelectorNestedElements(runningSelector);
                var commonNestedElementsToSelector = nestedElementsToSelector(Math.min(selectorNestedElements.length, runningSelectorNestedElements.length));
                return (commonNestedElementsToSelector(runningSelectorNestedElements) !==
                    commonNestedElementsToSelector(selectorNestedElements));
            }, runningSelectors), selectorsToEnd = _c[0], stillRunningSelectors = _c[1];
            selectorsToEnd.forEach(function (runningSelector) {
                var runningStream = output[runningSelector];
                outputStream.observe().head().each(function (x) {
                    runningStream.end();
                });
            });
            // NOTE: redefining this variable
            runningSelectors = stillRunningSelectors.concat([selector]);
            return { output: output, runningSelectors: runningSelectors };
        }, { output: {}, runningSelectors: [] });
        var streamMapBySelector = result.output;
        var finalRunningSelectors = result.runningSelectors;
        var selectors = fp_1.keys(selectorToCXML);
        parser.parse(inputStream, schema.document).then(function (Pathway) {
            finalRunningSelectors.forEach(function (finalRunningSelector) {
                streamMapBySelector[finalRunningSelector].end();
            });
            selectors.forEach(function (selector) {
                var thisStream = streamMapBySelector[selector];
                if (!thisStream["ended"]) {
                    //console.log(streamMapBySelector[selector]);
                    //console.log(`Failed to end stream for ${selector}. See above.`);
                    //throw new Error(`Failed to end stream for ${selector}. See above.`);
                    thisStream.end();
                    /*
                                     (thisStream._observers.length === 0
                                         ? thisStream
                                         : thisStream.observe())
                                         .debounce(17)
                                         .each(function() {
                                         thisStream.end();
                                         });
                                //*/
                }
            });
        }, function (err) {
            throw err;
        });
        /*
        streamMapBySelector.startCXML = function() {
          return hl(parser.parse(inputStream, schema.document)).map(function(
            Pathway
          ) {
            console.log("Pathway");
            console.log(Pathway);
            finalRunningSelectors.forEach(function(finalRunningSelector) {
              streamMapBySelector[finalRunningSelector].end();
            });
    
            selectors.forEach(function(selector) {
              const thisStream = streamMapBySelector[selector];
              if (!thisStream["ended"]) {
                //console.log(streamMapBySelector[selector]);
                console.log(`Failed to end stream for ${selector}. See above.`);
                //throw new Error(`Failed to end stream for ${selector}. See above.`);
                //thisStream.end();
              }
            });
          });
        };
            //*/
        return streamMapBySelector;
    };
    return CXMLXPath;
}());
exports.CXMLXPath = CXMLXPath;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiY3htbC14cGF0aC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9zcGlub2Zmcy9jeG1sLXhwYXRoLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7OztBQUFBLHVDQUFxQztBQUNyQyx5RkFBeUY7QUFFekYsa0ZBQWtGO0FBQ2xGLG9FQUFvRTtBQUNwRSxFQUFFO0FBQ0YsNkVBQTZFO0FBQzdFLCtCQUErQjtBQUMvQiwyQ0FBMkM7QUFDM0Msd0RBQXdEO0FBQ3hELEVBQUU7QUFDRix5RUFBeUU7QUFDekUsa0VBQWtFO0FBQ2xFLCtEQUErRDtBQUMvRCwrRkFBK0Y7QUFDL0YsK0RBQStEO0FBQy9ELGtFQUFrRTtBQUVsRSxnQ0FBdUU7QUFDdkUsNkJBQStCO0FBRS9CLHlDQUEyQztBQXVCM0Msa0VBQWtFO0FBQ2xFLHNEQUFzRDtBQUN0RCxJQUFNLG1CQUFtQixHQUFHLGlDQUFpQyxDQUFDO0FBRTlELDBCQUEwQixRQUFRO0lBQ2hDLE1BQU0sQ0FBQyxRQUFRLENBQUMsT0FBTyxDQUFDLG1CQUFtQixFQUFFLEVBQUUsQ0FBQyxDQUFDLEtBQUssQ0FBQyxHQUFHLENBQUMsQ0FBQyxNQUFNLEdBQUcsQ0FBQyxDQUFDO0FBQ3pFLENBQUM7QUFFRCxJQUFNLHdCQUF3QixHQUFHLFVBQUssQ0FBQyxVQUFTLFdBQVcsRUFBRSxjQUFjO0lBQ3pFLE1BQU0sQ0FBQyxjQUFjLENBQUMsS0FBSyxDQUFDLENBQUMsRUFBRSxXQUFXLENBQUMsQ0FBQyxJQUFJLENBQUMsR0FBRyxDQUFDLENBQUM7QUFDeEQsQ0FBQyxDQUFDLENBQUM7QUFFSCxtQ0FBbUMsUUFBUTtJQUN6QyxNQUFNLENBQUMsUUFBUSxDQUFDLE9BQU8sQ0FBQyxtQkFBbUIsRUFBRSxFQUFFLENBQUMsQ0FBQyxLQUFLLENBQUMsR0FBRyxDQUFDLENBQUM7QUFDOUQsQ0FBQztBQUVEO0lBTUUsbUJBQ0UsV0FBVyxFQUNYLE1BQU0sRUFDTixpQkFBc0Q7UUFBdEQsa0NBQUEsRUFBQSxzQkFBOEMsRUFBRSxFQUFFLEVBQUUsRUFBRTtRQUV0RCxJQUFJLENBQUMsT0FBTyxHQUFHLElBQUksSUFBSSxDQUFDLE1BQU0sQ0FBQyxpQkFBaUIsQ0FBQyxDQUFDO1FBQ2xELElBQUksQ0FBQyxPQUFPLEdBQUcsTUFBTSxDQUFDO1FBQ3RCLElBQUksQ0FBQyxZQUFZLEdBQUcsV0FBVyxDQUFDO0lBQ2xDLENBQUM7SUFFRCx5QkFBSyxHQUFMLFVBQ0UsY0FBa0M7UUFFbEMsSUFBTSxXQUFXLEdBQUcsSUFBSSxDQUFDLFlBQVksQ0FBQztRQUN0QyxJQUFNLE1BQU0sR0FBRyxJQUFJLENBQUMsT0FBTyxDQUFDO1FBQzVCLElBQU0sTUFBTSxHQUFHLElBQUksQ0FBQyxPQUFPLENBQUM7UUFNNUIsSUFBTSxNQUFNLEdBQUcsWUFBTyxDQUFDLGNBQWMsQ0FBQyxDQUFDLE1BQU0sQ0FDM0MsVUFBUyxFQUE0QixFQUFFLEVBQXlCO2dCQUFyRCxrQkFBTSxFQUFFLHNDQUFnQjtnQkFBSyxnQkFBUSxFQUFFLHFCQUFhO1lBQzdELElBQU0sWUFBWSxHQUVkLEVBQUUsRUFBRSxDQUFDO1lBRVQsSUFBTSxTQUFTLEdBQUcsUUFBUSxDQUFDLEtBQUssQ0FBQyxtQkFBbUIsQ0FBQyxDQUFDO1lBRXRELE1BQU0sQ0FBQyxNQUFNO2dCQUNpQixpQ0FBeUI7Z0JBQXJEOztnQkFZQSxDQUFDO2dCQVhDLCtCQUFPLEdBQVA7b0JBQ0UsRUFBRSxDQUFDLENBQUMsU0FBUyxDQUFDLENBQUMsQ0FBQzt3QkFDZCxZQUFZLENBQUMsS0FBSyxDQUFDLGNBQVMsQ0FBQyxJQUFJLENBQUMsQ0FBQyxDQUFDO29CQUN0QyxDQUFDO2dCQUNILENBQUM7Z0JBRUQsOEJBQU0sR0FBTjtvQkFDRSxFQUFFLENBQUMsQ0FBQyxDQUFDLFNBQVMsQ0FBQyxDQUFDLENBQUM7d0JBQ2YsWUFBWSxDQUFDLEtBQUssQ0FBQyxjQUFTLENBQUMsSUFBSSxDQUFDLENBQUMsQ0FBQztvQkFDdEMsQ0FBQztnQkFDSCxDQUFDO2dCQUNILG9CQUFDO1lBQUQsQ0FBQyxBQVpELENBQTRCLGFBQWEsQ0FBQyxXQUFXLElBYXJELFFBQVEsQ0FDVCxDQUFDO1lBRUYsTUFBTSxDQUFDLFFBQVEsQ0FBQyxHQUFHLFlBQVksQ0FBQztZQUNoQyxJQUFNLEtBQUssR0FBRyxnQkFBZ0IsQ0FBQyxRQUFRLENBQUMsQ0FBQztZQUN6QyxJQUFNLHNCQUFzQixHQUFHLHlCQUF5QixDQUFDLFFBQVEsQ0FBQyxDQUFDO1lBRTdELElBQUE7Ozs7O2dDQWdCYyxFQWhCYixzQkFBYyxFQUFFLDZCQUFxQixDQWdCdkI7WUFFckIsY0FBYyxDQUFDLE9BQU8sQ0FBQyxVQUFTLGVBQWU7Z0JBQzdDLElBQU0sYUFBYSxHQUFHLE1BQU0sQ0FBQyxlQUFlLENBQUMsQ0FBQztnQkFDOUMsWUFBWSxDQUFDLE9BQU8sRUFBRSxDQUFDLElBQUksRUFBRSxDQUFDLElBQUksQ0FBQyxVQUFTLENBQUM7b0JBQzNDLGFBQWEsQ0FBQyxHQUFHLEVBQUUsQ0FBQztnQkFDdEIsQ0FBQyxDQUFDLENBQUM7WUFDTCxDQUFDLENBQUMsQ0FBQztZQUNILGlDQUFpQztZQUNqQyxnQkFBZ0IsR0FBRyxxQkFBcUIsQ0FBQyxNQUFNLENBQUMsQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDO1lBRTVELE1BQU0sQ0FBQyxFQUFFLE1BQU0sUUFBQSxFQUFFLGdCQUFnQixrQkFBQSxFQUFFLENBQUM7UUFDdEMsQ0FBQyxFQUNELEVBQUUsTUFBTSxFQUFFLEVBQUUsRUFBRSxnQkFBZ0IsRUFBRSxFQUFFLEVBQUUsQ0FDckMsQ0FBQztRQUNGLElBQU0sbUJBQW1CLEdBQUcsTUFBTSxDQUFDLE1BQTZCLENBQUM7UUFDakUsSUFBTSxxQkFBcUIsR0FBRyxNQUFNLENBQUMsZ0JBQWdCLENBQUM7UUFFdEQsSUFBTSxTQUFTLEdBQUcsU0FBSSxDQUFDLGNBQWMsQ0FBQyxDQUFDO1FBRXZDLE1BQU0sQ0FBQyxLQUFLLENBQUMsV0FBVyxFQUFFLE1BQU0sQ0FBQyxRQUFRLENBQUMsQ0FBQyxJQUFJLENBQzdDLFVBQVMsT0FBTztZQUNkLHFCQUFxQixDQUFDLE9BQU8sQ0FBQyxVQUFTLG9CQUFvQjtnQkFDekQsbUJBQW1CLENBQUMsb0JBQW9CLENBQUMsQ0FBQyxHQUFHLEVBQUUsQ0FBQztZQUNsRCxDQUFDLENBQUMsQ0FBQztZQUVILFNBQVMsQ0FBQyxPQUFPLENBQUMsVUFBUyxRQUFRO2dCQUNqQyxJQUFNLFVBQVUsR0FBRyxtQkFBbUIsQ0FBQyxRQUFRLENBQUMsQ0FBQztnQkFDakQsRUFBRSxDQUFDLENBQUMsQ0FBQyxVQUFVLENBQUMsT0FBTyxDQUFDLENBQUMsQ0FBQyxDQUFDO29CQUN6Qiw2Q0FBNkM7b0JBQzdDLGtFQUFrRTtvQkFDbEUsc0VBQXNFO29CQUN0RSxVQUFVLENBQUMsR0FBRyxFQUFFLENBQUM7b0JBQ2pCOzs7Ozs7OztvQ0FRRjtnQkFDQSxDQUFDO1lBQ0gsQ0FBQyxDQUFDLENBQUM7UUFDTCxDQUFDLEVBQ0QsVUFBUyxHQUFHO1lBQ1YsTUFBTSxHQUFHLENBQUM7UUFDWixDQUFDLENBQ0YsQ0FBQztRQUVGOzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7O2dCQXNCRTtRQUVGLE1BQU0sQ0FBQyxtQkFBbUIsQ0FBQztJQUM3QixDQUFDO0lBQ0gsZ0JBQUM7QUFBRCxDQUFDLEFBcEpELElBb0pDO0FBcEpZLDhCQUFTIn0=