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.isValidTopic = exports.isValidTopicFilter = exports.DEFAULT_KEEP_ALIVE = exports.normalize_payload_to_buffer = exports.normalize_payload = void 0;8/**9 * Converts payload to Buffer or string regardless of the supplied type10 * @param payload The payload to convert11 * @internal12 */13function normalize_payload(payload) {14    if (payload instanceof Buffer) {15        // pass Buffer through16        return payload;17    }18    if (typeof payload === 'string') {19        // pass string through20        return payload;21    }22    if (ArrayBuffer.isView(payload)) {23        // return Buffer with view upon the same bytes (no copy)24        const view = payload;25        return Buffer.from(view.buffer, view.byteOffset, view.byteLength);26    }27    if (payload instanceof ArrayBuffer) {28        // return Buffer with view upon the same bytes (no copy)29        return Buffer.from(payload);30    }31    if (typeof payload === 'object') {32        // Convert Object to JSON string33        return JSON.stringify(payload);34    }35    if (!payload) {36        return "";37    }38    throw new TypeError("payload parameter must be a string, object, or DataView.");39}40exports.normalize_payload = normalize_payload;41/**42 * Converts payload to Buffer only, regardless of the supplied type43 * @param payload The payload to convert44 * @internal45 */46function normalize_payload_to_buffer(payload) {47    let normalized = normalize_payload(payload);48    if (typeof normalized === 'string') {49        // pass string through50        return Buffer.from(normalized);51    }52    return normalized;53}54exports.normalize_payload_to_buffer = normalize_payload_to_buffer;55/** @internal */56exports.DEFAULT_KEEP_ALIVE = 1200;57function isValidTopicInternal(topic, isFilter) {58    if (topic.length === 0 || topic.length > 65535) {59        return false;60    }61    let sawHash = false;62    for (let segment of topic.split('/')) {63        if (sawHash) {64            return false;65        }66        if (segment.length === 0) {67            continue;68        }69        if (segment.includes("+")) {70            if (!isFilter) {71                return false;72            }73            if (segment.length > 1) {74                return false;75            }76        }77        if (segment.includes("#")) {78            if (!isFilter) {79                return false;80            }81            if (segment.length > 1) {82                return false;83            }84            sawHash = true;85        }86    }87    return true;88}89function isValidTopicFilter(topicFilter) {90    if (typeof (topicFilter) !== 'string') {91        return false;92    }93    let topicFilterAsString = topicFilter;94    return isValidTopicInternal(topicFilterAsString, true);95}96exports.isValidTopicFilter = isValidTopicFilter;97function isValidTopic(topic) {98    if (typeof (topic) !== 'string') {99        return false;100    }101    let topicAsString = topic;102    return isValidTopicInternal(topicAsString, false);103}104exports.isValidTopic = isValidTopic;105/**106 * Wrapper class containing a one-use singleton handle that can be used to trigger sending the acknowledgement (Puback in107 * QoS 1, Pubrec in QoS 2) packet for an incoming publish.108 */109class PublishAcknowledgementHandleWrapper {110    constructor(handle) {111        this.ackHandle = handle;112    }113    /**114     * Attempt to take the acknowledgement handle held by the wrapper.  This will only succeed for the first caller;115     * after the initial call, null will be returned.  By taking the handle, the caller assumes responsibility116     * for sending the acknowledgement packet associated with the incoming publish packet.  Failing to trigger the117     * acknowledgement will cause the broker to potentially re-send the publish.118     */119    acquireHandle() {120        let handle = this.ackHandle;121        this.ackHandle = null;122        return handle;123    }124}125exports.PublishAcknowledgementHandleWrapper = PublishAcknowledgementHandleWrapper;126function movePublishAcknowledgementHandleWrapper(wrapper, compositionFunctor) {127    if (wrapper) {128        let handle = wrapper.acquireHandle();129        if (compositionFunctor && handle) {130            let interiorHandle = handle;131            handle = new PublishAcknowledgementHandle(() => {132                interiorHandle.invokeAcknowledgement();133                compositionFunctor();134            });135        }136        return new PublishAcknowledgementHandleWrapper(handle);137    }138    return undefined;139}140/** @internal */141function emitAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {142    ackHandleWrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);143    if (ackHandleWrapper) {144        ackEventPayload[wrapperFieldName] = ackHandleWrapper;145        emitter.emitWithCallback(ackEvent, () => {146            if (ackHandleWrapper) {147                let handle = ackHandleWrapper.acquireHandle();148                if (handle) {149                    // Even if corked, all listeners have had a chance to react to the event150                    // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.151                    handle.invokeAcknowledgement();152                }153            }154        }, ackEventPayload);155    }156    else {157        emitter.emit(ackEvent, ackEventPayload);158    }159}160exports.emitAcknowledgeableEvent = emitAcknowledgeableEvent;161/** @internal */162function queueAcknowledgeableEvent(emitter, ackEvent, ackEventPayload, wrapperFieldName, ackHandleWrapper, compositionFunctor) {163    let wrapper = movePublishAcknowledgementHandleWrapper(ackHandleWrapper, compositionFunctor);164    queueMicrotask(() => {165        if (wrapper) {166            ackEventPayload[wrapperFieldName] = wrapper;167            emitter.emitWithCallback(ackEvent, () => {168                if (wrapper) {169                    let handle = wrapper.acquireHandle();170                    if (handle) {171                        // Even if corked, all listeners have had a chance to react to the event172                        // and acquire the acknowledgement handle if they wanted to.  If no one did so, then we do it ourselves.173                        handle.invokeAcknowledgement();174                    }175                }176            }, ackEventPayload);177        }178        else {179            emitter.emit(ackEvent, ackEventPayload);180        }181    });182}183exports.queueAcknowledgeableEvent = queueAcknowledgeableEvent;184/**185 * Object that allows the holder to trigger the acknowledgement for an associated publish packet.186 */187class PublishAcknowledgementHandle {188    constructor(acknowledgementFunction) {189        this.acknowledgementFunction = acknowledgementFunction;190    }191    /**192     * trigger the acknowledgement for an associated Publish packet193     */194    invokeAcknowledgement() {195        let acknowledgementFunction = this.acknowledgementFunction;196        this.acknowledgementFunction = undefined;197        if (acknowledgementFunction) {198            acknowledgementFunction();199        }200    }201}202exports.PublishAcknowledgementHandle = PublishAcknowledgementHandle;203//# sourceMappingURL=mqtt_shared.js.map