cosmos-sql-language-service/dist/facade/LanguageServiceFacade.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.LanguageServiceFacade = exports.ParseReason = void 0;
var Q = require("q");
var monaco_editor_1 = require("monaco-editor");
var ParseReason;
(function (ParseReason) {
    ParseReason[ParseReason["GetCompletionWords"] = 1] = "GetCompletionWords";
    ParseReason[ParseReason["GetErrors"] = 2] = "GetErrors";
})(ParseReason = exports.ParseReason || (exports.ParseReason = {}));
var LanguageServiceFacade = /** @class */ (function () {
    function LanguageServiceFacade() {
    }
    LanguageServiceFacade.GetLanguageServiceParseResult = function (str, parseReason) {
        var timeExceeded = Q.Promise(function (resolve, reject) {
            var wait = setTimeout(function () {
                var words = {};
                resolve(words);
            }, LanguageServiceFacade.timeout);
        });
        var result = LanguageServiceFacade.GetParseResult(str, parseReason);
        var workingWorker = (parseReason === ParseReason.GetCompletionWords ? LanguageServiceFacade.workingWorkerForCompletion : LanguageServiceFacade.workingWorkerForGettingError);
        return Q.race([timeExceeded, result]).then(function (words) {
            workingWorker.terminate();
            return words;
        });
    };
    LanguageServiceFacade.timeout = 2000;
    LanguageServiceFacade.workingWorkerForCompletion = null;
    LanguageServiceFacade.workingWorkerForGettingError = null;
    LanguageServiceFacade.GetParseResult = function (str, parseReason) {
        return Q.Promise(function (resolve) {
            var workingWorker = (parseReason === ParseReason.GetCompletionWords ? LanguageServiceFacade.workingWorkerForCompletion : LanguageServiceFacade.workingWorkerForGettingError);
            // terminate the expired worker.
            if (workingWorker != null) {
                workingWorker.terminate();
            }
            var currentUrlWithoutQueryParamsAndHashRoute = window.location.protocol + "//" + window.location.host + window.location.pathname;
            var url = currentUrlWithoutQueryParamsAndHashRoute.replace(/\/[^\/]*$/, '/node_modules/@azure/cosmos-language-service/dist/worker/dist/LanguageServiceWorker.js');
            if (parseReason === ParseReason.GetCompletionWords) {
                LanguageServiceFacade.workingWorkerForCompletion = new Worker(url);
                workingWorker = LanguageServiceFacade.workingWorkerForCompletion;
            }
            else {
                LanguageServiceFacade.workingWorkerForGettingError = new Worker(url);
                workingWorker = LanguageServiceFacade.workingWorkerForGettingError;
            }
            workingWorker.onmessage = function (ev) {
                var processedResults = [];
                var parseResults = ev.data;
                if (parseReason === ParseReason.GetCompletionWords) {
                    parseResults.forEach(function (label) {
                        if (!!label) {
                            processedResults.push({
                                label: label,
                                insertText: label,
                                kind: monaco_editor_1.languages.CompletionItemKind.Keyword
                            });
                        }
                    });
                    var finalResult = { suggestions: processedResults };
                    resolve(finalResult);
                }
                else if (parseReason === ParseReason.GetErrors) {
                    parseResults.forEach(function (err) {
                        var mark = {
                            severity: monaco_editor_1.MarkerSeverity.Error,
                            message: err.Message,
                            startLineNumber: err.line,
                            startColumn: err.column,
                            endLineNumber: err.line,
                            endColumn: err.column
                        };
                        processedResults.push(mark);
                    });
                    resolve(processedResults);
                }
            };
            var source = {
                code: str,
                reason: parseReason
            };
            workingWorker.postMessage(source);
        });
    };
    return LanguageServiceFacade;
}());
exports.LanguageServiceFacade = LanguageServiceFacade;
//# sourceMappingURL=LanguageServiceFacade.js.map