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 */6Object.defineProperty(exports, "__esModule", { value: true });7exports.PublishAcknowledgementHandle = exports.queueAcknowledgeableEvent = exports.emitAcknowledgeableEvent = exports.PublishAcknowledgementHandleWrapper = exports.DEFAULT_RECEIVE_MAXIMUM = exports.MAXIMUM_PACKET_SIZE = exports.MAXIMUM_VARIABLE_LENGTH_INTEGER = exports.DEFAULT_KEEP_ALIVE = exports.AWSIoTMetrics = exports.SDK_NAME = exports.normalize_payload = exports.ProtocolMode = void 0;8/**9 * @internal10 */11var ProtocolMode;12(function (ProtocolMode) {13    ProtocolMode[ProtocolMode["Mqtt311"] = 0] = "Mqtt311";14    ProtocolMode[ProtocolMode["Mqtt5"] = 1] = "Mqtt5";15})(ProtocolMode = exports.ProtocolMode || (exports.ProtocolMode = {}));16/**17 * Converts payload to Buffer or string regardless of the supplied type18 * @param payload The payload to convert19 * @internal20 */21function normalize_payload(payload) {22    if (payload instanceof Buffer) {23        // pass Buffer through24        return payload;25    }26    if (typeof payload === 'string') {27        // pass string through28        return payload;29    }30    if (ArrayBuffer.isView(payload)) {31        // return Buffer with view upon the same bytes (no copy)32        var view = payload;33        return Buffer.from(view.buffer, view.byteOffset, view.byteLength);34    }35    if (payload instanceof ArrayBuffer) {36        // return Buffer with view upon the same bytes (no copy)37        return Buffer.from(payload);38    }39    if (typeof payload === 'object') {40        // Convert Object to JSON string41        return JSON.stringify(payload);42    }43    if (!payload) {44        return "";45    }46    throw new TypeError("payload parameter must be a string, object, or DataView.");47}48exports.normalize_payload = normalize_payload;49/**50 * SDK name used for metrics and identification51 * @internal52 */53exports.SDK_NAME = "IoTDeviceSDK/JS";54/**55 * IoT Device SDK Metrics Structure56 */57var AWSIoTMetrics = /** @class */ (function () {58    function AWSIoTMetrics() {59        /**60         * Name of the library61         */62        this.libraryName = exports.SDK_NAME;63        this.metadata = new Array;64    }65    return AWSIoTMetrics;66}());67exports.AWSIoTMetrics = AWSIoTMetrics;68/** @internal */69exports.DEFAULT_KEEP_ALIVE = 1200;70/** @internal */71exports.MAXIMUM_VARIABLE_LENGTH_INTEGER = 268435455;72/** @internal */73exports.MAXIMUM_PACKET_SIZE = 5 + exports.MAXIMUM_VARIABLE_LENGTH_INTEGER;74/** @internal */75exports.DEFAULT_RECEIVE_MAXIMUM = 65535;76/**77 * Wrapper class containing a one-use singleton handle that can be used to trigger sending the acknowledgement (Puback in78 * QoS 1, Pubrec in QoS 2) packet for an incoming publish.79 */80var PublishAcknowledgementHandleWrapper = /** @class */ (function () {81    function PublishAcknowledgementHandleWrapper(handle) {82        this.ackHandle = handle;83    }84    /**85     * Attempt to take the acknowledgement handle held by the wrapper.  This will only succeed for the first caller;86     * after the initial call, null will be returned.  By taking the handle, the caller assumes responsibility87     * for sending the acknowledgement packet associated with the incoming publish packet.  Failing to trigger the88     * acknowledgement will cause the broker to potentially re-send the publish.89     */90    PublishAcknowledgementHandleWrapper.prototype.acquireHandle = function () {91        var handle = this.ackHandle;92        this.ackHandle = null;93        return handle;94    };95    return PublishAcknowledgementHandleWrapper;96}());97exports.PublishAcknowledgementHandleWrapper = PublishAcknowledgementHandleWrapper;98function movePublishAcknowledgementHandleWrapper(wrapper, compositionFunctor) {99    if (wrapper) {100        var handle = wrapper.acquireHandle();101        if (compositionFunctor && handle) {102            var interiorHandle_1 = handle;103            handle = new PublishAcknowledgementHandle(function () {104                interiorHandle_1.invokeAcknowledgement();105                compositionFunctor();106            });107        }108        return new PublishAcknowledgementHandleWrapper(handle);109    }110    return undefined;111}112/** @internal */113function emitAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {114    ackHandleWrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);115    if (ackHandleWrapper) {116        ackEventPayload[wrapperFieldName] = ackHandleWrapper;117        emitter.emitWithCallback(ackEvent, function () {118            if (ackHandleWrapper) {119                var handle = ackHandleWrapper.acquireHandle();120                if (handle) {121                    // Even if corked, all listeners have had a chance to react to the event122                    // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.123                    handle.invokeAcknowledgement();124                }125            }126        }, ackEventPayload);127    }128    else {129        emitter.emit(ackEvent, ackEventPayload);130    }131}132exports.emitAcknowledgeableEvent = emitAcknowledgeableEvent;133/** @internal */134function queueAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {135    var wrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);136    queueMicrotask(function () {137        if (wrapper) {138            ackEventPayload[wrapperFieldName] = wrapper;139            emitter.emitWithCallback(ackEvent, function () {140                if (wrapper) {141                    var handle = wrapper.acquireHandle();142                    if (handle) {143                        // Even if corked, all listeners have had a chance to react to the event144                        // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.145                        handle.invokeAcknowledgement();146                    }147                }148            }, ackEventPayload);149        }150        else {151            emitter.emit(ackEvent, ackEventPayload);152        }153    });154}155exports.queueAcknowledgeableEvent = queueAcknowledgeableEvent;156/**157 * Object that allows the holder to trigger the acknowledgement for an associated publish packet.158 */159var PublishAcknowledgementHandle = /** @class */ (function () {160    function PublishAcknowledgementHandle(acknowledgementFunction) {161        this.acknowledgementFunction = acknowledgementFunction;162    }163    /**164     * trigger the acknowledgement for an associated Publish packet165     */166    PublishAcknowledgementHandle.prototype.invokeAcknowledgement = function () {167        var acknowledgementFunction = this.acknowledgementFunction;168        this.acknowledgementFunction = undefined;169        if (acknowledgementFunction) {170            acknowledgementFunction();171        }172    };173    return PublishAcknowledgementHandle;174}());175exports.PublishAcknowledgementHandle = PublishAcknowledgementHandle;176//# sourceMappingURL=mqtt_shared.js.map