File Explorer

1"use strict";2/**3 * @packageDocumentation4 * @module mqtt55 */6var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {7    if (k2 === undefined) k2 = k;8    var desc = Object.getOwnPropertyDescriptor(m, k);9    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {10      desc = { enumerable: true, get: function() { return m[k]; } };11    }12    Object.defineProperty(o, k2, desc);13}) : (function(o, m, k, k2) {14    if (k2 === undefined) k2 = k;15    o[k2] = m[k];16}));17var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {18    Object.defineProperty(o, "default", { enumerable: true, value: v });19}) : function(o, v) {20    o["default"] = v;21});22var __importStar = (this && this.__importStar) || function (mod) {23    if (mod && mod.__esModule) return mod;24    var result = {};25    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);26    __setModuleDefault(result, mod);27    return result;28};29var __read = (this && this.__read) || function (o, n) {30    var m = typeof Symbol === "function" && o[Symbol.iterator];31    if (!m) return o;32    var i = m.call(o), r, ar = [], e;33    try {34        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);35    }36    catch (error) { e = { error: error }; }37    finally {38        try {39            if (r && !r.done && (m = i["return"])) m.call(i);40        }41        finally { if (e) throw e.error; }42    }43    return ar;44};45var __values = (this && this.__values) || function(o) {46    var s = typeof Symbol === "function" && Symbol.iterator, m = s && o[s], i = 0;47    if (m) return m.call(o);48    if (o && typeof o.length === "number") return {49        next: function () {50            if (o && i >= o.length) o = void 0;51            return { value: o && o[i++], done: !o };52        }53    };54    throw new TypeError(s ? "Object is not iterable." : "Symbol.iterator is not defined.");55};56Object.defineProperty(exports, "__esModule", { value: true });57exports.transform_mqtt_js_unsuback_to_crt_unsuback = exports.transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options = exports.transform_mqtt_js_puback_to_crt_puback = exports.transform_mqtt_js_publish_to_crt_publish = exports.transform_crt_publish_to_mqtt_js_publish_options = exports.transform_mqtt_js_subscription_grants_to_crt_suback = exports.transform_mqtt_js_suback_to_crt_suback = exports.transform_crt_subscribe_to_mqtt_js_subscribe_options = exports.transform_crt_subscribe_to_mqtt_js_subscription_map = exports.transform_mqtt_js_disconnect_to_crt_disconnect = exports.transform_crt_disconnect_to_mqtt_js_disconnect = exports.transform_mqtt_js_user_properties_to_crt_user_properties = exports.transform_crt_user_properties_to_mqtt_js_user_properties = exports.create_mqtt_js_client_config_from_crt_client_config = exports.compute_mqtt_js_reconnect_delay_from_crt_max_delay = exports.getOrderedReconnectDelayBounds = exports.create_negotiated_settings = exports.transform_mqtt_js_connack_to_crt_connack = exports.DEFAULT_MIN_CONNECTED_TIME_TO_RESET_RECONNECT_DELAY_MS = exports.DEFAULT_MAX_RECONNECT_DELAY_MS = exports.DEFAULT_MIN_RECONNECT_DELAY_MS = exports.DEFAULT_CONNECT_TIMEOUT_MS = exports.DEFAULT_RECEIVE_MAXIMUM = exports.MAXIMUM_PACKET_SIZE = exports.MAXIMUM_VARIABLE_LENGTH_INTEGER = void 0;58var mqtt_shared = __importStar(require("../common/mqtt_shared"));59var mqtt5 = __importStar(require("./mqtt5"));60var utils = __importStar(require("../common/utils"));61var error_1 = require("./error");62exports.MAXIMUM_VARIABLE_LENGTH_INTEGER = 268435455;63exports.MAXIMUM_PACKET_SIZE = 5 + exports.MAXIMUM_VARIABLE_LENGTH_INTEGER;64exports.DEFAULT_RECEIVE_MAXIMUM = 65535;65exports.DEFAULT_CONNECT_TIMEOUT_MS = 30000;66exports.DEFAULT_MIN_RECONNECT_DELAY_MS = 1000;67exports.DEFAULT_MAX_RECONNECT_DELAY_MS = 120000;68exports.DEFAULT_MIN_CONNECTED_TIME_TO_RESET_RECONNECT_DELAY_MS = 30000;69/** @internal */70function transform_mqtt_js_connack_to_crt_connack(mqtt_js_connack) {71    var _a, _b, _c, _d, _e, _f, _g, _h, _j, _k, _l, _m, _o, _p, _q, _r;72    if (mqtt_js_connack == null || mqtt_js_connack == undefined) {73        throw new error_1.CrtError("transform_mqtt_js_connack_to_crt_connack: mqtt_js_connack not defined");74    }75    var connack = {76        type: mqtt5.PacketType.Connack,77        sessionPresent: mqtt_js_connack.sessionPresent,78        reasonCode: (_a = mqtt_js_connack.reasonCode) !== null && _a !== void 0 ? _a : mqtt5.ConnectReasonCode.Success79    };80    utils.set_defined_property(connack, "sessionExpiryInterval", (_b = mqtt_js_connack.properties) === null || _b === void 0 ? void 0 : _b.sessionExpiryInterval);81    utils.set_defined_property(connack, "receiveMaximum", (_c = mqtt_js_connack.properties) === null || _c === void 0 ? void 0 : _c.receiveMaximum);82    utils.set_defined_property(connack, "maximumQos", (_d = mqtt_js_connack.properties) === null || _d === void 0 ? void 0 : _d.maximumQoS);83    utils.set_defined_property(connack, "retainAvailable", (_e = mqtt_js_connack.properties) === null || _e === void 0 ? void 0 : _e.retainAvailable);84    utils.set_defined_property(connack, "maximumPacketSize", (_f = mqtt_js_connack.properties) === null || _f === void 0 ? void 0 : _f.maximumPacketSize);85    utils.set_defined_property(connack, "assignedClientIdentifier", (_g = mqtt_js_connack.properties) === null || _g === void 0 ? void 0 : _g.assignedClientIdentifier);86    utils.set_defined_property(connack, "topicAliasMaximum", (_h = mqtt_js_connack.properties) === null || _h === void 0 ? void 0 : _h.topicAliasMaximum);87    utils.set_defined_property(connack, "reasonString", (_j = mqtt_js_connack.properties) === null || _j === void 0 ? void 0 : _j.reasonString);88    utils.set_defined_property(connack, "userProperties", transform_mqtt_js_user_properties_to_crt_user_properties((_k = mqtt_js_connack.properties) === null || _k === void 0 ? void 0 : _k.userProperties));89    utils.set_defined_property(connack, "wildcardSubscriptionsAvailable", (_l = mqtt_js_connack.properties) === null || _l === void 0 ? void 0 : _l.wildcardSubscriptionAvailable);90    utils.set_defined_property(connack, "subscriptionIdentifiersAvailable", (_m = mqtt_js_connack.properties) === null || _m === void 0 ? void 0 : _m.subscriptionIdentifiersAvailable);91    utils.set_defined_property(connack, "sharedSubscriptionsAvailable", (_o = mqtt_js_connack.properties) === null || _o === void 0 ? void 0 : _o.sharedSubscriptionAvailable);92    utils.set_defined_property(connack, "serverKeepAlive", (_p = mqtt_js_connack.properties) === null || _p === void 0 ? void 0 : _p.serverKeepAlive);93    utils.set_defined_property(connack, "responseInformation", (_q = mqtt_js_connack.properties) === null || _q === void 0 ? void 0 : _q.responseInformation);94    utils.set_defined_property(connack, "serverReference", (_r = mqtt_js_connack.properties) === null || _r === void 0 ? void 0 : _r.serverReference);95    return connack;96}97exports.transform_mqtt_js_connack_to_crt_connack = transform_mqtt_js_connack_to_crt_connack;98/** @internal */99function create_negotiated_settings(config, connack) {100    var _a, _b, _c, _d, _e, _f, _g, _h, _j, _k, _l, _m, _o, _p, _q, _r, _s, _t, _u, _v, _w;101    if (config == null || config == undefined) {102        throw new error_1.CrtError("create_negotiated_settings: config not defined");103    }104    if (connack == null || connack == undefined) {105        throw new error_1.CrtError("create_negotiated_settings: connack not defined");106    }107    return {108        maximumQos: Math.min((_a = connack.maximumQos) !== null && _a !== void 0 ? _a : mqtt5.QoS.ExactlyOnce, mqtt5.QoS.AtLeastOnce),109        sessionExpiryInterval: (_d = (_b = connack.sessionExpiryInterval) !== null && _b !== void 0 ? _b : (_c = config.connectProperties) === null || _c === void 0 ? void 0 : _c.sessionExpiryIntervalSeconds) !== null && _d !== void 0 ? _d : 0,110        receiveMaximumFromServer: (_e = connack.receiveMaximum) !== null && _e !== void 0 ? _e : exports.DEFAULT_RECEIVE_MAXIMUM,111        maximumPacketSizeToServer: (_f = connack.maximumPacketSize) !== null && _f !== void 0 ? _f : exports.MAXIMUM_PACKET_SIZE,112        topicAliasMaximumToServer: Math.min((_h = (_g = config.topicAliasingOptions) === null || _g === void 0 ? void 0 : _g.outboundCacheMaxSize) !== null && _h !== void 0 ? _h : 0, (_j = connack.topicAliasMaximum) !== null && _j !== void 0 ? _j : 0),113        topicAliasMaximumToClient: (_l = (_k = config.topicAliasingOptions) === null || _k === void 0 ? void 0 : _k.inboundCacheMaxSize) !== null && _l !== void 0 ? _l : 0,114        serverKeepAlive: (_p = (_m = connack.serverKeepAlive) !== null && _m !== void 0 ? _m : (_o = config.connectProperties) === null || _o === void 0 ? void 0 : _o.keepAliveIntervalSeconds) !== null && _p !== void 0 ? _p : mqtt_shared.DEFAULT_KEEP_ALIVE,115        retainAvailable: (_q = connack.retainAvailable) !== null && _q !== void 0 ? _q : true,116        wildcardSubscriptionsAvailable: (_r = connack.wildcardSubscriptionsAvailable) !== null && _r !== void 0 ? _r : true,117        subscriptionIdentifiersAvailable: (_s = connack.subscriptionIdentifiersAvailable) !== null && _s !== void 0 ? _s : true,118        sharedSubscriptionsAvailable: (_t = connack.sharedSubscriptionsAvailable) !== null && _t !== void 0 ? _t : true,119        rejoinedSession: connack.sessionPresent,120        clientId: (_w = (_u = connack.assignedClientIdentifier) !== null && _u !== void 0 ? _u : (_v = config.connectProperties) === null || _v === void 0 ? void 0 : _v.clientId) !== null && _w !== void 0 ? _w : ""121    };122}123exports.create_negotiated_settings = create_negotiated_settings;124/** @internal */125function create_mqtt_js_will_from_crt_config(connectProperties) {126    var _a, _b;127    if (!connectProperties || !connectProperties.will) {128        return undefined;129    }130    var crtWill = connectProperties.will;131    var hasWillProperties = false;132    var willProperties = {};133    hasWillProperties = utils.set_defined_property(willProperties, "willDelayInterval", connectProperties.willDelayIntervalSeconds) || hasWillProperties;134    if (crtWill.payloadFormat !== undefined) {135        hasWillProperties = utils.set_defined_property(willProperties, "payloadFormatIndicator", crtWill.payloadFormat == mqtt5.PayloadFormatIndicator.Utf8) || hasWillProperties;136    }137    hasWillProperties = utils.set_defined_property(willProperties, "messageExpiryInterval", crtWill.messageExpiryIntervalSeconds) || hasWillProperties;138    hasWillProperties = utils.set_defined_property(willProperties, "contentType", crtWill.contentType) || hasWillProperties;139    hasWillProperties = utils.set_defined_property(willProperties, "responseTopic", crtWill.responseTopic) || hasWillProperties;140    hasWillProperties = utils.set_defined_property(willProperties, "correlationData", crtWill.correlationData) || hasWillProperties;141    hasWillProperties = utils.set_defined_property(willProperties, "userProperties", transform_crt_user_properties_to_mqtt_js_user_properties(crtWill.userProperties)) || hasWillProperties;142    var will = {143        topic: crtWill.topicName,144        payload: (_a = crtWill.payload) !== null && _a !== void 0 ? _a : mqtt_shared.normalize_payload_to_buffer(""),145        qos: crtWill.qos,146        retain: (_b = crtWill.retain) !== null && _b !== void 0 ? _b : false147    };148    if (hasWillProperties) {149        will["properties"] = willProperties;150    }151    return will;152}153/** @internal */154function getOrderedReconnectDelayBounds(configMin, configMax) {155    var minDelay = Math.max(1, configMin !== null && configMin !== void 0 ? configMin : exports.DEFAULT_MIN_RECONNECT_DELAY_MS);156    var maxDelay = Math.max(1, configMax !== null && configMax !== void 0 ? configMax : exports.DEFAULT_MAX_RECONNECT_DELAY_MS);157    if (minDelay > maxDelay) {158        return [maxDelay, minDelay];159    }160    else {161        return [minDelay, maxDelay];162    }163}164exports.getOrderedReconnectDelayBounds = getOrderedReconnectDelayBounds;165/** @internal */166function should_mqtt_js_use_clean_start(session_behavior) {167    return session_behavior !== mqtt5.ClientSessionBehavior.RejoinPostSuccess && session_behavior !== mqtt5.ClientSessionBehavior.RejoinAlways;168}169/** @internal */170function compute_mqtt_js_reconnect_delay_from_crt_max_delay(maxReconnectDelayMs) {171    /*172     * This is an attempt to guarantee that the mqtt-js will never try to reconnect on its own and instead always173     * be controlled by our reconnection scheduler logic.174     */175    return maxReconnectDelayMs * 2 + 60000;176}177exports.compute_mqtt_js_reconnect_delay_from_crt_max_delay = compute_mqtt_js_reconnect_delay_from_crt_max_delay;178function validate_required_uint16(propertyName, value) {179    if (value < 0 || value > 65535) {180        throw new error_1.CrtError("Invalid value for property ".concat(propertyName, ": ") + value);181    }182}183function validate_optional_uint16(propertyName, value) {184    if (value !== undefined) {185        validate_required_uint16(propertyName, value);186    }187}188function validate_required_uint32(propertyName, value) {189    if (value < 0 || value >= 4294967296) {190        throw new error_1.CrtError("Invalid value for property ".concat(propertyName, ": ") + value);191    }192}193function validate_optional_uint32(propertyName, value) {194    if (value !== undefined) {195        validate_required_uint32(propertyName, value);196    }197}198function validate_required_nonnegative_uint32(propertyName, value) {199    if (value <= 0 || value >= 4294967296) {200        throw new error_1.CrtError("Invalid value for property ".concat(propertyName, ": ") + value);201    }202}203function validate_optional_nonnegative_uint32(propertyName, value) {204    if (value !== undefined) {205        validate_required_nonnegative_uint32(propertyName, value);206    }207}208function validate_mqtt5_client_config(crtConfig) {209    var _a, _b, _c, _d, _e, _f;210    if (crtConfig == null || crtConfig == undefined) {211        throw new error_1.CrtError("validate_mqtt5_client_config: crtConfig not defined");212    }213    validate_required_uint16("keepAliveIntervalSeconds", (_b = (_a = crtConfig.connectProperties) === null || _a === void 0 ? void 0 : _a.keepAliveIntervalSeconds) !== null && _b !== void 0 ? _b : 0);214    validate_optional_uint32("sessionExpiryIntervalSeconds", (_c = crtConfig.connectProperties) === null || _c === void 0 ? void 0 : _c.sessionExpiryIntervalSeconds);215    validate_optional_uint16("receiveMaximum", (_d = crtConfig.connectProperties) === null || _d === void 0 ? void 0 : _d.receiveMaximum);216    validate_optional_nonnegative_uint32("maximumPacketSizeBytes", (_e = crtConfig.connectProperties) === null || _e === void 0 ? void 0 : _e.maximumPacketSizeBytes);217    validate_optional_uint32("willDelayIntervalSeconds", (_f = crtConfig.connectProperties) === null || _f === void 0 ? void 0 : _f.willDelayIntervalSeconds);218}219/** @internal */220function create_mqtt_js_client_config_from_crt_client_config(crtConfig) {221    var _a, _b, _c, _d, _e, _f, _g, _h, _j, _k, _l, _m, _o, _p;222    validate_mqtt5_client_config(crtConfig);223    var _q = __read(getOrderedReconnectDelayBounds(crtConfig.minReconnectDelayMs, crtConfig.maxReconnectDelayMs), 2), _ = _q[0], maxDelay = _q[1];224    maxDelay = compute_mqtt_js_reconnect_delay_from_crt_max_delay(maxDelay);225    var mqttJsClientConfig = {226        protocolVersion: 5,227        keepalive: (_b = (_a = crtConfig.connectProperties) === null || _a === void 0 ? void 0 : _a.keepAliveIntervalSeconds) !== null && _b !== void 0 ? _b : mqtt_shared.DEFAULT_KEEP_ALIVE,228        connectTimeout: (_c = crtConfig.connectTimeoutMs) !== null && _c !== void 0 ? _c : exports.DEFAULT_CONNECT_TIMEOUT_MS,229        clean: should_mqtt_js_use_clean_start(crtConfig.sessionBehavior),230        reconnectPeriod: maxDelay,231        // @ts-ignore232        autoUseTopicAlias: false,233        // @ts-ignore234        autoAssignTopicAlias: false,235        queueQoSZero: false,236        transformWsUrl: undefined,237        resubscribe: false238    };239    var topic_aliasing_options = crtConfig.topicAliasingOptions;240    if (topic_aliasing_options) {241        switch ((_d = topic_aliasing_options.outboundBehavior) !== null && _d !== void 0 ? _d : mqtt5.OutboundTopicAliasBehaviorType.Default) {242            case mqtt5.OutboundTopicAliasBehaviorType.LRU:243                // @ts-ignore244                mqttJsClientConfig.autoUseTopicAlias = true;245                // @ts-ignore246                mqttJsClientConfig.autoAssignTopicAlias = true;247                break;248            case mqtt5.OutboundTopicAliasBehaviorType.Manual:249                // @ts-ignore250                mqttJsClientConfig.autoUseTopicAlias = true;251                break;252            default:253                break;254        }255    }256    /*257     * If you leave clientId undefined, mqtt-js will make up some weird thing for you, but the intent is that it258     * should pass the empty client id so that the server assigns you one.259     */260    utils.set_defined_property(mqttJsClientConfig, "clientId", (_f = (_e = crtConfig.connectProperties) === null || _e === void 0 ? void 0 : _e.clientId) !== null && _f !== void 0 ? _f : "");261    utils.set_defined_property(mqttJsClientConfig, "username", (_g = crtConfig.connectProperties) === null || _g === void 0 ? void 0 : _g.username);262    utils.set_defined_property(mqttJsClientConfig, "password", (_h = crtConfig.connectProperties) === null || _h === void 0 ? void 0 : _h.password);263    utils.set_defined_property(mqttJsClientConfig, "will", create_mqtt_js_will_from_crt_config(crtConfig.connectProperties));264    var hasProperties = false;265    var properties = {};266    hasProperties = utils.set_defined_property(properties, "sessionExpiryInterval", (_j = crtConfig.connectProperties) === null || _j === void 0 ? void 0 : _j.sessionExpiryIntervalSeconds) || hasProperties;267    hasProperties = utils.set_defined_property(properties, "receiveMaximum", (_k = crtConfig.connectProperties) === null || _k === void 0 ? void 0 : _k.receiveMaximum) || hasProperties;268    hasProperties = utils.set_defined_property(properties, "maximumPacketSize", (_l = crtConfig.connectProperties) === null || _l === void 0 ? void 0 : _l.maximumPacketSizeBytes) || hasProperties;269    hasProperties = utils.set_defined_property(properties, "requestResponseInformation", (_m = crtConfig.connectProperties) === null || _m === void 0 ? void 0 : _m.requestResponseInformation) || hasProperties;270    hasProperties = utils.set_defined_property(properties, "requestProblemInformation", (_o = crtConfig.connectProperties) === null || _o === void 0 ? void 0 : _o.requestProblemInformation) || hasProperties;271    hasProperties = utils.set_defined_property(properties, "userProperties", transform_crt_user_properties_to_mqtt_js_user_properties((_p = crtConfig.connectProperties) === null || _p === void 0 ? void 0 : _p.userProperties)) || hasProperties;272    if (hasProperties) {273        mqttJsClientConfig["properties"] = properties;274    }275    return mqttJsClientConfig;276}277exports.create_mqtt_js_client_config_from_crt_client_config = create_mqtt_js_client_config_from_crt_client_config;278/** @internal */279function transform_crt_user_properties_to_mqtt_js_user_properties(userProperties) {280    var e_1, _a;281    if (!userProperties) {282        return undefined;283    }284    /*285     * More restricted version of mqtt.UserProperties so that we can have type-checking but don't need to handle286     * the non-array case.287     */288    var mqttJsProperties = {};289    try {290        for (var userProperties_1 = __values(userProperties), userProperties_1_1 = userProperties_1.next(); !userProperties_1_1.done; userProperties_1_1 = userProperties_1.next()) {291            var property = userProperties_1_1.value;292            var key = property.name;293            if (!(key in mqttJsProperties)) {294                mqttJsProperties[key] = [];295            }296            mqttJsProperties[key].push(property.value);297        }298    }299    catch (e_1_1) { e_1 = { error: e_1_1 }; }300    finally {301        try {302            if (userProperties_1_1 && !userProperties_1_1.done && (_a = userProperties_1.return)) _a.call(userProperties_1);303        }304        finally { if (e_1) throw e_1.error; }305    }306    return mqttJsProperties;307}308exports.transform_crt_user_properties_to_mqtt_js_user_properties = transform_crt_user_properties_to_mqtt_js_user_properties;309/** @internal */310function transform_mqtt_js_user_properties_to_crt_user_properties(userProperties) {311    var e_2, _a, e_3, _b;312    if (!userProperties) {313        return undefined;314    }315    var crtProperties = undefined;316    try {317        for (var _c = __values(Object.entries(userProperties)), _d = _c.next(); !_d.done; _d = _c.next()) {318            var _e = __read(_d.value, 2), propName = _e[0], propValue = _e[1];319            var values = (typeof propValue === 'string') ? [propValue] : propValue;320            try {321                for (var values_1 = (e_3 = void 0, __values(values)), values_1_1 = values_1.next(); !values_1_1.done; values_1_1 = values_1.next()) {322                    var valueIter = values_1_1.value;323                    var propertyEntry = { name: propName, value: valueIter };324                    if (!crtProperties) {325                        crtProperties = [propertyEntry];326                    }327                    else {328                        crtProperties.push(propertyEntry);329                    }330                }331            }332            catch (e_3_1) { e_3 = { error: e_3_1 }; }333            finally {334                try {335                    if (values_1_1 && !values_1_1.done && (_b = values_1.return)) _b.call(values_1);336                }337                finally { if (e_3) throw e_3.error; }338            }339        }340    }341    catch (e_2_1) { e_2 = { error: e_2_1 }; }342    finally {343        try {344            if (_d && !_d.done && (_a = _c.return)) _a.call(_c);345        }346        finally { if (e_2) throw e_2.error; }347    }348    return crtProperties;349}350exports.transform_mqtt_js_user_properties_to_crt_user_properties = transform_mqtt_js_user_properties_to_crt_user_properties;351function validate_crt_disconnect(disconnect) {352    if (disconnect == null || disconnect == undefined) {353        throw new error_1.CrtError("validate_crt_disconnect: disconnect not defined");354    }355    validate_optional_uint32("sessionExpiryIntervalSeconds", disconnect.sessionExpiryIntervalSeconds);356}357/** @internal */358function transform_crt_disconnect_to_mqtt_js_disconnect(disconnect) {359    validate_crt_disconnect(disconnect);360    var properties = {};361    var propertiesValid = false;362    propertiesValid = utils.set_defined_property(properties, "sessionExpiryInterval", disconnect.sessionExpiryIntervalSeconds) || propertiesValid;363    propertiesValid = utils.set_defined_property(properties, "reasonString", disconnect.reasonString) || propertiesValid;364    propertiesValid = utils.set_defined_property(properties, "userProperties", transform_crt_user_properties_to_mqtt_js_user_properties(disconnect.userProperties)) || propertiesValid;365    propertiesValid = utils.set_defined_property(properties, "serverReference", disconnect.serverReference) || propertiesValid;366    var mqttJsDisconnect = {367        cmd: 'disconnect',368        reasonCode: disconnect.reasonCode369    };370    if (propertiesValid) {371        mqttJsDisconnect["properties"] = properties;372    }373    return mqttJsDisconnect;374}375exports.transform_crt_disconnect_to_mqtt_js_disconnect = transform_crt_disconnect_to_mqtt_js_disconnect;376/** @internal **/377function transform_mqtt_js_disconnect_to_crt_disconnect(disconnect) {378    var _a, _b, _c, _d, _e;379    if (disconnect == null || disconnect == undefined) {380        throw new error_1.CrtError("transform_mqtt_js_disconnect_to_crt_disconnect: disconnect not defined");381    }382    var crtDisconnect = {383        type: mqtt5.PacketType.Disconnect,384        reasonCode: (_a = disconnect.reasonCode) !== null && _a !== void 0 ? _a : mqtt5.DisconnectReasonCode.NormalDisconnection385    };386    utils.set_defined_property(crtDisconnect, "sessionExpiryIntervalSeconds", (_b = disconnect.properties) === null || _b === void 0 ? void 0 : _b.sessionExpiryInterval);387    utils.set_defined_property(crtDisconnect, "reasonString", (_c = disconnect.properties) === null || _c === void 0 ? void 0 : _c.reasonString);388    utils.set_defined_property(crtDisconnect, "userProperties", transform_mqtt_js_user_properties_to_crt_user_properties((_d = disconnect.properties) === null || _d === void 0 ? void 0 : _d.userProperties));389    utils.set_defined_property(crtDisconnect, "serverReference", (_e = disconnect.properties) === null || _e === void 0 ? void 0 : _e.serverReference);390    return crtDisconnect;391}392exports.transform_mqtt_js_disconnect_to_crt_disconnect = transform_mqtt_js_disconnect_to_crt_disconnect;393function validate_crt_subscribe(subscribe) {394    if (subscribe == null || subscribe == undefined) {395        throw new error_1.CrtError("validate_crt_subscribe: subscribe not defined");396    }397    validate_optional_uint32("subscriptionIdentifier", subscribe.subscriptionIdentifier);398}399/** @internal **/400function transform_crt_subscribe_to_mqtt_js_subscription_map(subscribe) {401    var e_4, _a;402    var _b, _c, _d;403    validate_crt_subscribe(subscribe);404    var subscriptionMap = {};405    try {406        for (var _e = __values(subscribe.subscriptions), _f = _e.next(); !_f.done; _f = _e.next()) {407            var subscription = _f.value;408            var mqttJsSub = {409                qos: subscription.qos,410                nl: (_b = subscription.noLocal) !== null && _b !== void 0 ? _b : false,411                rap: (_c = subscription.retainAsPublished) !== null && _c !== void 0 ? _c : false,412                rh: (_d = subscription.retainHandlingType) !== null && _d !== void 0 ? _d : mqtt5.RetainHandlingType.SendOnSubscribe413            };414            subscriptionMap[subscription.topicFilter] = mqttJsSub;415        }416    }417    catch (e_4_1) { e_4 = { error: e_4_1 }; }418    finally {419        try {420            if (_f && !_f.done && (_a = _e.return)) _a.call(_e);421        }422        finally { if (e_4) throw e_4.error; }423    }424    return subscriptionMap;425}426exports.transform_crt_subscribe_to_mqtt_js_subscription_map = transform_crt_subscribe_to_mqtt_js_subscription_map;427/** @internal **/428function transform_crt_subscribe_to_mqtt_js_subscribe_options(subscribe) {429    var properties = {};430    var propertiesValid = false;431    if (subscribe == null || subscribe == undefined) {432        throw new error_1.CrtError("transform_crt_subscribe_to_mqtt_js_subscribe_options: subscribe not defined");433    }434    propertiesValid = utils.set_defined_property(properties, "subscriptionIdentifier", subscribe.subscriptionIdentifier) || propertiesValid;435    propertiesValid = utils.set_defined_property(properties, "userProperties", transform_crt_user_properties_to_mqtt_js_user_properties(subscribe.userProperties)) || propertiesValid;436    var options = {437        qos: 0438    };439    if (propertiesValid) {440        options["properties"] = properties;441    }442    return options;443}444exports.transform_crt_subscribe_to_mqtt_js_subscribe_options = transform_crt_subscribe_to_mqtt_js_subscribe_options;445/** @internal **/446function transform_mqtt_js_suback_to_crt_suback(mqttJsSuback) {447    var _a, _b;448    if (!mqttJsSuback) {449        throw new error_1.CrtError("transform_mqtt_js_suback_to_crt_suback: mqttJsSuback not defined");450    }451    var crtSuback = {452        type: mqtt5.PacketType.Suback,453        reasonCodes: mqttJsSuback.granted.map(function (value, index, array) { return value; }),454    };455    if (mqttJsSuback.properties) {456        utils.set_defined_property(crtSuback, "reasonString", (_a = mqttJsSuback.properties) === null || _a === void 0 ? void 0 : _a.reasonString);457        utils.set_defined_property(crtSuback, "userProperties", transform_mqtt_js_user_properties_to_crt_user_properties((_b = mqttJsSuback.properties) === null || _b === void 0 ? void 0 : _b.userProperties));458    }459    return crtSuback;460}461exports.transform_mqtt_js_suback_to_crt_suback = transform_mqtt_js_suback_to_crt_suback;462/** @internal **/463function transform_mqtt_js_subscription_grants_to_crt_suback(subscriptionsGranted) {464    if (subscriptionsGranted == null || subscriptionsGranted == undefined) {465        throw new error_1.CrtError("transform_mqtt_js_subscription_grants_to_crt_suback: subscriptionsGranted not defined");466    }467    var crtSuback = {468        type: mqtt5.PacketType.Suback,469        reasonCodes: subscriptionsGranted.map(function (subscription, index, array) { return subscription.qos; })470    };471    /*472     * TODO: mqtt-js does not expose the suback packet to subscribe's completion callback, so we cannot extract473     * reasonString and userProperties atm.474     *475     * Revisit if this changes.476     */477    return crtSuback;478}479exports.transform_mqtt_js_subscription_grants_to_crt_suback = transform_mqtt_js_subscription_grants_to_crt_suback;480function validate_crt_publish(publish) {481    if (publish == null || publish == undefined) {482        throw new error_1.CrtError("validate_crt_publish: publish not defined");483    }484    validate_optional_uint32("messageExpiryIntervalSeconds", publish.messageExpiryIntervalSeconds);485}486/** @internal */487function transform_crt_publish_to_mqtt_js_publish_options(publish) {488    var _a;489    validate_crt_publish(publish);490    var properties = {};491    var propertiesValid = false;492    if (publish.payloadFormat !== undefined) {493        propertiesValid = utils.set_defined_property(properties, "payloadFormatIndicator", publish.payloadFormat == mqtt5.PayloadFormatIndicator.Utf8) || propertiesValid;494    }495    propertiesValid = utils.set_defined_property(properties, "messageExpiryInterval", publish.messageExpiryIntervalSeconds) || propertiesValid;496    propertiesValid = utils.set_defined_property(properties, "responseTopic", publish.responseTopic) || propertiesValid;497    propertiesValid = utils.set_defined_property(properties, "correlationData", publish.correlationData) || propertiesValid;498    propertiesValid = utils.set_defined_property(properties, "userProperties", transform_crt_user_properties_to_mqtt_js_user_properties(publish.userProperties)) || propertiesValid;499    propertiesValid = utils.set_defined_property(properties, "contentType", publish.contentType) || propertiesValid;500    propertiesValid = utils.set_defined_property(properties, "topicAlias", publish.topicAlias) || propertiesValid;501    var mqttJsPublish = {502        qos: publish.qos,503        retain: (_a = publish.retain) !== null && _a !== void 0 ? _a : false,504    };505    if (propertiesValid) {506        mqttJsPublish["properties"] = properties;507    }508    return mqttJsPublish;509}510exports.transform_crt_publish_to_mqtt_js_publish_options = transform_crt_publish_to_mqtt_js_publish_options;511/** @internal **/512function transform_mqtt_js_publish_to_crt_publish(publish) {513    var _a, _b, _c, _d, _e, _f;514    if (publish == null || publish == undefined) {515        throw new error_1.CrtError("transform_mqtt_js_publish_to_crt_publish: publish not defined");516    }517    var crtPublish = {518        type: mqtt5.PacketType.Publish,519        qos: publish.qos,520        retain: publish.retain,521        topicName: publish.topic,522        payload: publish.payload523    };524    if (publish.properties) {525        if (publish.properties.payloadFormatIndicator !== undefined) {526            utils.set_defined_property(crtPublish, "payloadFormat", publish.properties.payloadFormatIndicator ? mqtt5.PayloadFormatIndicator.Utf8 : mqtt5.PayloadFormatIndicator.Bytes);527        }528        utils.set_defined_property(crtPublish, "messageExpiryIntervalSeconds", (_a = publish.properties) === null || _a === void 0 ? void 0 : _a.messageExpiryInterval);529        utils.set_defined_property(crtPublish, "responseTopic", (_b = publish.properties) === null || _b === void 0 ? void 0 : _b.responseTopic);530        utils.set_defined_property(crtPublish, "correlationData", (_c = publish.properties) === null || _c === void 0 ? void 0 : _c.correlationData);531        utils.set_defined_property(crtPublish, "userProperties", transform_mqtt_js_user_properties_to_crt_user_properties((_d = publish.properties) === null || _d === void 0 ? void 0 : _d.userProperties));532        utils.set_defined_property(crtPublish, "contentType", (_e = publish.properties) === null || _e === void 0 ? void 0 : _e.contentType);533        var subIds = (_f = publish.properties) === null || _f === void 0 ? void 0 : _f.subscriptionIdentifier;534        var subIdsType = typeof subIds;535        if (subIds) {536            if (subIdsType == 'number') {537                crtPublish["subscriptionIdentifiers"] = [subIds];538            }539            else if (Array.isArray(subIds)) {540                crtPublish["subscriptionIdentifiers"] = subIds;541            }542        }543    }544    return crtPublish;545}546exports.transform_mqtt_js_publish_to_crt_publish = transform_mqtt_js_publish_to_crt_publish;547/** @internal **/548function transform_mqtt_js_puback_to_crt_puback(puback) {549    var _a, _b, _c;550    if (puback == null || puback == undefined) {551        throw new error_1.CrtError("transform_mqtt_js_puback_to_crt_puback: puback not defined");552    }553    var crtPuback = {554        type: mqtt5.PacketType.Puback,555        reasonCode: (_a = puback.reasonCode) !== null && _a !== void 0 ? _a : mqtt5.PubackReasonCode.Success,556    };557    if (puback.properties) {558        utils.set_defined_property(crtPuback, "reasonString", (_b = puback.properties) === null || _b === void 0 ? void 0 : _b.reasonString);559        utils.set_defined_property(crtPuback, "userProperties", transform_mqtt_js_user_properties_to_crt_user_properties((_c = puback.properties) === null || _c === void 0 ? void 0 : _c.userProperties));560    }561    return crtPuback;562}563exports.transform_mqtt_js_puback_to_crt_puback = transform_mqtt_js_puback_to_crt_puback;564/** @internal **/565function transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options(unsubscribe) {566    if (unsubscribe == null || unsubscribe == undefined) {567        throw new error_1.CrtError("transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options: unsubscribe not defined");568    }569    var properties = {};570    var propertiesValid = false;571    propertiesValid = utils.set_defined_property(properties, "userProperties", transform_crt_user_properties_to_mqtt_js_user_properties(unsubscribe.userProperties));572    var options = {};573    if (propertiesValid) {574        options["properties"] = properties;575    }576    return options;577}578exports.transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options = transform_crt_unsubscribe_to_mqtt_js_unsubscribe_options;579/** @internal **/580function transform_mqtt_js_unsuback_to_crt_unsuback(packet) {581    var _a, _b;582    if (packet == null || packet == undefined) {583        throw new error_1.CrtError("transform_mqtt_js_unsuback_to_crt_unsuback: packet not defined");584    }585    var reasonCodes = packet.reasonCode;586    var codes;587    if (Array.isArray(reasonCodes)) {588        codes = reasonCodes;589    }590    else if (typeof reasonCodes == 'number') {591        codes = [reasonCodes];592    }593    else {594        codes = [];595    }596    var crtUnsuback = {597        type: mqtt5.PacketType.Unsuback,598        reasonCodes: codes599    };600    if (packet.properties) {601        utils.set_defined_property(crtUnsuback, "reasonString", (_a = packet.properties) === null || _a === void 0 ? void 0 : _a.reasonString);602        utils.set_defined_property(crtUnsuback, "userProperties", transform_mqtt_js_user_properties_to_crt_user_properties((_b = packet.properties) === null || _b === void 0 ? void 0 : _b.userProperties));603    }604    return crtUnsuback;605}606exports.transform_mqtt_js_unsuback_to_crt_unsuback = transform_mqtt_js_unsuback_to_crt_unsuback;607//# sourceMappingURL=mqtt5_utils.js.map