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        const 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 */57class AWSIoTMetrics {58    constructor() {59        /**60         * Name of the library61         */62        this.libraryName = exports.SDK_NAME;63        this.metadata = new Array;64    }65}66exports.AWSIoTMetrics = AWSIoTMetrics;67/** @internal */68exports.DEFAULT_KEEP_ALIVE = 1200;69/** @internal */70exports.MAXIMUM_VARIABLE_LENGTH_INTEGER = 268435455;71/** @internal */72exports.MAXIMUM_PACKET_SIZE = 5 + exports.MAXIMUM_VARIABLE_LENGTH_INTEGER;73/** @internal */74exports.DEFAULT_RECEIVE_MAXIMUM = 65535;75/**76 * Wrapper class containing a one-use singleton handle that can be used to trigger sending the acknowledgement (Puback in77 * QoS 1, Pubrec in QoS 2) packet for an incoming publish.78 */79class PublishAcknowledgementHandleWrapper {80    constructor(handle) {81        this.ackHandle = handle;82    }83    /**84     * Attempt to take the acknowledgement handle held by the wrapper.  This will only succeed for the first caller;85     * after the initial call, null will be returned.  By taking the handle, the caller assumes responsibility86     * for sending the acknowledgement packet associated with the incoming publish packet.  Failing to trigger the87     * acknowledgement will cause the broker to potentially re-send the publish.88     */89    acquireHandle() {90        let handle = this.ackHandle;91        this.ackHandle = null;92        return handle;93    }94}95exports.PublishAcknowledgementHandleWrapper = PublishAcknowledgementHandleWrapper;96function movePublishAcknowledgementHandleWrapper(wrapper, compositionFunctor) {97    if (wrapper) {98        let handle = wrapper.acquireHandle();99        if (compositionFunctor && handle) {100            let interiorHandle = handle;101            handle = new PublishAcknowledgementHandle(() => {102                interiorHandle.invokeAcknowledgement();103                compositionFunctor();104            });105        }106        return new PublishAcknowledgementHandleWrapper(handle);107    }108    return undefined;109}110/** @internal */111function emitAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {112    ackHandleWrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);113    if (ackHandleWrapper) {114        ackEventPayload[wrapperFieldName] = ackHandleWrapper;115        emitter.emitWithCallback(ackEvent, () => {116            if (ackHandleWrapper) {117                let handle = ackHandleWrapper.acquireHandle();118                if (handle) {119                    // Even if corked, all listeners have had a chance to react to the event120                    // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.121                    handle.invokeAcknowledgement();122                }123            }124        }, ackEventPayload);125    }126    else {127        emitter.emit(ackEvent, ackEventPayload);128    }129}130exports.emitAcknowledgeableEvent = emitAcknowledgeableEvent;131/** @internal */132function queueAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {133    let wrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);134    queueMicrotask(() => {135        if (wrapper) {136            ackEventPayload[wrapperFieldName] = wrapper;137            emitter.emitWithCallback(ackEvent, () => {138                if (wrapper) {139                    let handle = wrapper.acquireHandle();140                    if (handle) {141                        // Even if corked, all listeners have had a chance to react to the event142                        // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.143                        handle.invokeAcknowledgement();144                    }145                }146            }, ackEventPayload);147        }148        else {149            emitter.emit(ackEvent, ackEventPayload);150        }151    });152}153exports.queueAcknowledgeableEvent = queueAcknowledgeableEvent;154/**155 * Object that allows the holder to trigger the acknowledgement for an associated publish packet.156 */157class PublishAcknowledgementHandle {158    constructor(acknowledgementFunction) {159        this.acknowledgementFunction = acknowledgementFunction;160    }161    /**162     * trigger the acknowledgement for an associated Publish packet163     */164    invokeAcknowledgement() {165        let acknowledgementFunction = this.acknowledgementFunction;166        this.acknowledgementFunction = undefined;167        if (acknowledgementFunction) {168            acknowledgementFunction();169        }170    }171}172exports.PublishAcknowledgementHandle = PublishAcknowledgementHandle;173//# sourceMappingURL=mqtt_shared.js.map