File Explorer

1"use strict";2/*3 * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.4 * SPDX-License-Identifier: Apache-2.0.5 */6var __values = (this && this.__values) || function(o) {7    var s = typeof Symbol === "function" && Symbol.iterator, m = s && o[s], i = 0;8    if (m) return m.call(o);9    if (o && typeof o.length === "number") return {10        next: function () {11            if (o && i >= o.length) o = void 0;12            return { value: o && o[i++], done: !o };13        }14    };15    throw new TypeError(s ? "Object is not iterable." : "Symbol.iterator is not defined.");16};17Object.defineProperty(exports, "__esModule", { value: true });18exports.PublishAcknowledgementHandle = exports.queueAcknowledgeableEvent = exports.emitAcknowledgeableEvent = exports.PublishAcknowledgementHandleWrapper = exports.isValidTopic = exports.isValidTopicFilter = exports.DEFAULT_KEEP_ALIVE = exports.normalize_payload_to_buffer = exports.normalize_payload = void 0;19/**20 * Converts payload to Buffer or string regardless of the supplied type21 * @param payload The payload to convert22 * @internal23 */24function normalize_payload(payload) {25    if (payload instanceof Buffer) {26        // pass Buffer through27        return payload;28    }29    if (typeof payload === 'string') {30        // pass string through31        return payload;32    }33    if (ArrayBuffer.isView(payload)) {34        // return Buffer with view upon the same bytes (no copy)35        var view = payload;36        return Buffer.from(view.buffer, view.byteOffset, view.byteLength);37    }38    if (payload instanceof ArrayBuffer) {39        // return Buffer with view upon the same bytes (no copy)40        return Buffer.from(payload);41    }42    if (typeof payload === 'object') {43        // Convert Object to JSON string44        return JSON.stringify(payload);45    }46    if (!payload) {47        return "";48    }49    throw new TypeError("payload parameter must be a string, object, or DataView.");50}51exports.normalize_payload = normalize_payload;52/**53 * Converts payload to Buffer only, regardless of the supplied type54 * @param payload The payload to convert55 * @internal56 */57function normalize_payload_to_buffer(payload) {58    var normalized = normalize_payload(payload);59    if (typeof normalized === 'string') {60        // pass string through61        return Buffer.from(normalized);62    }63    return normalized;64}65exports.normalize_payload_to_buffer = normalize_payload_to_buffer;66/** @internal */67exports.DEFAULT_KEEP_ALIVE = 1200;68function isValidTopicInternal(topic, isFilter) {69    var e_1, _a;70    if (topic.length === 0 || topic.length > 65535) {71        return false;72    }73    var sawHash = false;74    try {75        for (var _b = __values(topic.split('/')), _c = _b.next(); !_c.done; _c = _b.next()) {76            var segment = _c.value;77            if (sawHash) {78                return false;79            }80            if (segment.length === 0) {81                continue;82            }83            if (segment.includes("+")) {84                if (!isFilter) {85                    return false;86                }87                if (segment.length > 1) {88                    return false;89                }90            }91            if (segment.includes("#")) {92                if (!isFilter) {93                    return false;94                }95                if (segment.length > 1) {96                    return false;97                }98                sawHash = true;99            }100        }101    }102    catch (e_1_1) { e_1 = { error: e_1_1 }; }103    finally {104        try {105            if (_c && !_c.done && (_a = _b.return)) _a.call(_b);106        }107        finally { if (e_1) throw e_1.error; }108    }109    return true;110}111function isValidTopicFilter(topicFilter) {112    if (typeof (topicFilter) !== 'string') {113        return false;114    }115    var topicFilterAsString = topicFilter;116    return isValidTopicInternal(topicFilterAsString, true);117}118exports.isValidTopicFilter = isValidTopicFilter;119function isValidTopic(topic) {120    if (typeof (topic) !== 'string') {121        return false;122    }123    var topicAsString = topic;124    return isValidTopicInternal(topicAsString, false);125}126exports.isValidTopic = isValidTopic;127/**128 * Wrapper class containing a one-use singleton handle that can be used to trigger sending the acknowledgement (Puback in129 * QoS 1, Pubrec in QoS 2) packet for an incoming publish.130 */131var PublishAcknowledgementHandleWrapper = /** @class */ (function () {132    function PublishAcknowledgementHandleWrapper(handle) {133        this.ackHandle = handle;134    }135    /**136     * Attempt to take the acknowledgement handle held by the wrapper.  This will only succeed for the first caller;137     * after the initial call, null will be returned.  By taking the handle, the caller assumes responsibility138     * for sending the acknowledgement packet associated with the incoming publish packet.  Failing to trigger the139     * acknowledgement will cause the broker to potentially re-send the publish.140     */141    PublishAcknowledgementHandleWrapper.prototype.acquireHandle = function () {142        var handle = this.ackHandle;143        this.ackHandle = null;144        return handle;145    };146    return PublishAcknowledgementHandleWrapper;147}());148exports.PublishAcknowledgementHandleWrapper = PublishAcknowledgementHandleWrapper;149function movePublishAcknowledgementHandleWrapper(wrapper, compositionFunctor) {150    if (wrapper) {151        var handle = wrapper.acquireHandle();152        if (compositionFunctor && handle) {153            var interiorHandle_1 = handle;154            handle = new PublishAcknowledgementHandle(function () {155                interiorHandle_1.invokeAcknowledgement();156                compositionFunctor();157            });158        }159        return new PublishAcknowledgementHandleWrapper(handle);160    }161    return undefined;162}163/** @internal */164function emitAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {165    ackHandleWrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);166    if (ackHandleWrapper) {167        ackEventPayload[wrapperFieldName] = ackHandleWrapper;168        emitter.emitWithCallback(ackEvent, function () {169            if (ackHandleWrapper) {170                var handle = ackHandleWrapper.acquireHandle();171                if (handle) {172                    // Even if corked, all listeners have had a chance to react to the event173                    // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.174                    handle.invokeAcknowledgement();175                }176            }177        }, ackEventPayload);178    }179    else {180        emitter.emit(ackEvent, ackEventPayload);181    }182}183exports.emitAcknowledgeableEvent = emitAcknowledgeableEvent;184/** @internal */185function queueAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {186    var wrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);187    queueMicrotask(function () {188        if (wrapper) {189            ackEventPayload[wrapperFieldName] = wrapper;190            emitter.emitWithCallback(ackEvent, function () {191                if (wrapper) {192                    var handle = wrapper.acquireHandle();193                    if (handle) {194                        // Even if corked, all listeners have had a chance to react to the event195                        // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.196                        handle.invokeAcknowledgement();197                    }198                }199            }, ackEventPayload);200        }201        else {202            emitter.emit(ackEvent, ackEventPayload);203        }204    });205}206exports.queueAcknowledgeableEvent = queueAcknowledgeableEvent;207/**208 * Object that allows the holder to trigger the acknowledgement for an associated publish packet.209 */210var PublishAcknowledgementHandle = /** @class */ (function () {211    function PublishAcknowledgementHandle(acknowledgementFunction) {212        this.acknowledgementFunction = acknowledgementFunction;213    }214    /**215     * trigger the acknowledgement for an associated Publish packet216     */217    PublishAcknowledgementHandle.prototype.invokeAcknowledgement = function () {218        var acknowledgementFunction = this.acknowledgementFunction;219        this.acknowledgementFunction = undefined;220        if (acknowledgementFunction) {221            acknowledgementFunction();222        }223    };224    return PublishAcknowledgementHandle;225}());226exports.PublishAcknowledgementHandle = PublishAcknowledgementHandle;227//# sourceMappingURL=mqtt_shared.js.map