KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use _cacheDisabled method in Puppeteer

Best JavaScript code snippet using puppeteer

baas.js

Source:baas.js

1/*!2 * NEC Mobile Backend Platform JavaScript SDK version 7.5.03 *4 * Copyright (C) 2014-2018, NEC CORPORATION.5 * All rights reserved.6 *7 * 1. Redistributions of source code must retain the above copyright notice,8 *    this list of conditions and the following disclaimer.9 * 2. Redistributions in binary form must reproduce the above copyright notice,10 *    this list of conditions and the following disclaimer in the documentation11 *    and/or other materials provided with the distribution.12 *13 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS14 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT15 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR16 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT17 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,18 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT19 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,20 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY21 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE23 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.24 */25"use strict";26var XMLHttpRequest, localStorage;27(function(root, setup) {28    var _module = {exports: {}};29    var _exports = _module.exports;30    setup.call(root, _module, _exports);31    if (typeof module !== "undefined" &&32        typeof module.exports !== "undefined" &&33        typeof process !== "undefined" &&34        typeof require !== "undefined") {35        module.exports = _exports;36    } else {37        root.Nebula = _exports.Nebula;38    }39})(this, function(module, exports) {40"use strict";41var __extends = (this && this.__extends) || (function () {42    var extendStatics = function (d, b) {43        extendStatics = Object.setPrototypeOf ||44            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||45            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };46        return extendStatics(d, b);47    }48    return function (d, b) {49        extendStatics(d, b);50        function __() { this.constructor = d; }51        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());52    };53})();54Object.defineProperty(exports, "__esModule", { value: true });55exports.root = this;56exports.nbError = function (message) {57    if (typeof console !== "undefined") {58        console.log("[BAAS ERROR] : " + message);59    }60};61exports.nbLogger = function (message) {62    if (exports.Nebula.getDebugMode() === "debug" && typeof console !== "undefined") {63        console.log("[BAAS] : " + message);64    }65};66exports._doBadRequestCallback = function (callbacks, name) {67    exports.nbLogger(name + "#invalid parameter.");68    var error = exports._createError(400, "Invalid Arguments", "Invalid Arguments");69    if (callbacks && callbacks.error) {70        callbacks.error(error);71        return;72    }73    else {74        return Promise.reject(error);75    }76};77exports._promisify = function (promise, callbacks) {78    if (callbacks) {79        promise.then(function (arg) {80            if (callbacks.success) {81                callbacks.success(arg);82            }83        }).catch(function (err) {84            if (callbacks.error) {85                callbacks.error(err);86            }87        });88        return undefined;89    }90    else {91        return promise;92    }93};94exports._createError = function (status, statusText, responseText, data) {95    var error = new Error(statusText + "(" + status + ")");96    error.status = status;97    error.statusText = statusText;98    error.responseText = responseText;99    if (data) {100        error.data = data;101    }102    return error;103};104exports._errorText = function (error) {105    if (error && error.message) {106        return error.message;107    }108    return error;109};110exports._isObject = function (value) {111    var type = typeof value;112    return value && type === 'object' || type === 'function';113};114exports._compareObject = function (src, target) {115    var srcKeys = Object.keys(src);116    var targetKeys = Object.keys(target);117    if (srcKeys.length !== targetKeys.length) {118        return false;119    }120    for (var _i = 0, srcKeys_1 = srcKeys; _i < srcKeys_1.length; _i++) {121        var key = srcKeys_1[_i];122        if (exports._isObject(src[key]) && exports._isObject(target[key])) {123            if (!exports._compareObject(src[key], target[key])) {124                return false;125            }126        }127        else {128            if (src[key] !== target[key]) {129                return false;130            }131        }132    }133    return true;134};135exports.nbAssert = function (assert, message) {136    if (!assert) {137        if (exports.Nebula.getDebugMode() === "debug") {138            throw new Error("Assertion failed. " + message);139        }140        else {141            exports.nbError("Assertion failed. " + message);142        }143    }144};145exports.isNodeJs = function () {146    return typeof require !== "undefined" && typeof process !== "undefined";147};148exports._node_require = function (module) {149    try {150        if (exports.isNodeJs()) {151            return eval('require')(module);152        }153        else {154            return null;155        }156    }157    catch (e) {158        return null;159    }160};161exports.URL = exports._node_require('url');162exports.https = exports._node_require('https');163exports.http = exports._node_require('http');164exports.tls = exports._node_require('tls');165exports.fs = exports._node_require('fs');166exports.util = exports._node_require('util');167var __http2 = null;168try {169    __http2 = exports._node_require('http2'); 170}171catch (e) {172}173exports.http2 = __http2;174exports._hasXhr = function () {175    return typeof XMLHttpRequest !== "undefined";176};177var HttpRequestExecutor =  (function () {178    function HttpRequestExecutor(req) {179        this._req = req;180        this._resolve = req._resolve;181        this._reject = req._reject;182    }183    HttpRequestExecutor.closeHttp2Session = function (authority) {184        if (exports._hasXhr()) {185            HttpXhr.closeHttp2Session(authority);186        }187        else {188            HttpNode.closeHttp2Session(authority);189        }190    };191    HttpRequestExecutor.create = function (req) {192        if (exports._hasXhr()) {193            return this._xhrFactory(req);194        }195        else {196            return this._nodeFactory(req);197        }198    };199    HttpRequestExecutor.setXhrFactory = function (factory) {200        this._xhrFactory = factory;201    };202    HttpRequestExecutor.setNodeFactory = function (factory) {203        this._nodeFactory = factory;204    };205    return HttpRequestExecutor;206}());207exports.HttpRequestExecutor = HttpRequestExecutor;208var HttpRequest =  (function () {209    function HttpRequest(service, path, option) {210        this._rawMessage = false;211        this._useHttp2 = false;212        exports.nbLogger("HttpRequest#start:path = " + path);213        this._service = service;214        this._url = this._service.getBaseUri();215        if (!(option && option.noprefix)) {216            this._url += "/" + this._service.getRestApiVersion() + "/" + this._service.getTenantID();217        }218        this._url = encodeURI(this._url) + path;219        this._headers = {};220        this._contentType = null;221        this._responseType = null;222        this._queryParams = null;223        this._data = null;224        this._receiveResponseHeaders = false;225        this._timeout = HttpRequest.getDefaultTimeout();226        this._useHttp2 = this._service.getHttp2();227        var _currentObj = this._service.getCurrentUser();228        if (_currentObj === null) {229            this._sessionToken = null;230        }231        else {232            this._sessionToken = _currentObj.sessionToken;233        }234    }235    HttpRequest.getProxy = function () {236        return HttpRequest._proxy;237    };238    HttpRequest.setProxy = function (proxy) {239        HttpRequest._proxy = proxy;240    };241    HttpRequest.setHttpAgent = function (agent) {242        HttpRequest._httpAgent = agent;243    };244    HttpRequest.setHttpsAgent = function (agent, options) {245        HttpRequest._httpsAgent = agent;246        HttpRequest._httpsAgentOptions = options;247    };248    Object.defineProperty(HttpRequest.prototype, "service", {249        get: function () {250            return this._service;251        },252        enumerable: true,253        configurable: true254    });255    Object.defineProperty(HttpRequest.prototype, "responseHeaders", {256        get: function () {257            return this._responseHeaders;258        },259        set: function (value) {260            this._responseHeaders = value;261        },262        enumerable: true,263        configurable: true264    });265    HttpRequest.setDefaultTimeout = function (timeout) {266        this._defaultTimeout = timeout;267    };268    HttpRequest.getDefaultTimeout = function () {269        return this._defaultTimeout;270    };271    Object.defineProperty(HttpRequest.prototype, "rawMessage", {272        get: function () {273            return this._rawMessage;274        },275        set: function (value) {276            this._rawMessage = value;277        },278        enumerable: true,279        configurable: true280    });281    Object.defineProperty(HttpRequest.prototype, "useHttp2", {282        get: function () {283            return this._useHttp2;284        },285        set: function (value) {286            if (value && exports.http2 == null) {287                throw new Error("No http2 support.");288            }289            this._useHttp2 = value;290        },291        enumerable: true,292        configurable: true293    });294    HttpRequest.prototype.setReceiveResponseHeaders = function (receive) {295        this._receiveResponseHeaders = receive;296        return this;297    };298    HttpRequest.prototype.execute = function () {299        var _this = this;300        return new Promise(function (resolve, reject) {301            _this._resolve = resolve;302            _this._reject = reject;303            _this._headers["X-Application-Id"] = _this._service.getAppID();304            _this._headers["X-Application-Key"] = _this._service.getAppKey();305            if (_this._contentType !== null) {306                _this._headers["Content-Type"] = _this._contentType;307            }308            if (_this._sessionToken !== null) {309                _this._headers["X-Session-Token"] = _this._sessionToken;310            }311            var url = _this._url;312            if (_this._queryParams) {313                var p = [];314                for (var _i = 0, _a = Object.keys(_this._queryParams); _i < _a.length; _i++) {315                    var key = _a[_i];316                    if (_this._queryParams.hasOwnProperty(key)) {317                        p.push(encodeURIComponent(key) + "=" + encodeURIComponent(_this._queryParams[key]));318                    }319                }320                if (p.length > 0) {321                    url += "?" + p.join("&");322                }323            }324            var body;325            if (!(_this._data != null)) {326                body = null;327            }328            else if ((typeof _this._data === "string") ||329                (typeof Blob !== "undefined" && Blob !== null && _this._data instanceof Blob) ||330                (typeof Buffer !== "undefined" && Buffer !== null && Buffer.isBuffer(_this._data))) {331                body = _this._data;332            }333            else {334                body = JSON.stringify(_this._data);335            }336            var executor = HttpRequestExecutor.create(_this);337            if (_this._rawMessage) {338                executor.setReturnRawMessage(_this._rawMessage);339            }340            executor.execute(_this._method, url, _this._headers, body, _this._timeout, _this._responseType, _this._receiveResponseHeaders, _this._useHttp2);341        });342    };343    HttpRequest.closeHttp2Session = function (authority) {344        HttpRequestExecutor.closeHttp2Session(authority);345    };346    HttpRequest.prototype.setMethod = function (method) {347        this._method = method;348        return this;349    };350    HttpRequest.prototype.setContentType = function (contentType) {351        this._contentType = contentType;352        return this;353    };354    HttpRequest.prototype.setQueryParams = function (params) {355        this._queryParams = params;356        return this;357    };358    HttpRequest.prototype.addQueryParams = function (params) {359        if (params) {360            for (var _i = 0, _a = Object.keys(params); _i < _a.length; _i++) {361                var key = _a[_i];362                this.setQueryParam(key, params[key]);363            }364        }365        return this;366    };367    HttpRequest.prototype.setQueryParam = function (key, value) {368        if (!this._queryParams) {369            this._queryParams = {};370        }371        this._queryParams[key] = value;372        return this;373    };374    HttpRequest.prototype.setData = function (data) {375        this._data = data;376        return this;377    };378    HttpRequest.prototype.setSessionToken = function (sessionToken) {379        this._sessionToken = sessionToken;380        return this;381    };382    HttpRequest.prototype.setResponseType = function (responseType) {383        this._responseType = responseType;384        return this;385    };386    HttpRequest.prototype.addRequestHeader = function (header, value) {387        if (this._headers[header] !== undefined) {388            exports.nbLogger("HTTP Request Warning : This header already exists.");389        }390        this._headers[header] = value;391        return this;392    };393    HttpRequest._defaultTimeout = 0;394    return HttpRequest;395}());396exports.HttpRequest = HttpRequest;397exports.initHttpXhr = function () {398    HttpRequestExecutor.setXhrFactory(function (req) { return new HttpXhr(req); });399};400var HttpXhr =  (function (_super) {401    __extends(HttpXhr, _super);402    function HttpXhr(req) {403        var _this = _super.call(this, req) || this;404        _this._onReadyStateChange = _this._onReadyStateChange.bind(_this);405        return _this;406    }407    HttpXhr.prototype.setReturnRawMessage = function (rawMessage) {408        throw new Error("Not supported");409    };410    HttpXhr.prototype.execute = function (method, url, headers, body, timeout, responseType, receiveResponseHeaders, useHttp2) {411        var _this = this;412        this._receiveResponseHeaders = receiveResponseHeaders;413        this._xhr = this._createXhr();414        this._xhr.open(method, url, true);415        this._xhr.onreadystatechange = this._onReadyStateChange;416        for (var _i = 0, _a = Object.keys(headers); _i < _a.length; _i++) {417            var key = _a[_i];418            var value = headers[key];419            this._xhr.setRequestHeader(key, value);420        }421        this._xhr.timeout = timeout;422        this._xhr.ontimeout = function (e) {423            _this._onXhrTimeout(e);424        };425        try {426            var userAgent = exports.root.navigator.userAgent.toLowerCase();427            if (userAgent.match(/msie/) || userAgent.match(/trident/)) {428                this._xhr.setRequestHeader("Pragma", "no-cache");429                this._xhr.setRequestHeader("Cache-Control", "no-cache");430                this._xhr.setRequestHeader("If-Modified-Since", "Thu, 01 Jun 1970 00:00:00 GMT");431            }432            else {433            }434        }435        catch (e) {436        }437        if (responseType != null) {438            this._xhr.responseType = responseType;439        }440        this._xhr.send(body);441    };442    HttpXhr.closeHttp2Session = function (authority) {443        throw new Error("not support");444    };445    HttpXhr.prototype._createXhr = function () {446        if (!exports._hasXhr()) {447            throw new Error("No XMLHttpRequest");448        }449        return new XMLHttpRequest();450    };451    HttpXhr.prototype._onReadyStateChange = function () {452        var xhr = this._xhr;453        if (xhr.readyState === 4) {454            if (xhr.status >= 200 && xhr.status < 300) {455                var body = (xhr.response != null) ? xhr.response : xhr.responseText;456                if (this._receiveResponseHeaders) {457                    return this._resolve({458                        body: body,459                        headers: xhr.getAllResponseHeaders(),460                        status: xhr.status461                    });462                }463                else {464                    return this._resolve(body);465                }466            }467            else {468                var error = exports._createError(xhr.status, xhr.statusText, "");469                if (xhr.responseType !== "blob") {470                    error.responseText = xhr.responseText;471                }472                if (xhr.status === 0) {473                    error.statusText = "Not Found";474                    error.responseText = "Not found anything that matches the request URI.";475                }476                exports.nbError("HTTP Request Error: " + error.message + " " + error.responseText);477                return this._reject(error);478            }479        }480    };481    HttpXhr.prototype._onXhrTimeout = function (e) {482        var error = exports._createError(0, "Timeout error", e.toString());483        exports.nbError("HTTP Response Error: Timeout Error: " + e.toString());484        this._reject(error);485    };486    return HttpXhr;487}(HttpRequestExecutor));488exports.HttpXhr = HttpXhr;489HttpRequestExecutor.setXhrFactory(function (req) {490    return new HttpXhr(req);491});492exports.initHttpNode = function () {493    HttpRequestExecutor.setNodeFactory(function (req) { return new HttpNode(req); });494};495var HttpNode =  (function (_super) {496    __extends(HttpNode, _super);497    function HttpNode(req) {498        var _this = _super.call(this, req) || this;499        _this._rawMessage = false;500        return _this;501    }502    HttpNode.prototype.setReturnRawMessage = function (returnRawMessage) {503        this._rawMessage = returnRawMessage;504    };505    HttpNode.prototype.execute = function (method, urlString, headers, body, timeout, responseType, receiveResponseHeaders, useHttp2) {506        this._responseType = responseType;507        this._receiveResponseHeaders = receiveResponseHeaders;508        var url;509        try {510            url = exports.URL.parse(urlString);511        }512        catch (e) {513            exports.nbError("Bad URL: " + urlString);514            this._reject(exports._createError(0, "Bad URL: " + urlString, ""));515            return;516        }517        var isHttps = HttpNode._isHttps(url);518        var options = {519            method: method,520            hostname: url.hostname,521            port: url.port,522            path: url.path,523            headers: headers,524            agent: isHttps ? HttpRequest._httpsAgent : HttpRequest._httpAgent,525            timeout: timeout,526            pfx: null,527            passphrase: null,528            key: null,529            cert: null,530            ca: null,531            rejectUnauthorized: true532        };533        if (isHttps) {534            var allowedClientCertOptions = ['pfx', 'passphrase', 'key', 'cert', 'ca'];535            var clientCertOptions = this._req.service._config.clientCertOptions;536            if (clientCertOptions != null) {537                for (var key in clientCertOptions) {538                    if (allowedClientCertOptions.indexOf(key) >= 0) {539                        options[key] = clientCertOptions[key];540                    }541                    else {542                        exports.nbError('invalid parameter ' + key + ' detected. value: ' + JSON.stringify(clientCertOptions[key]));543                        this._reject(exports._createError(0, 'invalid parameter: ' + key, ' value: ' + JSON.stringify(clientCertOptions[key])));544                        return;545                    }546                }547            }548            if (this._req.service._config.allowSelfSignedCert) {549                options.rejectUnauthorized = false;550                exports.nbLogger('HTTPS Request Warning : accept self-signed certificate. make sure the risk of this setting.');551            }552            else {553                options.rejectUnauthorized = true;554            }555        }556        if (isHttps && options.agent != null && HttpRequest._httpsAgentOptions != null) {557            try {558                exports.tls.createSecureContext(HttpRequest._httpsAgentOptions);559            }560            catch (e) {561                exports.nbError("HttpsAgentOptions invalid. check proxy options " + e.toString());562                var error = exports._createError(0, "Client Error", e.toString());563                this._reject(error);564                return;565            }566        }567        if (exports.http2 != null && useHttp2) {568            this._sendHttp2Request(url, options, body);569        }570        else {571            this._sendHttpRequest(url, options, body);572        }573    };574    HttpNode.prototype._sendHttp2Request = function (url, options, body) {575        var authority = url.protocol + '//' + url.hostname;576        if (url.port != null) {577            authority += ':' + url.port;578        }579        var sessions = HttpNode.getHttp2Sessions();580        for (var key in sessions) {581            var session = sessions[key];582            if (session.destroyed == true || session.closed == true) {583                exports.nbLogger('http2 session ' + authority + ' is destroyed or closed state');584                HttpNode.closeHttp2Session(key);585            }586        }587        var http2Session = HttpNode.getHttp2Session(authority);588        if (http2Session == null) {589            exports.nbLogger('create http2 session: [' + authority + ']');590            var http2SessionOptions = {591                allowHTTP1: true,592                pfx: options['pfx'],593                passphrase: options['passphrase'],594                key: options['key'],595                cert: options['cert'],596                ca: options['ca'],597                rejectUnauthorized: options['rejectUnauthorized']598            };599            http2Session = exports.http2.connect(authority, (HttpNode._isHttps(url) ? http2SessionOptions : undefined));600            HttpNode.setHttp2Session(authority, http2Session);601        }602        var outgoingHttpHeaders = options.headers;603        outgoingHttpHeaders[':method'] = options.method;604        outgoingHttpHeaders[':path'] = url.path;605        var http2Stream = http2Session.request(outgoingHttpHeaders);606        if (options.timeout > 0) {607            http2Stream.setTimeout(options.timeout, function () {608                HttpNode._closeStream(http2Stream);609                var error = exports._createError(0, "HTTP/2 Request timeout: " + options.timeout + "[msec]", "");610                exports.nbError("Timeout detected: " + error);611            });612        }613        if (this._rawMessage) {614            this._resolve(http2Stream); 615        }616        else {617            this._setHttp2ResponseHandlers(http2Stream);618        }619        if (body != null) {620            if (typeof body === "string" || body instanceof String || body instanceof Buffer) {621                http2Stream.write(body);622            }623            else {624                http2Stream.write(JSON.stringify(body));625            }626        }627        http2Stream.end();628    };629    HttpNode.prototype._sendHttpRequest = function (url, options, body) {630        var _this = this;631        var handler = function (res) {632            if (_this._rawMessage) {633                _this._resolve(res);634            }635            else {636                var status_1 = res.statusCode;637                _this._req.responseHeaders = res.headers;638                _this._setResponseHandlers(status_1, res);639            }640        };641        var req = HttpNode._isHttps(url) ? exports.https.request(options, handler) : exports.http.request(options, handler);642        if (options.timeout > 0) {643            req.setTimeout(options.timeout, function () { return req.abort(); });644        }645        req.on('error', function (e) {646            var error = exports._createError(0, "HTTP request error", e.toString());647            exports.nbError("HTTP Request Error: " + e.toString());648            _this._reject(error);649        });650        if (body != null) {651            if (typeof body === "string" || body instanceof String || body instanceof Buffer) {652                req.write(body);653            }654            else {655                req.write(JSON.stringify(body));656            }657        }658        req.end();659    };660    HttpNode._isHttps = function (url) {661        return (url.protocol === 'https:');662    };663    HttpNode.prototype._setResponseHandlers = function (status, res) {664        var _this = this;665        var chunks = [];666        res.on('data', function (data) {667            chunks.push(data);668        });669        res.on('end', function () {670            var buffer = Buffer.concat(chunks);671            var responseBody = _this._parseNodeResponse(buffer);672            if (200 <= status && status < 300) {673                if (_this._receiveResponseHeaders) {674                    _this._resolve({675                        body: responseBody,676                        headers: res.headers,677                        status: status678                    });679                }680                else {681                    _this._resolve(responseBody);682                }683            }684            else {685                var responseText = (_this._responseType !== "buffer" && responseBody != null) ? responseBody.toString() : "";686                var error = exports._createError(status, res.statusMessage, responseText, responseBody);687                exports.nbError("HTTP Response Error: status=" + status + " - " + res.statusMessage);688                _this._reject(error);689            }690        });691        res.on('error', function (e) {692            var error = exports._createError(0, "Client Error", e.toString());693            exports.nbError("HTTP Response Error: Client Error: " + e.toString());694            _this._reject(error);695        });696    };697    HttpNode.prototype._setHttp2ResponseHandlers = function (stream) {698        var _this = this;699        var chunks = [];700        var resHeaders = {};701        var statusCode = 0;702        stream.on('response', function (headers, flags) {703            resHeaders = headers;704            statusCode = Number(headers[exports.http2.constants.HTTP2_HEADER_STATUS]);705        }).on('data', function (data) {706            chunks.push(data);707        }).on('end', function () {708            var buffer = Buffer.concat(chunks);709            var responseBody = _this._parseNodeResponse(buffer);710            HttpNode._closeStream(stream);711            if (200 <= statusCode && statusCode < 300) {712                if (_this._receiveResponseHeaders) {713                    _this._resolve({714                        body: responseBody,715                        headers: resHeaders,716                        status: statusCode717                    });718                }719                else {720                    _this._resolve(responseBody);721                }722            }723            else {724                var statusMessage = (statusCode == 0) ? "Unable to get proper response" : "";725                var responseText = (_this._responseType !== "buffer" && responseBody != null) ? responseBody.toString() : "";726                var error = exports._createError(statusCode, statusMessage, responseText, responseBody);727                exports.nbError("HTTP/2 Response Error: status=" + statusCode);728                _this._reject(error);729            }730        }).on('error', function (e) {731            HttpNode._closeStream(stream);732            var error = exports._createError(0, "HTTP/2 Stream Error", e.toString());733            exports.nbError("HTTP/2 Stream Error: " + e.toString());734            _this._reject(error);735        }).on('push', function (headers, flags) {736            exports.nbLogger('HTTP/2 Stream push');737        }).on('finish', function () {738            exports.nbLogger('HTTP/2 Stream finish');739        }).on('altsvc', function (alt, origin, streamId) {740            exports.nbLogger('HTTP/2 Stream altsvc');741        }).on('aborted', function () {742            exports.nbLogger('HTTP/2 Stream aborted');743        });744    };745    HttpNode.prototype._parseNodeResponse = function (buffer) {746        try {747            switch (this._responseType) {748                default:749                case 'text':750                    return buffer.toString('utf-8');751                case 'json':752                    var s = buffer.toString('utf-8');753                    try {754                        return JSON.parse(s);755                    }756                    catch (e) {757                        return s;758                    }759                case 'buffer':760                    return buffer;761            }762        }763        catch (e) {764            exports.nbError("bad response: e=" + e.toString());765            return null;766        }767    };768    HttpNode._closeSession = function (session, callback) {769        if ('close' in session) {770            session.close(callback); 771        }772        else if ('shutdown' in session) {773            var options = { 'graceful': true };774            session.shutdown(options, callback); 775        }776        else {777            session.destroy();778            session.removeAllListeners();779        }780    };781    HttpNode._closeStream = function (stream) {782        if ('close' in stream) {783            stream.close(); 784        }785        else {786            stream.destroy(); 787        }788    };789    HttpNode.getHttp2Sessions = function () {790        return HttpNode._http2Sessions;791    };792    HttpNode.getHttp2Session = function (authority) {793        var session = null;794        if (authority in HttpNode._http2Sessions) {795            session = HttpNode._http2Sessions[authority];796        }797        return session;798    };799    HttpNode.setHttp2Session = function (authority, session) {800        HttpNode._http2Sessions[authority] = session;801    };802    HttpNode.closeHttp2Session = function (authority) {803        if (authority === undefined) {804            for (var key in HttpNode._http2Sessions) {805                HttpNode.closeHttp2Session(key);806            }807            return;808        }809        var session = HttpNode._http2Sessions[authority];810        if (session != null) {811            if (session.destroyed) {812                session.removeAllListeners();813                exports.nbLogger('HTTP/2 session [' + authority + '] is already destroyed');814            }815            else {816                exports.nbLogger('HTTP/2 session [' + authority + '] is going to close');817                HttpNode._closeSession(session, function () {818                    session.removeAllListeners();819                    exports.nbLogger('HTTP/2 session [' + authority + '] has been closed');820                });821            }822            delete HttpNode._http2Sessions[authority];823        }824    };825    HttpNode._http2Sessions = {};826    return HttpNode;827}(HttpRequestExecutor));828exports.HttpNode = HttpNode;829HttpRequestExecutor.setNodeFactory(function (req) {830    return new HttpNode(req);831});832var _SdeRequest =  (function () {833    function _SdeRequest(className, methodName) {834        exports.nbLogger("_SdeRequest(), className=" + (className) + ", methodName=" + (methodName));835        this._className = className;836        this._methodName = methodName;837        this._data = null;838    }839    _SdeRequest.prototype.setData = function (data) {840        return this._data = data;841    };842    _SdeRequest.prototype.execute = function () {843        var callbacks = {};844        var promise = new Promise(function (resolve, reject) {845            callbacks.success = resolve;846            return callbacks.error = reject;847        });848        var reqId = _SdeRequest._createRequestId();849        _SdeRequest._callbacks[reqId] = callbacks;850        exports.nbLogger("_SdeRequest.execute(), reqId=" + reqId);851        if (!(this._data != null)) {852            this._data = {};853        }854        var data = {855            data: this._data 856        };857        var sdeParams = {858            action: ((this._className) + "." + (this._methodName)),859            request_id: reqId,860            params: JSON.stringify(data),861            callback: "Nebula._SdeRequest.sdeCallback"862        };863        exports.nbLogger("_SdeRequest.execute(), sdeParams=" + JSON.stringify(sdeParams));864        exports.sde.smt.common.exIfExecute("NebulaSdePlugin", "execute", sdeParams);865        return promise;866    };867    _SdeRequest._createRequestId = function () {868        for (var i = 0; i < 1000; i++) {869            var requestId = "id_" + this._requestId;870            this._requestId++;871            if (this._requestId >= 1000) {872                this._requestId = 0;873            }874            if (!this._callbacks[requestId]) {875                exports.nbLogger("_SdeRequest._createRequestId(), requestId=" + requestId);876                return requestId;877            }878        }879        exports.nbLogger("FATAL Error: Nebula._SdeRequest._createRequestId(), callback slot full!");880        throw new Error("Could not create request ID, callback slot full!");881    };882    _SdeRequest.sdeCallback = function (params) {883        try {884            exports.nbLogger("_SdeRequest.sdeCallback()");885            exports.nbLogger("  params=" + JSON.stringify(params));886            exports.nbLogger("  requestId=" + params.requestId);887            exports.nbLogger("  status=" + params.status);888            exports.nbLogger("  statusText=" + params.statusText);889            exports.nbLogger("  responseText=" + params.responseText);890            exports.nbLogger("  response=" + params.response);891            var requestId = params.requestId;892            if (requestId != null && _SdeRequest._callbacks[requestId] != null) {893                var callbacks = _SdeRequest._callbacks[requestId];894                exports.nbLogger("  requestId=" + requestId);895                exports.nbLogger("  _callbacks[requestId]=" + callbacks);896                var status_2 = params.status;897                if (!status_2) {898                    exports.nbLogger("_SdeRequest.sdeCallback(), warning:: not found status property");899                    status_2 = 0;900                }901                if (status_2 >= 200 && status_2 < 300) {902                    exports.nbLogger("_SdeRequest.sdeCallback(), call success callback");903                    callbacks.success(JSON.stringify(params.response));904                }905                else {906                    var errorResult = exports._createError(params.status, params.statusText, params.responseText);907                    exports.nbLogger("Nebula._SdeRequest.sdeCallback(), call error callback: " + errorResult.message908                        + " " + errorResult.responseText);909                    callbacks.error(errorResult);910                }911                delete _SdeRequest._callbacks[requestId];912                exports.nbLogger("_SdeRequest.sdeCallback(), _callbacks : " + JSON.stringify(_SdeRequest._callbacks));913            }914            else {915                exports.nbError("_SdeRequest.sdeCallback(), not found requestId=" + requestId);916            }917        }918        catch (e) {919            exports.nbError("_SdeRequest.sdeCallback(), e=" + e);920        }921    };922    _SdeRequest._callbacks = {};923    _SdeRequest._requestId = 0;924    return _SdeRequest;925}());926exports._SdeRequest = _SdeRequest;927var _SdeNetworkEventListener =  (function () {928    function _SdeNetworkEventListener() {929    }930    _SdeNetworkEventListener.setCallback = function (callback) {931        this._callback = callback;932        exports.nbLogger("_SdeNetworkEventListener.setCallback(), callback=" + callback);933        var data = {};934        if (callback) {935            data.set = true;936        }937        else {938            data.set = false;939        }940        var sdeParams = {941            params: JSON.stringify(data),942            callback: ""943        };944        exports.nbLogger("_SdeNetworkEventListener.setCallback(), sdeParams=" + JSON.stringify(sdeParams));945        return exports.sde.smt.common.exIfExecute("NebulaNetworkEventManager", "setNetworkEventListener", sdeParams);946    };947    _SdeNetworkEventListener.onNetworkStateChanged = function (params) {948        try {949            exports.nbLogger("_SdeNetworkEventListener.onNetworkStateChanged(), params=" + JSON.stringify(params));950            if (this._callback != null && this._callback.onNetworkStateChanged != null) {951                if (params.isOnline != null) {952                    this._callback.onNetworkStateChanged(params.isOnline);953                }954                else {955                    exports.nbError("_SdeNetworkEventListener.onNetworkStateChanged(), invalid parameters");956                }957            }958            else {959                exports.nbLogger("_SdeNetworkEventListener.onNetworkStateChanged(), no callback");960            }961        }962        catch (e) {963            exports.nbError("_SdeNetworkEventListener.onNetworkStateChanged(), exception=" + e);964        }965    };966    return _SdeNetworkEventListener;967}());968exports._SdeNetworkEventListener = _SdeNetworkEventListener;969var _SdeSyncEventListener =  (function () {970    function _SdeSyncEventListener() {971    }972    _SdeSyncEventListener.setListener = function (bucket, listener) {973        if (bucket == null) {974            exports.nbError("_SdeSyncEventListener.setCallback(), no bucket");975            return;976        }977        exports.nbLogger("_SdeSyncEventListener.setCallback(), before : _listeners=" + JSON.stringify(this._listeners));978        var bucketName = bucket.getBucketName();979        var bucketMode = bucket.getBucketMode();980        if (listener == null) {981            this._listeners[bucketName] = listener;982            this._bucketMode[bucketName] = bucketMode;983        }984        else {985            if (this._listeners[bucketName] != null) {986                delete this._listeners[bucketName];987            }988            if (this._bucketMode[bucketName] != null) {989                delete this._bucketMode[bucketName];990            }991        }992        exports.nbLogger("_SdeSyncEventListener.setCallback(), after  : _listeners=" + JSON.stringify(this._listeners));993        var data = {};994        data.bucketName = bucketName;995        data.bucketMode = bucketMode;996        if (listener) {997            data.set = true;998        }999        else {1000            data.set = false;1001        }1002        var sdeParams = {1003            params: JSON.stringify(data),1004            callback: ""1005        };1006        exports.nbLogger("_SyncEventListener.setCallback(), sdeParams=" + JSON.stringify(sdeParams));1007        return exports.sde.smt.common.exIfExecute("NebulaSyncEventManager", "setSyncEventListener", sdeParams);1008    };1009    _SdeSyncEventListener.resolveConflict = function (data) {1010        exports.nbLogger("_SyncEventListener.resolveConflict(), data=" + data);1011        var sdeParams = {1012            params: JSON.stringify(data),1013            callback: ""1014        };1015        exports.nbLogger("_SyncEventListener.resolveConflict(), sdeParams=" + JSON.stringify(sdeParams));1016        return exports.sde.smt.common.exIfExecute("NebulaSyncEventManager", "resolveConflict", sdeParams);1017    };1018    _SdeSyncEventListener.onSyncStart = function (params) {1019        try {1020            exports.nbLogger("_SdeSyncEventListener.onSyncStart(), params=" + JSON.stringify(params));1021            if (params.bucketName != null) {1022                var bucketName = params.bucketName;1023                var listener = _SdeSyncEventListener._listeners[bucketName];1024                if (listener && listener.onSyncStart) {1025                    listener.onSyncStart(bucketName);1026                }1027                else {1028                    exports.nbLogger("_SdeSyncEventListener.onSyncStart(), no callback or onSyncStart");1029                }1030            }1031            else {1032                exports.nbLogger("_SdeSyncEventListener.onSyncStart(), no bucketName");1033            }1034        }1035        catch (e) {1036            exports.nbLogger("_SdeSyncEventListener.onSyncStart(), exception=" + e);1037        }1038    };1039    _SdeSyncEventListener.onSyncCompleted = function (params) {1040        try {1041            exports.nbLogger("_SdeSyncEventListener.onSyncCompleted(), params=" + JSON.stringify(params));1042            exports.nbLogger("_SdeSyncEventListener.onSyncCompleted(), bucketName=" + params.bucketName);1043            exports.nbLogger("_SdeSyncEventListener.onSyncCompleted(), objectIds=" + params.objectIds);1044            if (params.bucketName != null && params.objectIds != null) {1045                var bucketName = params.bucketName;1046                var listener = _SdeSyncEventListener._listeners[bucketName];1047                if (listener && listener.onSyncCompleted) {1048                    listener.onSyncCompleted(bucketName, params.objectIds);1049                }1050                else {1051                    exports.nbLogger("_SdeSyncEventListener.onSyncCompleted(), no callback or onSyncCompleted");1052                }1053            }1054            else {1055                exports.nbLogger("_SdeSyncEventListener.onSyncCompleted(), no bucketName or objectIds");1056            }1057        }1058        catch (e) {1059            exports.nbLogger("_SdeSyncEventListener.onSyncCompleted(), exception=" + e);1060        }1061    };1062    _SdeSyncEventListener.onSyncConflicted = function (params) {1063        try {1064            exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), params=" + JSON.stringify(params));1065            exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), bucketName=" + params.bucketName);1066            exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), resolveId=" + params.resolveId);1067            exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), client=" + params.client);1068            exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), server=" + params.server);1069            if (params.bucketName != null && params.resolveId != null && params.client != null && params.server != null) {1070                var bucketName = params.bucketName;1071                var bucketMode = this._bucketMode[bucketName];1072                if (!(bucketMode != null)) {1073                    bucketMode = exports.Nebula.BUCKET_MODE_REPLICA;1074                }1075                var listener = this._listeners[bucketName];1076                if (listener && listener.onSyncConflicted) {1077                    var bucket = new exports.Nebula.ObjectBucket(bucketName, bucketMode);1078                    bucket._setResolveId(params.resolveId);1079                    listener.onSyncConflicted(bucket, params.client, params.server);1080                }1081                else {1082                    exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), no callback or onSyncCompleted");1083                }1084            }1085            else {1086                exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), invalid parameters");1087            }1088        }1089        catch (e) {1090            exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), exception=" + e);1091        }1092    };1093    _SdeSyncEventListener.onResolveConflict = function (params) {1094        try {1095            exports.nbLogger("_SdeSyncEventListener.onResolveConflict(), params=" + JSON.stringify(params));1096            exports.nbLogger("_SdeSyncEventListener.onResolveConflict(), resolve=" + params.resolve);1097            exports.nbLogger("_SdeSyncEventListener.onResolveConflict(), object=" + params.object);1098            if (params.bucketName != null && params.resolve != null && params.object != null) {1099                var bucketName = params.bucketName;1100                var listener = _SdeSyncEventListener._listeners[bucketName];1101                if (listener && listener["onResolveConflict"]) {1102                    listener.onResolveConflict(params.object, params.resolve);1103                }1104                else {1105                    exports.nbLogger("Nebula._SdeSyncEventListener.onResolveConflict(), no callback or onResolveConflict");1106                }1107            }1108            else {1109                exports.nbLogger("_SdeSyncEventListener.onSyncConflicted(), invalid parameters");1110            }1111        }1112        catch (e) {1113            exports.nbLogger("_SdeSyncEventListener.onResolveConflict(), exception=" + e);1114        }1115    };1116    _SdeSyncEventListener.onSyncError = function (params) {1117        try {1118            exports.nbLogger("_SdeSyncEventListener.onSyncError(), params=" + JSON.stringify(params));1119            exports.nbLogger("_SdeSyncEventListener.onSyncError(), errorCode=" + params.errorCode);1120            exports.nbLogger("_SdeSyncEventListener.onSyncError(), object=" + params.object);1121            if (params.bucketName != null && params.errorCode != null && params.object != null) {1122                var bucketName = params.bucketName;1123                var listener = _SdeSyncEventListener._listeners[bucketName];1124                if (listener != null && listener.onSyncError != null) {1125                    listener.onSyncError(params.errorCode, params.object);1126                }1127                else {1128                    exports.nbLogger("_SdeSyncEventListener.onSyncError(), no callback or onSyncError");1129                }1130            }1131            else {1132                exports.nbLogger("_SdeSyncEventListener.onSyncError(), invalid parameters");1133            }1134        }1135        catch (e) {1136            exports.nbLogger("_SdeSyncEventListener.onSyncError(), exception=" + e);1137        }1138    };1139    _SdeSyncEventListener._listeners = {};1140    _SdeSyncEventListener._bucketMode = {};1141    return _SdeSyncEventListener;1142}());1143exports._SdeSyncEventListener = _SdeSyncEventListener;1144var AccountLink =  (function () {1145    function AccountLink() {1146    }1147    Object.defineProperty(AccountLink.prototype, "_id", {1148        get: function () { return this.__id; },1149        set: function (value) { this.__id = value; },1150        enumerable: true,1151        configurable: true1152    });1153    Object.defineProperty(AccountLink.prototype, "iss", {1154        get: function () { return this._iss; },1155        set: function (value) { this._iss = value; },1156        enumerable: true,1157        configurable: true1158    });1159    Object.defineProperty(AccountLink.prototype, "sub", {1160        get: function () { return this._sub; },1161        set: function (value) { this._sub = value; },1162        enumerable: true,1163        configurable: true1164    });1165    Object.defineProperty(AccountLink.prototype, "op", {1166        get: function () { return this._op; },1167        set: function (value) { this._op = value; },1168        enumerable: true,1169        configurable: true1170    });1171    AccountLink.prototype._setAccountLink = function (obj) {1172        if (obj._id != null) {1173            this.__id = obj._id;1174        }1175        if (obj.iss != null) {1176            this._iss = obj.iss;1177        }1178        if (obj.sub != null) {1179            this._sub = obj.sub;1180        }1181        if (obj.op != null) {1182            this._op = obj.op;1183        }1184        return this;1185    };1186    return AccountLink;1187}());1188exports.AccountLink = AccountLink;1189exports.AclPermission = {1190    READ: "r",1191    WRITE: "w",1192    CREATE: "c",1193    UPDATE: "u",1194    DELETE: "d",1195    ADMIN: "admin",1196    OWNER: "owner"1197};1198exports.AclGroup = {1199    AUTHENTICATED: "g:authenticated",1200    ANONYMOUS: "g:anonymous"1201};1202var Acl =  (function () {1203    function Acl(json) {1204        exports.nbLogger("Acl(), json=" + json);1205        this._acl = {1206            r: [],1207            w: [],1208            c: [],1209            u: [],1210            d: [],1211            admin: []1212        };1213        if (json) {1214            for (var _i = 0, _a = [Acl.OWNER, Acl.READ, Acl.WRITE, Acl.CREATE, Acl.UPDATE, Acl.DELETE, Acl.ADMIN]; _i < _a.length; _i++) {1215                var key = _a[_i];1216                if (json[key]) {1217                    this._acl[key] = json[key];1218                }1219            }1220        }1221    }1222    Acl.prototype.addEntry = function (permission, entry) {1223        var entries = this._acl[permission];1224        if (!entries) {1225            return false;1226        }1227        if (!entry) {1228            return false;1229        }1230        var add = null;1231        if (entry instanceof User) {1232            add = entry._id;1233        }1234        else if (entry instanceof Group) {1235            add = "g:" + entry.groupname;1236        }1237        else {1238            add = entry;1239        }1240        var exist = false;1241        for (var _i = 0, entries_1 = entries; _i < entries_1.length; _i++) {1242            var target = entries_1[_i];1243            if (target === add) {1244                exist = true;1245                break;1246            }1247        }1248        if (!exist) {1249            entries.push(add);1250            exports.nbLogger("Acl.addEntry(), added entry=" + add);1251            return true;1252        }1253        return false;1254    };1255    Acl.prototype.removeEntry = function (permission, entry) {1256        var entries = this._acl[permission];1257        if (!entries) {1258            return false;1259        }1260        if (!entry) {1261            return false;1262        }1263        var remove = null;1264        if (entry instanceof User) {1265            remove = entry._id;1266        }1267        else if (entry instanceof Group) {1268            remove = "g:" + entry.groupname;1269        }1270        else {1271            remove = entry;1272        }1273        for (var i = 0; i < entries.length; i++) {1274            var target = entries[i];1275            if (target === remove) {1276                entries.splice(i, 1);1277                exports.nbLogger("Acl.removeEntry(), removed entry=" + remove);1278                break;1279            }1280        }1281    };1282    Acl.prototype._setOwner = function (owner) {1283        this._acl[Acl.OWNER] = owner;1284    };1285    Acl.prototype.getOwner = function () {1286        if (this._acl.owner) {1287            return this._acl.owner;1288        }1289        return null;1290    };1291    Acl.prototype.getEntries = function (permission) {1292        var entries = this._acl[permission];1293        if (!entries) {1294            return null;1295        }1296        return entries;1297    };1298    Acl.prototype._set = function (acl) {1299        this._acl = acl;1300    };1301    Acl.prototype._hasEntry = function (permission, target) {1302        var entries = this._acl[permission];1303        if (entries) {1304            for (var _i = 0, entries_2 = entries; _i < entries_2.length; _i++) {1305                var entry = entries_2[_i];1306                if (entry === target) {1307                    return true;1308                }1309            }1310        }1311        return false;1312    };1313    Acl.prototype._toString = function (keyName) {1314        return JSON.stringify(this._toJsonObject(keyName));1315    };1316    Acl.prototype._toJsonObject = function (keyName) {1317        if (keyName === "ACL" || keyName === "contentACL") {1318            var json = {};1319            json[keyName] = this._acl;1320            return json;1321        }1322        else {1323            return this._acl;1324        }1325    };1326    Acl.READ = "r";1327    Acl.WRITE = "w";1328    Acl.CREATE = "c";1329    Acl.UPDATE = "u";1330    Acl.DELETE = "d";1331    Acl.ADMIN = "admin";1332    Acl.OWNER = "owner";1333    Acl.AUTHENTICATED = "g:authenticated";1334    Acl.ANONYMOUS = "g:anonymous";1335    return Acl;1336}());1337exports.Acl = Acl;1338exports.RegexOption = {1339    CASE_INSENSITIVITY: "i"1340};1341var Clause =  (function () {1342    function Clause(clause) {1343        if (clause != null) {1344            this._clause = clause;1345        }1346        else {1347            this._clause = {};1348        }1349    }1350    Clause.prototype._setParams = function (key, operator, value, options) {1351        if (operator === null) {1352            this._clause[key] = value;1353        }1354        else {1355            var data = {};1356            if (exports._isObject(this._clause[key])) {1357                data = this._clause[key];1358            }1359            data[operator] = value;1360            if (options) {1361                data["$options"] = options;1362            }1363            this._clause[key] = data;1364        }1365        return this;1366    };1367    Clause.prototype.json = function () {1368        return this._clause;1369    };1370    Clause.equals = function (key, value) {1371        return new Clause().equals(key, value);1372    };1373    Clause.prototype.equals = function (key, value) {1374        var operator = null;1375        if (value != null && exports._isObject(value)) {1376            operator = "$eq";1377        }1378        return this._setParams(key, operator, value);1379    };1380    Clause.notEquals = function (key, value) {1381        return new Clause().notEquals(key, value);1382    };1383    Clause.prototype.notEquals = function (key, value) {1384        return this._setParams(key, "$ne", value);1385    };1386    Clause.lessThan = function (key, value) {1387        return new Clause().lessThan(key, value);1388    };1389    Clause.prototype.lessThan = function (key, value) {1390        return this._setParams(key, "$lt", value);1391    };1392    Clause.lessThanOrEqual = function (key, value) {1393        return new Clause().lessThanOrEqual(key, value);1394    };1395    Clause.prototype.lessThanOrEqual = function (key, value) {1396        return this._setParams(key, "$lte", value);1397    };1398    Clause.greaterThan = function (key, value) {1399        return new Clause().greaterThan(key, value);1400    };1401    Clause.prototype.greaterThan = function (key, value) {1402        return this._setParams(key, "$gt", value);1403    };1404    Clause.greaterThanOrEqual = function (key, value) {1405        return new Clause().greaterThanOrEqual(key, value);1406    };1407    Clause.prototype.greaterThanOrEqual = function (key, value) {1408        return this._setParams(key, "$gte", value);1409    };1410    Clause.in = function (key, values) {1411        return new Clause().in(key, values);1412    };1413    Clause.prototype.in = function (key, values) {1414        return this._setParams(key, "$in", values);1415    };1416    Clause.all = function (key, values) {1417        return new Clause().all(key, values);1418    };1419    Clause.prototype.all = function (key, values) {1420        return this._setParams(key, "$all", values);1421    };1422    Clause.exist = function (key, value) {1423        return new Clause().exist(key, value);1424    };1425    Clause.prototype.exist = function (key, value) {1426        if (typeof value === "boolean") {1427            return this._setParams(key, "$exists", value);1428        }1429        throw new Error("exist: value is not boolean");1430    };1431    Clause.regex = function (key, expression, option) {1432        return new Clause().regex(key, expression, option);1433    };1434    Clause.prototype.regex = function (key, expression, option) {1435        return this._setParams(key, "$regex", expression, option);1436    };1437    Clause.prototype.not = function (key) {1438        var data;1439        if (this._clause === null || !(this._clause[key] != null)) {1440            return null;1441        }1442        else if (exports._isObject(this._clause[key])) {1443            data = {1444                "$not": this._clause[key]1445            };1446            this._clause[key] = data;1447        }1448        else {1449            data = {1450                "$not": {1451                    "$eq": this._clause[key]1452                }1453            };1454            this._clause[key] = data;1455        }1456        return this;1457    };1458    Clause.and = function () {1459        var clauses = [];1460        for (var _i = 0; _i < arguments.length; _i++) {1461            clauses[_i] = arguments[_i];1462        }1463        var values = Clause._convertClauseArray(clauses);1464        return new Clause()._setParams("$and", null, values);1465    };1466    Clause.or = function () {1467        var clauses = [];1468        for (var _i = 0; _i < arguments.length; _i++) {1469            clauses[_i] = arguments[_i];1470        }1471        var values = Clause._convertClauseArray(clauses);1472        return new Clause()._setParams("$or", null, values);1473    };1474    Clause._convertClauseArray = function (clauseArray) {1475        var values = [];1476        for (var _i = 0, clauseArray_1 = clauseArray; _i < clauseArray_1.length; _i++) {1477            var clause = clauseArray_1[_i];1478            var value = clause.json();1479            if (value != null) {1480                values.push(value);1481            }1482        }1483        return values;1484    };1485    return Clause;1486}());1487exports.Clause = Clause;1488var ObjectQuery =  (function () {1489    function ObjectQuery() {1490        this._clause = null;1491        this._limit = -1;1492        this._skip = 0;1493        this._sort = [];1494        this._deleteMark = false;1495        this._countQuery = false;1496        this._projection = null;1497    }1498    ObjectQuery.prototype.getClause = function () {1499        return this._clause;1500    };1501    ObjectQuery.prototype.getLimit = function () {1502        return this._limit;1503    };1504    ObjectQuery.prototype.getSkipCount = function () {1505        return this._skip;1506    };1507    ObjectQuery.prototype.getSort = function () {1508        return this._sort;1509    };1510    ObjectQuery.prototype.getSortOrder = function () {1511        var result = [];1512        for (var i = 0; i < this._sort.length; i++) {1513            var key = this._sort[i];1514            var e = {};1515            if (key.match(/^-/)) {1516                e[key.substr(1)] = false;1517            }1518            else {1519                e[key] = true;1520            }1521            result.push(e);1522        }1523        return result;1524    };1525    ObjectQuery.prototype._getDeleteMark = function () {1526        return this._deleteMark;1527    };1528    ObjectQuery.prototype.getProjection = function () {1529        return this._projection;1530    };1531    ObjectQuery.prototype._setDeleteMark = function (mark) {1532        if (typeof mark === "boolean") {1533            exports.nbLogger("ObjectQuery._setDeleteMark(), mark=" + mark + ", cur=" + this._deleteMark);1534            this._deleteMark = mark;1535        }1536        else {1537            throw new Error("deleteMark must be boolean");1538        }1539    };1540    ObjectQuery.prototype._toParam = function () {1541        var json = this._toParamJson();1542        if (json.where) {1543            json.where = JSON.stringify(json.where);1544        }1545        if (json.projection) {1546            json.projection = JSON.stringify(json.projection);1547        }1548        return json;1549    };1550    ObjectQuery.prototype._toParamJson = function () {1551        var json = {};1552        if (this._clause) {1553            json.where = this._clause.json();1554        }1555        if (this._sort.length > 0) {1556            json.order = this._sort.join(",");1557        }1558        json.skip = this._skip;1559        json.limit = this._limit;1560        if (this._countQuery) {1561            json.count = 1;1562        }1563        if (this._deleteMark) {1564            json.deleteMark = 1;1565        }1566        if (this._projection) {1567            json.projection = this._projection;1568        }1569        return json;1570    };1571    ObjectQuery._toObjectQuery = function (queryJson) {1572        var query = new ObjectQuery();1573        exports.nbLogger("ObjectQuery._toObjectQuery(), queryJson=" + JSON.stringify(queryJson));1574        if (queryJson["limit"] != null) {1575            query.setLimit(queryJson["limit"]);1576        }1577        if (queryJson["skip"] != null) {1578            query.setSkipCount(queryJson["skip"]);1579        }1580        var sort = queryJson["sort"];1581        if (sort != null) {1582            for (var _i = 0, _a = Object.keys(sort); _i < _a.length; _i++) { 1583                var sortKey = _a[_i];1584                query.setSortOrder(sortKey, sort[sortKey]);1585            }1586        }1587        var clause = queryJson["clause"];1588        if (clause != null && Object.keys(clause).length !== 0) {1589            query.setClause(new Clause(clause));1590        }1591        if (queryJson["deleteMark"] != null) {1592            query._setDeleteMark(queryJson["deleteMark"]);1593        }1594        if (queryJson["countQuery"] != null) {1595            query._setCountQuery(queryJson["countQuery"]);1596        }1597        return query;1598    };1599    ObjectQuery.prototype._equals = function (that) {1600        if (this._limit !== that.getLimit()) {1601            return false;1602        }1603        if (this._skip !== that.getSkipCount()) {1604            return false;1605        }1606        if (this._deleteMark !== that._getDeleteMark()) {1607            return false;1608        }1609        if (this._countQuery !== that._isCountQuery()) {1610            return false;1611        }1612        if (this._projection) {1613            if (that.getProjection()) {1614                if (!exports._compareObject(this._projection, that.getProjection())) {1615                    return false;1616                }1617            }1618            else {1619                return false;1620            }1621        }1622        else {1623            if (that.getProjection()) {1624                return false;1625            }1626        }1627        if (this._clause) {1628            if (that.getClause()) {1629                if (!exports._compareObject(this._clause.json(), that.getClause().json())) {1630                    return false;1631                }1632            }1633            else {1634                return false;1635            }1636        }1637        else {1638            if (that.getClause()) {1639                return false;1640            }1641        }1642        return exports._compareObject(this._sort, that.getSortOrder());1643    };1644    ObjectQuery.prototype.setClause = function (clause) {1645        if (clause === null || clause instanceof Clause) {1646            this._clause = clause;1647        }1648        else {1649            throw new Error("clause must be instanceof Nebula.Clause or null");1650        }1651        return this;1652    };1653    ObjectQuery.prototype.setLimit = function (limit) {1654        if (limit >= -1) {1655            this._limit = limit;1656        }1657        else {1658            throw new Error("Invalid limit range");1659        }1660        return this;1661    };1662    ObjectQuery.prototype.setSkipCount = function (skip) {1663        if (skip >= 0) {1664            this._skip = skip;1665        }1666        else {1667            throw new Error("Invalid skip range");1668        }1669        return this;1670    };1671    ObjectQuery.prototype.setSort = function (sort) {1672        this._sort = sort;1673        return this;1674    };1675    ObjectQuery.prototype.setSortOrder = function (key, isAsc) {1676        if (!key) {1677            throw new Error("No key");1678        }1679        if (typeof isAsc !== "boolean") {1680            throw new Error("isAsc must be boolean");1681        }1682        if (isAsc) {1683            this._sort.push(key);1684        }1685        else {1686            this._sort.push("-" + key);1687        }1688        return this;1689    };1690    ObjectQuery.prototype.clearSortOrder = function (key) {1691        if (key === void 0) { key = null; }1692        if (!key) {1693            this._sort = [];1694        }1695        else {1696            for (var i = 0; i < this._sort.length; i++) {1697                var k = this._sort[i];1698                if (k === key || k === "-" + key) {1699                    this._sort.splice(i, 1);1700                    break;1701                }1702            }1703        }1704        return this;1705    };1706    ObjectQuery.prototype._setCountQuery = function (countQuery) {1707        if (typeof countQuery === "boolean") {1708            this._countQuery = countQuery;1709        }1710        else {1711            throw new Error("countQuery must be boolean");1712        }1713        return this;1714    };1715    ObjectQuery.prototype._isCountQuery = function () {1716        return this._countQuery;1717    };1718    ObjectQuery.prototype.setProjection = function (projectionJson) {1719        if (projectionJson && exports._isObject(projectionJson)) {1720            this._projection = projectionJson;1721        }1722        else if (projectionJson === null) {1723            this._projection = null;1724        }1725        else {1726            throw new Error("projection must be object or null");1727        }1728        return this;1729    };1730    return ObjectQuery;1731}());1732exports.ObjectQuery = ObjectQuery;1733var User =  (function () {1734    function User(service) {1735        if (service === void 0) { service = exports.Nebula; }1736        this._service = service;1737        this.__id = null;1738        this._username = null;1739        this._email = null;1740        this._password = null;1741        this._options = null;1742        this._groups = null;1743        this._createdAt = null;1744        this._updatedAt = null;1745        this._lastLoginAt = null;1746        this._etag = null;1747        this._sessionToken = null;1748        this._expire = null;1749        this._clientCertUser = null;1750        this._federated = false;1751        this._primaryLinkedUserId = null;1752    }1753    Object.defineProperty(User.prototype, "_id", {1754        get: function () { return this.__id; },1755        set: function (value) { this.__id = value; },1756        enumerable: true,1757        configurable: true1758    });1759    Object.defineProperty(User.prototype, "username", {1760        get: function () { return this._username; },1761        set: function (value) { this._username = value; },1762        enumerable: true,1763        configurable: true1764    });1765    Object.defineProperty(User.prototype, "email", {1766        get: function () { return this._email; },1767        set: function (value) { this._email = value; },1768        enumerable: true,1769        configurable: true1770    });1771    Object.defineProperty(User.prototype, "password", {1772        get: function () { return this._password; },1773        set: function (value) { this._password = value; },1774        enumerable: true,1775        configurable: true1776    });1777    Object.defineProperty(User.prototype, "options", {1778        get: function () { return this._options; },1779        set: function (value) { this._options = value; },1780        enumerable: true,1781        configurable: true1782    });1783    Object.defineProperty(User.prototype, "groups", {1784        get: function () { return this._groups; },1785        set: function (value) { this._groups = value; },1786        enumerable: true,1787        configurable: true1788    });1789    Object.defineProperty(User.prototype, "createdAt", {1790        get: function () { return this._createdAt; },1791        set: function (value) { this._createdAt = value; },1792        enumerable: true,1793        configurable: true1794    });1795    Object.defineProperty(User.prototype, "updatedAt", {1796        get: function () { return this._updatedAt; },1797        set: function (value) { this._updatedAt = value; },1798        enumerable: true,1799        configurable: true1800    });1801    Object.defineProperty(User.prototype, "lastLoginAt", {1802        get: function () { return this._lastLoginAt; },1803        set: function (value) { this._lastLoginAt = value; },1804        enumerable: true,1805        configurable: true1806    });1807    Object.defineProperty(User.prototype, "etag", {1808        get: function () { return this._etag; },1809        set: function (value) { this._etag = value; },1810        enumerable: true,1811        configurable: true1812    });1813    Object.defineProperty(User.prototype, "sessionToken", {1814        get: function () { return this._sessionToken; },1815        set: function (value) { this._sessionToken = value; },1816        enumerable: true,1817        configurable: true1818    });1819    Object.defineProperty(User.prototype, "expire", {1820        get: function () { return this._expire; },1821        set: function (value) { this._expire = value; },1822        enumerable: true,1823        configurable: true1824    });1825    Object.defineProperty(User.prototype, "clientCertUser", {1826        get: function () { return this._clientCertUser; },1827        set: function (value) { this._clientCertUser = value; },1828        enumerable: true,1829        configurable: true1830    });1831    Object.defineProperty(User.prototype, "federated", {1832        get: function () { return this._federated; },1833        set: function (value) { this._federated = value; },1834        enumerable: true,1835        configurable: true1836    });1837    Object.defineProperty(User.prototype, "primaryLinkedUserId", {1838        get: function () { return this._primaryLinkedUserId; },1839        set: function (value) { this._primaryLinkedUserId = value; },1840        enumerable: true,1841        configurable: true1842    });1843    User.prototype._setUserInfo = function (response) {1844        exports.nbLogger("User._setUserInfo#start");1845        var jsonObj;1846        try {1847            jsonObj = JSON.parse(response);1848        }1849        catch (undefined) {1850            exports.nbError("User._setUserInfo#json error.");1851            jsonObj = null;1852        }1853        if (jsonObj !== null) {1854            if (jsonObj._id !== undefined) {1855                this._id = jsonObj._id;1856            }1857            if (jsonObj.username !== undefined) {1858                this.username = jsonObj.username;1859            }1860            if (jsonObj.email !== undefined) {1861                this.email = jsonObj.email;1862            }1863            if (jsonObj.password !== undefined) {1864                this.password = jsonObj.password;1865            }1866            if (jsonObj.options !== undefined) {1867                this.options = jsonObj.options;1868            }1869            if (jsonObj.groups !== undefined) {1870                this.groups = jsonObj.groups;1871            }1872            if (jsonObj.createdAt !== undefined) {1873                this.createdAt = jsonObj.createdAt;1874            }1875            if (jsonObj.updatedAt !== undefined) {1876                this.updatedAt = jsonObj.updatedAt;1877            }1878            if (jsonObj.lastLoginAt !== undefined) {1879                this.lastLoginAt = jsonObj.lastLoginAt;1880            }1881            if (jsonObj.etag !== undefined) {1882                this.etag = jsonObj.etag;1883            }1884            if (jsonObj.sessionToken !== undefined) {1885                this.sessionToken = jsonObj.sessionToken;1886            }1887            if (jsonObj.expire !== undefined) {1888                this.expire = jsonObj.expire;1889            }1890            if (jsonObj.clientCertUser !== undefined) {1891                this.clientCertUser = jsonObj.clientCertUser;1892            }1893            if (jsonObj.federated !== undefined) {1894                this.federated = jsonObj.federated;1895            }1896            if (jsonObj.primaryLinkedUserId !== undefined) {1897                this.primaryLinkedUserId = jsonObj.primaryLinkedUserId;1898            }1899        }1900    };1901    User.prototype.set = function (property, value) {1902        switch (property) {1903            case "_id":1904                this._id = value;1905                break;1906            case "username":1907                this.username = value;1908                break;1909            case "email":1910                this.email = value;1911                break;1912            case "password":1913                this.password = value;1914                break;1915            case "options":1916                this.options = value;1917                break;1918            case "createdAt":1919                this.createdAt = value;1920                break;1921            case "updatedAt":1922                this._updatedAt = value;1923                break;1924            case "sessionToken":1925                this.sessionToken = value;1926                break;1927            case "expire":1928                this.expire = value;1929                break;1930            case "clientCertUser":1931                this.clientCertUser = value;1932                break;1933            case "federated":1934                this.federated = value;1935                break;1936            case "primaryLinkedUserId":1937                this.primaryLinkedUserId = value;1938                break;1939            default:1940                exports.nbError("Invalid property: " + property);1941                throw new Error("Invalid property: " + property);1942        }1943    };1944    User.prototype.get = function (property) {1945        switch (property) {1946            case "_id":1947                return this._id;1948            case "username":1949                return this.username;1950            case "email":1951                return this.email;1952            case "password":1953                return this.password;1954            case "options":1955                return this.options;1956            case "groups":1957                return this.groups;1958            case "createdAt":1959                return this.createdAt;1960            case "updatedAt":1961                return this.updatedAt;1962            case "sessionToken":1963                return this.sessionToken;1964            case "expire":1965                return this.expire;1966            case "clientCertUser":1967                return this.clientCertUser;1968            case "federated":1969                return this.federated;1970            case "primaryLinkedUserId":1971                return this.primaryLinkedUserId;1972            default:1973                exports.nbError("Invalid property");1974                throw new Error("Invalid property name");1975        }1976    };1977    User.prototype.register = function (callbacks) {1978        var _this = this;1979        exports.nbLogger("User.register#start");1980        var request;1981        if (this._service.isOffline()) {1982            request = new _SdeRequest("NebulaUser", "register");1983        }1984        else {1985            var path = "/users";1986            exports.nbLogger("User.register#REST API Request path = " + path);1987            request = new HttpRequest(this._service, path);1988            request.setMethod("POST");1989            request.setContentType("application/json");1990        }1991        var registerParams;1992        if (this.clientCertUser === true) {1993            registerParams = {1994                clientCertUser: true,1995                username: this.username1996            };1997        }1998        else {1999            registerParams = {2000                email: this.email,2001                password: this.password2002            };2003            if (this.username != null) {2004                registerParams.username = this.username;2005            }2006        }2007        if (this.options !== null) {2008            registerParams.options = this.options;2009        }2010        request.setData(registerParams);2011        var promise = request.execute()2012            .then(function (response) {2013            exports.nbLogger("User.register#success callback start");2014            exports.nbLogger("User.register#response = " + response);2015            _this._setUserInfo(response);2016            return _this;2017        })2018            .catch(function (error) {2019            exports.nbLogger("User.register#error callback start");2020            exports.nbLogger(("User.register#error = " + (exports._errorText(error))));2021            return Promise.reject(error);2022        });2023        exports.nbLogger("User.register#end");2024        return exports._promisify(promise, callbacks);2025    };2026    User.login = function (userInfo, callbacks) { return null; };2027    User._login = function (service, userInfo, callbacks) {2028        exports.nbLogger("User.login#start");2029        if (userInfo == null || (userInfo.email == null && userInfo.username == null && userInfo.token == null)) {2030            throw new Error("User.login: No username nor email nor token");2031        }2032        if (userInfo.password == null && userInfo.token == null) {2033            throw new Error("User.login: No password nor token");2034        }2035        var request;2036        if (service.isOffline()) {2037            request = new _SdeRequest("NebulaUser", "login");2038        }2039        else {2040            var path = "/login";2041            exports.nbLogger("User.login#REST API Request path = " + path);2042            request = new HttpRequest(service, path);2043            request.setSessionToken(null);2044            request.setMethod("POST");2045            request.setContentType("application/json");2046        }2047        request.setData(userInfo);2048        var user = new service.User();2049        user.email = userInfo.email;2050        user.username = userInfo.username;2051        var promise = request.execute()2052            .then(function (response) {2053            exports.nbLogger("User.login#success callback start");2054            exports.nbLogger("User.login#response = " + response);2055            user._setUserInfo(response);2056            service.setCurrentUser(user);2057            return user;2058        })2059            .catch(function (error) {2060            exports.nbLogger("User.login#error callback start");2061            exports.nbLogger(("User.login#error = " + (exports._errorText(error))));2062            return Promise.reject(error);2063        });2064        exports.nbLogger("User.login#end");2065        return exports._promisify(promise, callbacks);2066    };2067    User.logout = function (callbacks) { return null; };2068    User._logout = function (service, callbacks) {2069        exports.nbLogger("User.logout#start");2070        var request;2071        if (service.isOffline()) {2072            request = new _SdeRequest("NebulaUser", "logout");2073        }2074        else {2075            var path = "/login";2076            exports.nbLogger("User.logout#REST API Request path = " + path);2077            request = new HttpRequest(service, path);2078            request.setMethod("DELETE");2079            request.setContentType("application/json");2080        }2081        var promise = request.execute()2082            .then(function (response) {2083            exports.nbLogger("User.logout#success callback start");2084            exports.nbLogger("User.logout#response = " + response);2085            service.removeCurrentUser();2086            return;2087        })2088            .catch(function (error) {2089            exports.nbLogger("User.logout#error callback start");2090            exports.nbLogger(("User.logout#error = " + (exports._errorText(error))));2091            service.removeCurrentUser();2092            return Promise.reject(error);2093        });2094        exports.nbLogger("User.logout#end");2095        return exports._promisify(promise, callbacks);2096    };2097    User.current = function (callbacks) { return null; };2098    User._current = function (service, callbacks) {2099        var user = null;2100        var _currentObj = service.getCurrentUser();2101        if (_currentObj !== null) {2102            user = new service.User();2103            user._setUserInfo(JSON.stringify(_currentObj));2104        }2105        if (callbacks && callbacks.success) {2106            callbacks.success(user);2107        }2108        return user;2109    };2110    User.saveCurrent = function (userInfo) { };2111    User._saveCurrent = function (service, userInfo) {2112        if (service.isOffline()) {2113            throw new Error("Not supported in offline mode");2114        }2115        if ((userInfo === null)) {2116            service.removeCurrentUser();2117        }2118        else {2119            var newInfo = service.getCurrentUser() || {};2120            for (var key in userInfo) {2121                if (userInfo.hasOwnProperty(key)) {2122                    newInfo[key] = userInfo[key];2123                }2124            }2125            var user = new service.User();2126            user._setUserInfo(JSON.stringify(newInfo));2127            service.setCurrentUser(user);2128        }2129    };2130    User.queryCurrent = function (callbacks) { return null; };2131    User._queryCurrent = function (service, callbacks) {2132        exports.nbLogger("User.queryCurrent#start");2133        var request;2134        if (service.isOffline()) {2135            var _currentObj = service.getCurrentUser();2136            if (_currentObj === null) {2137                return exports._promisify(Promise.resolve(null), callbacks);2138            }2139            request = new _SdeRequest("NebulaUser", "current");2140        }2141        else {2142            var path = "/users/current";2143            exports.nbLogger("User.queryCurrent#REST API Request path = " + path);2144            request = new HttpRequest(service, path);2145            request.setMethod("GET");2146            request.setContentType("application/json");2147        }2148        var promise = request.execute()2149            .then(function (response) {2150            exports.nbLogger("User.queryCurrent#success callback start");2151            exports.nbLogger("User.queryCurrent#response = " + response);2152            var user = new service.User();2153            user._setUserInfo(response);2154            return user;2155        })2156            .catch(function (error) {2157            exports.nbLogger("User.queryCurrent#error callback start");2158            exports.nbLogger(("User.queryCurrent#error = " + (exports._errorText(error))));2159            return Promise.reject(error);2160        });2161        exports.nbLogger("User.queryCurrent#end");2162        return exports._promisify(promise, callbacks);2163    };2164    User.query = function (conditions, callbacks) { return null; };2165    User._query = function (service, conditions, callbacks) {2166        exports.nbLogger("User.query#start");2167        var request;2168        if (service.isOffline()) {2169            request = new _SdeRequest("NebulaUser", "query");2170            if (conditions !== null) {2171                request.setData(conditions);2172            }2173        }2174        else {2175            var path = "/users";2176            var queryParams = {};2177            if (conditions) {2178                if (conditions._id) {2179                    path = "/users/" + encodeURIComponent(conditions._id);2180                }2181                else if (conditions.email) {2182                    queryParams.email = conditions.email;2183                }2184                else if (conditions.username) {2185                    queryParams.username = conditions.username;2186                }2187                if (conditions.skip != null) {2188                    queryParams.skip = conditions.skip;2189                }2190                if (conditions.limit != null) {2191                    queryParams.limit = conditions.limit;2192                }2193            } 2194            exports.nbLogger("User.query#REST API Request path = " + path);2195            request = new HttpRequest(service, path);2196            request.setMethod("GET");2197            request.setQueryParams(queryParams);2198            request.setContentType("application/json");2199        }2200        var promise = request.execute()2201            .then(function (response) {2202            exports.nbLogger("User.query#success callback start");2203            exports.nbLogger("User.query#response = " + response);2204            var obj = JSON.parse(response);2205            var objArray = [];2206            var userArray = [];2207            var i = 0;2208            if (obj.results === undefined) {2209                objArray.push(obj);2210            }2211            else {2212                objArray = obj.results;2213            }2214            while (i < objArray.length) {2215                var user = new service.User();2216                user._setUserInfo(JSON.stringify(objArray[i]));2217                userArray.push(user);2218                i++;2219            }2220            if (conditions != null && conditions.countQuery) {2221                return {2222                    users: userArray,2223                    count: obj.count2224                };2225            }2226            else {2227                return userArray;2228            }2229        })2230            .catch(function (error) {2231            exports.nbLogger("User.query#error callback start");2232            exports.nbLogger(("User.query#error = " + (exports._errorText(error))));2233            return Promise.reject(error);2234        });2235        exports.nbLogger("User.query#end");2236        return exports._promisify(promise, callbacks);2237    };2238    User.update = function (user, callbacks) { return null; };2239    User._update = function (service, user, callbacks) {2240        if (!(user instanceof User)) {2241            throw new Error("User.update: not User instance");2242        }2243        if (user._service !== service) {2244            throw new Error("Service does not match");2245        }2246        return user._update(callbacks);2247    };2248    User.prototype._update = function (callbacks) {2249        var _this = this;2250        var path;2251        var request;2252        var error;2253        exports.nbLogger("User.update#start");2254        if (this._id === null) {2255            exports.nbLogger("User.update: no user id");2256            error = exports._createError(400, "Bad Request (local)", "no user id.");2257            return exports._promisify(Promise.reject(error), callbacks);2258        }2259        var updateParams = {};2260        if (this._service.isOffline()) {2261            request = new _SdeRequest("NebulaUser", "update");2262            updateParams._id = this._id;2263        }2264        else {2265            path = "/users/" + this._id;2266            exports.nbLogger("User.update#REST API Request path = " + path);2267            request = new HttpRequest(this._service, path);2268            request.setMethod("PUT");2269            request.setContentType("application/json");2270            delete updateParams._id;2271        }2272        if (this.email !== null) {2273            updateParams.email = this.email;2274        }2275        if (this.username !== null) {2276            updateParams.username = this.username;2277        }2278        if (this.password !== null) {2279            updateParams.password = this.password;2280        }2281        if (this.options !== null) {2282            updateParams.options = this.options;2283        }2284        request.setData(updateParams);2285        var promise = request.execute()2286            .then(function (response) {2287            exports.nbLogger("User.update#success callback start");2288            exports.nbLogger("User.update#response = " + response);2289            _this._setUserInfo(response);2290            return _this;2291        })2292            .catch(function (error) {2293            exports.nbLogger("User.update#error callback start");2294            exports.nbLogger(("User.update#error = " + (exports._errorText(error))));2295            return Promise.reject(error);2296        });2297        exports.nbLogger("User.update#end");2298        return exports._promisify(promise, callbacks);2299    };2300    User.remove = function (user, callbacks) { return null; };2301    User._remove = function (service, user, callbacks) {2302        if (!(user instanceof User)) {2303            throw new Error("User.remove: not User instance");2304        }2305        if (user._service !== service) {2306            throw new Error("User.remove: service does not match");2307        }2308        return user._remove(callbacks);2309    };2310    User.prototype._remove = function (callbacks) {2311        var _this = this;2312        exports.nbLogger("User.remove#start");2313        if (this._id === null) {2314            exports.nbLogger("User.remove: no user id.");2315            var error = exports._createError(400, "Bad argument (local)", "no user id.");2316            return exports._promisify(Promise.reject(error), callbacks);2317        }2318        var request;2319        if (this._service.isOffline()) {2320            request = new _SdeRequest("NebulaUser", "delete");2321            request.setData({2322                _id: this._id2323            });2324        }2325        else {2326            var path = "/users/" + this._id;2327            exports.nbLogger("User.remove#REST API Request path = " + path);2328            request = new HttpRequest(this._service, path);2329            request.setMethod("DELETE");2330        }2331        var promise = request.execute()2332            .then(function (response) {2333            exports.nbLogger("User.remove#success callback start");2334            exports.nbLogger("User.remove#response = " + response);2335            var _currentUser = _this._service.getCurrentUser();2336            if (_currentUser !== null) {2337                if (_this._id === _currentUser._id) {2338                    exports.nbLogger("User.remove#delete user is current user");2339                    _this._service.removeCurrentUser();2340                }2341            }2342            return;2343        })2344            .catch(function (error) {2345            exports.nbLogger("User.remove#error callback start");2346            exports.nbLogger(("User.remove#error = " + (exports._errorText(error))));2347            return Promise.reject(error);2348        });2349        exports.nbLogger("User.remove#end");2350        return exports._promisify(promise, callbacks);2351    };2352    User.resetPassword = function (userInfo, callbacks) { return null; };2353    User._resetPassword = function (service, userInfo, callbacks) {2354        exports.nbLogger("User.resetPassword#start");2355        if (userInfo == null || (userInfo.email == null && userInfo.username == null)) {2356            throw new Error("User.resetPassword: bad arguments");2357        }2358        var request;2359        if (service.isOffline()) {2360            request = new _SdeRequest("NebulaUser", "resetPassword");2361        }2362        else {2363            var path = "/request_password_reset";2364            exports.nbLogger("User.resetPassword#REST API Request path = " + path);2365            request = new HttpRequest(service, path);2366            request.setSessionToken(null);2367            request.setMethod("POST");2368            request.setContentType("application/json");2369        }2370        var resetParams;2371        if (((userInfo.email !== undefined) && (userInfo.username !== undefined))) {2372            resetParams = {2373                email: userInfo.email,2374                username: userInfo.username2375            };2376        }2377        else if (((userInfo.email !== undefined) && (userInfo.username === undefined))) {2378            resetParams = {2379                email: userInfo.email2380            };2381        }2382        else if (((userInfo.email === undefined) && (userInfo.username !== undefined))) {2383            resetParams = {2384                username: userInfo.username2385            };2386        }2387        request.setData(resetParams);2388        var promise = request.execute()2389            .then(function (response) {2390            exports.nbLogger("User.resetPassword#success callback start");2391            exports.nbLogger("User.resetPassword#response = " + response);2392            return;2393        })2394            .catch(function (error) {2395            exports.nbLogger("User.resetPassword#error callback start");2396            exports.nbLogger(("User.resetPassword#error = " + (exports._errorText(error))));2397            return Promise.reject(error);2398        });2399        exports.nbLogger("User.delete#end");2400        return exports._promisify(promise, callbacks);2401    };2402    User.getAccountLinks = function (user, callbacks) { return null; };2403    User._getAccountLinks = function (service, user, callbacks) {2404        if (!(user instanceof User)) {2405            throw new Error("User.getAccountLinks: not User instance");2406        }2407        if (user._service !== service) {2408            throw new Error("User.getAccountLinks: Service does not match");2409        }2410        return user._getAccountLinks(callbacks);2411    };2412    User.prototype._getAccountLinks = function (callbacks) {2413        exports.nbLogger("User.getAccountLinks#start");2414        if (this._service.isOffline()) {2415            throw new Error("User.getAccountLinks: offline mode is not supported");2416        }2417        if (this._id === null) {2418            throw new Error("User.getAccountLinks: no user id");2419        }2420        var path = "/users/" + this._id + "/links";2421        exports.nbLogger("User.getAccountLinks#REST API Request path = " + path);2422        var request = new HttpRequest(this._service, path);2423        request.setMethod("GET");2424        var promise = request.execute()2425            .then(function (response) {2426            exports.nbLogger("User.getAccountLinks#response = " + response);2427            var resObj = JSON.parse(response);2428            var resArray = resObj.results;2429            var links = [];2430            if (resArray != null) {2431                for (var _i = 0, resArray_1 = resArray; _i < resArray_1.length; _i++) {2432                    var obj = resArray_1[_i];2433                    var link = new AccountLink();2434                    link._setAccountLink(obj);2435                    links.push(link);2436                }2437            }2438            return links;2439        })2440            .catch(function (error) {2441            exports.nbLogger(("User.getAccountLinks#error = " + (exports._errorText(error))));2442            return Promise.reject(error);2443        });2444        exports.nbLogger("User.getAccountLinks#end");2445        return exports._promisify(promise, callbacks);2446    };2447    User.deleteAccountLink = function (user, linkedUserId, callbacks) { return null; };2448    User._deleteAccountLink = function (service, user, linkedUserId, callbacks) {2449        if (!(user instanceof User)) {2450            throw new Error("User.deleteAccountLink: not User instance");2451        }2452        if (user._service !== service) {2453            throw new Error("User.deleteAccountLink: Service does not match");2454        }2455        if (linkedUserId == null) {2456            throw new Error("User.deleteAccountLink: no linkedUserId");2457        }2458        return user._deleteAccountLink(linkedUserId, callbacks);2459    };2460    User.prototype._deleteAccountLink = function (linkedUserId, callbacks) {2461        exports.nbLogger("User.deleteAccountLink#start");2462        if (this._service.isOffline()) {2463            throw new Error("User.deleteAccountLink: offline mode is not supported");2464        }2465        if (this._id === null) {2466            throw new Error("User.deleteAccountLink: no user id");2467        }2468        if (this.primaryLinkedUserId !== null && this.primaryLinkedUserId === linkedUserId) {2469            throw new Error("User.deleteAccountLink: linkedUserId is primaryLinkedUserId");2470        }2471        var path = "/users/" + this._id + "/links/" + linkedUserId;2472        exports.nbLogger("User.deleteAccountLink#REST API Request path = " + path);2473        var request = new HttpRequest(this._service, path);2474        request.setMethod("DELETE");2475        var promise = request.execute()2476            .then(function (response) {2477            exports.nbLogger("User.deleteAccountLink#response = " + response);2478            return;2479        })2480            .catch(function (error) {2481            exports.nbLogger(("User.deleteAccountLink#error = " + (exports._errorText(error))));2482            return Promise.reject(error);2483        });2484        exports.nbLogger("User.deleteAccountLink#end");2485        return exports._promisify(promise, callbacks);2486    };2487    return User;2488}());2489exports.User = User;2490exports.declareUser = function (_service) {2491    var _a;2492    _service.User = (_a =  (function (_super) {2493            __extends(_User, _super);2494            function _User() {2495                var _this = _super.call(this, _service) || this;2496                exports.nbLogger("User.constructor");2497                return _this;2498            }2499            _User.login = function (userInfo, callbacks) {2500                return _super._login.call(this, _service, userInfo, callbacks);2501            };2502            _User.logout = function (callbacks) {2503                return _super._logout.call(this, _service, callbacks);2504            };2505            _User.current = function (callbacks) {2506                return _super._current.call(this, _service, callbacks);2507            };2508            _User.saveCurrent = function (userInfo) {2509                _super._saveCurrent.call(this, _service, userInfo);2510            };2511            _User.queryCurrent = function (callbacks) {2512                return _super._queryCurrent.call(this, _service, callbacks);2513            };2514            _User.query = function (conditions, callbacks) {2515                return _super._query.call(this, _service, conditions, callbacks);2516            };2517            _User.update = function (user, callbacks) {2518                return _super._update.call(this, _service, user, callbacks);2519            };2520            _User.remove = function (user, callbacks) {2521                return _super._remove.call(this, _service, user, callbacks);2522            };2523            _User.resetPassword = function (userInfo, callbacks) {2524                return _super._resetPassword.call(this, _service, userInfo, callbacks);2525            };2526            _User.getAccountLinks = function (user, callbacks) {2527                return _super._getAccountLinks.call(this, _service, user, callbacks);2528            };2529            _User.deleteAccountLink = function (user, linkedUserId, callbacks) {2530                return _super._deleteAccountLink.call(this, _service, user, linkedUserId, callbacks);2531            };2532            return _User;2533        }(User)),2534        _a.delete = _a.remove,2535        _a);2536};2537var Group =  (function () {2538    function Group(groupname, service) {2539        if (service === void 0) { service = exports.Nebula; }2540        this._service = service;2541        this._id = null;2542        this.groupname = null;2543        this.users = [];2544        this.groups = [];2545        this.acl = null;2546        this.createdAt = null;2547        this.updatedAt = null;2548        this.etag = null;2549        if (((typeof groupname) === "string") && groupname !== "") {2550            this.groupname = groupname;2551        }2552    }2553    Object.defineProperty(Group.prototype, "_id", {2554        get: function () { return this.__id; },2555        set: function (value) { this.__id = value; },2556        enumerable: true,2557        configurable: true2558    });2559    Object.defineProperty(Group.prototype, "groupname", {2560        get: function () { return this._groupname; },2561        set: function (value) { this._groupname = value; },2562        enumerable: true,2563        configurable: true2564    });2565    Object.defineProperty(Group.prototype, "users", {2566        get: function () { return this._users; },2567        set: function (value) { this._users = value; },2568        enumerable: true,2569        configurable: true2570    });2571    Object.defineProperty(Group.prototype, "groups", {2572        get: function () { return this._groups; },2573        set: function (value) { this._groups = value; },2574        enumerable: true,2575        configurable: true2576    });2577    Object.defineProperty(Group.prototype, "acl", {2578        get: function () { return this._acl; },2579        set: function (value) {2580            if (value != null && !(value instanceof Acl)) {2581                throw new Error("acl is not Acl instance!");2582            }2583            this._acl = value;2584        },2585        enumerable: true,2586        configurable: true2587    });2588    Object.defineProperty(Group.prototype, "createdAt", {2589        get: function () { return this._createdAt; },2590        set: function (value) { this._createdAt = value; },2591        enumerable: true,2592        configurable: true2593    });2594    Object.defineProperty(Group.prototype, "updatedAt", {2595        get: function () { return this._updatedAt; },2596        set: function (value) { this._updatedAt = value; },2597        enumerable: true,2598        configurable: true2599    });2600    Object.defineProperty(Group.prototype, "etag", {2601        get: function () { return this._etag; },2602        set: function (value) { this._etag = value; },2603        enumerable: true,2604        configurable: true2605    });2606    Group.prototype._setGroupInfo = function (response) {2607        var jsonObj;2608        try {2609            jsonObj = JSON.parse(response);2610        }2611        catch (undefined) {2612            exports.nbError("Group._setGroupInfo#json error.");2613            return;2614        }2615        if (jsonObj._id !== undefined) {2616            this._id = jsonObj._id;2617        }2618        if (jsonObj.name !== undefined) {2619            this.groupname = jsonObj.name;2620        }2621        if (jsonObj.users !== undefined) {2622            this.users = jsonObj.users;2623        }2624        if (jsonObj.groups !== undefined) {2625            this.groups = jsonObj.groups;2626        }2627        if (jsonObj.ACL !== undefined) {2628            this.acl = new Acl();2629            this.acl._set(jsonObj.ACL);2630            if (jsonObj.ACL.owner !== undefined) {2631                this.acl._setOwner(jsonObj.ACL.owner);2632            }2633        }2634        if (jsonObj.createdAt !== undefined) {2635            this.createdAt = jsonObj.createdAt;2636        }2637        if (jsonObj.updatedAt !== undefined) {2638            this.updatedAt = jsonObj.updatedAt;2639        }2640        if (jsonObj.etag !== undefined) {2641            return this.etag = jsonObj.etag;2642        }2643    };2644    Group.prototype.set = function (property, value) {2645        switch (property) {2646            case "_id":2647                this._id = value;2648                break;2649            case "groupname":2650                this.groupname = value;2651                break;2652            case "users":2653                this.users = value;2654                break;2655            case "groups":2656                this.groups = value;2657                break;2658            case "acl":2659                this.acl = value;2660                break;2661            case "createdAt":2662                this.createdAt = value;2663                break;2664            case "updatedAt":2665                this.updatedAt = value;2666                break;2667            case "etag":2668                this.etag = value;2669                break;2670            default:2671                exports.nbError("Invalid property: " + property);2672                throw new Error("Invalid property: " + property);2673        }2674    };2675    Group.prototype.get = function (property) {2676        switch (property) {2677            case "_id":2678                return this._id;2679            case "groupname":2680                return this.groupname;2681            case "users":2682                return this.users;2683            case "groups":2684                return this.groups;2685            case "acl":2686                return this.acl;2687            case "createdAt":2688                return this.createdAt;2689            case "updatedAt":2690                return this.updatedAt;2691            case "etag":2692                return this.etag;2693            default:2694                exports.nbError("Invalid property: " + property);2695                throw new Error("Invalid property: " + property);2696        }2697    };2698    Group.prototype.addEntry = function (entry) {2699        exports.nbLogger("Group.addEntry#start");2700        var _entries = [];2701        var _add = null;2702        if (entry instanceof this._service.User) {2703            _add = entry._id;2704            _entries = this.users;2705        }2706        else if (entry instanceof this._service.Group) {2707            _add = entry.groupname;2708            _entries = this.groups;2709        }2710        else {2711            throw new Error("Group.addEntry: Invalid entry");2712        }2713        var _exists = false;2714        for (var _i = 0, _entries_1 = _entries; _i < _entries_1.length; _i++) {2715            var _entry = _entries_1[_i];2716            if (_entry === _add) {2717                _exists = true;2718            }2719        }2720        if (!_exists) {2721            _entries.push(_add);2722        }2723        exports.nbLogger("Group.addEntry#end");2724        return true;2725    };2726    Group.prototype.removeEntry = function (entry) {2727        exports.nbLogger("Group.removeEntry#start");2728        var _entries = [];2729        var _remove = null;2730        if (entry instanceof this._service.User) {2731            _remove = entry._id;2732            _entries = this.users;2733        }2734        else if (entry instanceof this._service.Group) {2735            _remove = entry.groupname;2736            _entries = this.groups;2737        }2738        else {2739            throw new Error("Group.removeEntry: Invalid entry");2740        }2741        for (var i = 0; i < _entries.length; i++) {2742            if (_entries[i] === _remove) {2743                _entries.splice(i, 1);2744                break;2745            }2746        }2747        exports.nbLogger("Group.removeEntry#end");2748        return true;2749    };2750    Group.prototype.save = function (callbacks) {2751        var _this = this;2752        exports.nbLogger("Group.save#start");2753        if (this.groupname == null) {2754            throw new Error("Group.save: no group name");2755        }2756        var saveParams = {};2757        var request;2758        if (this._service.isOffline()) {2759            request = new _SdeRequest("NebulaGroup", "save");2760            saveParams.groupname = this.groupname;2761            if (this.etag != null) {2762                saveParams.etag = this.etag;2763            }2764        }2765        else {2766            var path = "/groups/" + encodeURIComponent(this.groupname);2767            exports.nbLogger("Group.save#REST API Request path = " + path);2768            request = new HttpRequest(this._service, path);2769            if (this.etag != null) {2770                request.setQueryParam("etag", this.etag);2771            }2772            request.setMethod("PUT");2773            request.setContentType("application/json");2774        }2775        saveParams.users = this.users;2776        saveParams.groups = this.groups;2777        if (this.acl !== null) {2778            saveParams.ACL = this.acl._toJsonObject();2779        }2780        request.setData(saveParams);2781        var promise = request.execute().then(function (response) {2782            exports.nbLogger("Group.save#success callback start");2783            exports.nbLogger("Group.save#response = " + response);2784            _this._setGroupInfo(response);2785            return _this;2786        }).catch(function (error) {2787            exports.nbLogger("Group.save#error callback start");2788            exports.nbLogger(("Group.save#error = " + (exports._errorText(error))));2789            return Promise.reject(error);2790        });2791        exports.nbLogger("Group.save#end");2792        return exports._promisify(promise, callbacks);2793    };2794    Group.prototype.addMembers = function (userIds, groups, callbacks) {2795        return this._addRemoveMembers("add", userIds, groups, callbacks);2796    };2797    Group.prototype.removeMembers = function (userIds, groups, callbacks) {2798        return this._addRemoveMembers("remove", userIds, groups, callbacks);2799    };2800    Group.prototype._addRemoveMembers = function (mode, userIds, groups, callbacks) {2801        var _this = this;2802        exports.nbLogger("Group." + mode + "Members#start");2803        if (this.groupname == null) {2804            throw new Error("No group name");2805        }2806        if (this._service.isOffline()) {2807            throw new Error("offline mode is not supported.");2808        }2809        var path = "/groups/" + encodeURIComponent(this.groupname) + ("/" + mode + "Members");2810        var request = new HttpRequest(this._service, path);2811        request.setMethod("PUT");2812        request.setContentType("application/json");2813        var body = {2814            users: userIds != null ? userIds : [],2815            groups: groups != null ? groups : []2816        };2817        request.setData(body);2818        var promise = request.execute().then(function (response) {2819            exports.nbLogger("Group." + mode + "Members#response = " + response);2820            _this._setGroupInfo(response);2821            return _this;2822        }).catch(function (error) {2823            exports.nbLogger("Group." + mode + "Members#error = " + exports._errorText(error));2824            return Promise.reject(error);2825        });2826        return exports._promisify(promise, callbacks);2827    };2828    Group.remove = function (group, callbacks) { return null; };2829    Group._remove = function (service, group, callbacks) {2830        if (!(group instanceof Group)) {2831            throw new Error("Group.remove: not Group instance!");2832        }2833        if (group._service !== service) {2834            throw new Error("Service does not match");2835        }2836        return group._remove(callbacks);2837    };2838    Group.prototype._remove = function (callbacks) {2839        exports.nbLogger("Group.remove#start");2840        var request;2841        if (this._service.isOffline()) {2842            request = new _SdeRequest("NebulaGroup", "delete");2843            var deleteParams = {2844                groupname: this.groupname2845            };2846            var etag = this.etag;2847            if (etag != null) {2848                deleteParams.etag = etag;2849            }2850            request.setData(deleteParams);2851        }2852        else {2853            var path = "/groups/" + encodeURIComponent(this.groupname);2854            exports.nbLogger("Group.remove#REST API Request path = " + path);2855            request = new HttpRequest(this._service, path);2856            var etag = this.etag;2857            if (etag != null) {2858                request.setQueryParam("etag", etag);2859            }2860            request.setMethod("DELETE");2861        }2862        var promise = request.execute().then(function (response) {2863            exports.nbLogger("Group.remove#success callback start");2864            exports.nbLogger("Group.remove#response = " + response);2865            return;2866        }).catch(function (error) {2867            exports.nbLogger("Group.remove#error callback start");2868            exports.nbLogger(("Group.remove#error = " + (exports._errorText(error))));2869            return Promise.reject(error);2870        });2871        exports.nbLogger("Group.remove#end");2872        return exports._promisify(promise, callbacks);2873    };2874    Group.query = function (conditions, callbacks) { return null; };2875    Group._query = function (service, conditions, callbacks) {2876        exports.nbLogger("Group.query#start");2877        var groupname = null;2878        if (conditions != null) {2879            if (conditions.groupname != null) {2880                groupname = conditions.groupname;2881            }2882            else {2883                throw new Error("Group.query: no groupname in conditions");2884            }2885        }2886        var request;2887        if (service.isOffline()) {2888            request = new _SdeRequest("NebulaGroup", "query");2889            if (groupname !== null) {2890                request.setData({2891                    groupname: groupname2892                });2893            }2894        }2895        else {2896            var path = void 0;2897            if (groupname !== null) {2898                path = "/groups/" + encodeURIComponent(groupname);2899            }2900            else {2901                path = "/groups";2902            }2903            exports.nbLogger("Group.query#REST API Request path = " + path);2904            request = new HttpRequest(service, path);2905            request.setMethod("GET");2906            request.setContentType("application/json");2907        }2908        var promise = request.execute().then(function (response) {2909            exports.nbLogger("Group.query#response = " + response);2910            var obj = JSON.parse(response);2911            var objArray = [];2912            var groupArray = [];2913            if (obj.results === undefined) {2914                objArray.push(obj);2915            }2916            else {2917                objArray = obj.results;2918            }2919            for (var _i = 0, objArray_1 = objArray; _i < objArray_1.length; _i++) {2920                var obj_1 = objArray_1[_i];2921                var group = new service.Group(obj_1.name);2922                group._setGroupInfo(JSON.stringify(obj_1));2923                groupArray.push(group);2924            }2925            return groupArray;2926        }).catch(function (error) {2927            exports.nbLogger(("Group.query#error = " + (exports._errorText(error))));2928            return Promise.reject(error);2929        });2930        exports.nbLogger("Group.query#end");2931        return exports._promisify(promise, callbacks);2932    };2933    return Group;2934}());2935exports.Group = Group;2936exports.declareGroup = function (_service) {2937    var _a;2938    _service.Group = (_a =  (function (_super) {2939            __extends(_Group, _super);2940            function _Group(groupname) {2941                var _this = _super.call(this, groupname, _service) || this;2942                exports.nbLogger("Group.constructor");2943                return _this;2944            }2945            _Group.remove = function (group, callbacks) {2946                return _super._remove.call(this, _service, group, callbacks);2947            };2948            _Group.query = function (conditions, callbacks) {2949                return _super._query.call(this, _service, conditions, callbacks);2950            };2951            return _Group;2952        }(Group)),2953        _a.delete = _a.remove,2954        _a);2955};2956var FileMetadata =  (function () {2957    function FileMetadata() {2958        this._createdAt = null;2959        this._updatedAt = null;2960        this._acl = null;2961        this._contentType = null;2962        this._publicUrl = null;2963        this._fileName = null;2964        this._fileSize = -1;2965        this._syncState = FileMetadata.SYNC_STATE_UNDEFINED;2966        this._lastSyncTime = null;2967        this._metaId = null;2968        this._metaETag = null;2969        this._fileETag = null;2970        this._options = null;2971        this._cacheDisabled = false;2972    }2973    FileMetadata.prototype.getFileName = function () {2974        return this._fileName;2975    };2976    FileMetadata.prototype.setFileName = function (fileName) {2977        exports.nbLogger("FileMetadata.setFileName(), " + this._fileName + " ---> " + fileName);2978        this._fileName = fileName;2979        return this;2980    };2981    FileMetadata.prototype.getAcl = function () {2982        return this._acl;2983    };2984    FileMetadata.prototype.setAcl = function (acl) {2985        if (acl != null && !(acl instanceof Acl)) {2986            throw new Error("FileMetadata.setAcl: Not Acl instance!");2987        }2988        this._acl = acl;2989        return this;2990    };2991    FileMetadata.prototype.getContentType = function () {2992        return this._contentType;2993    };2994    FileMetadata.prototype.setContentType = function (contentType) {2995        exports.nbLogger("FileMetadata.setContentType(), " + this._contentType + " -> " + contentType);2996        this._contentType = contentType;2997        return this;2998    };2999    FileMetadata.prototype.getCreatedAt = function () {3000        return this._createdAt;3001    };3002    FileMetadata.prototype._setCreatedAt = function (createdAt) {3003        this._createdAt = createdAt;3004        return this;3005    };3006    FileMetadata.prototype.getUpdatedAt = function () {3007        return this._updatedAt;3008    };3009    FileMetadata.prototype._setUpdatedAt = function (updatedAt) {3010        this._updatedAt = updatedAt;3011        return this;3012    };3013    FileMetadata.prototype.getSize = function () {3014        return this._fileSize;3015    };3016    FileMetadata.prototype._setSize = function (size) {3017        this._fileSize = size;3018        return this;3019    };3020    FileMetadata.prototype.getPublicUrl = function () {3021        return this._publicUrl;3022    };3023    FileMetadata.prototype._setPublicUrl = function (url) {3024        this._publicUrl = url;3025        return this;3026    };3027    FileMetadata.prototype.getFileSyncState = function () {3028        return this._syncState;3029    };3030    FileMetadata.prototype._setFileSyncState = function (syncState) {3031        this._syncState = syncState;3032        return this;3033    };3034    FileMetadata.prototype.getLastSyncTime = function () {3035        return this._lastSyncTime;3036    };3037    FileMetadata.prototype._setLastSyncTime = function (lastSyncTime) {3038        this._lastSyncTime = lastSyncTime;3039        return this;3040    };3041    FileMetadata.prototype.getMetaId = function () {3042        return this._metaId;3043    };3044    FileMetadata.prototype._setMetaId = function (metaId) {3045        this._metaId = metaId;3046        return this;3047    };3048    FileMetadata.prototype.getMetaETag = function () {3049        return this._metaETag;3050    };3051    FileMetadata.prototype._setMetaETag = function (metaETag) {3052        this._metaETag = metaETag;3053        return this;3054    };3055    FileMetadata.prototype.getFileETag = function () {3056        return this._fileETag;3057    };3058    FileMetadata.prototype._setFileETag = function (fileETag) {3059        this._fileETag = fileETag;3060        return this;3061    };3062    FileMetadata.prototype.getOptions = function () {3063        return this._options;3064    };3065    FileMetadata.prototype.setOptions = function (options) {3066        this._options = options;3067        return this;3068    };3069    FileMetadata.prototype.isCacheDisabled = function () {3070        return this._cacheDisabled;3071    };3072    FileMetadata.prototype.setCacheDisabled = function (cacheDisabled) {3073        this._cacheDisabled = cacheDisabled;3074        return this;3075    };3076    FileMetadata.prototype._setMetadata = function (obj) {3077        if (obj.filename != null) {3078            this.setFileName(obj.filename);3079        }3080        if (obj.contentType != null) {3081            this.setContentType(obj.contentType);3082        }3083        if (obj.ACL != null) {3084            var acl = new Acl(obj.ACL);3085            this.setAcl(acl);3086        }3087        if (obj["length"] != null) {3088            this._setSize(obj["length"]);3089        }3090        if (obj.publicUrl != null) {3091            this._setPublicUrl(obj.publicUrl);3092        }3093        if (obj.createdAt != null) {3094            this._setCreatedAt(obj.createdAt);3095        }3096        if (obj.updatedAt != null) {3097            this._setUpdatedAt(obj.updatedAt);3098        }3099        if (obj.lastSyncTime != null) {3100            this._setLastSyncTime(obj.lastSyncTime);3101        }3102        if (obj.metaId != null) {3103            this._setMetaId(obj.metaId);3104        }3105        if (obj.metaETag != null) {3106            this._setMetaETag(obj.metaETag);3107        }3108        if (obj.fileETag != null) {3109            this._setFileETag(obj.fileETag);3110        }3111        if (obj.options != null) {3112            this.setOptions(obj.options);3113        }3114        if (obj.cacheDisabled != null) {3115            this.setCacheDisabled(obj.cacheDisabled);3116        }3117        if (obj.fileSyncState != null) {3118            this._setFileSyncState(obj.fileSyncState);3119        }3120        return this;3121    };3122    FileMetadata.SYNC_STATE_UNDEFINED = -1;3123    FileMetadata.SYNC_STATE_SYNCED = 0;3124    FileMetadata.SYNC_STATE_DIRTY = 1;3125    FileMetadata.SYNC_STATE_SYNCING = 3;3126    FileMetadata.SYNC_STATE_CONFLICTED = 5;3127    return FileMetadata;3128}());3129exports.FileMetadata = FileMetadata;3130var BaseBucket =  (function () {3131    function BaseBucket(service, name, type, mode) {3132        if (mode === void 0) { mode = exports.Nebula.BUCKET_MODE_ONLINE; }3133        this._service = service;3134        this._type = type;3135        this._name = name;3136        this._acl = null;3137        this._contentAcl = null;3138        this._description = null;3139        if (mode !== exports.Nebula.BUCKET_MODE_ONLINE && mode !== exports.Nebula.BUCKET_MODE_REPLICA && mode !== exports.Nebula.BUCKET_MODE_LOCAL) {3140            this._mode = exports.Nebula.BUCKET_MODE_ONLINE;3141        }3142        else {3143            this._mode = mode;3144        }3145    }3146    BaseBucket._baseLoadBucket = function (type, service, name, mode, callbacks) {3147        exports.nbLogger("BaseBucket.loadBucket(), name=" + name + ", type=" + type + ", callbacks=" + callbacks + ", mode=" + mode);3148        var req;3149        if (service.isOffline()) {3150            req = new _SdeRequest(BaseBucket.getClassName(type), "loadBucket");3151            var body = {3152                bucketName: name3153            };3154            if (mode !== exports.Nebula.BUCKET_MODE_ONLINE && mode !== exports.Nebula.BUCKET_MODE_REPLICA && mode !== exports.Nebula.BUCKET_MODE_LOCAL) {3155                mode = exports.Nebula.BUCKET_MODE_ONLINE;3156            }3157            body.bucketMode = mode;3158            req.setData(body);3159        }3160        else {3161            var path = "/buckets/" + type + "/" + encodeURIComponent(name);3162            req = new HttpRequest(service, path);3163            req.setMethod("GET");3164            req.setContentType("application/json");3165        }3166        var promise = req.execute().then(function (response) {3167            try {3168                exports.nbLogger("BaseBucket.loadBucket(), success : " + response);3169                var resObj = JSON.parse(response);3170                var resName = resObj.name;3171                if (resName == null) {3172                    exports.nbLogger("BaseBucket.loadBucket(), invalid bucket name, name=" + resName);3173                    var error = exports._createError(0, "Invalid response", "", name);3174                    return Promise.reject(error);3175                }3176                exports.nbLogger("BaseBucket.loadBucket(), new Bucket, name=" + resName);3177                var bucket = void 0;3178                if (type === "file") {3179                    bucket = new service.FileBucket(resName);3180                }3181                else {3182                    bucket = new service.ObjectBucket(resName, mode);3183                }3184                var resAcl = resObj.ACL;3185                if (resAcl != null) {3186                    exports.nbLogger("BaseBucket.loadBucket(), acl=" + resAcl);3187                    var acl = new Acl();3188                    acl._set(resAcl);3189                    bucket.setAcl(acl);3190                }3191                var resContentAcl = resObj.contentACL;3192                if (resContentAcl != null) {3193                    exports.nbLogger("BaseBucket.loadBucket(), contentAcl=" + resContentAcl);3194                    var contentAcl = new Acl();3195                    contentAcl._set(resContentAcl);3196                    bucket.setContentAcl(contentAcl);3197                }3198                var resDescription = resObj.description;3199                if (resDescription != null) {3200                    exports.nbLogger("BaseBucket.loadBucket(), description=" + resDescription);3201                    bucket.setDescription(resDescription);3202                }3203                return Promise.resolve(bucket);3204            }3205            catch (e) {3206                exports.nbLogger("BaseBucket.loadBucket(), error : exception" + e);3207                var error = exports._createError(0, e, e.toString(), name);3208                return Promise.reject(error);3209            }3210        }, function (error) {3211            exports.nbLogger(("BaseBucket.loadBucket(), error: " + (exports._errorText(error))));3212            error.data = name;3213            return Promise.reject(error);3214        });3215        return exports._promisify(promise, callbacks);3216    };3217    BaseBucket._baseGetBucketList = function (type, service, local, callbacks) {3218        exports.nbLogger("BaseBucket.getBucketList(), type=" + type + ", callbacks=" + callbacks);3219        var req;3220        if (service.isOffline()) {3221            var method = "getBucketList";3222            if (local) {3223                method = "getLocalBucketList";3224            }3225            req = new _SdeRequest(BaseBucket.getClassName(type), method);3226        }3227        else {3228            var path = "/buckets/" + type;3229            req = new HttpRequest(service, path);3230            req.setMethod("GET");3231            req.setContentType("application/json");3232        }3233        var promise = req.execute().then(function (response) {3234            try {3235                exports.nbLogger("BaseBucket.getBucketList(), success : " + response);3236                var resObj = JSON.parse(response);3237                var buckets = resObj.results;3238                if (buckets != null) {3239                    exports.nbLogger("BaseBucket.getBucketList(), buckets=" + buckets);3240                    var bucketNames = [];3241                    for (var _i = 0, buckets_1 = buckets; _i < buckets_1.length; _i++) {3242                        var bucket = buckets_1[_i];3243                        exports.nbLogger("BaseBucket.getBucketList(), success : add bucketName = " + bucket.name);3244                        if (bucket.name != null) {3245                            bucketNames.push(bucket.name);3246                        }3247                        else {3248                            exports.nbLogger("BaseBucket.getBucketList(), [WARNING] No name in response");3249                        }3250                    }3251                    return Promise.resolve(bucketNames);3252                }3253                else {3254                    exports.nbLogger("BaseBucket.getBucketList(), invalid response");3255                    var error = exports._createError(0, "Invalid response", "", name);3256                    return Promise.reject(error);3257                }3258            }3259            catch (e) {3260                exports.nbLogger("BaseBucket.getBucketList(), error : exception" + e);3261                var error = exports._createError(0, e, e);3262                return Promise.reject(error);3263            }3264        }, function (error) {3265            exports.nbLogger(("BaseBucket.getBucketList(), error: " + (exports._errorText(error))));3266            return Promise.reject(error);3267        });3268        return exports._promisify(promise, callbacks);3269    };3270    BaseBucket.prototype.saveBucket = function (callbacks) {3271        var _this = this;3272        exports.nbLogger("BaseBucket.saveBucket(), callbacks=" + callbacks);3273        var req;3274        if (this._service.isOffline()) {3275            req = new _SdeRequest(BaseBucket.getClassName(this._type), "saveBucket");3276        }3277        else {3278            var path = this.getPath();3279            req = new HttpRequest(this._service, path);3280            req.setMethod("PUT");3281            req.setContentType("application/json");3282        }3283        var body = {};3284        if (this._acl != null) {3285            body.ACL = this._acl._toJsonObject();3286        }3287        if (this._contentAcl != null) {3288            body.contentACL = this._contentAcl._toJsonObject();3289        }3290        if (this._description != null) {3291            body.description = this._description;3292        }3293        if (this._service.isOffline()) {3294            body.bucketName = this.getBucketName();3295            body.bucketMode = this.getBucketMode();3296        }3297        req.setData(body);3298        exports.nbLogger("BaseBucket.saveBucket(), body=" + JSON.stringify(body));3299        var promise = req.execute().then(function (response) {3300            exports.nbLogger("success : " + response);3301            exports.nbLogger("bucketName : " + _this.getBucketName());3302            try {3303                exports.nbLogger("success : " + response);3304                var resObj = JSON.parse(response);3305                if (resObj.ACL != null) {3306                    if (!_this._acl) {3307                        _this._acl = new Acl();3308                    }3309                    _this._acl._set(resObj.ACL);3310                }3311                if (resObj.contentACL != null) {3312                    if (!_this._contentAcl) {3313                        _this._contentAcl = new Acl();3314                    }3315                    _this._contentAcl._set(resObj.contentACL);3316                }3317                return Promise.resolve(_this);3318            }3319            catch (e) {3320                exports.nbLogger("error : " + e);3321                return Promise.reject(e);3322            }3323        }, function (err) {3324            exports.nbLogger(("error: " + (exports._errorText(err))));3325            err.data = _this;3326            return Promise.reject(err);3327        });3328        return exports._promisify(promise, callbacks);3329    };3330    BaseBucket.prototype.deleteBucket = function (callbacks) {3331        var _this = this;3332        exports.nbLogger("BaseBucket.deleteBucket(), callbacks=" + callbacks);3333        var req;3334        if (this._service.isOffline()) {3335            req = new _SdeRequest(BaseBucket.getClassName(this._type), "deleteBucket");3336            var body = {3337                bucketName: this.getBucketName(),3338                bucketMode: this.getBucketMode()3339            };3340            req.setData(body);3341        }3342        else {3343            var path = this.getPath();3344            req = new HttpRequest(this._service, path);3345            req.setMethod("DELETE");3346            req.setContentType("application/json");3347        }3348        var promise = req.execute().then(function () {3349            exports.nbLogger("BaseBucket.deleteBucket(), success");3350            return _this;3351        }, function (err) {3352            exports.nbLogger(("BaseBucket.deleteBucket(), error: " + (exports._errorText(err))));3353            err.data = _this;3354            return Promise.reject(err);3355        });3356        return exports._promisify(promise, callbacks);3357    };3358    BaseBucket.prototype.setAcl = function (acl) {3359        if (acl != null && !(acl instanceof Acl)) {3360            throw new Error("setAcl: not Acl instance!");3361        }3362        this._acl = acl;3363    };3364    BaseBucket.prototype.getAcl = function () {3365        return this._acl;3366    };3367    BaseBucket.prototype.setContentAcl = function (acl) {3368        if (acl != null && !(acl instanceof Acl)) {3369            throw new Error("setContentAcl: not Acl instance!");3370        }3371        this._contentAcl = acl;3372    };3373    BaseBucket.prototype.getContentAcl = function () {3374        return this._contentAcl;3375    };3376    BaseBucket.prototype.setDescription = function (description) {3377        this._description = description;3378    };3379    BaseBucket.prototype.getDescription = function () {3380        return this._description;3381    };3382    BaseBucket.prototype.getBucketName = function () {3383        return this._name;3384    };3385    BaseBucket.prototype.setBucketName = function (name) {3386        this._name = name;3387    };3388    BaseBucket.prototype.getBucketMode = function () {3389        return this._mode;3390    };3391    BaseBucket.prototype.getPath = function (option) {3392        var path = "/buckets" + "/" + this._type + "/" + encodeURIComponent(this._name);3393        if (option != null) {3394            path = path + option;3395        }3396        return path;3397    };3398    BaseBucket.prototype.getDataPath = function (option) {3399        var dataType = "objects";3400        if (this._type === "file") {3401            dataType = "files";3402        }3403        var path = "/" + dataType + "/" + encodeURIComponent(this._name);3404        if (option != null) {3405            path = path + option;3406        }3407        return path;3408    };3409    BaseBucket.getClassName = function (type) {3410        var className = "NebulaObjectBucket";3411        if (type === "file") {3412            className = "NebulaFileBucket";3413        }3414        return className;3415    };3416    BaseBucket.prototype.getClassName = function () {3417        return BaseBucket.getClassName(this._type);3418    };3419    return BaseBucket;3420}());3421exports.BaseBucket = BaseBucket;3422var ObjectBucket =  (function (_super) {3423    __extends(ObjectBucket, _super);3424    function ObjectBucket(name, mode, service) {3425        if (mode === void 0) { mode = exports.Nebula.BUCKET_MODE_ONLINE; }3426        if (service === void 0) { service = exports.Nebula; }3427        var _this = _super.call(this, service, name, "object", mode) || this;3428        _this._resolveId = null;3429        return _this;3430    }3431    ObjectBucket.loadBucket = function (name, callbacks, mode) { return null; };3432    ObjectBucket._loadBucket = function (service, name, callbacks, mode) {3433        exports.nbLogger("ObjectBucket.loadBucket(), name=" + name + ", callbacks=" + callbacks);3434        return BaseBucket._baseLoadBucket("object", service, name, mode, callbacks);3435    };3436    ObjectBucket.getBucketList = function (callbacks) { return null; };3437    ObjectBucket._getBucketList = function (service, callbacks) {3438        exports.nbLogger("ObjectBucket.getBucketList(), callbacks=" + callbacks);3439        return BaseBucket._baseGetBucketList("object", service, false, callbacks);3440    };3441    ObjectBucket.getLocalBucketList = function (callbacks) { return null; };3442    ObjectBucket._getLocalBucketList = function (service, callbacks) {3443        exports.nbLogger("ObjectBucket.getLocalBucketList(), callbacks=" + callbacks);3444        return BaseBucket._baseGetBucketList("object", service, true, callbacks);3445    };3446    ObjectBucket.prototype.saveBucket = function (callbacks) {3447        return _super.prototype.saveBucket.call(this, callbacks);3448    };3449    ObjectBucket.prototype.deleteBucket = function (callbacks) {3450        return _super.prototype.deleteBucket.call(this, callbacks);3451    };3452    ObjectBucket.prototype.setAcl = function (acl) {3453        _super.prototype.setAcl.call(this, acl);3454        return this;3455    };3456    ObjectBucket.prototype.getAcl = function () {3457        return _super.prototype.getAcl.call(this);3458    };3459    ObjectBucket.prototype.setContentAcl = function (acl) {3460        _super.prototype.setContentAcl.call(this, acl);3461        return this;3462    };3463    ObjectBucket.prototype.getContentAcl = function () {3464        return _super.prototype.getContentAcl.call(this);3465    };3466    ObjectBucket.prototype.setDescription = function (description) {3467        return _super.prototype.setDescription.call(this, description);3468    };3469    ObjectBucket.prototype.getDescription = function () {3470        return _super.prototype.getDescription.call(this);3471    };3472    ObjectBucket.prototype.getBucketName = function () {3473        return _super.prototype.getBucketName.call(this);3474    };3475    ObjectBucket.prototype._setBucketName = function (name) {3476        return _super.prototype.setBucketName.call(this, name);3477    };3478    ObjectBucket.prototype.getBucketMode = function () {3479        return _super.prototype.getBucketMode.call(this);3480    };3481    ObjectBucket.prototype.load = function (objectId, callbacks) {3482        exports.nbLogger("ObjectBucket.load()");3483        if (objectId == null) {3484            exports.nbError("ObjectBucket.load(), Parameter is invalid");3485            throw new Error("No objectId");3486        }3487        var req;3488        if (this._service.isOffline()) {3489            req = new _SdeRequest(this.getClassName(), "load");3490            var body = {3491                bucketName: this.getBucketName(),3492                bucketMode: this.getBucketMode(),3493                objectId: objectId3494            };3495            req.setData(body);3496        }3497        else {3498            var path = this.getDataPath("/" + objectId);3499            req = new HttpRequest(this._service, path);3500            req.setMethod("GET");3501            req.setContentType("application/json");3502        }3503        var promise = req.execute().then(function (response) {3504            try {3505                var resObj = JSON.parse(response);3506                exports.nbLogger("ObjectBucket.load(), success : response=" + response);3507                return Promise.resolve(resObj);3508            }3509            catch (e) {3510                exports.nbLogger("ObjectBucket.load(), error : response=" + response);3511                var errorResult = exports._createError(0, "Invalid response from server", e);3512                errorResult.data = objectId;3513                return Promise.reject(errorResult);3514            }3515        }, function (err) {3516            exports.nbLogger(("ObjectBucket.load(), error: " + (exports._errorText(err))));3517            err.data = objectId;3518            return Promise.reject(err);3519        });3520        return exports._promisify(promise, callbacks);3521    };3522    ObjectBucket.prototype.remove = function (objectId, callbacks, etag) {3523        exports.nbLogger("ObjectBucket.delete)");3524        if (!objectId) {3525            exports.nbError("ObjectBucket.remove(), Parameter is invalid");3526            throw new Error("No objectId");3527        }3528        var req;3529        if (this._service.isOffline()) {3530            req = new _SdeRequest(this.getClassName(), "delete");3531            var body = {3532                bucketName: this.getBucketName(),3533                bucketMode: this.getBucketMode(),3534                objectId: objectId3535            };3536            if (etag) {3537                body.etag = etag;3538            }3539            req.setData(body);3540        }3541        else {3542            var path = this.getDataPath("/" + objectId);3543            req = new HttpRequest(this._service, path);3544            req.setMethod("DELETE");3545            req.setContentType("application/json");3546            if (etag) {3547                req.setQueryParam("etag", etag);3548            }3549        }3550        var promise = req.execute().then(function (response) {3551            exports.nbLogger("ObjectBucket.delete(), success");3552            return objectId;3553        }, function (err) {3554            exports.nbLogger(("ObjectBucket.delete(), error: " + (exports._errorText(err))));3555            err.objectId = objectId;3556            return Promise.reject(err);3557        });3558        return exports._promisify(promise, callbacks);3559    };3560    ObjectBucket.prototype.delete = function (objectId, callbacks, etag) {3561        return this.remove(objectId, callbacks, etag);3562    };3563    ObjectBucket.prototype.save = function (object, callbacks) {3564        exports.nbLogger("ObjectBucket.save()");3565        if (!object) {3566            exports.nbError("ObjectBucket.save(), Parameter is invalid");3567            throw new Error("No object");3568        }3569        var req;3570        if (this._service.isOffline()) {3571            req = new _SdeRequest(this.getClassName(), "save");3572            var body = {3573                object: object,3574                bucketName: this.getBucketName(),3575                bucketMode: this.getBucketMode()3576            };3577            req.setData(body);3578        }3579        else {3580            var queryParams = {};3581            var path = void 0, method = void 0;3582            if (object._id != null) {3583                path = this.getDataPath("/" + object._id);3584                method = "PUT";3585                if (object.etag != null) {3586                    queryParams.etag = object.etag;3587                }3588            }3589            else {3590                path = this.getDataPath();3591                method = "POST";3592            }3593            exports.nbLogger("ObjectBucket.save(), path=" + path);3594            req = new HttpRequest(this._service, path);3595            req.setContentType("application/json");3596            req.setMethod(method);3597            req.setQueryParams(queryParams);3598            req.setData(object);3599        }3600        var promise = req.execute().then(function (response) {3601            try {3602                var resObj = JSON.parse(response);3603                exports.nbLogger("ObjectBucket.save(), success");3604                return resObj;3605            }3606            catch (e) {3607                exports.nbLogger("ObjectBucket.save(), error : exception=" + e);3608                var errorResult = exports._createError(0, "Invalid response from server", e);3609                errorResult.data = object;3610                return Promise.reject(errorResult);3611            }3612        }, function (err) {3613            exports.nbLogger(("ObjectBucket.save(), error: " + (exports._errorText(err))));3614            err.data = object;3615            return Promise.reject(err);3616        });3617        return exports._promisify(promise, callbacks);3618    };3619    ObjectBucket.prototype.query = function (aQuery, callbacks) {3620        return this._query(aQuery, {3621            longQuery: this._service.ObjectBucket.useLongQuery3622        }, callbacks);3623    };3624    ObjectBucket.prototype.longQuery = function (aQuery, callbacks) {3625        return this._query(aQuery, {3626            longQuery: true3627        }, callbacks);3628    };3629    ObjectBucket.prototype.queryWithCount = function (aQuery, callbacks) {3630        return this._query(aQuery, {3631            countQuery: true,3632            longQuery: this._service.ObjectBucket.useLongQuery3633        }, callbacks);3634    };3635    ObjectBucket.prototype.longQueryWithCount = function (aQuery, callbacks) {3636        return this._query(aQuery, {3637            countQuery: true,3638            longQuery: true3639        }, callbacks);3640    };3641    ObjectBucket.prototype._query = function (aQuery, option, callbacks) {3642        exports.nbLogger("ObjectBucket.query()");3643        if (option.countQuery) {3644            if (aQuery == null) {3645                aQuery = new ObjectQuery();3646            }3647            aQuery._setCountQuery(option.countQuery);3648        }3649        var req;3650        var path;3651        if (this._service.isOffline()) {3652            req = new _SdeRequest(this.getClassName(), "query");3653            var body = {};3654            if (aQuery != null) {3655                if (aQuery.getClause() != null && aQuery.getClause().json() != null) {3656                    body.clause = aQuery.getClause().json();3657                }3658                body.limit = aQuery.getLimit();3659                body.skip = aQuery.getSkipCount();3660                body.sort = aQuery.getSort();3661                body.deleteMark = aQuery._getDeleteMark();3662                body.countQuery = aQuery._isCountQuery();3663            }3664            body.bucketName = this.getBucketName();3665            body.bucketMode = this.getBucketMode();3666            req.setData(body);3667        }3668        else if (!option.longQuery) {3669            path = this.getDataPath();3670            req = new HttpRequest(this._service, path);3671            req.setMethod("GET");3672            if (aQuery != null) {3673                req.setQueryParams(aQuery._toParam());3674            }3675        }3676        else {3677            path = this.getDataPath("/_query");3678            req = new HttpRequest(this._service, path);3679            req.setMethod("POST");3680            req.setContentType("application/json");3681            req.setData((aQuery != null) ? aQuery._toParamJson() : {});3682        }3683        var promise = req.execute().then(function (response) {3684            try {3685                var resObj = JSON.parse(response);3686                var objects = resObj.results;3687                exports.nbLogger("ObjectBucket.query(), success : size=" + objects.length);3688                if (aQuery != null && aQuery._isCountQuery() === true) {3689                    var count = -1;3690                    if (resObj.count != null) {3691                        count = resObj.count;3692                    }3693                    return {3694                        objects: objects,3695                        count: count3696                    };3697                }3698                else {3699                    return objects;3700                }3701            }3702            catch (e) {3703                exports.nbLogger("ObjectBucket.query(), error : exception=" + e);3704                var errorResult = exports._createError(0, e.toString(), e);3705                return Promise.reject(errorResult);3706            }3707        }, function (err) {3708            exports.nbLogger(("ObjectBucket.query(), error: " + (exports._errorText(err))));3709            return Promise.reject(err);3710        });3711        return exports._promisify(promise, callbacks);3712    };3713    ObjectBucket.prototype._checkOfflineService = function () {3714        if (this._service !== exports.Nebula) {3715            exports.nbError("ObjectBucket.setSyncScope(): Can't use for multitenant instance");3716            throw new Error("No multitenant support");3717        }3718        if (!this._service.isOffline()) {3719            exports.nbError("ObjectBucket.setSyncScope(), supported offline mode only");3720            throw new Error("No offline mode enabled");3721        }3722    };3723    ObjectBucket.prototype.aggregate = function (pipeline, options, callbacks) {3724        exports.nbLogger("ObjectBucket.aggregate()");3725        var path = this.getDataPath("/_aggregate");3726        var req = new HttpRequest(this._service, path);3727        req.setMethod("POST");3728        req.setContentType("application/json");3729        var data = { pipeline: pipeline };3730        if (options != null) {3731            data.options = options;3732        }3733        req.setData(data);3734        var promise = req.execute().then(function (response) {3735            try {3736                var resObj = JSON.parse(response);3737                var objects = resObj.results;3738                exports.nbLogger("ObjectBucket.aggregate(), success : size=" + objects.length);3739                return objects;3740            }3741            catch (e) {3742                exports.nbLogger("ObjectBucket.aggregate(), error : exception=" + e);3743                var errorResult = exports._createError(0, e.toString(), e);3744                return Promise.reject(errorResult);3745            }3746        }, function (err) {3747            exports.nbLogger(("ObjectBucket.aggregate(), error: " + (exports._errorText(err))));3748            return Promise.reject(err);3749        });3750        return exports._promisify(promise, callbacks);3751    };3752    ObjectBucket.prototype.setSyncScope = function (scope, callbacks) {3753        this._checkOfflineService();3754        var req = new _SdeRequest(BaseBucket.getClassName(), "setSyncScope");3755        var body = {};3756        var query = {};3757        if (scope != null) {3758            if (scope.getClause() != null && scope.getClause().json() != null) {3759                query.clause = scope.getClause().json();3760            }3761            body.scope = query;3762        }3763        body.bucketName = this.getBucketName();3764        body.bucketMode = this.getBucketMode();3765        exports.nbLogger("ObjectBucket.setSyncScope(), body=" + JSON.stringify(body));3766        req.setData(body);3767        var promise = req.execute().then(function (response) {3768            exports.nbLogger("ObjectBucket.setSyncScope(), success : response=" + response);3769            return;3770        }, function (err) {3771            exports.nbLogger(("ObjectBucket.setSyncScope(), error: " + (exports._errorText(err))));3772            return Promise.reject(err);3773        });3774        return exports._promisify(promise, callbacks);3775    };3776    ObjectBucket.prototype.getSyncScope = function (callbacks) {3777        this._checkOfflineService();3778        var req = new _SdeRequest(BaseBucket.getClassName(), "getSyncScope");3779        var body = {3780            bucketName: this.getBucketName(),3781            bucketMode: this.getBucketMode()3782        };3783        req.setData(body);3784        var promise = req.execute().then(function (response) {3785            exports.nbLogger("ObjectBucket.getSyncScope(), success : response=" + response);3786            try {3787                var resObj = JSON.parse(response);3788                if (resObj.scope != null) {3789                    var query = null;3790                    if (!exports._compareObject(resObj.scope, {})) {3791                        query = ObjectQuery._toObjectQuery(resObj.scope);3792                    }3793                    exports.nbLogger("ObjectBucket.getSyncScope(), success : callback_data=" + resObj.scope);3794                    return Promise.resolve(query);3795                }3796                else {3797                    exports.nbLogger("ObjectBucket.getSyncScope(), error : no scope property");3798                    return Promise.reject(exports._createError(0, "Invalid response - no scope property", ""));3799                }3800            }3801            catch (e) {3802                exports.nbLogger("ObjectBucket.getSyncScope(), error : exception=" + e);3803                return Promise.reject(exports._createError(0, e.toString(), e));3804            }3805        }, function (err) {3806            exports.nbLogger(("ObjectBucket.getSyncScope(), error: " + (exports._errorText(err))));3807            return Promise.reject(err);3808        });3809        return exports._promisify(promise, callbacks);3810    };3811    ObjectBucket.prototype.getResolveConflictPolicy = function (callbacks) {3812        exports.nbLogger("ObjectBucket.getResolveConflictPolicy()");3813        this._checkOfflineService();3814        var req = new _SdeRequest(BaseBucket.getClassName(), "getResolveConflictPolicy");3815        var body = {3816            bucketName: this.getBucketName(),3817            bucketMode: this.getBucketMode()3818        };3819        req.setData(body);3820        var promise = req.execute().then(function (response) {3821            exports.nbLogger("ObjectBucket.getResolveConflictPolicy(), success : response=" + response);3822            try {3823                var resObj = JSON.parse(response);3824                if (resObj.results != null) {3825                    return Promise.resolve(resObj.results); 3826                }3827                else {3828                    exports.nbLogger("ObjectBucket.getResolveConflictPolicy(), error : no results");3829                    return Promise.reject(exports._createError(0, "No results", ""));3830                }3831            }3832            catch (e) {3833                exports.nbLogger("ObjectBucket.getResolveConflictPolicy(), error : exception=" + e);3834                return Promise.reject(exports._createError(0, e.toString(), e));3835            }3836        }, function (err) {3837            exports.nbLogger(("ObjectBucket.getResolveConflictPolicy(), error: " + (exports._errorText(err))));3838            return Promise.reject(err);3839        });3840        return exports._promisify(promise, callbacks);3841    };3842    ObjectBucket.prototype.setResolveConflictPolicy = function (policy, callbacks) {3843        exports.nbLogger("ObjectBucket.setResolveConflictPolicy()");3844        this._checkOfflineService();3845        if (policy == null) {3846            exports.nbError("ObjectBucket.setResolveConflictPolicy(), invalid parameter: no policy");3847            throw new Error("No policy");3848        }3849        var req = new _SdeRequest(BaseBucket.getClassName(), "setResolveConflictPolicy");3850        var body = {3851            bucketName: this.getBucketName(),3852            bucketMode: this.getBucketMode(),3853            policy: policy3854        };3855        req.setData(body);3856        var promise = req.execute().then(function (response) {3857            exports.nbLogger("ObjectBucket.setResolveConflictPolicy(), success : response=" + response);3858            return;3859        }, function (err) {3860            exports.nbLogger(("ObjectBucket.setResolveConflictPolicy(), error: " + (exports._errorText(err))));3861            return Promise.reject(err);3862        });3863        return exports._promisify(promise, callbacks);3864    };3865    ObjectBucket.prototype.removeCacheBucket = function (callbacks) {3866        exports.nbLogger("ObjectBucket.removeCacheBucket()");3867        this._checkOfflineService();3868        var req = new _SdeRequest(BaseBucket.getClassName(), "removeCacheBucket");3869        var body = {3870            bucketName: this.getBucketName(),3871            bucketMode: this.getBucketMode()3872        };3873        req.setData(body);3874        var promise = req.execute().then(function (response) {3875            exports.nbLogger("ObjectBucket.removeCacheBucket(), success : response=" + response);3876            return;3877        }, function (err) {3878            exports.nbLogger(("ObjectBucket.removeCacheBucket(), error: " + (exports._errorText(err))));3879            return Promise.reject(err);3880        });3881        return exports._promisify(promise, callbacks);3882    };3883    ObjectBucket.prototype.setSyncEventListener = function (listener) {3884        this._checkOfflineService();3885        return _SdeSyncEventListener.setListener(this, listener);3886    };3887    ObjectBucket.sync = function (callbacks) { return null; };3888    ObjectBucket._sync = function (service, callbacks) {3889        exports.nbLogger("ObjectBucket.sync()");3890        if (service !== exports.Nebula) {3891            exports.nbError("ObjectBucket.setSyncScope(): Can't use for multitenant instance");3892            throw new Error("No multitenant support");3893        }3894        if (!service.isOffline()) {3895            exports.nbError("ObjectBucket.sync(), supported offline mode only");3896            throw new Error("No offline mode enabled");3897        }3898        var req = new _SdeRequest(BaseBucket.getClassName(), "sync");3899        var promise = req.execute().then(function (response) {3900            exports.nbLogger("ObjectBucket.sync(), success : response=" + response);3901            return;3902        }, function (err) {3903            exports.nbLogger(("ObjectBucket.sync(), error: " + (exports._errorText(err))));3904            return Promise.reject(err);3905        });3906        return exports._promisify(promise, callbacks);3907    };3908    ObjectBucket.prototype.syncBucket = function (callbacks) {3909        exports.nbLogger("ObjectBucket.syncBucket()");3910        this._checkOfflineService();3911        var req = new _SdeRequest(BaseBucket.getClassName(), "syncBucket");3912        var body = {3913            bucketName: this.getBucketName(),3914            bucketMode: this.getBucketMode()3915        };3916        req.setData(body);3917        var promise = req.execute().then(function (response) {3918            exports.nbLogger("ObjectBucket.syncBucket(), success : response=" + response);3919            return;3920        }, function (err) {3921            exports.nbLogger(("ObjectBucket.syncBucket(), error: " + (exports._errorText(err))));3922            return Promise.reject(err);3923        });3924        return exports._promisify(promise, callbacks);3925    };3926    ObjectBucket.prototype.resolveConflict = function (objectId, resolve) {3927        exports.nbLogger("ObjectBucket.resolveConflict()");3928        this._checkOfflineService();3929        if (objectId == null || resolve == null || this._resolveId == null) {3930            exports.nbError("ObjectBucket.syncObject(), invalid parameter, objectId=" + objectId + ", resolve=" + resolve + ", resolveId=" + this._resolveId);3931            throw new Error("No objectId/resolve/resolveId");3932        }3933        var data = {3934            bucketName: this.getBucketName(),3935            bucketMode: this.getBucketMode(),3936            objectId: objectId,3937            resolveId: this._getResolveId(),3938            resolve: resolve3939        };3940        return _SdeSyncEventListener.resolveConflict(data);3941    };3942    ObjectBucket.prototype.setIndexToLocal = function (index, callbacks) {3943        exports.nbLogger("ObjectBucket.setIndexLocal()");3944        this._checkOfflineService();3945        if (!index) {3946            exports.nbError("ObjectBucket.setIndexLocal(), parameter is invalid");3947            throw new Error("No index");3948        }3949        if (!index.index) {3950            exports.nbError("ObjectBucket.setIndexLocal(), index is invalid");3951            throw new Error("No index property");3952        }3953        var req = new _SdeRequest(this.getClassName(), "setIndexToLocal");3954        index.bucketName = this.getBucketName();3955        index.bucketMode = this.getBucketMode();3956        req.setData(index);3957        var promise = req.execute().then(function () {3958            exports.nbLogger("ObjectBucket.setIndexLocal(), success");3959            return;3960        }, function (err) {3961            exports.nbLogger(("ObjectBucket.setIndexLocal(), error: " + (exports._errorText(err))));3962            return Promise.reject(err);3963        });3964        return exports._promisify(promise, callbacks);3965    };3966    ObjectBucket.prototype.getIndexFromLocal = function (callbacks) {3967        exports.nbLogger("ObjectBucket.getIndexLocal()");3968        this._checkOfflineService();3969        var req = new _SdeRequest(this.getClassName(), "getIndexFromLocal");3970        var body = {3971            bucketName: this.getBucketName(),3972            bucketMode: this.getBucketMode()3973        };3974        req.setData(body);3975        var promise = req.execute().then(function (response) {3976            exports.nbLogger("ObjectBucket.getIndexLocal(), success");3977            try {3978                var resObj = JSON.parse(response);3979                var index = resObj.results;3980                return index;3981            }3982            catch (e) {3983                exports.nbLogger("ObjectBucket.getIndexLocal(), success : exception=" + e);3984                var errorResult = exports._createError(0, e.toString(), e);3985                return Promise.reject(errorResult);3986            }3987        }, function (err) {3988            exports.nbLogger(("ObjectBucket.getIndexLocal(), error: " + (exports._errorText(err))));3989            return Promise.reject(err);3990        });3991        return exports._promisify(promise, callbacks);3992    };3993    ObjectBucket.prototype.getLastSyncTime = function (callbacks) {3994        exports.nbLogger("ObjectBucket.getLastSyncTime()");3995        this._checkOfflineService();3996        var req = new _SdeRequest(BaseBucket.getClassName(), "getLastSyncTime");3997        var body = {3998            bucketName: this.getBucketName(),3999            bucketMode: this.getBucketMode()4000        };4001        req.setData(body);4002        var promise = req.execute().then(function (response) {4003            exports.nbLogger("ObjectBucket.getLastSyncTime(), success : response=" + response);4004            try {4005                var resObj = JSON.parse(response);4006                if (resObj.results != null) {4007                    return resObj.results; 4008                }4009                else {4010                    exports.nbLogger("ObjectBucket.getLastSyncTime(), success : no results");4011                    return null;4012                }4013            }4014            catch (e) {4015                exports.nbLogger("ObjectBucket.getLastSyncTime(), error : exception=" + e);4016                return Promise.reject(exports._createError(0, e.toString(), e));4017            }4018        }, function (err) {4019            exports.nbLogger(("ObjectBucket.getLastSyncTime(), error: " + (exports._errorText(err))));4020            return Promise.reject(err);4021        });4022        return exports._promisify(promise, callbacks);4023    };4024    ObjectBucket.prototype._getResolveId = function () {4025        exports.nbLogger("ObjectBucket._getResolveId(), resolveId=" + this._resolveId);4026        return this._resolveId;4027    };4028    ObjectBucket.prototype._setResolveId = function (resolveId) {4029        exports.nbLogger("ObjectBucket._setResolveId(), cur=" + this._resolveId + ", new=" + resolveId);4030        return this._resolveId = resolveId;4031    };4032    ObjectBucket.prototype.batch = function (request, callbacks) {4033        var path = this.getDataPath("/_batch");4034        var req = new HttpRequest(this._service, path);4035        req.setMethod("POST");4036        req.setContentType("application/json");4037        req.setData(request.json);4038        var promise = req.execute().then(function (response) {4039            var json = JSON.parse(response);4040            var failedCount = 0;4041            for (var _i = 0, _a = json.results; _i < _a.length; _i++) {4042                var result = _a[_i];4043                if (result.result !== "ok") {4044                    failedCount++;4045                }4046            }4047            json.failedCount = failedCount;4048            return json;4049        }, function (err) {4050            return Promise.reject(err);4051        });4052        return exports._promisify(promise, callbacks);4053    };4054    ObjectBucket.useLongQuery = false; 4055    ObjectBucket.CONFLICT_POLICY_MANUAL = 0;4056    ObjectBucket.CONFLICT_POLICY_CLIENT = 1;4057    ObjectBucket.CONFLICT_POLICY_SERVER = 2;4058    ObjectBucket.RESOLVE_CONFLICT_UNDEFINED = -1;4059    ObjectBucket.RESOLVE_CONFLICT_CLIENT = 1;4060    ObjectBucket.RESOLVE_CONFLICT_SERVER = 2;4061    ObjectBucket.SYNC_ERROR_UNDEFINED = -1;4062    ObjectBucket.SYNC_ERROR_PUSH = 0;4063    ObjectBucket.SYNC_ERROR_PULL = 1;4064    ObjectBucket.SYNC_ERROR_OVERLAP_ID = 2;4065    ObjectBucket.SYNC_ERROR_PUSH_RESYNCING = 3;4066    return ObjectBucket;4067}(BaseBucket));4068exports.ObjectBucket = ObjectBucket;4069exports.declareObjectBucket = function (_service) {4070    var _a;4071    _service.ObjectBucket = (_a =  (function (_super) {4072            __extends(_ObjectBucket, _super);4073            function _ObjectBucket(name, mode) {4074                if (mode === void 0) { mode = exports.Nebula.BUCKET_MODE_ONLINE; }4075                return _super.call(this, name, mode, _service) || this;4076            }4077            _ObjectBucket.loadBucket = function (name, callbacks, mode) {4078                return _super._loadBucket.call(this, _service, name, callbacks, mode);4079            };4080            _ObjectBucket.getBucketList = function (callbacks) {4081                return _super._getBucketList.call(this, _service, callbacks);4082            };4083            _ObjectBucket.getLocalBucketList = function (callbacks) {4084                return _super._getLocalBucketList.call(this, _service, callbacks);4085            };4086            _ObjectBucket.sync = function (callbacks) {4087                return _super._sync.call(this, _service, callbacks);4088            };4089            return _ObjectBucket;4090        }(ObjectBucket)),4091        _a.useLongQuery = false,4092        _a);4093};4094var FileBucket =  (function (_super) {4095    __extends(FileBucket, _super);4096    function FileBucket(name, service) {4097        if (service === void 0) { service = exports.Nebula; }4098        var _this = _super.call(this, service, name, "file") || this;4099        _this._resolveId = null;4100        return _this;4101    }4102    FileBucket.loadBucket = function (name, callbacks) { return null; };4103    FileBucket._loadBucket = function (service, name, callbacks) {4104        exports.nbLogger("FileBucket.loadBucket(), name=" + name + ", callbacks=" + callbacks);4105        return BaseBucket._baseLoadBucket("file", service, name, exports.Nebula.BUCKET_MODE_ONLINE, callbacks);4106    };4107    FileBucket.getBucketList = function (callbacks) { return null; };4108    FileBucket._getBucketList = function (service, callbacks) {4109        return BaseBucket._baseGetBucketList("file", service, false, callbacks);4110    };4111    FileBucket.prototype.saveBucket = function (callbacks) {4112        return _super.prototype.saveBucket.call(this, callbacks);4113    };4114    FileBucket.prototype.deleteBucket = function (callbacks) {4115        return _super.prototype.deleteBucket.call(this, callbacks);4116    };4117    FileBucket.prototype.setAcl = function (acl) {4118        _super.prototype.setAcl.call(this, acl);4119        return this;4120    };4121    FileBucket.prototype.getAcl = function () {4122        return _super.prototype.getAcl.call(this);4123    };4124    FileBucket.prototype.setContentAcl = function (acl) {4125        _super.prototype.setContentAcl.call(this, acl);4126        return this;4127    };4128    FileBucket.prototype.getContentAcl = function () {4129        return _super.prototype.getContentAcl.call(this);4130    };4131    FileBucket.prototype.setDescription = function (description) {4132        _super.prototype.setDescription.call(this, description);4133        return this;4134    };4135    FileBucket.prototype.getDescription = function () {4136        return _super.prototype.getDescription.call(this);4137    };4138    FileBucket.prototype.getBucketName = function () {4139        return _super.prototype.getBucketName.call(this);4140    };4141    FileBucket.prototype._setBucketName = function (name) {4142        _super.prototype.setBucketName.call(this, name);4143        return this;4144    };4145    FileBucket.prototype._save = function (fileName, data, metadata, update, callbacks) {4146        exports.nbLogger("FileBucket._save()");4147        if (!fileName) {4148            exports.nbLogger("FileBucket._save(), Parameter is invalid : fileName");4149            throw new Error("No fileName");4150        }4151        if (!data) {4152            exports.nbLogger("FileBucket._save(), Parameter is invalid : data");4153            throw new Error("No data");4154        }4155        if (!(typeof Blob !== "undefined" && Blob !== null) && !(typeof Buffer !== "undefined" && Buffer !== null)) {4156            exports.nbLogger("FileBucket._save(), Not supported Blob nor Buffer");4157            throw new Error("No Blob/Buffer support");4158        }4159        if ((typeof data !== "string")4160            && (typeof Blob !== "undefined" && Blob !== null && !(data instanceof Blob))4161            && (typeof Buffer !== "undefined" && Buffer !== null && !(Buffer.isBuffer(data)))) {4162            exports.nbLogger("FileBucket._save(), Data is not String, Blob nor Buffer");4163            throw new Error("data is not String, Blob nor Buffer");4164        }4165        if (!update) {4166            if (!metadata || !metadata.getContentType()) {4167                exports.nbLogger("FileBucket._save(), Parameter is invalid : metadata.contentType");4168                throw new Error("No contentType in metadata");4169            }4170        }4171        var path = this.getDataPath("/" + encodeURIComponent(fileName));4172        exports.nbLogger("FileBucket._save(), path=" + path);4173        var req = new HttpRequest(this._service, path);4174        if (update) {4175            req.setMethod("PUT");4176        }4177        else {4178            req.setMethod("POST");4179            req.setContentType(metadata.getContentType());4180            if (metadata.getAcl() != null) {4181                req.addRequestHeader("X-ACL", metadata.getAcl()._toString());4182            }4183            if (metadata.getOptions() != null) {4184                req.addRequestHeader("X-Meta-Options", JSON.stringify(metadata.getOptions()));4185            }4186        }4187        req.setData(data);4188        var promise = req.execute().then(function (response) {4189            try {4190                var resObj = JSON.parse(response);4191                if (metadata === null) {4192                    metadata = new FileMetadata();4193                }4194                metadata._setMetadata(resObj);4195                return Promise.resolve(metadata);4196            }4197            catch (e) {4198                exports.nbLogger("FileBucket._save(), success: exception=" + e);4199                var error = exports._createError(0, "Invalid response from server", e, fileName);4200                return Promise.reject(error);4201            }4202        }, function (error) {4203            exports.nbLogger(("FileBucket._save(), error: " + (exports._errorText(error))));4204            error.data = fileName;4205            return Promise.reject(error);4206        });4207        return exports._promisify(promise, callbacks);4208    };4209    FileBucket.prototype.saveAs = function (fileName, data, metadata, callbacks) {4210        return this._save(fileName, data, metadata, false, callbacks);4211    };4212    FileBucket.prototype.save = function (fileName, data, callbacks) {4213        return this._save(fileName, data, null, true, callbacks);4214    };4215    FileBucket.prototype.load = function (fileName, callbacks) {4216        return this._load(fileName, undefined, callbacks);4217    };4218    FileBucket.prototype.loadWithOptions = function (fileName, options, callbacks) {4219        return this._load(fileName, options, callbacks);4220    };4221    FileBucket.prototype._load = function (fileName, options, callbacks) {4222        exports.nbLogger("FileBucket._load()");4223        if (!(typeof fileName !== "undefined" && fileName !== null)) {4224            exports.nbLogger("FileBucket._load(), Parameter is invalid : fileName");4225            throw new Error("No fileName");4226        }4227        var rawRequest = false;4228        if (typeof options !== "undefined") {4229            if (options === null || typeof options !== "object") {4230                exports.nbLogger("FileBucket._load(), Invalid options: " + options);4231                throw new Error("Invalid options: " + options);4232            }4233            if (options["rawRequest"] === true) {4234                if (!(typeof Blob !== "undefined" && Blob !== null) && !(typeof Buffer !== "undefined" && Buffer !== null)) {4235                    exports.nbLogger("FileBucket._load(), Not supported Blob nor Buffer");4236                    throw new Error("No Blob/Buffer support");4237                }4238                rawRequest = true;4239            }4240        }4241        var path = this.getDataPath("/" + encodeURIComponent(fileName));4242        exports.nbLogger("FileBucket._load(), path=" + path);4243        var req = new HttpRequest(this._service, path);4244        req.setMethod("GET");4245        if (rawRequest) {4246            req.rawMessage = true;4247        }4248        else {4249            if (typeof Blob !== "undefined" && Blob !== null) {4250                req.setResponseType("blob");4251            }4252            else if (typeof Buffer !== "undefined" && Buffer !== null) {4253                req.setResponseType("buffer");4254            }4255        }4256        if (typeof options !== "undefined") {4257            var receiveResponse = options["extraResponse"];4258            if (receiveResponse === true) {4259                req.setReceiveResponseHeaders(true);4260            }4261            var start = options["rangeStart"];4262            var end = options["rangeEnd"];4263            var range = FileBucket._createRangeValue(start, end);4264            if (range !== undefined) {4265                req.addRequestHeader("Range", "bytes=" + range);4266            }4267            var ifMatch = options["ifMatch"];4268            if (typeof ifMatch !== "undefined") {4269                req.addRequestHeader("If-Match", '"' + ifMatch + '"');4270            }4271            var ifRange = options["ifRange"];4272            if (typeof ifRange !== "undefined") {4273                req.addRequestHeader("If-Range", '"' + ifRange + '"');4274            }4275        }4276        var promise = req.execute().then(function (response) {4277            return response;4278        }, function (err) {4279            exports.nbLogger(("FileBucket._load(), error: " + (exports._errorText(err))));4280            err.data = fileName;4281            return Promise.reject(err);4282        });4283        return exports._promisify(promise, callbacks);4284    };4285    FileBucket._createRangeValue = function (start, end) {4286        if (start !== undefined && (!Number.isInteger(start) || start < 0)) {4287            throw new Error("invalid rangeStart value: " + start);4288        }4289        if (end !== undefined && (!Number.isInteger(end) || end < 0)) {4290            throw new Error("invalid rangeEnd value: " + end);4291        }4292        var range = undefined;4293        if (start === undefined && end === undefined) {4294        }4295        else if (start !== undefined && end === undefined) {4296            range = start + "-";4297        }4298        else if (start === undefined && end !== undefined) {4299            range = "-" + end;4300        }4301        else {4302            range = start + "-" + end;4303        }4304        return range;4305    };4306    FileBucket.prototype.remove = function (fileName, callbacks) {4307        exports.nbLogger("FileBucket.delete()");4308        if (!(typeof fileName !== "undefined" && fileName !== null)) {4309            exports.nbLogger("FileBucket.delete(), Parameter is invalid : fileName");4310            throw new Error("No fileName");4311        }4312        var req;4313        if (this._service.isOffline()) {4314            req = new _SdeRequest(this.getClassName(), "delete");4315            var body = {4316                bucketName: this.getBucketName(),4317                fileName: fileName4318            };4319            req.setData(body);4320        }4321        else {4322            var path = this.getDataPath("/" + encodeURIComponent(fileName));4323            exports.nbLogger("FileBucket.delete(), path=" + path);4324            req = new HttpRequest(this._service, path);4325            req.setMethod("DELETE");4326        }4327        var promise = req.execute().then(function (response) {4328            exports.nbLogger("FileBucket.delete(), success: " + fileName);4329            return fileName;4330        }, function (err) {4331            exports.nbLogger(("FileBucket.delete(), error: " + (exports._errorText(err)) + " : " + (fileName)));4332            err.data = fileName;4333            return Promise.reject(err);4334        });4335        return exports._promisify(promise, callbacks);4336    };4337    FileBucket.prototype.delete = function (fileName, callbacks) {4338        return this.remove(fileName, callbacks);4339    };4340    FileBucket.prototype._createMetadata = function (obj) {4341        var metadata = new FileMetadata();4342        metadata._setMetadata(obj);4343        return metadata;4344    };4345    FileBucket.prototype._publish = function (fileName, published, callbacks) {4346        var _this = this;4347        exports.nbLogger("FileBucket._publish(), fileName=" + fileName + ", setFlg=" + published);4348        if (!(typeof fileName !== "undefined" && fileName !== null)) {4349            exports.nbLogger("FileBucket._publish(), Parameter is invalid : fileName");4350            throw new Error("No fileName");4351        }4352        var req;4353        if (this._service.isOffline()) {4354            req = new _SdeRequest(this.getClassName(), "publish");4355            var body = {4356                bucketName: this.getBucketName(),4357                fileName: fileName,4358                published: published4359            };4360            req.setData(body);4361        }4362        else {4363            var path = this.getDataPath("/" + encodeURIComponent(fileName) + "/publish");4364            exports.nbLogger("FileBucket._publish(), path=" + path);4365            req = new HttpRequest(this._service, path);4366            if (published) {4367                req.setMethod("PUT");4368            }4369            else {4370                req.setMethod("DELETE");4371            }4372        }4373        var promise = req.execute().then(function (response) {4374            exports.nbLogger("FileBucket._publish(), success: " + fileName);4375            try {4376                var resObj = JSON.parse(response);4377                var metadata = _this._createMetadata(resObj);4378                return Promise.resolve(metadata);4379            }4380            catch (e) {4381                exports.nbLogger("FileBucket._publish(), success: exception=" + e);4382                var errorResult = exports._createError(0, "Invalid response from server", e);4383                errorResult.data = fileName;4384                return Promise.reject(errorResult);4385            }4386        }, function (err) {4387            exports.nbLogger(("FileBucket._publish(), error: " + (exports._errorText) + " : " + (fileName)));4388            err.data = fileName;4389            return Promise.reject(err);4390        });4391        return exports._promisify(promise, callbacks);4392    };4393    FileBucket.prototype.publish = function (fileName, callbacks) {4394        exports.nbLogger("FileBucket.publish()");4395        return this._publish(fileName, true, callbacks);4396    };4397    FileBucket.prototype.unpublish = function (fileName, callbacks) {4398        exports.nbLogger("FileBucket.unpublish()");4399        return this._publish(fileName, false, callbacks);4400    };4401    FileBucket.prototype._getList = function (published, deleteMark, callbacks) {4402        var _this = this;4403        exports.nbLogger("FileBucket._getList(), published=" + published);4404        var req;4405        if (this._service.isOffline()) {4406            req = new _SdeRequest(this.getClassName(), "getList");4407            var body = {4408                bucketName: this.getBucketName(),4409                published: published,4410                deleteMark: deleteMark4411            };4412            req.setData(body);4413        }4414        else {4415            var path = this.getDataPath();4416            exports.nbLogger("FileBucket._getList(), path=" + path);4417            req = new HttpRequest(this._service, path);4418            req.setMethod("GET");4419            if (published) {4420                req.setQueryParam("published", "1");4421            }4422            if (deleteMark) {4423                req.setQueryParam("deleteMark", "1");4424            }4425        }4426        var promise = req.execute().then(function (response) {4427            exports.nbLogger("FileBucket._getList(), success");4428            try {4429                var resObj = JSON.parse(response);4430                var resArray = resObj.results;4431                var metaList = [];4432                if (resArray != null) {4433                    for (var _i = 0, resArray_2 = resArray; _i < resArray_2.length; _i++) {4434                        var obj = resArray_2[_i];4435                        var metadata = _this._createMetadata(obj);4436                        metaList.push(metadata);4437                    }4438                }4439                return Promise.resolve(metaList);4440            }4441            catch (e) {4442                exports.nbLogger("FileBucket._getList(), success: exception=" + e);4443                var errorResult = exports._createError(0, "Invalid response from server", e);4444                return Promise.reject(errorResult);4445            }4446        }, function (err) {4447            exports.nbLogger(("FileBucket._getList(), error: " + (exports._errorText(err))));4448            return Promise.reject(err);4449        });4450        return exports._promisify(promise, callbacks);4451    };4452    FileBucket.prototype.getList = function (callbacks) {4453        exports.nbLogger("FileBucket.getList()");4454        return this._getList(false, false, callbacks);4455    };4456    FileBucket.prototype.getPublishedList = function (callbacks) {4457        exports.nbLogger("FileBucket.getPublishedList()");4458        return this._getList(true, false, callbacks);4459    };4460    FileBucket.prototype.getMetadata = function (fileName, callbacks) {4461        var _this = this;4462        exports.nbLogger("FileBucket.getMetadata(), fileName=" + fileName);4463        if (!(typeof fileName !== "undefined" && fileName !== null)) {4464            exports.nbLogger("FileBucket.getMetadata(), Parameter is invalid : fileName");4465            throw new Error("No fileName");4466        }4467        var req;4468        if (this._service.isOffline()) {4469            req = new _SdeRequest(this.getClassName(), "getMetadata");4470            var body = {4471                bucketName: this.getBucketName(),4472                fileName: fileName4473            };4474            req.setData(body);4475        }4476        else {4477            var path = this.getDataPath("/" + encodeURIComponent(fileName) + "/meta");4478            exports.nbLogger("FileBucket.getMetadata(), path=" + path);4479            req = new HttpRequest(this._service, path);4480            req.setMethod("GET");4481        }4482        var promise = req.execute().then(function (response) {4483            exports.nbLogger("FileBucket.getMetadata(), success");4484            try {4485                var resObj = JSON.parse(response);4486                var metadata = _this._createMetadata(resObj);4487                return Promise.resolve(metadata);4488            }4489            catch (e) {4490                exports.nbLogger("FileBucket.getMetadata(), Invalid response : " + response);4491                var errorResult = exports._createError(0, "Invalid response from server", e);4492                errorResult.data = fileName;4493                return Promise.reject(errorResult);4494            }4495        }, function (err) {4496            exports.nbLogger(("FileBucket.getMetadata(), error: " + (exports._errorText(err))));4497            err.data = fileName;4498            return Promise.reject(err);4499        });4500        return exports._promisify(promise, callbacks);4501    };4502    FileBucket.prototype.updateMetadata = function (fileName, metadata, callbacks) {4503        exports.nbLogger("FileBucket.updateMetadata(), fileName=" + fileName);4504        if (fileName == null || fileName === "") {4505            exports.nbLogger("FileBucket.updateMetadata(), Parameter is invalid : fileName");4506            throw new Error("No fileName");4507        }4508        if (!(metadata instanceof FileMetadata)) {4509            exports.nbLogger("FileBucket.updateMetadata(), Parameter is invalid : metadata");4510            throw new Error("metadata is not instance of FileMetadata");4511        }4512        var body = {};4513        var req;4514        if (this._service.isOffline()) {4515            req = new _SdeRequest(this.getClassName(), "updateMetadata");4516            body.bucketName = this.getBucketName();4517            body.targetFileName = fileName;4518            body.cacheDisabled = metadata.isCacheDisabled();4519        }4520        else {4521            var path = this.getDataPath("/" + encodeURIComponent(fileName) + "/meta");4522            exports.nbLogger("FileBucket.updateMetadata(), path=" + path);4523            req = new HttpRequest(this._service, path);4524            req.setMethod("PUT");4525        }4526        if (metadata.getFileName() != null) {4527            body.filename = metadata.getFileName();4528        }4529        if (metadata.getContentType() != null) {4530            body.contentType = metadata.getContentType();4531        }4532        if (metadata.getAcl() != null) {4533            body.ACL = metadata.getAcl()._toJsonObject();4534        }4535        if (metadata.getOptions() != null) {4536            body.options = JSON.stringify(metadata.getOptions());4537        }4538        req.setData(body);4539        var promise = req.execute().then(function (response) {4540            exports.nbLogger("FileBucket.updateMetadata(), success");4541            try {4542                var resObj = JSON.parse(response);4543                metadata._setMetadata(resObj);4544                return Promise.resolve(metadata);4545            }4546            catch (e) {4547                exports.nbLogger("FileBucket.updateMetadata(), success: exception=" + e);4548                var errorResult = exports._createError(0, "Invalid response from server", e);4549                errorResult.data = fileName;4550                return Promise.reject(errorResult);4551            }4552        }, function (err) {4553            exports.nbLogger(("FileBucket.updateMetadata(), error: " + (exports._errorText(err))));4554            err.data = fileName;4555            return Promise.reject(err);4556        });4557        return exports._promisify(promise, callbacks);4558    };4559    FileBucket._checkOfflineService = function (service) {4560        if (service !== exports.Nebula) {4561            exports.nbLogger("ObjectBucket.setSyncScope(): Can't use for multitenant instance");4562            throw new Error("No multitenant support");4563        }4564        if (!service.isOffline()) {4565            exports.nbLogger("ObjectBucket.setSyncScope(), supported offline mode only");4566            throw new Error("No offline mode enabled");4567        }4568    };4569    FileBucket.selectUploadFile = function (callbacks) { return null; };4570    FileBucket._selectUploadFile = function (service, callbacks) {4571        exports.nbLogger("FileBucket.selectUploadFile()");4572        this._checkOfflineService(service);4573        var req = new _SdeRequest(BaseBucket.getClassName("file"), "selectUploadFile");4574        var promise = req.execute().then(function (response) {4575            try {4576                var resObj = JSON.parse(response);4577                return Promise.resolve(resObj);4578            }4579            catch (e) {4580                exports.nbLogger("FileBucket.selectUploadFile(), success: exception=" + e);4581                var errorResult = exports._createError(0, "Invalid response from server", e);4582                return Promise.reject(errorResult);4583            }4584        }, function (err) {4585            exports.nbLogger(("FileBucket.selectUploadFile(), error: " + (exports._errorText(err))));4586            return Promise.reject(err);4587        });4588        return exports._promisify(promise, callbacks);4589    };4590    FileBucket.selectDirectory = function (callbacks) { return null; };4591    FileBucket._selectDirectory = function (service, callbacks) {4592        exports.nbLogger("FileBucket.selectDirectory()");4593        this._checkOfflineService(service);4594        var req = new _SdeRequest(BaseBucket.getClassName("file"), "selectDirectory");4595        var promise = req.execute().then(function (response) {4596            try {4597                var resObj = JSON.parse(response);4598                return Promise.resolve(resObj.path);4599            }4600            catch (e) {4601                exports.nbLogger("FileBucket.selectUploadFile(), success: exception=" + e);4602                var errorResult = exports._createError(0, "Invalid response from server", e);4603                return Promise.reject(errorResult);4604            }4605        }, function (err) {4606            exports.nbLogger(("FileBucket.selectDirectory(), error: " + (exports._errorText(err))));4607            return Promise.reject(err);4608        });4609        return exports._promisify(promise, callbacks);4610    };4611    FileBucket.prototype._uploadFile = function (fileName, filePath, metadata, update, callbacks) {4612        exports.nbLogger("FileBucket._uploadFile()");4613        if (!this._service.isOffline()) {4614            exports.nbLogger("FileBucket._uploadFile(), only offline mode");4615            throw new Error("No offline mode enabled");4616        }4617        if (!fileName || fileName === "") {4618            exports.nbLogger("FileBucket._uploadFile(), Parameter is invalid : fileName");4619            throw new Error("No fileName");4620        }4621        if (!filePath || filePath === "") {4622            exports.nbLogger("FileBucket._uploadFile(), Parameter is invalid : filePath");4623            throw new Error("No filePath");4624        }4625        if (!metadata || !metadata.getContentType() || metadata.getContentType() === "") {4626            exports.nbLogger("FileBucket._uploadFile(), Parameter is invalid : metadata");4627            throw new Error("No metadata.contentType");4628        }4629        var method = "uploadNewFile";4630        if (update) {4631            method = "uploadUpdateFile";4632        }4633        var req = new _SdeRequest(this.getClassName(), method);4634        var body = {};4635        body.bucketName = this.getBucketName();4636        body.fileName = fileName;4637        body.filePath = filePath;4638        body.cacheDisabled = metadata.isCacheDisabled();4639        body.contentType = metadata.getContentType();4640        if (metadata.getAcl() != null) {4641            body.ACL = metadata.getAcl()._toJsonObject();4642        }4643        if (metadata.getOptions() != null) {4644            body.options = JSON.stringify(metadata.getOptions());4645        }4646        req.setData(body);4647        var promise = req.execute().then(function (response) {4648            try {4649                var resObj = JSON.parse(response);4650                if (metadata === null) {4651                    metadata = new FileMetadata();4652                }4653                metadata._setMetadata(resObj);4654                return Promise.resolve(metadata);4655            }4656            catch (e) {4657                exports.nbLogger("FileBucket.uploadNewFile(), success: exception=" + e);4658                var errorResult = exports._createError(0, "Invalid response from server", e);4659                errorResult.data = fileName;4660                return Promise.reject(errorResult);4661            }4662        }, function (err) {4663            exports.nbLogger(("FileBucket.uploadNewFile(), error: " + (exports._errorText(err))));4664            err.data = fileName;4665            return Promise.reject(err);4666        });4667        return exports._promisify(promise, callbacks);4668    };4669    FileBucket.prototype.uploadNewFile = function (fileName, filePath, metadata, callbacks) {4670        exports.nbLogger("FileBucket.uploadNewFile()");4671        return this._uploadFile(fileName, filePath, metadata, false, callbacks);4672    };4673    FileBucket.prototype.uploadUpdateFile = function (fileName, filePath, metadata, callbacks) {4674        exports.nbLogger("FileBucket.uploadUpdateFile()");4675        return this._uploadFile(fileName, filePath, metadata, true, callbacks);4676    };4677    FileBucket.prototype.downloadFile = function (fileName, filePath, callbacks) {4678        exports.nbLogger("FileBucket.downloadFile()");4679        FileBucket._checkOfflineService(this._service);4680        if (!fileName || fileName === "") {4681            exports.nbLogger("FileBucket.downloadFile(), Parameter is invalid : fileName");4682            throw new Error("No fileName");4683        }4684        if (!filePath || filePath === "") {4685            exports.nbLogger("FileBucket.downloadFile(), Parameter is invalid : filePath");4686            throw new Error("No filePath");4687        }4688        var req = new _SdeRequest(this.getClassName(), "downloadFile");4689        var body = {4690            bucketName: this.getBucketName(),4691            fileName: fileName,4692            filePath: filePath4693        };4694        req.setData(body);4695        var promise = req.execute().then(function (response) {4696            try {4697                var resObj = JSON.parse(response);4698                exports.nbLogger("FileBucket.downloadFile(), response=" + response);4699                return Promise.resolve(fileName);4700            }4701            catch (e) {4702                exports.nbLogger("FileBucket.downloadFile(), success: exception=" + e);4703                var errorResult = exports._createError(0, "Invalid response from server", e);4704                errorResult.data = fileName;4705                return Promise.reject(errorResult);4706            }4707        }, function (err) {4708            exports.nbLogger(("FileBucket.downloadFile(), error: " + (exports._errorText(err))));4709            err.data = fileName;4710            return Promise.reject(err);4711        });4712        return exports._promisify(promise, callbacks);4713    };4714    FileBucket.prototype.requestCancel = function (fileName, callbacks) {4715        exports.nbLogger("FileBucket.requestCancel()");4716        FileBucket._checkOfflineService(this._service);4717        if (!(typeof fileName !== "undefined" && fileName !== null) || fileName === "") {4718            exports.nbLogger("FileBucket.requestCancel(), Parameter is invalid : fileName");4719            throw new Error("No fileName");4720        }4721        var req = new _SdeRequest(this.getClassName(), "requestCancel");4722        var body = {4723            bucketName: this.getBucketName(),4724            fileName: fileName4725        };4726        req.setData(body);4727        var promise = req.execute().then(function (response) {4728            try {4729                exports.nbLogger("FileBucket.requestCancel(), response=" + response);4730                return Promise.resolve(fileName);4731            }4732            catch (e) {4733                exports.nbLogger("FileBucket.requestCancel(), success: exception=" + e);4734                var errorResult = exports._createError(0, "Invalid response from server", e);4735                errorResult.data = fileName;4736                return Promise.reject(errorResult);4737            }4738        }, function (err) {4739            exports.nbLogger(("FileBucket.requestCancel(), error: " + (exports._errorText(err))));4740            err.data = fileName;4741            return Promise.reject(err);4742        });4743        return exports._promisify(promise, callbacks);4744    };4745    return FileBucket;4746}(BaseBucket));4747exports.FileBucket = FileBucket;4748exports.declareFileBucket = function (_service) {4749    _service.FileBucket =  (function (_super) {4750        __extends(_FileBucket, _super);4751        function _FileBucket(name) {4752            return _super.call(this, name, _service) || this;4753        }4754        _FileBucket.loadBucket = function (name, callbacks) {4755            return _super._loadBucket.call(this, _service, name, callbacks);4756        };4757        _FileBucket.getBucketList = function (callbacks) {4758            return _super._getBucketList.call(this, _service, callbacks);4759        };4760        _FileBucket.selectUploadFile = function (callbacks) {4761            return _super._selectUploadFile.call(this, _service, callbacks);4762        };4763        _FileBucket.selectDirectory = function (callbacks) {4764            return _super._selectDirectory.call(this, _service, callbacks);4765        };4766        return _FileBucket;4767    }(FileBucket));4768};4769var CustomApi =  (function () {4770    function CustomApi(apiname, method, subpath, service) {4771        if (service === void 0) { service = exports.Nebula; }4772        this._service = service;4773        this.apiname = apiname;4774        this.method = method;4775        this.subpath = subpath;4776        this.headers = {};4777        this.queryParams = {};4778        this.receiveResponseHeaders = false;4779        this.path = "/api/" + apiname;4780        if (subpath) {4781            if (subpath.indexOf("/") !== 0) {4782                this.path += "/";4783            }4784            this.path += subpath;4785        }4786    }4787    CustomApi.prototype.clearHeaders = function () {4788        this.headers = {};4789    };4790    CustomApi.prototype.setContentType = function (contentType) {4791        this.contentType = contentType;4792        return this;4793    };4794    CustomApi.prototype.addHeader = function (name, value) {4795        this.headers[name] = value;4796        return this;4797    };4798    CustomApi.prototype.addQueryParam = function (name, value) {4799        this.queryParams[name] = value;4800        return this;4801    };4802    CustomApi.prototype.setBinaryResponse = function () {4803        if (typeof Blob !== "undefined" && Blob !== null) {4804            this.responseType = "blob";4805        }4806        else if (typeof Buffer !== "undefined" && Buffer !== null) {4807            this.responseType = "buffer";4808        }4809        else {4810            throw new Error("No blob / buffer");4811        }4812        return this;4813    };4814    CustomApi.prototype.setReceiveResponseHeaders = function (receive) {4815        this.receiveResponseHeaders = receive;4816        return this;4817    };4818    CustomApi.prototype.execute = function (data, callbacks) {4819        return this._execute(data, false, callbacks);4820    };4821    CustomApi.prototype.executeRaw = function (data) {4822        return this._execute(data, true);4823    };4824    CustomApi.prototype._execute = function (data, rawMessage, callbacks) {4825        var request = new HttpRequest(this._service, this.path);4826        request.setMethod(this.method);4827        request.addQueryParams(this.queryParams);4828        if (data) {4829            if (this.method === "GET" || this.method === "DELETE") {4830                request.addQueryParams(data);4831            }4832            else {4833                request.setData(data);4834            }4835        }4836        if (!rawMessage) {4837            if (this.responseType != null) {4838                request.setResponseType(this.responseType);4839            }4840        }4841        else {4842            request.rawMessage = true;4843        }4844        if (this.contentType != null) {4845            request.setContentType(this.contentType);4846        }4847        for (var _i = 0, _a = Object.keys(this.headers); _i < _a.length; _i++) {4848            var key = _a[_i];4849            request.addRequestHeader(key, this.headers[key]);4850        }4851        request.setReceiveResponseHeaders(this.receiveResponseHeaders);4852        var promise = request.execute()4853            .then(function (response) {4854            exports.nbLogger("CustomApi#success");4855            return response;4856        })4857            .catch(function (err) {4858            exports.nbLogger("CustomApi#error " + exports._errorText(err));4859            return Promise.reject(err);4860        });4861        return exports._promisify(promise, callbacks);4862    };4863    return CustomApi;4864}());4865exports.CustomApi = CustomApi;4866exports.declareCustomApi = function (_service) {4867    _service.CustomApi =  (function (_super) {4868        __extends(_CustomApi, _super);4869        function _CustomApi(apiname, method, subpath) {4870            return _super.call(this, apiname, method, subpath, _service) || this;4871        }4872        return _CustomApi;4873    }(CustomApi));4874};4875var ApnsFields =  (function () {4876    function ApnsFields() {4877        this._fields = {};4878    }4879    Object.defineProperty(ApnsFields.prototype, "badge", {4880        get: function () {4881            return this._fields.badge;4882        },4883        set: function (badge) {4884            if (!this._isInteger(badge)) {4885                throw new Error("ApnsFields.badge, Not integer: " + badge);4886            }4887            this._fields.badge = badge;4888        },4889        enumerable: true,4890        configurable: true4891    });4892    Object.defineProperty(ApnsFields.prototype, "sound", {4893        get: function () {4894            return this._fields.sound;4895        },4896        set: function (sound) {4897            if (typeof sound !== "string") {4898                throw new Error("ApnsFields.sound, Not string: " + sound);4899            }4900            this._fields.sound = sound;4901        },4902        enumerable: true,4903        configurable: true4904    });4905    Object.defineProperty(ApnsFields.prototype, "contentAvailable", {4906        get: function () {4907            return this._fields["content-available"];4908        },4909        set: function (contentAvailable) {4910            if (!this._isInteger(contentAvailable)) {4911                throw new Error("ApnsFields.contentAvailable, Not integer: " + contentAvailable);4912            }4913            this._fields["content-available"] = contentAvailable;4914        },4915        enumerable: true,4916        configurable: true4917    });4918    Object.defineProperty(ApnsFields.prototype, "category", {4919        get: function () {4920            return this._fields.category;4921        },4922        set: function (category) {4923            if (typeof category !== "string") {4924                throw new Error("ApnsFields.category, Not string: " + category);4925            }4926            this._fields.category = category;4927        },4928        enumerable: true,4929        configurable: true4930    });4931    ApnsFields.prototype._isInteger = function (value) {4932        return typeof value === 'number' &&4933            isFinite(value) &&4934            Math.floor(value) === value;4935    };4936    return ApnsFields;4937}());4938exports.ApnsFields = ApnsFields;4939var GcmFields =  (function () {4940    function GcmFields() {4941        this._fields = {};4942    }4943    Object.defineProperty(GcmFields.prototype, "title", {4944        get: function () {4945            return this._fields.title;4946        },4947        set: function (title) {4948            if (typeof title === "string") {4949                this._fields.title = title;4950            }4951            else {4952                throw new Error("GcmFields.title, Invalid value: " + title);4953            }4954        },4955        enumerable: true,4956        configurable: true4957    });4958    Object.defineProperty(GcmFields.prototype, "uri", {4959        get: function () {4960            return this._fields.uri;4961        },4962        set: function (uri) {4963            if (typeof uri === "string") {4964                this._fields.uri = uri;4965            }4966            else {4967                throw new Error("GcmFields.uri, Invalid value: " + uri);4968            }4969        },4970        enumerable: true,4971        configurable: true4972    });4973    return GcmFields;4974}());4975exports.GcmFields = GcmFields;4976var SseFields =  (function () {4977    function SseFields() {4978        this._fields = {};4979    }4980    Object.defineProperty(SseFields.prototype, "eventId", {4981        get: function () {4982            return this._fields.sseEventId;4983        },4984        set: function (eventId) {4985            if (typeof eventId !== "string") {4986                throw new Error("SseFields.eventId, Not string: " + eventId);4987            }4988            this._fields.sseEventId = eventId;4989        },4990        enumerable: true,4991        configurable: true4992    });4993    Object.defineProperty(SseFields.prototype, "eventType", {4994        get: function () {4995            return this._fields.sseEventType;4996        },4997        set: function (eventType) {4998            if (typeof eventType !== "string") {4999                throw new Error("SseFields.eventType, Not string: " + eventType);5000            }5001            this._fields.sseEventType = eventType;5002        },5003        enumerable: true,5004        configurable: true5005    });5006    return SseFields;5007}());5008exports.SseFields = SseFields;5009var PushSender =  (function () {5010    function PushSender(service) {5011        if (service === void 0) { service = exports.Nebula; }5012        this._service = service;5013    }5014    PushSender.prototype.send = function (callbacks) {5015        exports.nbLogger("PushSender.send()");5016        var path = "/push/notifications";5017        var request = new HttpRequest(this._service, path);5018        request.setMethod("POST");5019        request.setContentType("application/json");5020        request.setData(this._toJson());5021        var promise = request.execute().then(function (response) {5022            exports.nbLogger("PushSender.send#success : response = " + response);5023            try {5024                return JSON.parse(response);5025            }5026            catch (e) {5027                exports.nbLogger("PushSender.send#error : exception=" + e);5028                var errorResult = exports._createError(0, "Invalid response from server", e);5029                return Promise.reject(errorResult);5030            }5031        }, function (error) {5032            exports.nbLogger(("PushSender.send#error = " + (exports._errorText(error))));5033            return Promise.reject(error);5034        });5035        return exports._promisify(promise, callbacks);5036    };5037    PushSender.prototype._toJson = function () {5038        var json = {};5039        if (this._clause != null) {5040            json.query = this._clause.json();5041        }5042        if (this._message != null) {5043            json.message = this._message;5044        }5045        if (this._allowedReceivers != null) {5046            json.allowedReceivers = this._allowedReceivers;5047        }5048        if (this._apnsFields != null) {5049            this._copyKeys(this._apnsFields._fields, json);5050        }5051        if (this._gcmFields != null) {5052            this._copyKeys(this._gcmFields._fields, json);5053        }5054        if (this._sseFields != null) {5055            this._copyKeys(this._sseFields._fields, json);5056        }5057        return json;5058    };5059    PushSender.prototype._copyKeys = function (from, to) {5060        for (var _i = 0, _a = Object.keys(from); _i < _a.length; _i++) {5061            var key = _a[_i];5062            to[key] = from[key];5063        }5064    };5065    Object.defineProperty(PushSender.prototype, "clause", {5066        get: function () {5067            return this._clause;5068        },5069        set: function (clause) {5070            if (!(clause instanceof Clause)) {5071                throw new Error("PushSender.clause, Invalid type");5072            }5073            this._clause = clause;5074        },5075        enumerable: true,5076        configurable: true5077    });5078    Object.defineProperty(PushSender.prototype, "message", {5079        get: function () {5080            return this._message;5081        },5082        set: function (message) {5083            if (typeof message !== "string") {5084                throw new Error("PushSender.message, Not string: " + message);5085            }5086            this._message = message;5087            exports.nbLogger("push.message = " + this._message);5088        },5089        enumerable: true,5090        configurable: true5091    });5092    Object.defineProperty(PushSender.prototype, "allowedReceivers", {5093        get: function () {5094            return this._allowedReceivers;5095        },5096        set: function (receivers) {5097            if (!Array.isArray(receivers)) {5098                throw new Error("PushSender.allowedReceivers, Not Array");5099            }5100            this._allowedReceivers = receivers;5101        },5102        enumerable: true,5103        configurable: true5104    });5105    Object.defineProperty(PushSender.prototype, "apnsFields", {5106        get: function () {5107            return this._apnsFields;5108        },5109        set: function (fields) {5110            if (!(fields instanceof ApnsFields)) {5111                throw new Error("PushSender.apnsFields, Invalid instance type");5112            }5113            this._apnsFields = fields;5114        },5115        enumerable: true,5116        configurable: true5117    });5118    Object.defineProperty(PushSender.prototype, "gcmFields", {5119        get: function () {5120            return this._gcmFields;5121        },5122        set: function (fields) {5123            if (!(fields instanceof GcmFields)) {5124                throw new Error("PushSender.gcmFields, Invalid instance type");5125            }5126            this._gcmFields = fields;5127        },5128        enumerable: true,5129        configurable: true5130    });5131    Object.defineProperty(PushSender.prototype, "sseFields", {5132        get: function () {5133            return this._sseFields;5134        },5135        set: function (fields) {5136            if (!(fields instanceof SseFields)) {5137                throw new Error("PushSender.sseFields, Invalid instance type");5138            }5139            this._sseFields = fields;5140        },5141        enumerable: true,5142        configurable: true5143    });5144    PushSender.ApnsFields = ApnsFields;5145    PushSender.GcmFields = GcmFields;5146    PushSender.SseFields = SseFields;5147    return PushSender;5148}());5149exports.PushSender = PushSender;5150exports.declarePushSender = function (_service) {5151    _service.PushSender =  (function (_super) {5152        __extends(_PushSender, _super);5153        function _PushSender() {5154            return _super.call(this, _service) || this;5155        }5156        return _PushSender;5157    }(PushSender));5158};5159var BatchRequest =  (function () {5160    function BatchRequest() {5161        this.requests = [];5162        this.json = { requests: this.requests };5163    }5164    BatchRequest.prototype.addInsertRequest = function (object) {5165        if (object.etag) {5166            throw new Error("ETag exists");5167        }5168        this.requests.push({5169            op: "insert",5170            data: object5171        });5172    };5173    BatchRequest.prototype.addUpdateRequest = function (object) {5174        if (!object._id) {5175            throw new Error("No id");5176        }5177        var req = {5178            op: "update",5179            _id: object._id,5180            data: { "$full_update": object }5181        };5182        if (object.etag) {5183            req.etag = object.etag;5184        }5185        this.requests.push(req);5186    };5187    BatchRequest.prototype.addDeleteRequest = function (object) {5188        if (!object._id) {5189            throw new Error("No id");5190        }5191        var req = {5192            op: "delete",5193            _id: object._id5194        };5195        if (object.etag) {5196            req.etag = object.etag;5197        }5198        this.requests.push(req);5199    };5200    return BatchRequest;5201}());5202exports.BatchRequest = BatchRequest;5203var LocalStorageInMemory =  (function () {5204    function LocalStorageInMemory() {5205        this.data = {};5206    }5207    LocalStorageInMemory.prototype.getItem = function (key) {5208        return this.data[key];5209    };5210    LocalStorageInMemory.prototype.setItem = function (key, value) {5211        this.data[key] = value;5212    };5213    LocalStorageInMemory.prototype.removeItem = function (key) {5214        delete this.data[key];5215    };5216    return LocalStorageInMemory;5217}());5218exports.LocalStorageInMemory = LocalStorageInMemory;5219var NebulaConfig =  (function () {5220    function NebulaConfig(params) {5221        this.offline = false;5222        this.allowSelfSignedCert = false;5223        this.debugMode = "release";5224        this.enableHttp2 = false;5225        this.tenant = params.tenant;5226        this.appId = params.appId;5227        this.appKey = params.appKey;5228        this.baseUri = params.baseUri;5229        if (this.tenant == null)5230            throw new Error("No tenant");5231        if (this.appId == null)5232            throw new Error("No appId");5233        if (this.appKey == null)5234            throw new Error("No appKey");5235        if (this.baseUri == null)5236            throw new Error("No baseUri");5237        if (this.baseUri.slice(-1) === "/") {5238            this.baseUri = this.baseUri.slice(0, -1);5239        }5240        if (params.offline !== undefined && params.offline === true) {5241            this.offline = params.offline;5242        }5243        if (params.allowSelfSignedCert !== undefined && params.allowSelfSignedCert === true) {5244            this.allowSelfSignedCert = params.allowSelfSignedCert;5245        }5246        if (params.serviceId !== undefined) {5247            this.serviceId = params.serviceId;5248        }5249        if (params.debugMode !== undefined) {5250            this.debugMode = params.debugMode;5251        }5252        if (params.enableHttp2 !== undefined) {5253            this.enableHttp2 = params.enableHttp2;5254        }5255    }5256    return NebulaConfig;5257}());5258exports.NebulaConfig = NebulaConfig;5259var NebulaService =  (function () {5260    function NebulaService() {5261        this.BUCKET_MODE_ONLINE = 0;5262        this.BUCKET_MODE_REPLICA = 1;5263        this.BUCKET_MODE_LOCAL = 2;5264        exports.declareUser(this);5265        exports.declareGroup(this);5266        exports.declareObjectBucket(this);5267        exports.declareFileBucket(this);5268        exports.declareCustomApi(this);5269        exports.declarePushSender(this);5270        this.NebulaService = NebulaService;5271        this.HttpRequest = HttpRequest;5272        this.AclPermission = exports.AclPermission;5273        this.AclGroup = exports.AclGroup;5274        this.Acl = Acl;5275        this.RegexOption = exports.RegexOption;5276        this.Clause = Clause;5277        this.ObjectQuery = ObjectQuery;5278        this.FileMetadata = FileMetadata;5279        this.BatchRequest = BatchRequest;5280        this.AccountLink = AccountLink;5281        this._SdeRequest = _SdeRequest;5282        this._SdeNetworkEventListener = _SdeNetworkEventListener;5283        this._SdeSyncEventListener = _SdeSyncEventListener;5284    }5285    NebulaService.prototype.getRestApiVersion = function () {5286        return 1;5287    };5288    NebulaService.prototype.getTenantID = function () {5289        if (this._config === undefined) {5290            return null;5291        }5292        else {5293            return this._config.tenant;5294        }5295    };5296    NebulaService.prototype.getBaseUri = function () {5297        if (this._config === undefined) {5298            return null;5299        }5300        else {5301            return this._config.baseUri;5302        }5303    };5304    NebulaService.prototype.getAppID = function () {5305        if (this._config === undefined) {5306            return null;5307        }5308        else {5309            return this._config.appId;5310        }5311    };5312    NebulaService.prototype.getAppKey = function () {5313        if (this._config === undefined) {5314            return null;5315        }5316        else {5317            return this._config.appKey;5318        }5319    };5320    NebulaService.prototype.setAppKey = function (key) {5321        if (!this._config) {5322            throw new Error("Not initialized");5323        }5324        this._config.appKey = key;5325        return this;5326    };5327    NebulaService.prototype.getServiceID = function () {5328        if (this._config === undefined) {5329            return null;5330        }5331        else {5332            return this._config.serviceId;5333        }5334    };5335    NebulaService.prototype.getDebugMode = function () {5336        if (this._config === undefined) {5337            return null;5338        }5339        else {5340            return this._config.debugMode;5341        }5342    };5343    NebulaService.prototype.isOffline = function () {5344        return this._config.offline;5345    };5346    NebulaService.prototype.isAllowSelfSignedCert = function () {5347        return this._config.allowSelfSignedCert;5348    };5349    NebulaService.prototype.setClientCertificate = function (certInfo) {5350        this._config.clientCertOptions = certInfo;5351        return this;5352    };5353    NebulaService.prototype.isClientCertSet = function () {5354        return (this._config.clientCertOptions != null);5355    };5356    NebulaService.prototype.getCurrentUser = function () {5357        var _saveStr = this._localStorage.getItem(this._userItemKey());5358        if (!_saveStr) {5359            return null;5360        }5361        try {5362            var _jsonObj = JSON.parse(_saveStr);5363            if (!("expire" in _jsonObj) || _jsonObj.expire < new Date().getTime() / 1000) {5364                _jsonObj = null;5365            }5366            return _jsonObj;5367        }5368        catch (e) {5369            exports.nbLogger("Nebula.getCurrentUser#" + e.message);5370            return null;5371        }5372    };5373    NebulaService.prototype.setCurrentUser = function (user) {5374        var _saveObj = {5375            _id: user._id,5376            username: user.username,5377            email: user.email,5378            sessionToken: user.sessionToken,5379            expire: user.expire,5380            options: user.options,5381            groups: user.groups5382        };5383        this._localStorage.setItem(this._userItemKey(), JSON.stringify(_saveObj));5384        return this;5385    };5386    NebulaService.prototype.setSessionToken = function (sessionToken) {5387        var expire = new Date().getTime() / 1000 + (60 * 60 * 24 * 365 * 100);5388        var _json = this.getCurrentUser();5389        if (_json === null) { 5390            _json = {5391                _id: "",5392                username: "",5393                email: "",5394                sessionToken: sessionToken,5395                expire: expire,5396                options: {},5397                groups: []5398            };5399        }5400        else {5401            _json.sessionToken = sessionToken;5402            _json.expire = expire;5403        }5404        this._localStorage.setItem(this._userItemKey(), JSON.stringify(_json));5405        return this;5406    };5407    NebulaService.prototype.removeCurrentUser = function () {5408        this._localStorage.removeItem(this._userItemKey());5409        return this;5410    };5411    NebulaService.prototype._userItemKey = function () {5412        var serviceId = this.getServiceID();5413        if (serviceId !== undefined) {5414            return this.getTenantID() + "_" + this.getAppID() + "_" + serviceId;5415        }5416        else {5417            return this.getTenantID() + "_" + this.getAppID();5418        }5419    };5420    NebulaService.prototype.getHttp2 = function () {5421        return this._config.enableHttp2;5422    };5423    NebulaService.prototype.setHttp2 = function (enable) {5424        this._config.enableHttp2 = enable;5425    };5426    NebulaService.prototype.initialize = function (params) {5427        var _this = this;5428        this._config = new NebulaConfig(params);5429        if (typeof localStorage !== 'undefined' && localStorage != null) {5430            this._localStorage = localStorage;5431        }5432        else {5433            this._localStorage = new LocalStorageInMemory();5434        }5435        if (this._config.offline) {5436            if (this !== exports.Nebula) {5437                throw new Error("No offline mode supported for multi-tenant instance.");5438            }5439            try {5440                var request = new _SdeRequest("Nebula", "initialize");5441                var initializeParams = {5442                    tenant: this.getTenantID(),5443                    appId: this.getAppID(),5444                    appKey: this.getAppKey(),5445                    baseUri: this.getBaseUri(),5446                    offline: this.isOffline(),5447                    allowSelfSignedCert: this.isAllowSelfSignedCert(),5448                    debugMode: this.getDebugMode(),5449                    enableHttp2: this.getHttp2()5450                };5451                request.setData(initializeParams);5452                request.execute().then(function (response) {5453                    exports.nbLogger("Nebula.initialize#Success");5454                    exports.nbLogger("Nebula.initialize#response = " + response);5455                }).catch(function (error) {5456                    exports.nbLogger("Nebula.initialize#Error = " + exports._errorText(error));5457                    _this._config.offline = false;5458                });5459            }5460            catch (e) {5461                exports.nbLogger("Nebula.initialize#" + e.message);5462                this._config.offline = false;5463            }5464        }5465        return this;5466    };5467    NebulaService.prototype.setLoginCacheValidTime = function (expire, callbacks) {5468        exports.nbLogger("Nebula.setLoginCacheValidTime#start");5469        if (expire <= 0) {5470            throw new Error("Nebula.setLoginCacheValidTime: bad expire");5471        }5472        if (!this.isOffline()) {5473            throw new Error("Not offline mode!");5474        }5475        var request = new _SdeRequest("Nebula", "setLoginCacheValidTime");5476        var setLoginCacheValidTimeParams = {5477            expire: expire5478        };5479        request.setData(setLoginCacheValidTimeParams);5480        var promise = request.execute().then(function () {5481            exports.nbLogger("Nebula.setLoginCacheValidTime#Success");5482            return;5483        }).catch(function (error) {5484            exports.nbLogger(("Nebula.setLoginCacheValidTime#error = " + (exports._errorText(error))));5485            return Promise.reject(error);5486        });5487        exports.nbLogger("Nebula.setLoginCacheValidTime#end");5488        return exports._promisify(promise, callbacks);5489    };5490    NebulaService.prototype.getLoginCacheValidTime = function (callbacks) {5491        exports.nbLogger("Nebula.getLoginCacheValidTime#start");5492        if (!this.isOffline()) {5493            throw new Error("Not offline mode!");5494        }5495        var request = new _SdeRequest("Nebula", "getLoginCacheValidTime");5496        var promise = request.execute().then(function (response) {5497            exports.nbLogger("Nebula.getLoginCacheValidTime#Success");5498            var jsonObj;5499            try {5500                jsonObj = JSON.parse(response);5501            }5502            catch (e) {5503                exports.nbError("Nebula.getLoginCacheValidTime#" + e.message);5504                jsonObj = null;5505            }5506            if (jsonObj !== null) {5507                return Promise.resolve(jsonObj.expire);5508            }5509            else {5510                var error = exports._createError(400, "Bad Response", "Response json error.");5511                return Promise.reject(error);5512            }5513        }).catch(function (error) {5514            exports.nbLogger("Nebula.getLoginCacheValidTime#error callback start");5515            exports.nbLogger(("Nebula.getLoginCacheValidTime#error = " + (exports._errorText(error))));5516            return Promise.reject(error);5517        });5518        exports.nbLogger("Nebula.getLoginCacheValidTime#end");5519        return exports._promisify(promise, callbacks);5520    };5521    NebulaService.prototype.setNetworkEventListener = function (listener) {5522        exports.nbLogger("Nebula.setNetworkEventListener#start");5523        var paramOk = false;5524        if (arguments.length === 1) {5525            if (listener != null) {5526                if (listener.onNetworkStateChanged !== undefined) {5527                    paramOk = true;5528                }5529            }5530            if (listener === null) {5531                paramOk = true;5532            }5533        }5534        if (!paramOk) {5535            exports.nbError("Nebula.setNetworkEventListener#invalid parameter.");5536            return;5537        }5538        if (this.isOffline()) {5539            _SdeNetworkEventListener.setCallback(listener);5540        }5541        else {5542            exports.nbLogger("Nebula.setNetworkEventListener#Disabled Offline");5543        }5544        exports.nbLogger("Nebula.setNetworkEventListener#end");5545        return this;5546    };5547    NebulaService.prototype.setHttpProxy = function (proxy) {5548        var agent = null;5549        if (proxy != null) {5550            NebulaService.verifyProxy(proxy);5551            agent = exports._node_require('tunnel-fork').httpOverHttp({ proxy: proxy });5552        }5553        HttpRequest.setProxy(proxy);5554        HttpRequest.setHttpAgent(agent);5555    };5556    NebulaService.prototype.setHttpsProxy = function (proxy, options) {5557        var agent = null;5558        if (proxy != null) {5559            if (options == null) {5560                options = {};5561            }5562            options.proxy = proxy;5563            NebulaService.verifyProxy(proxy);5564            agent = exports._node_require('tunnel-fork').httpsOverHttp(options);5565            agent.defaultPort = 443;5566        }5567        HttpRequest.setProxy(proxy);5568        HttpRequest.setHttpsAgent(agent, options);5569    };5570    NebulaService.verifyProxy = function (proxy) {5571        if (typeof proxy !== 'object') {5572            throw new Error("Bad proxy: not object");5573        }5574        if (proxy.host == null || typeof proxy.host !== "string") {5575            throw new Error("Bad proxy: host");5576        }5577        if (proxy.port == null || typeof proxy.port !== "number") {5578            throw new Error("Bad proxy: port");5579        }5580    };5581    return NebulaService;5582}());5583exports.NebulaService = NebulaService;5584exports.initHttpXhr();5585exports.initHttpNode();5586exports.Nebula = new NebulaService();...

NodeDefinition.js

Source:NodeDefinition.js

1// Copyright 2012 The Obvious Corporation.2/**3 * @fileoverview Contains the class definition for NodeDefinition which4 *     represents a node that has been added to a Graph instance and any5 *     dependencies it might have.6 * @author <a href="http://github.com/azulus">Jeremy Stanley</a>7 * @version 1.0.08 */9var util = require('util')10var utils = require('./utils')11var clone = utils.clone12/**13 * A node to be added to a graph which defines a handler for a given14 * unit of work which takes in specific inputs15 *16 * @param {./Graph} graph the graph to add the node to17 * @param {string} name the name of the node to be added18 * @constructor19 */20function NodeDefinition(graph, name) {21  this._description = null22  this._graph = graph23  this._name = name24  this._scope = 'default'25  this._inputArgs = []26  /** @private {Array.<utils.NodeInfo>} */27  this._args = []28  /** @private {Array.<{field: utils.NodeInfo, provides: Array.<Object|string>,29                        condition: (NodeCondition|undefined)}>} */30  this._builds = []31  this._modifiers = []32  this._cacheDisabled = false33  this._fn = null34  this._hasGettersEnabled = false35  /** @private {boolean} */36  this._lazyDependency = false37  /** @private {?string} */38  this._lazyContextName = null39  /** @private {Function} */40  this._errorFn = null41  /** @private {boolean} */42  this._singletonScoped = false43}44/**45 * A condition that a built node depends on.46 * @constructor47 */48function NodeCondition(field, value) {49  /** @type {utils.NodeInfo} */50  this.field = field51  /** @type {Array.<Object|string>} */52  this.provides = []53  /**54   * The truthiness value that this will compare against.55   * @type {boolean}56   */57  this.value = value58}59/**60 * Return whether this node requires getter wrapper objects for its inputs61 *62 * @return {boolean}63 */64NodeDefinition.prototype.hasGettersEnabled = function () {65  return this._hasGettersEnabled66}67/**68 * Specify that this node requires getter wrapper objects for its inputs69 *70 * @return {NodeDefinition} the current instance71 */72NodeDefinition.prototype.enableGetters = function () {73  this._hasGettersEnabled = true74  return this75}76/**77 * Retrieve the graph for this node78 *79 * @return {./Graph}80 */81NodeDefinition.prototype.getGraph = function () {82  return this._graph83}84/**85 * Retrieve an array of arguments for this node's function handler, including86 * both input args and built nodes.87 *88 * @return {Array.<utils.NodeInfo>} args89 */90NodeDefinition.prototype.getArgs = function () {91  return this._args92}93/**94 * @return {boolean} Whether this node has exactly one possible output per run(),95 *     because it has no arguments and is graph-scoped.96 */97NodeDefinition.prototype.isSingleResult = function () {98  return !this._inputArgs.length && !this.isCacheDisabled()99}100/**101 * Retrieve an array of all nodes to build for this node102 *103 * @return {Array.<Object|string>} builds104 */105NodeDefinition.prototype.getBuilds = function () {106  return this._builds107}108/**109 * Update the name of this node110 *111 * @param {string} name112 */113NodeDefinition.prototype.setName = function (name) {114  this._name = name115}116/**117 * Retrieve the name for this node118 *119 * @return {string}120 */121NodeDefinition.prototype.getName = function () {122  return this._name123}124/**125 * Update the call scope of this node126 *127 * @param {string} scope128 */129NodeDefinition.prototype.setScope = function (scope) {130  this._scope = scope131}132/**133 * Retrieve the call scope for this node134 *135 * @return {string}136 */137NodeDefinition.prototype.getScope = function () {138  return this._scope139}140/**141 * Create a copy of this node and attach it to a specified graph142 *143 * @param {./Graph} graph the graph to add the new node to144 * @return {NodeDefinition} the cloned node145 */146NodeDefinition.prototype.clone = function (graph) {147  var def = new NodeDefinition(graph, this._name)148  def._description = this._description149  def._name = this._name150  def._scope = this._scope151  def._inputArgs = clone(this._inputArgs)152  def._args = clone(this._args)153  def._builds = clone(this._builds)154  def._modifiers = clone(this._modifiers)155  def._fn = this._fn156  def._hasGettersEnabled = this._hasGettersEnabled157  def._cacheDisabled = clone(this._cacheDisabled)158  def._lazyDependency = this._lazyDependency159  def._lazyContextName = this._lazyContextName160  def._errorFn = this._errorFn161  def._singletonScoped = this._singletonScoped162  return def163}164/**165 * Specify that this node and all of this dependencies should be cached per graph.166 *167 * @return {NodeDefinition} returns the current NodeDefinition instance168 */169NodeDefinition.prototype.cacheSingleton = function () {170  this._singletonScoped = true171  // rebuild the callback function172  if (this._fn) {173    this.fn(this._fn)174  }175  return this176}177/**178 * @return {boolean} Whether this is a singleton scoped node.179 */180NodeDefinition.prototype.isSingletonScoped = function () {181  return this._singletonScoped182}183/**184 * Specify that this node should never be cached in a builder context185 *186 * @return {NodeDefinition} returns the current NodeDefinition instance187 */188NodeDefinition.prototype.disableNodeCache = function () {189  this._cacheDisabled = true190  return this191}192/**193 * Check whether the cache is disabled for this node194 *195 * @return {boolean}196 */197NodeDefinition.prototype.isCacheDisabled = function () {198  return this._cacheDisabled199}200/**201 * Set the description for this node202 *203 * @param {string} description204 * @return {NodeDefinition} returns the current NodeDefinition instance205 */206NodeDefinition.prototype.description = function (description) {207  this._description = description208  return this209}210/**211 * Get the description for this node212 *213 * @return {?string} returns the description for this node214 */215NodeDefinition.prototype.getDescription = function () {216  return this._description217}218/**219 * Get the handler function for this node220 *221 * @return {Function}222 */223NodeDefinition.prototype.getFunction = function () {224  return this._fn225}226/**227 * Get the error handler function for this node228 *229 * @return {Function}230 */231NodeDefinition.prototype.getErrorFunction = function () {232  return this._errorFn233}234/**235 * Define any inputs into this node (may be either explicit inputs with236 * no existing node defined *or* nodes with 0 dependencies)237 *238 * @param {string} var_args a variable number of arguments, each of which239 *     is a string representing a node name which represents a node with 0240 *     arguments or the name of a value that should be passed in by the caller241 * @return {NodeDefinition} returns the current NodeDefinition instance242 */243NodeDefinition.prototype.args = function (var_args) {244  var arr = []245  arr.push.apply(arr, arguments)246  return this.argList(arr)247}248/**249 * Define any inputs into this node (may be either explicit inputs with250 * no existing node defined *or* nodes with 0 dependencies)251 *252 * @param {Array.<string>} argList253 * @return {NodeDefinition} returns the current NodeDefinition instance254 */255NodeDefinition.prototype.argList = function (argList) {256  if (!Array.isArray(argList)) throw new Error('Expected an array, got ' + argList)257  for (var i = 0; i < argList.length; i += 1) {258    var argInfo = utils.getNodeInfoFromBuild(this._graph, argList[i])259    this._args.push(argInfo)260    this._inputArgs.push(argInfo.rootName)261  }262  if (this._argumentMirrors) {263    for (i = 0; i < this._argumentMirrors.length; i++) {264      this._argumentMirrors[i].argList(argList)265    }266  }267  return this268}269/**270 * Start configuring a node for use in .modifiers()271 *272 * @param {string|Object} field273 * @return {NodeDefinition} the current node274 */275NodeDefinition.prototype.configure = function (field) {276  if (typeof field == 'string') {277    return this.builds(utils.OUTPUT_PREFIX_PARTIAL + field)278  } else if (field && (typeof field == 'object')) {279    var keys = Object.keys(field)280    if (keys.length == 1) {281      var newField = {}282      newField[utils.OUTPUT_PREFIX_PARTIAL + keys[0]] = field[keys[0]]283      return this.builds(newField)284    }285  }286  throw new Error('Invalid configure() parameter ' + util.inspect(field))287}288/**289 * Specify that this node should build another node as an input290 *291 * @param {string|Object} field the node to build292 * @return {NodeDefinition} the current node293 */294NodeDefinition.prototype.builds = function (field) {295  var nodeInfo = utils.getNodeInfoFromBuild(this._graph, field)296  if (this._getArgIdx(nodeInfo) !== -1) {297    throw new Error('You may only use the same alias in a .builds() once in a subgraph')298  }299  var nodeName = nodeInfo.fullName300  if (typeof nodeName == 'string' && utils.isLazyArgRef(nodeName)) {301    if (!this._lazyContextName) throw new Error('You may not use lazyargs with non-lazy nodes.')302    var newArgRef = this._lazyContextName + '.args.' + utils.getLazyArgRef(nodeName)303    var newNodeInfo = {}304    newNodeInfo[nodeInfo.getAlias()] = newArgRef305    return this.builds(newNodeInfo).using('args.*')306  }307  this._builds.push({308    field: nodeInfo,309    provides: []310  })311  this._args.push(nodeInfo)312  return this313}314function buildObjectFromKeysAndArguments(keys, var_args) {315  var obj = {}316  for (var i = 0; i < keys.length; i++) {317    obj[keys[i]] = arguments[i + 1]318  }319  return obj320}321/**322 * Specify that a node to be built should take in a list of inputs323 *324 * @param {...(Object|string)} var_args a variable number of arguments325 *     which are either node names or a map of arg name to node name326 * @return {NodeDefinition} the current node327 */328NodeDefinition.prototype.using = function (var_args) {329  var args = Array.prototype.slice.call(arguments, 0)330  var nodeIdx = this._builds.length - 1331  for (var i = 0; i < args.length; i++) {332    var arg = args[i]333    var nodeInfo = utils.getNodeInfoFromInput(this._graph, arg)334    var nodeNames = nodeInfo.nodeName335    var wrapperArgs, wrapperUsing, argName, mappingObj, wrapperNodeName, newBuilds, j336    if (Array.isArray(nodeNames)) {337      if (!nodeNames.length) {338        // node has an empty array for inputs339        arg[nodeInfo.arg] = this._graph.literal(/** @type {Array} */ (nodeNames))340      } else {341        // the node has an array for inputs, build that as a separate node342        // and pass it as an input343        wrapperArgs = []344        wrapperUsing = []345        for (j = 0; j < nodeNames.length; j++) {346          argName = 'arg' + (j + 1)347          mappingObj = {}348          mappingObj[argName] = nodeNames[j]349          wrapperArgs.push(argName)350          wrapperUsing.push(mappingObj)351        }352        wrapperNodeName = this._graph.addAnonymous(nodeInfo.arg, this._graph.argsToArray, wrapperArgs)353        newBuilds = this.builds(utils.OUTPUT_PREFIX_IMPORTANT + wrapperNodeName)354        newBuilds.using.apply(newBuilds, wrapperUsing)355        arg[nodeInfo.arg] = wrapperNodeName356      }357    } else if (typeof nodeNames == 'object' && nodeNames != null) {358      // the node has an object for inputs, build that as a separate node359      // and pass it as an input360      wrapperArgs = []361      wrapperUsing = []362      var keys = Object.keys(nodeNames)363      for (j = 0; j < keys.length; j++) {364        argName = 'arg' + (j + 1)365        mappingObj = {}366        mappingObj[argName] = nodeNames[keys[j]]367        wrapperArgs.push(argName)368        wrapperUsing.push(mappingObj)369      }370      wrapperNodeName = this._graph.addAnonymous(nodeInfo.arg, buildObjectFromKeysAndArguments.bind(null, keys), wrapperArgs)371      newBuilds = this.builds(utils.OUTPUT_PREFIX_IMPORTANT + wrapperNodeName)372      newBuilds.using.apply(newBuilds, wrapperUsing)373      arg[nodeInfo.arg] = wrapperNodeName374    } else if (typeof nodeNames == 'string' && utils.isArgRef(nodeNames)) {375      // check that an existing arg is referenced376      var inputArg = utils.getArgRef(nodeNames).split('.')[0]377      if (!utils.isWildcardArgRef(nodeNames) && this._inputArgs.indexOf(inputArg) === -1) {378        throw new Error(nodeNames + ' is referenced but is not provided as an input')379      }380    }381    // If this .using() belongs to a conditional node, append to that,382    // otherwise append to the previous .builds() node.383    var target = this._builds[nodeIdx].condition || this._builds[nodeIdx]384    target.provides.push(arg)385  }386  return this387}388/**389 * Specify that this node should return a specific sub-node if this390 * is a subgraph391 *392 * @param {string} nodeName the name of the node to return393 * @return {NodeDefinition} the current instance394 */395NodeDefinition.prototype.returns = function (nodeName) {396  if (this._fn !== this._graph.subgraph) throw new Error('Only able to call .returns() on a subgraph')397  var wrapperNode = this._graph.addAnonymous(utils.NODE_PREFIX_AGGREGATOR_RETURN_VAL, this._graph.subgraph, ['nodeName'])398  return this.builds(wrapperNode)399    .using({nodeName: nodeName})400}401NodeDefinition.prototype.modifiers = function (var_args) {402  for (var i = 0; i < arguments.length; i += 1) {403    if (this._builds.length) {404      // create a new last field which pulls from the previous last405      var previousField = this._builds[this._builds.length - 1]406      // find a safe name to move this node to407      var nodeInfo = previousField.field408      var nodeName409      var j = 0410      do {411        j++412        nodeName = nodeInfo.aliasRealName + '-modifier' + j413      } while (this._getNode(nodeName))414      // find the existing arg info415      var argIdx = this._getArgIdx(nodeInfo)416      // rename the node417      var newNodeInfo = {}418      newNodeInfo[utils.OUTPUT_PREFIX_IMPORTANT + nodeName] = nodeInfo.fullName419      this._args[argIdx] = previousField.field = utils.getNodeInfoFromBuild(this._graph, newNodeInfo)420      // retrieve the modifier info421      var modifierNodeInfo = utils.getNodeInfoFromModifier(this._graph, arguments[i], nodeInfo.getAlias())422      // create a new field or clone the already configured field423      var fieldData = {}424      fieldData[nodeInfo.getAlias()] = modifierNodeInfo.nodeName425      var fieldDataInfo = utils.getNodeInfoFromBuild(this._graph, fieldData)426      var modifierNode = this._getNode(/** @type {string} */ (modifierNodeInfo.nodeName))427      if (modifierNode) {428        // clone the existing node429        this._builds.push(clone(modifierNode))430        this._builds[this._builds.length - 1].field = fieldDataInfo431      } else {432        // create a new node433        this.builds(fieldData)434        this._args.pop()435      }436      this._args.push(fieldDataInfo)437      // map the old node to the new node438      var usingData = {}439      usingData[modifierNodeInfo.arg] = nodeName440      this.using(usingData)441    } else {442      throw new Error('The ability to add modifiers directly to a graph node has been deprecated')443    }444  }445  return this446}447/**448 * Add a conditional node for the previous input node449 *450 * @param {Object|string} field451 * @param {boolean} condition The truthiness value to compare the452 *     conditional against.453 * @return {NodeDefinition} This454 */455NodeDefinition.prototype._addCondition = function(field, condition) {456  var nodeIdx = this._builds.length - 1457  var nodeInfo = utils.getNodeInfoFromInput(this._graph, field)458  var nodeName = nodeInfo.nodeName459  // TODO(kyle): Same logic as in .using(), factor out460  if (typeof nodeName == 'string' && utils.isArgRef(nodeName)) {461    // check that an existing arg is referenced462    var inputArg = utils.getArgRef(nodeName).split('.')[0]463    if (!utils.isWildcardArgRef(nodeName) && this._inputArgs.indexOf(inputArg) === -1) {464      throw new Error(nodeName + ' is referenced but is not provided as an input')465    }466  }467  this._builds[nodeIdx].condition = new NodeCondition(nodeInfo, condition)468  return this469}470NodeDefinition.prototype.when = function(field) {471  return this._addCondition(field, true)472}473NodeDefinition.prototype.unless = function(field) {474  return this._addCondition(field, false)475}476/**477 * Set the handler function for this node478 * @param {!Function} fn479 */480NodeDefinition.prototype.fn = function (fn) {481  if (this._singletonScoped) {482    var called = false483    var singletonScopedResults = this._graph.singletonScopedResultsInternal484    var name = this._name485    this._fn = function () {486      if (!called) {487        singletonScopedResults[name] = fn.apply(null, arguments)488        called = true489      }490      return singletonScopedResults[name]491    }492  } else {493    this._fn = fn494  }495  return this496}497/**498 * Set a handler function that invokes the given constructor.499 * @param {function(new:Object, ...)} Ctor500 */501NodeDefinition.prototype.ctor = function (Ctor) {502  this._setArgsFromFunction(Ctor)503  return this.fn(function () {504    return utils.applyNew(Ctor, arguments)505  })506}507/**508 * Set the handler function for this node, but inject based on parameter name instead509 * of based on order.510 *511 * If the parameters can't be found, this will throw an error.512 *513 * @param {!Function} fn514 */515NodeDefinition.prototype.inject = function (fn) {516  this._setArgsFromFunction(fn)517  return this.fn(fn)518}519/**520 * Re-arrange the node params from the function definition521 *522 * If the parameters can't be found, this will throw an error.523 *524 * @param {!Function} fn525 */526NodeDefinition.prototype._setArgsFromFunction = function (fn) {527  var paramNames = utils.parseFnParams(fn)528  var shortArgsNames = this._args.map(function (arg) {529    return utils.getNodeInjectorName(arg.aliasRealName)530  })531  // Sort the arguments so that the parameters get injected in the532  // right order.533  var newArgs = []534  var i535  for (i = 0; i < paramNames.length; i++) {536    var idx = shortArgsNames.indexOf(paramNames[i])537    if (idx === -1) {538      throw new Error('No injector found for parameter: ' + paramNames[i])539    }540    newArgs.push(this._args[idx])541    this._args.splice(idx, 1)542    shortArgsNames.splice(idx, 1)543  }544  // Push any args that are not included.545  newArgs.push.apply(newArgs, this._args)546  this._args = newArgs547}548/**549 * Set an error handler function for this node.550 * This function cannot do anything to stop the propagation of551 * the exception. It's mostly needed to handle thunk errors appropriately.552 * @param {function(Error, Array)} fn A function that takes two553 *     arguments: the error being propagated, and the Array of arguments554 *     passed to the normal handler function.555 */556NodeDefinition.prototype.errorFn = function (fn) {557  this._errorFn = fn558  return this559}560/**561 * Proxy function which can be used to chain newBuilder() requests back562 * to the graph563 */564NodeDefinition.prototype.newBuilder = function () {565  return this._graph.newBuilder.apply(this._graph, arguments)566}567/**568 * Proxy function which can be used to chain add() requests back569 * to the graph570 */571NodeDefinition.prototype.add = function () {572  return this._graph.add.apply(this._graph, arguments)573}574/**575 * In thunks, we have a series of nodes that all share the same arguments.576 *577 * Any arguments added to this node need to be mirrored on the mirrorNode.578 *579 * @param {NodeDefinition} mirrorNode580 */581NodeDefinition.prototype.addArgumentMirror = function (mirrorNode) {582  if (!this._argumentMirrors) {583    this._argumentMirrors = []584  }585  this._argumentMirrors.push(mirrorNode)586}587/**588 * If we're building a thunk, we create a lazy dependency from589 * the thunk to its synchronous subtree.590 *591 * This tells the Builder that it's OK to send the thunk function to nodes592 * that require it, event though its dependencies haven't resolved yet.593 *594 * This function should only be called from Graph.js, which sets up the necessary595 * dependencies so that calling the thunk function forces the subtree to resolve.596 *597 * @param {boolean} val598 */599NodeDefinition.prototype.setLazyDependencyInternal = function (val) {600  this._lazyDependency = val601  return this602}603/**604 * If we're building a thunk, this represents the source of deferreds605 * and arguments passed to the function.606 *607 * This function should only be called from Graph.js, which sets up the necessary608 * dependencies609 *610 * @param {NodeDefinition} lazyContext611 */612NodeDefinition.prototype.setLazyContextSourceInternal = function (lazyContext) {613  this._lazyContextName = lazyContext.getName()614  return this615}616/**617 * @return {boolean} Whether this is a lazy dependency.618 */619NodeDefinition.prototype.isLazyDependency = function () {620  return this._lazyDependency621}622/**623 * Get build info for a node that will be built by this node definition by its alias624 *625 * @param {string} alias the alias for the node626 * @return {Object} returns null if the build doesn't exist627 */628NodeDefinition.prototype._getNode = function (alias) {629  for (var i = 0; i < this._builds.length; i++) {630    if (this._builds[i].field.aliasRealName == alias) return this._builds[i]631  }632  return null633}634/**635 * Get the index for a node that will be built by this node definition636 *637 * @param {utils.NodeInfo} nodeInfo The node638 * @return {number} returns -1 if the alias doesn't exist639 */640NodeDefinition.prototype._getArgIdx = function (nodeInfo) {641  for (var i = 0; i < this._args.length; i++) {642    if (nodeInfo.isSameAlias(this._args[i])) return i643  }644  return -1645}...

Worker.mjs

Source:Worker.mjs

1/**2 * Main script to use service worker in TeqFW applications.3 *4 * This is standard ES6 module w/o TeqFW DI support (service workers don't allow dynamic `import()`).5 *6 * I suppose that SW files should be cached by browser itself, so these files are not under `./Front/` folder.7 * @namespace TeqFw_Web_Sw_Worker8 */9// MODULE'S IMPORT10import Config from './Config.mjs';11import MSG from '../Front/Mod/Sw/Enum/Message.mjs';12// MODULE'S VARS13const NS = 'TeqFw_Web_Sw_Worker';14/**15 * Service Worker events.16 */17const EVT = {18    ACTIVATE: 'activate',19    CONTENT_DELETE: 'contentdelete',20    FETCH: 'fetch',21    INSTALL: 'install',22    LANGUAGE_CHANGE: 'languagechange',23    MESSAGE: 'message',24    NOTIFICATION_CLICK: 'notificationclick',25    NOTIFICATION_CLOSE: 'notificationclose',26    PERIODIC_SYNC: 'periodicsync',27    PUSH: 'push',28    PUSH_SUBSCRIPTION_CHANGE: 'pushsubscriptionchange',29    SYNC: 'sync',30};31const API_STATIC_FILES = '/api/@teqfw/web/load/files_to_cache'; // get list of files to cache on SW installation32const CACHE_STATIC = 'static-cache-v1'; // store name to cache static resources33const CFG_CACHE_DISABLED = 'cache_disabled';34/**35 * Configuration object for SW. It is stored in IDB and is reloaded on service worker start.36 * @type {TeqFw_Web_Sw_Config}37 */38const _config = new Config();39/**40 * Entry point for the frontend application ('pub', 'admin').41 * @type {string}42 */43let _door;44/** @type {boolean} */45let _cacheDisabled = true; // disable by default TODO: invert logic here and in IndexedDB46/**47 * Log function to trace functionality of this module.48 * @type {function}49 */50let _log;51// MODULE'S FUNCS52/**53 * Send message to `index.html` to start bootstrap.54 */55function onActivate() {56    _log(`[TeqFw_Web_Sw_Worker]: on activate event is here...`);57    self.clients.claim();58}59function onFetch(event) {60    // FUNCS61    /**62     * Analyze route's URL and return 'true' if request should not be cached.63     * @param {Request} req64     * @returns {boolean}65     */66    function detectBypass(req) {67        // see TeqFw_Web_Shared_Defaults.SPACE_...68        const API = /(.*)(\/api\/)(.*)/;69        const CFG = /(.*)(\/cfg\/)(.*)/;70        const EBF = /(.*)(\/ebf\/)(.*)/; // events 'back-to-front'71        const EFB = /(.*)(\/efb\/)(.*)/; // events 'front-to-back'72        const res = !!(73            req.method === 'POST' ||74            req.url.match(API) ||75            req.url.match(CFG) ||76            req.url.match(EFB) ||77            req.url.match(EBF)78        );79        return res;80    }81    async function getFromCacheOrFetchAndCache(event) {82        try {83            const cache = await self.caches.open(CACHE_STATIC);84            const cachedResponse = await cache.match(event.request);85            if (cachedResponse) return cachedResponse;86            // wait until resource will be fetched from server and stored in cache87            const resp = await fetch(event.request);88            await cache.put(event.request, resp.clone());89            return resp;90        } catch (e) {91            _log(`[TeqFw_Web_Sw_Worker] error: ${JSON.stringify(e)}`);92        }93    }94    // MAIN95    const bypass = detectBypass(event.request);96    if (bypass === false)97        if (_cacheDisabled !== true)98            event.respondWith(getFromCacheOrFetchAndCache(event));99}100function onInstall(event) {101    // FUNCS102    /**103     * Load list of static file's URLs to cache locally.104     * @return {Promise<string[]>}105     */106    async function loadFilesToCache() {107        // Get list of static files from the server108        const data = {door: _door}; // see TeqFw_Web_Shared_WAPI_Load_FilesToCache.Request109        const req = new Request(API_STATIC_FILES, {110            method: 'POST',111            headers: {112                'Content-Type': 'application/json'113            },114            body: JSON.stringify({data})115        });116        const resp = await self.fetch(req);117        const json = await resp.json();118        const res = json?.data?.items ?? [];119        _log(`List of static files to cache is loaded (total items: ${res.length}).`);120        return res;121    }122    /**123     * Load urls from server and cache content locally. All URLs are separated to batches up to 10 URLs each.124     * @param {string[]} urls125     * @return {Promise<void>}126     */127    async function cacheStatics(urls) {128        try {129            if (Array.isArray(urls)) {130                // ... and load static files to the local cache131                const cacheStat = await caches.open(CACHE_STATIC);132                // METHOD 1133                // await cacheStat.addAll(files);134                // METHOD 2135                let total = 0;136                const SIZE = 10;137                while (total <= urls.length) {138                    const slice = urls.slice(total, total + SIZE);139                    await Promise.all(140                        slice.map(function (url) {141                            return cacheStat.add(url).catch(function (reason) {142                                _log(`SW install error: '${url}' failed, ${String(reason)}`);143                            });144                        })145                    );146                    total += SIZE;147                    const cached = total < urls.length ? total : urls.length;148                    _log(`Total '${cached}' URLs are cached.`);149                }150            }151            _log(`Static files are loaded and cached by Service Worker.`);152        } catch (e) {153            _log(`SW iInstallation error: ${JSON.stringify(e)}`);154        }155    }156    // MAIN157    event.waitUntil(158        loadFilesToCache()159            .then(cacheStatics)160            .catch((e) => {161                _log(`[TeqFw_Web_Sw_Worker] error: ${e.message}`);162            })163    );164}165/**166 * @param {MessageEvent} event167 */168async function onMessage(event) {169    // FUNCS170    async function cacheClean() {171        try {172            const cache = await self.caches.open(CACHE_STATIC);173            const keys = await cache.keys();174            keys.forEach((one) => cache.delete(one));175        } catch (e) {176            _log(`[TeqFw_Web_Sw_Worker] error: ${JSON.stringify(e)}`);177        }178    }179    // MAIN180    /** @type {TeqFw_Web_Front_Mod_Sw_Control.Message} */181    const data = event.data;182    const type = data.type;183    const payload = data.payload;184    let out;185    // perform requested operation186    if (type === MSG.CACHE_STATUS_GET) {187        _cacheDisabled = await _config.get(CFG_CACHE_DISABLED);188        out = !_cacheDisabled; // inversion for cache status189    } else if (type === MSG.CACHE_STATUS_SET) {190        _cacheDisabled = !payload; // inversion for cache status191        await _config.set(CFG_CACHE_DISABLED, _cacheDisabled);192    } else if (type === MSG.CACHE_CLEAN) {193        await cacheClean();194    }195    // ... then return result196    const res = Object.assign({}, data);197    res.payload = out;198    // noinspection JSCheckFunctionSignatures199    event.source.postMessage(res);200}201/**202 * Create log-function to trace service worker functionality.203 *204 * @param {string} uuid frontend identifier for service worker instance.205 * @return {(function(string, Object): void)}206 */207function createLogger(uuid) {208    // FUNCS209    /**210     * Log function to send log info to the server.211     * @param {string} msg212     * @param {Object} [meta]213     */214    return function log(msg, meta = {}) {215        if (navigator.onLine) {216            /** @type {TeqFw_Core_Shared_Dto_Log.Dto} */217            const item = {218                date: new Date(),219                isError: false,220                message: msg,221                meta: {},222                source: NS,223            };224            if (typeof meta === 'object') Object.assign(item.meta, meta);225            item.meta.frontUuid = uuid;226            /** @type {TeqFw_Web_Api_Shared_WAPI_Front_Log_Collect.Request} */227            const req = {item};228            fetch('./api/@teqfw/web/front/log/collect', {229                method: 'POST',230                headers: {231                    'Content-Type': 'application/json'232                },233                body: JSON.stringify({data: req}),234            });235        }236    }237}238/**239 * Setup function to populate Service Worker global scope.240 * @param {WorkerGlobalScope} scope241 * @param {string} [door]242 * @param {function(string):function} logFactory243 */244function setup({scope, door, logFactory}) {245    _log = logFactory(NS); // create log function for this es6-module246    _door = door;247    _config.get(CFG_CACHE_DISABLED).then((val) => _cacheDisabled = val);248    scope.addEventListener(EVT.ACTIVATE, onActivate);249    scope.addEventListener(EVT.FETCH, onFetch);250    scope.addEventListener(EVT.INSTALL, onInstall);251    scope.addEventListener(EVT.MESSAGE, onMessage);252    const entryPoint = _door ? 'root entry point' : `'${_door}' entry point`;253    _log(`Event listeners are registered for ${entryPoint}.`);254}255// MODULE'S MAIN256// Object.defineProperty(setup, 'namespace', {value: NS});257export {258    createLogger,259    setup...

Using AI Code Generation

1const puppeteer = require('puppeteer');2(async () => {3  const browser = await puppeteer.launch();4  const page = await browser.newPage();5  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});6  await page.screenshot({path: 'example.png'});7  await browser.close();8})();9const puppeteer = require('puppeteer');10(async () => {11  const browser = await puppeteer.launch();12  const page = await browser.newPage();13  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});14  await page.screenshot({path: 'example.png'});15  await browser.close();16})();17const puppeteer = require('puppeteer');18(async () => {19  const browser = await puppeteer.launch();20  const page = await browser.newPage();21  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});22  await page.screenshot({path: 'example.png'});23  await browser.close();24})();25const puppeteer = require('puppeteer');26(async () => {27  const browser = await puppeteer.launch();28  const page = await browser.newPage();29  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});30  await page.screenshot({path: 'example.png'});31  await browser.close();32})();33const puppeteer = require('puppeteer');34(async () => {35  const browser = await puppeteer.launch();36  const page = await browser.newPage();37  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});38  await page.screenshot({path: 'example.png'});39  await browser.close();40})();41const puppeteer = require('puppeteer

Using AI Code Generation

1const puppeteer = require('puppeteer');2(async () => {3  const browser = await puppeteer.launch();4  const page = await browser.newPage();5  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});6  await browser.close();7})();8const puppeteer = require('puppeteer');9(async () => {10  const browser = await puppeteer.launch();11  const page = await browser.newPage();12  await page.setRequestInterception(true);13  page.on('request', (request) => {14    if (request.resourceType() === 'image')15      request.abort();16      request.continue();17  });18  await browser.close();19})();20const puppeteer = require('puppeteer');21(async () => {22  const browser = await puppeteer.launch();23  const page = await browser.newPage();24  await page.setExtraHTTPHeaders({25    'Accept-Language': 'en-GB,en-US;q=0.9,en;q=0.8'26  });27  await browser.close();28})();29const puppeteer = require('puppeteer');30(async () => {31  const browser = await puppeteer.launch();32  const page = await browser.newPage();33  await page.setUserAgent('Mozilla/5.0 (Macintosh; Intel Mac OS X 10_14_2) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/71.0.3578.98 Safari/537.36');34  await browser.close();35})();36const puppeteer = require('puppeteer');37(async () => {38  const browser = await puppeteer.launch();39  const page = await browser.newPage();40  await page.emulate({41    viewport: {42    },43  });44  await browser.close();45})();

Using AI Code Generation

1const puppeteer = require('puppeteer');2(async () => {3  const browser = await puppeteer.launch();4  const page = await browser.newPage();5  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});6  await browser.close();7})();8const puppeteer = require('puppeteer');9(async () => {10  const browser = await puppeteer.launch();11  const page = await browser.newPage();12  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});13  await browser.close();14})();15const puppeteer = require('puppeteer');16(async () => {17  const browser = await puppeteer.launch();18  const page = await browser.newPage();19  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});20  await browser.close();21})();22const puppeteer = require('puppeteer');23(async () => {24  const browser = await puppeteer.launch();25  const page = await browser.newPage();26  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});27  await browser.close();28})();29const puppeteer = require('puppeteer');30(async () => {31  const browser = await puppeteer.launch();32  const page = await browser.newPage();33  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});34  await browser.close();35})();36const puppeteer = require('puppeteer');37(async () => {38  const browser = await puppeteer.launch();39  const page = await browser.newPage();40  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});41  await browser.close();42})();

Using AI Code Generation

1(async () => {2  const browser = await puppeteer.launch();3  const page = await browser.newPage();4  await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });5  await browser.close();6})();7(async () => {8  const browser = await puppeteer.launch();9  const page = await browser.newPage();10  await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });11  await browser.close();12})();13(async () => {14  const browser = await puppeteer.launch();15  const page = await browser.newPage();16  await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });17  await browser.close();18})();19(async () => {20  const browser = await puppeteer.launch();21  const page = await browser.newPage();22  await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });23  await browser.close();24})();25(async () => {26  const browser = await puppeteer.launch();27  const page = await browser.newPage();28  await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });29  await browser.close();30})();31(async () => {32  const browser = await puppeteer.launch();33  const page = await browser.newPage();34  await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });35  await browser.close();36})();37(async () => {38  const browser = await puppeteer.launch();39  const page = await browser.newPage();40  await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });

Using AI Code Generation

1const puppeteer = require('puppeteer');2(async () => {3  const browser = await puppeteer.launch({ headless: false });4  const page = await browser.newPage();5  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});6  await page.screenshot({path: 'google.png'});7  await browser.close();8})();9const puppeteer = require('puppeteer');10(async () => {11  const browser = await puppeteer.launch({ headless: false });12  const page = await browser.newPage();13  await page._client.send('Network.setCacheDisabled', {cacheDisabled: false});14  await page.screenshot({path: 'google.png'});15  await browser.close();16})();17const puppeteer = require('puppeteer');18(async () => {19  const browser = await puppeteer.launch({ headless: false });20  const page = await browser.newPage();21  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});22  await page.screenshot({path: 'google.png'});23  await browser.close();24})();25const puppeteer = require('puppeteer');26(async () => {27  const browser = await puppeteer.launch({ headless: false });28  const page = await browser.newPage();29  await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});30  await page.screenshot({path: 'google.png'});31  await browser.close();32})();

Using AI Code Generation

1const puppeteer = require('puppeteer');2(async () => {3  const browser = await puppeteer.launch({headless: false});4  const page = await browser.newPage();5  await page._client.send('Network.clearBrowserCache');6  await page.reload();7  await browser.close();8})();9const puppeteer = require('puppeteer');10(async () => {11  const browser = await puppeteer.launch({headless: false});12  const page = await browser.newPage();13  await page.setCacheEnabled(false);14  await page.reload();15  await browser.close();16})();17const puppeteer = require('puppeteer');18(async () => {19  const browser = await puppeteer.launch({headless: false});20  const page = await browser.newPage();21  await page.setCacheEnabled(true);22  await page.reload();23  await browser.close();24})();25const puppeteer = require('puppeteer');26(async () => {27  const browser = await puppeteer.launch({headless: false});28  const page = await browser.newPage();29  await page._client.send('Network.clearBrowserCache');30  await page.reload();31  await browser.close();32})();

Using AI Code Generation

1const puppeteer = require('puppeteer');2const browser = await puppeteer.launch();3const page = await browser.newPage();4await page._client.send('Network.enable');5await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});6await page.screenshot({path: 'screenshot.png'});7await browser.close();8const puppeteer = require('puppeteer');9const browser = await puppeteer.launch();10const page = await browser.newPage();11await page._client.send('Network.enable');12await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});13await page.screenshot({path: 'screenshot.png'});14await browser.close();15const puppeteer = require('puppeteer');16const browser = await puppeteer.launch();17const page = await browser.newPage();18await page._client.send('Network.enable');19await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});20await page.screenshot({path: 'screenshot.png'});21await browser.close();22const puppeteer = require('puppeteer');23const browser = await puppeteer.launch();24const page = await browser.newPage();25await page._client.send('Network.enable');26await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});27await page.screenshot({path: 'screenshot.png'});28await browser.close();29const puppeteer = require('puppeteer');30const browser = await puppeteer.launch();31const page = await browser.newPage();32await page._client.send('Network.enable');33await page._client.send('Network.setCacheDisabled', {cacheDisabled: true});34await page.screenshot({path: 'screenshot.png'});35await browser.close();36const puppeteer = require('puppeteer');

Using AI Code Generation

1const puppeteer = require('puppeteer');2(async () => {3    const browser = await puppeteer.launch({4    });5    const page = await browser.newPage();6    await page._client.send('Network.clearBrowserCache');7    await page.screenshot({path: 'google.png'});8    await browser.close();9})();10const puppeteer = require('puppeteer');11(async () => {12    const browser = await puppeteer.launch({13    });14    const page = await browser.newPage();15    await page._client.send('Network.clearBrowserCache');16    await page.screenshot({path: 'google.png'});17    await browser.close();18})();19const puppeteer = require('puppeteer');20(async () => {21    const browser = await puppeteer.launch({22    });23    const page = await browser.newPage();24    await page._client.send('Network.clearBrowserCache');25    await page.screenshot({path: 'google.png'});26    await browser.close();27})();28const puppeteer = require('puppeteer');29(async () => {30    const browser = await puppeteer.launch({31    });32    const page = await browser.newPage();33    await page._client.send('Network.clearBrowserCache');34    await page.screenshot({path: 'google.png'});35    await browser.close();36})();37const puppeteer = require('puppeteer');38(async () => {39    const browser = await puppeteer.launch({40    });41    const page = await browser.newPage();42    await page._client.send('Network.clearBrowserCache');43    await page.screenshot({path: 'google.png'});44    await browser.close();45})();46const puppeteer = require('puppeteer

Using AI Code Generation

1const puppeteer = require('puppeteer');2(async () => {3    const browser = await puppeteer.launch({4    });5    const page = await browser.newPage();6    await page._client.send('Network.clearBrowserCache');7    await page._client.send('Network.clearBrowserCookies');8    await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });9    await page.waitFor(5000);10    await browser.close();11})();12const puppeteer = require('puppeteer');13(async () => {14    const browser = await puppeteer.launch({15    });16    const page = await browser.newPage();17    await page._client.send('Network.clearBrowserCache');18    await page._client.send('Network.clearBrowserCookies');19    await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });20    await page.waitFor(5000);21    await page._client.send('Network.clearBrowserCache');22    await page._client.send('Network.clearBrowserCookies');23    await page._client.send('Network.setCacheDisabled', { cacheDisabled: true });24    await page.waitFor(5000);25    await browser.close();26})();

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.