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 __extends = (this && this.__extends) || (function () {7    var extendStatics = function (d, b) {8        extendStatics = Object.setPrototypeOf ||9            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||10            function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };11        return extendStatics(d, b);12    };13    return function (d, b) {14        if (typeof b !== "function" && b !== null)15            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");16        extendStatics(d, b);17        function __() { this.constructor = d; }18        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());19    };20})();21var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {22    if (k2 === undefined) k2 = k;23    var desc = Object.getOwnPropertyDescriptor(m, k);24    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {25      desc = { enumerable: true, get: function() { return m[k]; } };26    }27    Object.defineProperty(o, k2, desc);28}) : (function(o, m, k, k2) {29    if (k2 === undefined) k2 = k;30    o[k2] = m[k];31}));32var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {33    Object.defineProperty(o, "default", { enumerable: true, value: v });34}) : function(o, v) {35    o["default"] = v;36});37var __importStar = (this && this.__importStar) || function (mod) {38    if (mod && mod.__esModule) return mod;39    var result = {};40    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);41    __setModuleDefault(result, mod);42    return result;43};44var __exportStar = (this && this.__exportStar) || function(m, exports) {45    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);46};47var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {48    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }49    return new (P || (P = Promise))(function (resolve, reject) {50        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }51        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }52        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }53        step((generator = generator.apply(thisArg, _arguments || [])).next());54    });55};56var __generator = (this && this.__generator) || function (thisArg, body) {57    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;58    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;59    function verb(n) { return function (v) { return step([n, v]); }; }60    function step(op) {61        if (f) throw new TypeError("Generator is already executing.");62        while (g && (g = 0, op[0] && (_ = 0)), _) try {63            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;64            if (y = 0, t) op = [op[0] & 2, t.value];65            switch (op[0]) {66                case 0: case 1: t = op; break;67                case 4: _.label++; return { value: op[1], done: false };68                case 5: _.label++; y = op[1]; op = [0]; continue;69                case 7: op = _.ops.pop(); _.trys.pop(); continue;70                default:71                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }72                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }73                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }74                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }75                    if (t[2]) _.ops.pop();76                    _.trys.pop(); continue;77            }78            op = body.call(thisArg, _);79        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }80        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };81    }82};83Object.defineProperty(exports, "__esModule", { value: true });84exports.Mqtt5Client = exports.Mqtt5WebsocketUrlFactoryType = void 0;85/**86 * Browser specific MQTT5 client implementation87 *88 * @packageDocumentation89 * @module mqtt590 * @mergeTarget91 *92 */93var event_1 = require("../common/event");94var internal_mqtt_client = __importStar(require("./mqtt_internal/client"));95var client_1 = require("./mqtt_internal/client");96var mqtt5 = __importStar(require("../common/mqtt5"));97var mqtt5_packet = __importStar(require("../common/mqtt5_packet"));98var error_1 = require("./error");99var ws = __importStar(require("./ws"));100var mqtt_shared = __importStar(require("../common/mqtt_shared"));101var mqtt_shared_browser = __importStar(require("./mqtt_shared_browser"));102var aws_iot_metrics = __importStar(require("./aws_iot_metrics"));103var validate = __importStar(require("./mqtt_internal/validate"));104__exportStar(require("../common/mqtt5"), exports);105__exportStar(require("../common/mqtt5_packet"), exports);106/**107 * Type of url to construct when establishing an MQTT5 connection over websockets108 */109var Mqtt5WebsocketUrlFactoryType;110(function (Mqtt5WebsocketUrlFactoryType) {111    /**112     * Websocket connection over plain-text with no additional handshake transformation113     */114    Mqtt5WebsocketUrlFactoryType[Mqtt5WebsocketUrlFactoryType["Ws"] = 1] = "Ws";115    /**116     * Websocket connection over TLS with no additional handshake transformation117     */118    Mqtt5WebsocketUrlFactoryType[Mqtt5WebsocketUrlFactoryType["Wss"] = 2] = "Wss";119    /**120     * Websocket connection over TLS with a handshake signed by the Aws Sigv4 signing process121     */122    Mqtt5WebsocketUrlFactoryType[Mqtt5WebsocketUrlFactoryType["Sigv4"] = 3] = "Sigv4";123    /**124     * Websocket connection whose url is formed by a user-supplied callback function125     */126    Mqtt5WebsocketUrlFactoryType[Mqtt5WebsocketUrlFactoryType["Custom"] = 4] = "Custom";127})(Mqtt5WebsocketUrlFactoryType = exports.Mqtt5WebsocketUrlFactoryType || (exports.Mqtt5WebsocketUrlFactoryType = {}));128;129;130;131function convertSessionBehaviorToSessionPolicy(behavior) {132    switch (behavior) {133        case mqtt5.ClientSessionBehavior.Default:134        case mqtt5.ClientSessionBehavior.Clean:135            return internal_mqtt_client.ResumeSessionPolicyType.Never;136        case mqtt5.ClientSessionBehavior.RejoinPostSuccess:137            return internal_mqtt_client.ResumeSessionPolicyType.PostSuccess;138        case mqtt5.ClientSessionBehavior.RejoinAlways:139            return internal_mqtt_client.ResumeSessionPolicyType.Always;140        default:141            return internal_mqtt_client.ResumeSessionPolicyType.Default;142    }143}144function buildInternalConnectOptions(internalConnectOptions, clientConfig, connectProperties) {145    if (clientConfig.disableMetrics) {146        if (connectProperties === null || connectProperties === void 0 ? void 0 : connectProperties.username) {147            internalConnectOptions.username = connectProperties.username;148        }149    }150    else {151        internalConnectOptions.username = mqtt_shared_browser.buildFinalUsernameFromMetrics(aws_iot_metrics.create_metrics_mqtt5(clientConfig), connectProperties === null || connectProperties === void 0 ? void 0 : connectProperties.username);152    }153    if (!connectProperties) {154        return;155    }156    if (connectProperties.clientId !== undefined) {157        internalConnectOptions.clientId = connectProperties.clientId;158    }159    if (connectProperties.password !== undefined) {160        internalConnectOptions.password = connectProperties.password;161    }162    if (connectProperties.sessionExpiryIntervalSeconds !== undefined) {163        internalConnectOptions.sessionExpiryIntervalSeconds = connectProperties.sessionExpiryIntervalSeconds;164    }165    if (connectProperties.requestResponseInformation !== undefined) {166        internalConnectOptions.requestResponseInformation = connectProperties.requestResponseInformation;167    }168    if (connectProperties.requestProblemInformation !== undefined) {169        internalConnectOptions.requestProblemInformation = connectProperties.requestProblemInformation;170    }171    if (connectProperties.receiveMaximum !== undefined) {172        internalConnectOptions.receiveMaximum = connectProperties.receiveMaximum;173    }174    if (connectProperties.maximumPacketSizeBytes !== undefined) {175        internalConnectOptions.maximumPacketSizeBytes = connectProperties.maximumPacketSizeBytes;176    }177    if (connectProperties.willDelayIntervalSeconds !== undefined) {178        internalConnectOptions.willDelayIntervalSeconds = connectProperties.willDelayIntervalSeconds;179    }180    if (connectProperties.will !== undefined) {181        internalConnectOptions.will = connectProperties.will;182    }183    if (connectProperties.userProperties !== undefined) {184        internalConnectOptions.userProperties = connectProperties.userProperties;185    }186}187var DEFAULT_MQTT_PING_TIMEOUT_MS = 30 * 1000;188var DEFAULT_CONNECT_TIMEOUT_MS = 10 * 1000;189/**190 * Browser specific MQTT5 client implementation191 */192var Mqtt5Client = /** @class */ (function (_super) {193    __extends(Mqtt5Client, _super);194    /**195     * Client constructor196     *197     * @param config The configuration for this client198     */199    function Mqtt5Client(config) {200        var _this = this;201        var _a, _b, _c;202        _this = _super.call(this) || this;203        _this.config = config;204        _this.connected = false;205        _this.on_publish_received = function (event) {206            var messageReceivedEvent = {207                message: event.publish208            };209            mqtt_shared.queueAcknowledgeableEvent(_this, Mqtt5Client.MESSAGE_RECEIVED, messageReceivedEvent, "acknowledgementControl", event.acknowledgementControl);210        };211        if (!config) {212            throw new error_1.CrtError("Mqtt5Client constructor: config not defined");213        }214        var internalConnectOptions = {215            keepAliveIntervalSeconds: (_b = (_a = _this.config.connectProperties) === null || _a === void 0 ? void 0 : _a.keepAliveIntervalSeconds) !== null && _b !== void 0 ? _b : 1200,216            resumeSessionPolicy: convertSessionBehaviorToSessionPolicy(_this.config.sessionBehavior),217        };218        buildInternalConnectOptions(internalConnectOptions, config, config.connectProperties);219        var provider = undefined;220        if (_this.config.websocketOptions) {221            if (_this.config.websocketOptions.urlFactoryOptions.urlFactory == Mqtt5WebsocketUrlFactoryType.Sigv4) {222                var sigv4Options = _this.config.websocketOptions.urlFactoryOptions;223                provider = sigv4Options.credentialsProvider;224            }225        }226        var thisConfig = _this.config;227        var connectionFactory = function () {228            var _this = this;229            return new Promise(function (resolve, reject) { return __awaiter(_this, void 0, void 0, function () {230                var conn;231                return __generator(this, function (_a) {232                    switch (_a.label) {233                        case 0:234                            if (!provider) return [3 /*break*/, 2];235                            return [4 /*yield*/, provider.refreshCredentials()];236                        case 1:237                            _a.sent();238                            _a.label = 2;239                        case 2:240                            conn = ws.create_mqtt5_websocket_stream(thisConfig);241                            conn.on('error', function (err) {242                                reject(err);243                            });244                            conn.on('connect', function () {245                                resolve(conn);246                            });247                            return [2 /*return*/];248                    }249                });250            }); });251        };252        var internalConfig = {253            protocolVersion: mqtt_shared.ProtocolMode.Mqtt5,254            offlineQueuePolicy: internal_mqtt_client.OfflineQueuePolicy.PreserveQos1PlusPublishes,255            connectOptions: internalConnectOptions,256            pingTimeoutMillis: DEFAULT_MQTT_PING_TIMEOUT_MS,257            connectionFactory: connectionFactory,258            connectTimeoutMillis: (_c = config.connectTimeoutMs) !== null && _c !== void 0 ? _c : DEFAULT_CONNECT_TIMEOUT_MS,259            retryJitterMode: mqtt5.RetryJitterType.Default,260        };261        if (config.minReconnectDelayMs !== undefined) {262            internalConfig.minReconnectDelayMs = config.minReconnectDelayMs;263        }264        if (config.maxReconnectDelayMs !== undefined) {265            internalConfig.maxReconnectDelayMs = config.maxReconnectDelayMs;266        }267        if (config.minConnectedTimeToResetReconnectDelayMs !== undefined) {268            internalConfig.resetConnectionFailureCountMillis = config.minConnectedTimeToResetReconnectDelayMs;269        }270        _this.internalClient = new internal_mqtt_client.Client(internalConfig);271        _this.internalClient.on("connectionSuccess", _this.on_connection_success.bind(_this));272        _this.internalClient.on("connectionFailure", _this.on_connection_failure.bind(_this));273        _this.internalClient.on("disconnection", _this.on_disconnection.bind(_this));274        _this.internalClient.on("publishReceived", _this.on_publish_received.bind(_this));275        _this.internalClient.on("stopped", _this.on_stopped.bind(_this));276        _this.internalClient.on("connecting", _this.on_connecting.bind(_this));277        return _this;278    }279    /**280     * Triggers cleanup of native resources associated with the MQTT5 client.  On the browser, the implementation is281     * an empty function.282     */283    Mqtt5Client.prototype.close = function () { };284    /**285     * Notifies the MQTT5 client that you want it to maintain connectivity to the configured endpoint.286     * The client will attempt to stay connected using the properties of the reconnect-related parameters287     * in the mqtt5 client configuration.288     *289     * This is an asynchronous operation.290     */291    Mqtt5Client.prototype.start = function () {292        this.internalClient.start();293    };294    /**295     * Notifies the MQTT5 client that you want it to end connectivity to the configured endpoint, disconnecting any296     * existing connection and halting reconnection attempts.297     *298     * This is an asynchronous operation.  Once the process completes, no further events will be emitted until the client299     * has {@link start} invoked.  Invoking {@link start start()} after a {@link stop stop()} will always result in300     * a new MQTT session.301     *302     * @param disconnectPacket (optional) properties of a DISCONNECT packet to send as part of the shutdown process303     */304    Mqtt5Client.prototype.stop = function (disconnectPacket) {305        // maintain backwards comaptibility with previous implementation which let validation errors306        // trump the stop request307        if (disconnectPacket) {308            disconnectPacket.type = mqtt5_packet.PacketType.Disconnect;309            validate.validateInitialOutboundPacket(disconnectPacket, mqtt_shared.ProtocolMode.Mqtt5);310        }311        this.internalClient.stop(disconnectPacket);312    };313    /**314     * Subscribe to one or more topic filters by queuing a SUBSCRIBE packet to be sent to the server.315     *316     * @param packet SUBSCRIBE packet to send to the server317     * @returns a promise that will be rejected with an error or resolved with the SUBACK response318     */319    Mqtt5Client.prototype.subscribe = function (packet) {320        return __awaiter(this, void 0, void 0, function () {321            return __generator(this, function (_a) {322                switch (_a.label) {323                    case 0:324                        if (!packet) {325                            throw new error_1.CrtError("Invalid subscribe packet");326                        }327                        return [4 /*yield*/, this.internalClient.subscribe(packet)];328                    case 1: return [2 /*return*/, _a.sent()];329                }330            });331        });332    };333    /**334     * Unsubscribe from one or more topic filters by queuing an UNSUBSCRIBE packet to be sent to the server.335     *336     * @param packet UNSUBSCRIBE packet to send to the server337     * @returns a promise that will be rejected with an error or resolved with the UNSUBACK response338     */339    Mqtt5Client.prototype.unsubscribe = function (packet) {340        return __awaiter(this, void 0, void 0, function () {341            return __generator(this, function (_a) {342                switch (_a.label) {343                    case 0:344                        if (!packet) {345                            throw new error_1.CrtError("Invalid unsubscribe packet");346                        }347                        return [4 /*yield*/, this.internalClient.unsubscribe(packet)];348                    case 1: return [2 /*return*/, _a.sent()];349                }350            });351        });352    };353    /**354     * Send a message to subscribing clients by queuing a PUBLISH packet to be sent to the server.355     *356     * @param packet PUBLISH packet to send to the server357     * @returns a promise that will be rejected with an error or resolved with the PUBACK response (QoS 1), or358     * undefined (QoS 0)359     */360    Mqtt5Client.prototype.publish = function (packet) {361        return __awaiter(this, void 0, void 0, function () {362            var publishResult;363            return __generator(this, function (_a) {364                switch (_a.label) {365                    case 0:366                        if (!packet) {367                            throw new error_1.CrtError("Invalid publish packet");368                        }369                        return [4 /*yield*/, this.internalClient.publish(packet)];370                    case 1:371                        publishResult = _a.sent();372                        switch (publishResult.type) {373                            case client_1.PublishResultType.Qos1:374                                return [2 /*return*/, publishResult.packet];375                            default:376                                return [2 /*return*/, undefined];377                        }378                        return [2 /*return*/];379                }380            });381        });382    };383    /**384     * Queries whether the client is currently connected385     *386     * @returns whether the client is currently connected387     */388    Mqtt5Client.prototype.isConnected = function () {389        return this.connected;390    };391    Mqtt5Client.prototype.on = function (event, listener) {392        _super.prototype.on.call(this, event, listener);393        return this;394    };395    Mqtt5Client.prototype.on_connecting = function (event) {396        var _this = this;397        var attemptingConnectEvent = {};398        setTimeout(function () {399            _this.emit(Mqtt5Client.ATTEMPTING_CONNECT, attemptingConnectEvent);400        }, 0);401    };402    Mqtt5Client.prototype.on_connection_success = function (event) {403        var _this = this;404        this.connected = true;405        var settings = create_negotiated_settings(this.config, event.connack);406        var connectionSuccessEvent = {407            connack: event.connack,408            settings: settings409        };410        setTimeout(function () {411            _this.emit(Mqtt5Client.CONNECTION_SUCCESS, connectionSuccessEvent);412        }, 0);413    };414    Mqtt5Client.prototype.on_connection_failure = function (event) {415        var _this = this;416        var connectionFailureEvent = {417            error: event.error418        };419        if (event.connack) {420            connectionFailureEvent.connack = event.connack;421        }422        setTimeout(function () {423            _this.emit(Mqtt5Client.CONNECTION_FAILURE, connectionFailureEvent);424        }, 0);425    };426    Mqtt5Client.prototype.on_disconnection = function (event) {427        var _this = this;428        this.connected = false;429        var disconnectionEvent = {430            error: event.error431        };432        if (event.disconnect) {433            disconnectionEvent.disconnect = event.disconnect;434        }435        setTimeout(function () {436            _this.emit(Mqtt5Client.DISCONNECTION, disconnectionEvent);437        }, 0);438    };439    Mqtt5Client.prototype.on_stopped = function (event) {440        var _this = this;441        var stoppedEvent = {};442        setTimeout(function () {443            _this.emit(Mqtt5Client.STOPPED, stoppedEvent);444        }, 0);445    };446    /**447     * Event emitted when the client encounters a disruptive error condition.  Not currently used.448     *449     * Listener type: {@link ErrorEventListener}450     *451     * @event452     */453    Mqtt5Client.ERROR = 'error';454    /**455     * Event emitted when the client encounters a transient error event that will not disrupt promises based on456     * lifecycle events.  Currently, mqtt-js client error events are relayed to this event.457     *458     * Listener type: {@link ErrorEventListener}459     *460     * @event461     * @group Browser-only462     */463    Mqtt5Client.INFO = 'info';464    /**465     * Event emitted when an MQTT PUBLISH packet is received by the client.466     *467     * Listener type: {@link MessageReceivedEventListener}468     *469     * @event470     */471    Mqtt5Client.MESSAGE_RECEIVED = 'messageReceived';472    /**473     * Event emitted when the client begins a connection attempt.474     *475     * Listener type: {@link AttemptingConnectEventListener}476     *477     * @event478     */479    Mqtt5Client.ATTEMPTING_CONNECT = 'attemptingConnect';480    /**481     * Event emitted when the client successfully establishes an MQTT connection.  Only emitted after482     * an {@link ATTEMPTING_CONNECT attemptingConnect} event.483     *484     * Listener type: {@link ConnectionSuccessEventListener}485     *486     * @event487     */488    Mqtt5Client.CONNECTION_SUCCESS = 'connectionSuccess';489    /**490     * Event emitted when the client fails to establish an MQTT connection.  Only emitted after491     * an {@link ATTEMPTING_CONNECT attemptingConnect} event.492     *493     * Listener type: {@link ConnectionFailureEventListener}494     *495     * @event496     */497    Mqtt5Client.CONNECTION_FAILURE = 'connectionFailure';498    /**499     * Event emitted when the client's current connection is closed for any reason.  Only emitted after500     * a {@link CONNECTION_SUCCESS connectionSuccess} event.501     *502     * Listener type: {@link DisconnectionEventListener}503     *504     * @event505     */506    Mqtt5Client.DISCONNECTION = 'disconnection';507    /**508     * Event emitted when the client finishes shutdown as a result of the user invoking {@link stop}.509     *510     * Listener type: {@link StoppedEventListener}511     *512     * @event513     */514    Mqtt5Client.STOPPED = 'stopped';515    return Mqtt5Client;516}(event_1.BufferedEventEmitter));517exports.Mqtt5Client = Mqtt5Client;518function create_negotiated_settings(config, connack) {519    var _a, _b, _c, _d, _e, _f, _g, _h, _j, _k, _l, _m, _o, _p, _q, _r, _s, _t, _u, _v, _w;520    if (config == null || config == undefined) {521        throw new error_1.CrtError("create_negotiated_settings: config not defined");522    }523    if (connack == null || connack == undefined) {524        throw new error_1.CrtError("create_negotiated_settings: connack not defined");525    }526    return {527        maximumQos: Math.min((_a = connack.maximumQos) !== null && _a !== void 0 ? _a : mqtt5_packet.QoS.ExactlyOnce, mqtt5_packet.QoS.AtLeastOnce),528        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,529        receiveMaximumFromServer: (_e = connack.receiveMaximum) !== null && _e !== void 0 ? _e : mqtt_shared.DEFAULT_RECEIVE_MAXIMUM,530        maximumPacketSizeToServer: (_f = connack.maximumPacketSize) !== null && _f !== void 0 ? _f : mqtt_shared.MAXIMUM_PACKET_SIZE,531        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),532        topicAliasMaximumToClient: (_l = (_k = config.topicAliasingOptions) === null || _k === void 0 ? void 0 : _k.inboundCacheMaxSize) !== null && _l !== void 0 ? _l : 0,533        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,534        retainAvailable: (_q = connack.retainAvailable) !== null && _q !== void 0 ? _q : true,535        wildcardSubscriptionsAvailable: (_r = connack.wildcardSubscriptionsAvailable) !== null && _r !== void 0 ? _r : true,536        subscriptionIdentifiersAvailable: (_s = connack.subscriptionIdentifiersAvailable) !== null && _s !== void 0 ? _s : true,537        sharedSubscriptionsAvailable: (_t = connack.sharedSubscriptionsAvailable) !== null && _t !== void 0 ? _t : true,538        rejoinedSession: connack.sessionPresent,539        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 : ""540    };541}542//# sourceMappingURL=mqtt5.js.map