(window["webpackJsonp"]=window["webpackJsonp"]||[]).push([["chunk-5f0ec173"],{"05ee":function(t,e,r){"use strict";var n=r(5);function o(t,e){var r,o;return e.port=e.port||1883,e.hostname=e.hostname||e.host||"localhost",r=e.port,o=e.hostname,n.createConnection(r,o)}t.exports=o},"06a2":function(t,e,r){"use strict";var n,o=r("a671"),i=r("2031"),s=r("1a94"),a=r("96ae"),c=r("f508"),l=r("986b"),u=r("1c4a"),p=Object.defineProperty,h=Object.defineProperties;t.exports=n=function(t,e){if(!(this instanceof n))throw new TypeError("Constructor requires 'new'");h(this,{__list__:c("w",a(t)),__context__:c("w",e),__nextIndex__:c("w",0)}),e&&(s(e.on),e.on("_add",this._onAdd),e.on("_delete",this._onDelete),e.on("_clear",this._onClear))},delete n.prototype.constructor,h(n.prototype,i({_next:c(function(){var t;if(this.__list__)return this.__redo__&&(t=this.__redo__.shift(),void 0!==t)?t:this.__nextIndex__<this.__list__.length?this.__nextIndex__++:void this._unBind()}),next:c(function(){return this._createResult(this._next())}),_createResult:c(function(t){return void 0===t?{done:!0,value:void 0}:{done:!1,value:this._resolve(t)}}),_resolve:c(function(t){return this.__list__[t]}),_unBind:c(function(){this.__list__=null,delete this.__redo__,this.__context__&&(this.__context__.off("_add",this._onAdd),this.__context__.off("_delete",this._onDelete),this.__context__.off("_clear",this._onClear),this.__context__=null)}),toString:c(function(){return"[object "+(this[u.toStringTag]||"Object")+"]"})},l({_onAdd:c(function(t){t>=this.__nextIndex__||(++this.__nextIndex__,this.__redo__?(this.__redo__.forEach(function(e,r){e>=t&&(this.__redo__[r]=++e)},this),this.__redo__.push(t)):p(this,"__redo__",c("c",[t])))}),_onDelete:c(function(t){var e;t>=this.__nextIndex__||(--this.__nextIndex__,this.__redo__&&(e=this.__redo__.indexOf(t),-1!==e&&this.__redo__.splice(e,1),this.__redo__.forEach(function(e,r){e>t&&(this.__redo__[r]=--e)},this)))}),_onClear:c(function(){this.__redo__&&o.call(this.__redo__),this.__nextIndex__=0})}))),p(n.prototype,u.iterator,c(function(){return this}))},"09d9":function(t,e,r){"use strict";var n,o=r("e0f6"),i=r("f508"),s=r("1c4a"),a=r("06a2"),c=Object.defineProperty;n=t.exports=function(t){if(!(this instanceof n))throw new TypeError("Constructor requires 'new'");t=String(t),a.call(this,t),c(this,"__length__",i("",t.length))},o&&o(n,a),delete n.prototype.constructor,n.prototype=Object.create(a.prototype,{_next:i(function(){if(this.__list__)return this.__nextIndex__<this.__length__?this.__nextIndex__++:void this._unBind()}),_resolve:i(function(t){var e,r=this.__list__[t];return this.__nextIndex__===this.__length__?r:(e=r.charCodeAt(0),e>=55296&&e<=56319?r+this.__list__[this.__nextIndex__++]:r)})}),c(n.prototype,s.toStringTag,i("c","String Iterator"))},"0b16":function(t,e,r){"use strict";var n=r("9d88"),o=r("35e86");function i(){this.protocol=null,this.slashes=null,this.auth=null,this.host=null,this.port=null,this.hostname=null,this.hash=null,this.search=null,this.query=null,this.pathname=null,this.path=null,this.href=null}e.parse=w,e.resolve=k,e.resolveObject=I,e.format=S,e.Url=i;var s=/^([a-z0-9.+-]+:)/i,a=/:[0-9]*$/,c=/^(\/\/?(?!\/)[^\?\s]*)(\?[^\s]*)?$/,l=["<",">",'"',"`"," ","\r","\n","\t"],u=["{","}","|","\\","^","`"].concat(l),p=["'"].concat(u),h=["%","/","?",";","#"].concat(p),f=["/","?","#"],d=255,_=/^[+a-z0-9A-Z_-]{0,63}$/,m=/^([+a-z0-9A-Z_-]{0,63})(.*)$/,b={javascript:!0,"javascript:":!0},g={javascript:!0,"javascript:":!0},v={http:!0,https:!0,ftp:!0,gopher:!0,file:!0,"http:":!0,"https:":!0,"ftp:":!0,"gopher:":!0,"file:":!0},y=r("b383");function w(t,e,r){if(t&&o.isObject(t)&&t instanceof i)return t;var n=new i;return n.parse(t,e,r),n}function S(t){return o.isString(t)&&(t=w(t)),t instanceof i?t.format():i.prototype.format.call(t)}function k(t,e){return w(t,!1,!0).resolve(e)}function I(t,e){return t?w(t,!1,!0).resolveObject(e):e}i.prototype.parse=function(t,e,r){if(!o.isString(t))throw new TypeError("Parameter 'url' must be a string, not "+typeof t);var i=t.indexOf("?"),a=-1!==i&&i<t.indexOf("#")?"?":"#",l=t.split(a),u=/\\/g;l[0]=l[0].replace(u,"/"),t=l.join(a);var w=t;if(w=w.trim(),!r&&1===t.split("#").length){var S=c.exec(w);if(S)return this.path=w,this.href=w,this.pathname=S[1],S[2]?(this.search=S[2],this.query=e?y.parse(this.search.substr(1)):this.search.substr(1)):e&&(this.search="",this.query={}),this}var k=s.exec(w);if(k){k=k[0];var I=k.toLowerCase();this.protocol=I,w=w.substr(k.length)}if(r||k||w.match(/^\/\/[^@\/]+@[^@\/]+/)){var E="//"===w.substr(0,2);!E||k&&g[k]||(w=w.substr(2),this.slashes=!0)}if(!g[k]&&(E||k&&!v[k])){for(var x,O,P=-1,T=0;T<f.length;T++){var C=w.indexOf(f[T]);-1!==C&&(-1===P||C<P)&&(P=C)}O=-1===P?w.lastIndexOf("@"):w.lastIndexOf("@",P),-1!==O&&(x=w.slice(0,O),w=w.slice(O+1),this.auth=decodeURIComponent(x)),P=-1;for(T=0;T<h.length;T++){C=w.indexOf(h[T]);-1!==C&&(-1===P||C<P)&&(P=C)}-1===P&&(P=w.length),this.host=w.slice(0,P),w=w.slice(P),this.parseHost(),this.hostname=this.hostname||"";var A="["===this.hostname[0]&&"]"===this.hostname[this.hostname.length-1];if(!A)for(var j=this.hostname.split(/\./),R=(T=0,j.length);T<R;T++){var M=j[T];if(M&&!M.match(_)){for(var q="",N=0,B=M.length;N<B;N++)M.charCodeAt(N)>127?q+="x":q+=M[N];if(!q.match(_)){var U=j.slice(0,T),L=j.slice(T+1),D=M.match(m);D&&(U.push(D[1]),L.unshift(D[2])),L.length&&(w="/"+L.join(".")+w),this.hostname=U.join(".");break}}}this.hostname.length>d?this.hostname="":this.hostname=this.hostname.toLowerCase(),A||(this.hostname=n.toASCII(this.hostname));var $=this.port?":"+this.port:"",K=this.hostname||"";this.host=K+$,this.href+=this.host,A&&(this.hostname=this.hostname.substr(1,this.hostname.length-2),"/"!==w[0]&&(w="/"+w))}if(!b[I])for(T=0,R=p.length;T<R;T++){var V=p[T];if(-1!==w.indexOf(V)){var F=encodeURIComponent(V);F===V&&(F=escape(V)),w=w.split(V).join(F)}}var H=w.indexOf("#");-1!==H&&(this.hash=w.substr(H),w=w.slice(0,H));var z=w.indexOf("?");if(-1!==z?(this.search=w.substr(z),this.query=w.substr(z+1),e&&(this.query=y.parse(this.query)),w=w.slice(0,z)):e&&(this.search="",this.query={}),w&&(this.pathname=w),v[I]&&this.hostname&&!this.pathname&&(this.pathname="/"),this.pathname||this.search){$=this.pathname||"";var W=this.search||"";this.path=$+W}return this.href=this.format(),this},i.prototype.format=function(){var t=this.auth||"";t&&(t=encodeURIComponent(t),t=t.replace(/%3A/i,":"),t+="@");var e=this.protocol||"",r=this.pathname||"",n=this.hash||"",i=!1,s="";this.host?i=t+this.host:this.hostname&&(i=t+(-1===this.hostname.indexOf(":")?this.hostname:"["+this.hostname+"]"),this.port&&(i+=":"+this.port)),this.query&&o.isObject(this.query)&&Object.keys(this.query).length&&(s=y.stringify(this.query));var a=this.search||s&&"?"+s||"";return e&&":"!==e.substr(-1)&&(e+=":"),this.slashes||(!e||v[e])&&!1!==i?(i="//"+(i||""),r&&"/"!==r.charAt(0)&&(r="/"+r)):i||(i=""),n&&"#"!==n.charAt(0)&&(n="#"+n),a&&"?"!==a.charAt(0)&&(a="?"+a),r=r.replace(/[?#]/g,function(t){return encodeURIComponent(t)}),a=a.replace("#","%23"),e+i+r+a+n},i.prototype.resolve=function(t){return this.resolveObject(w(t,!1,!0)).format()},i.prototype.resolveObject=function(t){if(o.isString(t)){var e=new i;e.parse(t,!1,!0),t=e}for(var r=new i,n=Object.keys(this),s=0;s<n.length;s++){var a=n[s];r[a]=this[a]}if(r.hash=t.hash,""===t.href)return r.href=r.format(),r;if(t.slashes&&!t.protocol){for(var c=Object.keys(t),l=0;l<c.length;l++){var u=c[l];"protocol"!==u&&(r[u]=t[u])}return v[r.protocol]&&r.hostname&&!r.pathname&&(r.path=r.pathname="/"),r.href=r.format(),r}if(t.protocol&&t.protocol!==r.protocol){if(!v[t.protocol]){for(var p=Object.keys(t),h=0;h<p.length;h++){var f=p[h];r[f]=t[f]}return r.href=r.format(),r}if(r.protocol=t.protocol,t.host||g[t.protocol])r.pathname=t.pathname;else{var d=(t.pathname||"").split("/");while(d.length&&!(t.host=d.shift()));t.host||(t.host=""),t.hostname||(t.hostname=""),""!==d[0]&&d.unshift(""),d.length<2&&d.unshift(""),r.pathname=d.join("/")}if(r.search=t.search,r.query=t.query,r.host=t.host||"",r.auth=t.auth,r.hostname=t.hostname||t.host,r.port=t.port,r.pathname||r.search){var _=r.pathname||"",m=r.search||"";r.path=_+m}return r.slashes=r.slashes||t.slashes,r.href=r.format(),r}var b=r.pathname&&"/"===r.pathname.charAt(0),y=t.host||t.pathname&&"/"===t.pathname.charAt(0),w=y||b||r.host&&t.pathname,S=w,k=r.pathname&&r.pathname.split("/")||[],I=(d=t.pathname&&t.pathname.split("/")||[],r.protocol&&!v[r.protocol]);if(I&&(r.hostname="",r.port=null,r.host&&(""===k[0]?k[0]=r.host:k.unshift(r.host)),r.host="",t.protocol&&(t.hostname=null,t.port=null,t.host&&(""===d[0]?d[0]=t.host:d.unshift(t.host)),t.host=null),w=w&&(""===d[0]||""===k[0])),y)r.host=t.host||""===t.host?t.host:r.host,r.hostname=t.hostname||""===t.hostname?t.hostname:r.hostname,r.search=t.search,r.query=t.query,k=d;else if(d.length)k||(k=[]),k.pop(),k=k.concat(d),r.search=t.search,r.query=t.query;else if(!o.isNullOrUndefined(t.search)){if(I){r.hostname=r.host=k.shift();var E=!!(r.host&&r.host.indexOf("@")>0)&&r.host.split("@");E&&(r.auth=E.shift(),r.host=r.hostname=E.shift())}return r.search=t.search,r.query=t.query,o.isNull(r.pathname)&&o.isNull(r.search)||(r.path=(r.pathname?r.pathname:"")+(r.search?r.search:"")),r.href=r.format(),r}if(!k.length)return r.pathname=null,r.search?r.path="/"+r.search:r.path=null,r.href=r.format(),r;for(var x=k.slice(-1)[0],O=(r.host||t.host||k.length>1)&&("."===x||".."===x)||""===x,P=0,T=k.length;T>=0;T--)x=k[T],"."===x?k.splice(T,1):".."===x?(k.splice(T,1),P++):P&&(k.splice(T,1),P--);if(!w&&!S)for(;P--;P)k.unshift("..");!w||""===k[0]||k[0]&&"/"===k[0].charAt(0)||k.unshift(""),O&&"/"!==k.join("/").substr(-1)&&k.push("");var C=""===k[0]||k[0]&&"/"===k[0].charAt(0);if(I){r.hostname=r.host=C?"":k.length?k.shift():"";E=!!(r.host&&r.host.indexOf("@")>0)&&r.host.split("@");E&&(r.auth=E.shift(),r.host=r.hostname=E.shift())}return w=w||r.host&&k.length,w&&!C&&k.unshift(""),k.length?r.pathname=k.join("/"):(r.pathname=null,r.path=null),o.isNull(r.pathname)&&o.isNull(r.search)||(r.path=(r.pathname?r.pathname:"")+(r.search?r.search:"")),r.auth=t.auth||r.auth,r.slashes=r.slashes||t.slashes,r.href=r.format(),r},i.prototype.parseHost=function(){var t=this.host,e=a.exec(t);e&&(e=e[0],":"!==e&&(this.port=e.substr(1)),t=t.substr(0,t.length-e.length)),t&&(this.hostname=t)}},"0b24":function(t,e,r){"use strict";var n,o=r("a671"),i=r("3527"),s=r("e0f6"),a=r("1a94"),c=r("96ae"),l=r("f508"),u=r("c9fc"),p=r("1c4a"),h=r("3473"),f=r("c351"),d=r("1195"),_=r("b779"),m=Function.prototype.call,b=Object.defineProperties,g=Object.getPrototypeOf;t.exports=n=function(){var t,e,r,o=arguments[0];if(!(this instanceof n))throw new TypeError("Constructor requires 'new'");return r=_&&s&&Map!==n?s(new Map,g(this)):this,null!=o&&h(o),b(r,{__mapKeysData__:l("c",t=[]),__mapValuesData__:l("c",e=[])}),o?(f(o,function(r){var n=c(r)[0];r=r[1],-1===i.call(t,n)&&(t.push(n),e.push(r))},r),r):r},_&&(s&&s(n,Map),n.prototype=Object.create(Map.prototype,{constructor:l(n)})),u(b(n.prototype,{clear:l(function(){this.__mapKeysData__.length&&(o.call(this.__mapKeysData__),o.call(this.__mapValuesData__),this.emit("_clear"))}),delete:l(function(t){var e=i.call(this.__mapKeysData__,t);return-1!==e&&(this.__mapKeysData__.splice(e,1),this.__mapValuesData__.splice(e,1),this.emit("_delete",e,t),!0)}),entries:l(function(){return new d(this,"key+value")}),forEach:l(function(t){var e,r,n=arguments[1];a(t),e=this.entries(),r=e._next();while(void 0!==r)m.call(t,n,this.__mapValuesData__[r],this.__mapKeysData__[r],this),r=e._next()}),get:l(function(t){var e=i.call(this.__mapKeysData__,t);if(-1!==e)return this.__mapValuesData__[e]}),has:l(function(t){return-1!==i.call(this.__mapKeysData__,t)}),keys:l(function(){return new d(this,"key")}),set:l(function(t,e){var r,n=i.call(this.__mapKeysData__,t);return-1===n&&(n=this.__mapKeysData__.push(t)-1,r=!0),this.__mapValuesData__[n]=e,r&&this.emit("_add",n,t),this}),size:l.gs(function(){return this.__mapKeysData__.length}),values:l(function(){return new d(this,"value")}),toString:l(function(){return"[object Map]"})})),Object.defineProperty(n.prototype,p.iterator,l(function(){return this.entries()})),Object.defineProperty(n.prototype,p.toStringTag,l("c","Map"))},1126:function(t,e,r){"use strict";t.exports=function(t){return!!t&&("symbol"===typeof t||!!t.constructor&&("Symbol"===t.constructor.name&&"Symbol"===t[t.constructor.toStringTag]))}},1195:function(t,e,r){"use strict";var n,o=r("e0f6"),i=r("f508"),s=r("06a2"),a=r("1c4a").toStringTag,c=r("c682"),l=Object.defineProperties,u=s.prototype._unBind;n=t.exports=function(t,e){if(!(this instanceof n))return new n(t,e);s.call(this,t.__mapKeysData__,t),e&&c[e]||(e="key+value"),l(this,{__kind__:i("",e),__values__:i("w",t.__mapValuesData__)})},o&&o(n,s),n.prototype=Object.create(s.prototype,{constructor:i(n),_resolve:i(function(t){return"value"===this.__kind__?this.__values__[t]:"key"===this.__kind__?this.__list__[t]:[this.__list__[t],this.__values__[t]]}),_unBind:i(function(){this.__values__=null,u.call(this)}),toString:i(function(){return"[object Map Iterator]"})}),Object.defineProperty(n.prototype,a,i("c","Map Iterator"))},"14ab":function(t,e,r){"use strict";t.exports=function(){var t,e=Object.assign;return"function"===typeof e&&(t={foo:"raz"},e(t,{bar:"dwa"},{trzy:"trzy"}),t.foo+t.bar+t.trzy==="razdwatrzy")}},"14cf":function(t,e,r){"use strict";t.exports=function(){var t,e,r=Array.from;return"function"===typeof r&&(t=["raz","dwa"],e=r(t),Boolean(e&&e!==t&&"dwa"===e[1]))}},"175c":function(t,e,r){"use strict";r.r(e);var n=function(){var t=this,e=t.$createElement,r=t._self._c||e;return r("div",{staticClass:"websocket"},[r("div",{staticClass:"app-wrapper"},[r("el-tabs",{attrs:{type:"card","before-leave":t.handleBeforeLeave},on:{"tab-remove":t.handleTabEdit},model:{value:t.activeTab,callback:function(e){t.activeTab=e},expression:"activeTab"}},[t._l(t.tabs,function(e,n){return r("el-tab-pane",{key:n,attrs:{closable:n>0,name:e.name}},[r("span",{attrs:{slot:"label"},slot:"label"},[r("el-badge",{staticClass:"message-count",attrs:{hidden:0===e.messageCount,value:e.messageCount,max:99}},[t._v("\n            "+t._s(e.label)+"\n          ")])],1)])}),r("el-tab-pane",{key:"add",staticClass:"add-btn",attrs:{name:"add"}},[r("span",{attrs:{slot:"label"},slot:"label"},[r("i",{staticClass:"el-icon-plus"})])])],2),t._l(t.tabs,function(e,n){return r("web-socket-item",{directives:[{name:"show",rawName:"v-show",value:e.name===t.activeTab,expression:"item.name === activeTab"}],key:n,ref:e.name,refInFor:!0,attrs:{"message-count":e.messageCount},on:{"update:messageCount":function(r){return t.$set(e,"messageCount",r)},"update:message-count":function(r){return t.$set(e,"messageCount",r)}}})})],2)])},o=[],i=(r("ac6a"),r("6b54"),r("7f7f"),r("7514"),function(){var t=this,e=t.$createElement,r=t._self._c||e;return r("div",{staticClass:"websocket-item"},[r("el-card",{staticClass:"emq-list-card"},[r("div",{staticClass:"websocket-config"},[r("div",{staticClass:"emq-title"},[t._v("\n        "+t._s(t.$t("Tools.connectionConfiguration"))+"\n      ")]),r("el-form",{ref:"configForm",attrs:{"hide-required-asterisk":"",size:"small","label-position":"top",model:t.connection,rules:t.connectionRules},nativeOn:{keyup:function(e){return!e.type.indexOf("key")&&t._k(e.keyCode,"enter",13,e.key,"Enter")?null:t.createConnection(e)}}},[r("el-row",{attrs:{gutter:20}},[r("el-col",{attrs:{span:8}},[r("el-form-item",{attrs:{prop:"host",label:t.$t("Tools.host")}},[r("el-input",{attrs:{readonly:t.client.connected},model:{value:t.connection.host,callback:function(e){t.$set(t.connection,"host",e)},expression:"connection.host"}})],1)],1),r("el-col",{attrs:{span:8}},[r("el-form-item",{attrs:{prop:"port",label:t.$t("Tools.port")}},[r("el-input",{attrs:{type:"number",placeholder:"8083/8084",readonly:t.client.connected},model:{value:t.connection.port,callback:function(e){t.$set(t.connection,"port",t._n(e))},expression:"connection.port"}})],1)],1),r("el-col",{attrs:{span:8}},[r("el-form-item",{attrs:{prop:"endpoint",label:t.$t("Tools.mountPoint")}},[r("el-input",{attrs:{placeholder:"/mqtt",readonly:t.client.connected},model:{value:t.connection.endpoint,callback:function(e){t.$set(t.connection,"endpoint",e)},expression:"connection.endpoint"}})],1)],1),r("el-col",{attrs:{span:8}},[r("el-form-item",{attrs:{prop:"clientId",label:"Client ID"}},[r("el-input",{attrs:{readonly:t.client.connected},model:{value:t.connection.clientId,callback:function(e){t.$set(t.connection,"clientId",e)},expression:"connection.clientId"}},[r("i",{staticClass:"el-icon-refresh el-input_icon",attrs:{slot:"suffix",title:t.$t("Tools.randomGeneration"),disabled:t.client.connected},on:{click:t.refreshClientId},slot:"suffix"})])],1)],1),r("el-col",{attrs:{span:8}},[r("el-form-item",{attrs:{prop:"username",label:"Username"}},[r("el-input",{attrs:{readonly:t.client.connected},model:{value:t.connection.username,callback:function(e){t.$set(t.connection,"username",e)},expression:"connection.username"}})],1)],1),r("el-col",{attrs:{span:8}},[r("el-form-item",{attrs:{prop:"password",label:"Password"}},[r("el-input",{attrs:{readonly:t.client.connected},model:{value:t.connection.password,callback:function(e){t.$set(t.connection,"password",e)},expression:"connection.password"}})],1)],1),r("el-col",{attrs:{span:8}},[r("el-form-item",{attrs:{prop:"keepalive",label:"Keepalive"}},[r("el-input",{attrs:{readonly:t.client.connected,type:"number",placeholder:"60"},model:{value:t.connection.keepalive,callback:function(e){t.$set(t.connection,"keepalive",t._n(e))},expression:"connection.keepalive"}})],1)],1),r("el-col",{staticClass:"footer-area",attrs:{span:24}},[r("el-checkbox",{attrs:{disabled:t.client.connected},model:{value:t.connection.clean,callback:function(e){t.$set(t.connection,"clean",e)},expression:"connection.clean"}},[t._v("\n              Clean Session\n            ")]),r("el-checkbox",{attrs:{disabled:t.client.connected},on:{change:t.protocolsChange},model:{value:t.connection.ssl,callback:function(e){t.$set(t.connection,"ssl",e)},expression:"connection.ssl"}},[t._v("\n              SSL\n            ")])],1),r("el-col",{staticClass:"footer-area",attrs:{span:24}},[r("el-button",{staticClass:"conn-btn",staticStyle:{"margin-right":"20px"},attrs:{type:"primary",size:"small",disabled:t.client.connected||t.connecting},on:{click:t.createConnection}},[t._v("\n              "+t._s(t.client.connected?t.$t("Tools.connected"):t.connecting?t.$t("Tools.inConnection"):t.$t("Tools.connect"))+"\n            ")]),r("el-button",{staticClass:"conn-btn",attrs:{type:"danger",size:"small",disabled:!t.client.connected&&!t.connecting},on:{click:t.destroyConnection}},[t._v("\n              "+t._s(t.connecting?t.$t("Tools.cancelConnection"):t.$t("Tools.disconnect"))+"\n            ")])],1)],1)],1)],1)]),r("el-card",{staticClass:"emq-list-card"},[r("div",{staticClass:"emq-title"},[t._v("\n      "+t._s(t.$t("Tools.Subscription"))+"\n    ")]),r("el-row",{attrs:{gutter:20}},[r("el-col",{attrs:{span:12}},[r("el-form",{ref:"subForm",attrs:{"hide-required-asterisk":"",model:t.subscriptionsRecord,rules:t.subscriptionsRules,size:"small","label-position":"top"},nativeOn:{keyup:function(e){return!e.type.indexOf("key")&&t._k(e.keyCode,"enter",13,e.key,"Enter")?null:t._doSubscribe(e)}}},[r("el-form-item",{attrs:{prop:"topic",label:"Topic"}},[r("el-input",{model:{value:t.subscriptionsRecord.topic,callback:function(e){t.$set(t.subscriptionsRecord,"topic",e)},expression:"subscriptionsRecord.topic"}})],1),r("el-form-item",{attrs:{prop:"qos",label:"QoS"}},[r("emq-select",{attrs:{field:{list:[0,1,2]}},model:{value:t.subscriptionsRecord.qos,callback:function(e){t.$set(t.subscriptionsRecord,"qos",t._n(e))},expression:"subscriptionsRecord.qos"}})],1),r("div",[r("el-form-item",[r("el-button",{staticClass:"conn-btn",attrs:{type:"primary",size:"small"},on:{click:t._doSubscribe}},[t._v("\n                "+t._s(t.$t("Tools.Subscribe"))+"\n              ")])],1)],1)],1)],1),r("el-col",{attrs:{span:12}},[r("el-table",{staticStyle:{"margin-top":"10px"},attrs:{data:t.subscriptions,"max-height":"400px"}},[r("el-table-column",{attrs:{"show-overflow-tooltip":"",prop:"topic",label:"Topic","min-width":"180px"}}),r("el-table-column",{attrs:{prop:"qos",label:"QoS",width:"80px"}}),r("el-table-column",{attrs:{prop:"createAt",label:t.$t("Tools.time")}}),r("el-table-column",{attrs:{width:"80px"},scopedSlots:t._u([{key:"default",fn:function(e){var n=e.row;return[r("a",{staticClass:"btn",on:{click:function(e){return t._doUnSubscribe(n)}}},[t._v(t._s(t.$t("Base.cancel")))])]}}])})],1)],1)],1)],1),r("el-card",{staticClass:"emq-list-card"},[r("div",{staticClass:"emq-title"},[t._v("\n      "+t._s(t.$t("Tools.publish"))+"\n    ")]),r("div",{staticClass:"connection-wrapper"},[r("el-form",{ref:"pubForm",attrs:{"hide-required-asterisk":"","label-position":"top",model:t.messageRecord,rules:t.messageRecordRules,size:"small"},nativeOn:{keyup:function(e){return!e.type.indexOf("key")&&t._k(e.keyCode,"enter",13,e.key,"Enter")?null:t._doPublish(e)}}},[r("el-row",{attrs:{gutter:20}},[r("el-col",{attrs:{span:6}},[r("el-form-item",{attrs:{prop:"topic",label:"Topic"}},[r("el-input",{attrs:{size:"small"},model:{value:t.messageRecord.topic,callback:function(e){t.$set(t.messageRecord,"topic",e)},expression:"messageRecord.topic"}})],1)],1),r("el-col",{attrs:{span:6}},[r("el-form-item",{attrs:{prop:"payload",label:"Payload"}},[r("el-input",{attrs:{size:"small"},model:{value:t.messageRecord.payload,callback:function(e){t.$set(t.messageRecord,"payload",e)},expression:"messageRecord.payload"}})],1)],1),r("el-col",{attrs:{span:6}},[r("el-form-item",{attrs:{prop:"qos",label:"QoS"}},[r("emq-select",{attrs:{field:{list:[0,1,2]},size:"small"},model:{value:t.messageRecord.qos,callback:function(e){t.$set(t.messageRecord,"qos",t._n(e))},expression:"messageRecord.qos"}})],1)],1),r("el-col",{attrs:{span:6}},[r("el-form-item",[r("span",{attrs:{slot:"label"},slot:"label"},[t._v(" ")]),r("el-checkbox",{staticStyle:{"margin-right":"20px"},model:{value:t.messageRecord.retain,callback:function(e){t.$set(t.messageRecord,"retain",e)},expression:"messageRecord.retain"}},[t._v("Retain")]),r("el-button",{staticClass:"conn-btn",staticStyle:{float:"right"},attrs:{type:"primary",size:"small"},on:{click:t._doPublish}},[t._v("\n                "+t._s(t.$t("Tools.publish"))+"\n              ")])],1)],1)],1)],1)],1),r("el-row",{attrs:{gutter:20}},[r("el-col",{attrs:{span:12}},[r("div",{staticClass:"message-btn"},[t._v("\n          "+t._s(t.$t("Tools.received"))+"\n          "),r("i",{staticClass:"icon el-icon-refresh",attrs:{title:t.$t("Tools.clear")},on:{click:function(e){t.messageIn=[]}}})]),r("el-table",{staticClass:"list-table",staticStyle:{"margin-top":"10px"},attrs:{data:t.messageIn,"max-height":"400px"}},[r("el-table-column",{attrs:{"show-overflow-tooltip":"",prop:"topic",label:"Topic","min-width":"120px"}}),r("el-table-column",{attrs:{prop:"qos",label:"QoS",width:"80px"},scopedSlots:t._u([{key:"default",fn:function(e){var r=e.row;return[t._v(" "+t._s(r.qos)+" "+t._s(r.retain?" Retain":"")+" ")]}}])}),r("el-table-column",{attrs:{"show-overflow-tooltip":"",prop:"payload",label:"Payload","min-width":"180px"},scopedSlots:t._u([{key:"default",fn:function(e){var n=e.row;return[r("code",[t._v(t._s(n.payload))])]}}])}),r("el-table-column",{attrs:{prop:"createAt",label:t.$t("Tools.time")}})],1)],1),r("el-col",{attrs:{span:12}},[r("div",{staticClass:"message-btn"},[t._v("\n          "+t._s(t.$t("Tools.published"))+"\n          "),r("i",{staticClass:"icon el-icon-refresh",attrs:{title:t.$t("Tools.clear")},on:{click:function(e){t.messageOut=[]}}})]),r("el-table",{staticClass:"list-table",staticStyle:{"margin-top":"10px"},attrs:{data:t.messageOut,"max-height":"400px"}},[r("el-table-column",{attrs:{"show-overflow-tooltip":"",prop:"topic",label:"Topic","min-width":"120px"}}),r("el-table-column",{attrs:{prop:"qos",label:"QoS",width:"80px"},scopedSlots:t._u([{key:"default",fn:function(e){var r=e.row;return[t._v(" "+t._s(r.qos)+" "+t._s(r.retain?" Retain":"")+" ")]}}])}),r("el-table-column",{attrs:{"show-overflow-tooltip":"",prop:"payload",label:"Payload","min-width":"180px"},scopedSlots:t._u([{key:"default",fn:function(e){var n=e.row;return[r("code",[t._v(t._s(n.payload))])]}}])}),r("el-table-column",{attrs:{prop:"createAt",label:t.$t("Tools.time")}})],1)],1)],1)],1)],1)}),s=[],a=r("cebc"),c=(r("6762"),r("2fdb"),r("96cf"),r("3b8d")),l=(r("f559"),r("c5f6"),r("e7fc")),u=r.n(l),p=r("c1df"),h=r.n(p),f={name:"WebSocketItem",components:{},props:{messageCount:{type:Number,default:0}},data:function(){return{times:0,maxTims:4,connecting:!1,messageRecordRules:{topic:{required:!0,message:this.$t("Tools.pleaseEnter")}},stateIcon:{0:"el-icon-message",1:"el-icon-loading",3:"el-icon-warning"},connectionRules:{host:{required:!0},port:[{type:"number",required:!0,message:this.$t("Tools.pleaseEnter")},{type:"number",min:1,max:65535,message:this.$t("Tools.rangeError")}],keepalive:[{type:"number",required:!0,message:this.$t("Tools.pleaseEnter")},{type:"number",min:0,message:this.$t("Tools.rangeError")}]},subscriptionsRules:{topic:[{required:!0,message:this.$t("Tools.pleaseEnter")}]},client:{reconnecting:!1},connection:{host:this.getOption().host,port:this.getOption().port,protocols:this.getOption().protocols,clientId:this.getOption().clientId,ssl:this.getOption().ssl,endpoint:"/mqtt",username:"",password:"",keepalive:60,clean:!0,reconnectPeriod:4e3,connectTimeout:4e3,will:{topic:"",payload:"",qos:0,retain:!1}},messageRecord:{topic:"testtopic/1",qos:0,payload:'{ "msg": "hello" }',retain:!1},subscriptionsRecord:{topic:"testtopic/#",qos:0},subscriptions:[],messageIn:[],messageOut:[],activeIndex:"0",sessions:[]}},computed:{btnStatusText:function(){var t=this.$t("Tools.connect");return this.client.connected?t=this.$t("Tools.disconnect"):this.client.connecting&&(t=this.$t("Tools.inConnection")),t},connectUrl:function(){var t=this.connection,e=t.host,r=t.port,n=t.ssl,o=t.endpoint,i=n?"wss://":"ws://";return"".concat(i).concat(e,":").concat(r).concat(o.startsWith("/")?"":"/").concat(o)}},beforeDestroy:function(){this.destroyConnection()},methods:{addMessages:function(t,e){var r=5e3;this[t].unshift(e),this[t].length>r&&this[t].pop()},getNow:function(){return h()().format("HH:mm:ss")},onMessage:function(t,e){var r=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},n={out:!1,createAt:this.getNow(),topic:t,payload:e.toString(),qos:r.qos,retain:r.retain};this.addMessages("messageIn",n);var o=this.messageCount;this.$emit("update:messageCount",o+=1)},handleConnect:function(){this.client.connected?this.client.end():this.createConnection()},destroyConnection:function(){if(this.client.connected||this.connecting)try{this.connecting=!1,this.times=0,this.client.end(),this.$notify({title:this.$t("Tools.disconnected"),message:"",type:"success"}),this.connecting=!1}catch(t){this.$message.error(t.toString())}},_doUnSubscribe:function(t){var e=this;this.client.connected?this.client.unsubscribe(t.topic,function(r){r||(e.subscriptions=e.subscriptions.filter(function(e){return e.topic!==t.topic}))}):this.$message.error(this.$t("Tools.clientNotConnected"))},_doSubscribe:function(){var t=Object(c["a"])(regeneratorRuntime.mark(function t(){var e,r,n,o,i=this;return regeneratorRuntime.wrap(function(t){while(1)switch(t.prev=t.next){case 0:return t.next=2,this.$refs.subForm.validate();case 2:if(e=t.sent,e){t.next=5;break}return t.abrupt("return");case 5:if(this.client.connected){t.next=8;break}return this.$message.error(this.$t("Tools.clientNotConnected")),t.abrupt("return");case 8:r=this.subscriptionsRecord,n=r.topic,o=r.qos,this.client.subscribe(n,{qos:o},function(t,e){var r=!1;e.forEach(function(t){[0,1,2].includes(t.qos)||(r=!0)}),t||r?i.$message.error(i.$t("Tools.subscriptionFailure")):i.subscriptions.find(function(t){return t.topic===n})||i.subscriptions.unshift({topic:n,qos:o,createAt:i.getNow()})});case 10:case"end":return t.stop()}},t,this)}));function e(){return t.apply(this,arguments)}return e}(),_doPublish:function(){var t=Object(c["a"])(regeneratorRuntime.mark(function t(){var e,r,n,o,i,s,a=this;return regeneratorRuntime.wrap(function(t){while(1)switch(t.prev=t.next){case 0:return t.next=2,this.$refs.pubForm.validate();case 2:if(e=t.sent,e){t.next=5;break}return t.abrupt("return");case 5:if(this.client.connected){t.next=8;break}return this.$message.error(this.$t("Tools.clientNotConnected")),t.abrupt("return");case 8:r=this.messageRecord,n=r.topic,o=r.qos,i=r.payload,s=r.retain,this.client.publish(n,i,{qos:o,retain:s},function(t){if(t)a.$message.error(a.$t("Tools.publishingFailure"));else{var e={out:!0,createAt:a.getNow(),topic:n,payload:i,qos:o,retain:s};a.addMessages("messageOut",e)}});case 10:case"end":return t.stop()}},t,this)}));function e(){return t.apply(this,arguments)}return e}(),_getDefaultConnection:function(){return Object(a["a"])({},this.getOption(),{endpoint:"/mqtt",username:"",password:"",keepalive:60,clean:!0,reconnectPeriod:4e3,connectTimeout:4e3,will:{topic:"",payload:"",qos:0,retain:!1}})},protocolsChange:function(){var t=this.connection,e=t.port,r=t.ssl;r||8084!==e?r&&8083===e&&(this.connection.port=8084):this.connection.port=8083},refreshClientId:function(){this.client.connected||(this.connection.clientId=this.getOption().clientId)},createConnection:function(){var t=this;if(this.client.connected)return this.connecting=!1,void(this.times=0);this.$refs.configForm.validate(function(e){if(e){var r=t.connection,n=r.clientId,o=r.username,i=r.port,s=r.password,a=r.reconnectPeriod,c=r.keepalive,l=r.clean,p=r.connectTimeout,h=r.will;t.connecting=!0,t.times=0;try{t.client=u.a.connect(t.connectUrl,{port:i,clientId:n,username:o,password:s,reconnectPeriod:a,keepalive:c,clean:l,connectTimeout:p,will:h.topic?h:void 0}),window.client=t.client,t.client.on("error",function(e){t.$message.error(e.toString()),t.connecting=!1;try{t.client.end()}catch(r){t.$message.error(r.toString())}}),t.client.on("reconnect",function(){t.times>t.maxTims&&(t.destroyConnection(),t.$message.error(t.$t("Tools.connectionDisconnected"))),t.connecting&&(t.times+=1)}),t.client.on("connect",function(){t.$notify({title:t.$t("Tools.connected"),message:"",type:"success"}),t.connecting=!1}),t.client.on("message",t.onMessage),t.client.on("reconnection",t.onMessage)}catch(f){t.connecting=!1,t.$message.error(f.toString())}}})},getOption:function(){var t=window.location,e=t.protocol,r=t.hostname;return{host:r,protocols:"http:"===e?"ws":"wss",port:"http:"===e?8083:8084,clientId:"mqttjs_".concat(Math.random().toString(16).substr(2,8)),ssl:"https:"===e}},atSessionChange:function(t){this.activeIndex=t;var e=this.sessions[t];e&&(this.client=e.client||{},this.connection=e.connection||{},this.messageRecord=e.messageRecord||{},this.subscriptionsRecord=e.subscriptionsRecord||{},this.subscriptions=e.subscriptions||[])},sessionChange:function(t){this.activeIndex=t}}},d=f,_=(r("d751"),r("2877")),m=Object(_["a"])(d,i,s,!1,null,null,null),b=m.exports,g={name:"WebSocket",components:{WebSocketItem:b},props:{},data:function(){return{activeTab:"0",tabs:[{name:"0",label:this.$t("Tools.defaultConnection"),messageCount:0}]}},watch:{activeTab:function(t,e){var r=this.tabs.find(function(e){return e.name===t}),n=this.tabs.find(function(t){return t.name===e});n&&(n.messageCount=0),r||(r.messageCount=0)}},methods:{handleBeforeLeave:function(t){return"add"!==t||(this.handleTabEdit("add"),!1)},handleTabEdit:function(t){var e=this;if("add"===t){if(this.tabs.length>6)return void this.$message.error(this.$t("Tools.maxSix"));var r=this.tabs.length.toString();this.tabs.push({name:r,label:this.$t("Tools.connectionName"),messageCount:0}),this.activeTab=r}else{var n=this.$refs[t]&&this.$refs[t][0];if(!n)return;n.client&&n.client.connected&&n.client.end(),this.tabs.forEach(function(r,n){if(r.name===t){var o=e.tabs[n+1]||e.tabs[n-1];o&&(e.activeTab=o.name)}}),this.tabs=this.tabs.filter(function(e){return e.name!==t})}}}},v=g,y=(r("6bc4"),Object(_["a"])(v,n,o,!1,null,null,null));e["default"]=y.exports},"18ec":function(t,e,r){"use strict";var n="razdwatrzy";t.exports=function(){return"function"===typeof n.contains&&(!0===n.contains("dwa")&&!1===n.contains("foo"))}},"1a94":function(t,e,r){"use strict";t.exports=function(t){if("function"!==typeof t)throw new TypeError(t+" is not a function");return t}},"1c4a":function(t,e,r){"use strict";t.exports=r("ba61")()?Symbol:r("94ee")},"1fad":function(t,e,r){"use strict";var n=r("51e9"),o=r("3fb5"),i=r("faa1").EventEmitter,s=r("a7c9"),a=r("b289");function c(t){if(!(this instanceof c))return new c(t);this.settings=t||{},this._states=["_parseHeader","_parseLength","_parsePayload","_newPacket"],this._resetState()}o(c,i),c.prototype._resetState=function(){this.packet=new s,this.error=null,this._list=n(),this._stateCounter=0},c.prototype.parse=function(t){this.error&&this._resetState(),this._list.append(t);while((-1!==this.packet.length||this._list.length>0)&&this[this._states[this._stateCounter]]()&&!this.error)this._stateCounter++,this._stateCounter>=this._states.length&&(this._stateCounter=0);return this._list.length},c.prototype._parseHeader=function(){var t=this._list.readUInt8(0);return this.packet.cmd=a.types[t>>a.CMD_SHIFT],this.packet.retain=0!==(t&a.RETAIN_MASK),this.packet.qos=t>>a.QOS_SHIFT&a.QOS_MASK,this.packet.dup=0!==(t&a.DUP_MASK),this._list.consume(1),!0},c.prototype._parseLength=function(){var t=this._parseVarByteNum(!0);return t&&(this.packet.length=t.value,this._list.consume(t.bytes)),!!t},c.prototype._parsePayload=function(){var t=!1;if(0===this.packet.length||this._list.length>=this.packet.length){switch(this._pos=0,this.packet.cmd){case"connect":this._parseConnect();break;case"connack":this._parseConnack();break;case"publish":this._parsePublish();break;case"puback":case"pubrec":case"pubrel":case"pubcomp":this._parseConfirmation();break;case"subscribe":this._parseSubscribe();break;case"suback":this._parseSuback();break;case"unsubscribe":this._parseUnsubscribe();break;case"unsuback":this._parseUnsuback();break;case"pingreq":case"pingresp":break;case"disconnect":this._parseDisconnect();break;case"auth":this._parseAuth();break;default:this._emitError(new Error("Not supported"))}t=!0}return t},c.prototype._parseConnect=function(){var t,e,r,n,o,i,s={},c=this.packet;if(t=this._parseString(),null===t)return this._emitError(new Error("Cannot parse protocolId"));if("MQTT"!==t&&"MQIsdp"!==t)return this._emitError(new Error("Invalid protocolId"));if(c.protocolId=t,this._pos>=this._list.length)return this._emitError(new Error("Packet too short"));if(c.protocolVersion=this._list.readUInt8(this._pos),3!==c.protocolVersion&&4!==c.protocolVersion&&5!==c.protocolVersion)return this._emitError(new Error("Invalid protocol version"));if(this._pos++,this._pos>=this._list.length)return this._emitError(new Error("Packet too short"));if(s.username=this._list.readUInt8(this._pos)&a.USERNAME_MASK,s.password=this._list.readUInt8(this._pos)&a.PASSWORD_MASK,s.will=this._list.readUInt8(this._pos)&a.WILL_FLAG_MASK,s.will&&(c.will={},c.will.retain=0!==(this._list.readUInt8(this._pos)&a.WILL_RETAIN_MASK),c.will.qos=(this._list.readUInt8(this._pos)&a.WILL_QOS_MASK)>>a.WILL_QOS_SHIFT),c.clean=0!==(this._list.readUInt8(this._pos)&a.CLEAN_SESSION_MASK),this._pos++,c.keepalive=this._parseNum(),-1===c.keepalive)return this._emitError(new Error("Packet too short"));if(5===c.protocolVersion){var l=this._parseProperties();Object.getOwnPropertyNames(l).length&&(c.properties=l)}if(e=this._parseString(),null===e)return this._emitError(new Error("Packet too short"));if(c.clientId=e,s.will){if(5===c.protocolVersion){var u=this._parseProperties();Object.getOwnPropertyNames(u).length&&(c.will.properties=u)}if(r=this._parseString(),null===r)return this._emitError(new Error("Cannot parse will topic"));if(c.will.topic=r,n=this._parseBuffer(),null===n)return this._emitError(new Error("Cannot parse will payload"));c.will.payload=n}if(s.username){if(i=this._parseString(),null===i)return this._emitError(new Error("Cannot parse username"));c.username=i}if(s.password){if(o=this._parseBuffer(),null===o)return this._emitError(new Error("Cannot parse password"));c.password=o}return this.settings=c,c},c.prototype._parseConnack=function(){var t=this.packet;if(this._list.length<2)return null;if(t.sessionPresent=!!(this._list.readUInt8(this._pos++)&a.SESSIONPRESENT_MASK),5===this.settings.protocolVersion?t.reasonCode=this._list.readUInt8(this._pos++):t.returnCode=this._list.readUInt8(this._pos++),-1===t.returnCode||-1===t.reasonCode)return this._emitError(new Error("Cannot parse return code"));if(5===this.settings.protocolVersion){var e=this._parseProperties();Object.getOwnPropertyNames(e).length&&(t.properties=e)}},c.prototype._parsePublish=function(){var t=this.packet;if(t.topic=this._parseString(),null===t.topic)return this._emitError(new Error("Cannot parse topic"));if(!(t.qos>0)||this._parseMessageId()){if(5===this.settings.protocolVersion){var e=this._parseProperties();Object.getOwnPropertyNames(e).length&&(t.properties=e)}t.payload=this._list.slice(this._pos,t.length)}},c.prototype._parseSubscribe=function(){var t,e,r,n,o,i,s,c=this.packet;if(1!==c.qos)return this._emitError(new Error("Wrong subscribe header"));if(c.subscriptions=[],this._parseMessageId()){if(5===this.settings.protocolVersion){var l=this._parseProperties();Object.getOwnPropertyNames(l).length&&(c.properties=l)}while(this._pos<c.length){if(t=this._parseString(),null===t)return this._emitError(new Error("Cannot parse topic"));if(this._pos>=c.length)return this._emitError(new Error("Malformed Subscribe Payload"));e=this._parseByte(),r=e&a.SUBSCRIBE_OPTIONS_QOS_MASK,i=0!==(e>>a.SUBSCRIBE_OPTIONS_NL_SHIFT&a.SUBSCRIBE_OPTIONS_NL_MASK),o=0!==(e>>a.SUBSCRIBE_OPTIONS_RAP_SHIFT&a.SUBSCRIBE_OPTIONS_RAP_MASK),n=e>>a.SUBSCRIBE_OPTIONS_RH_SHIFT&a.SUBSCRIBE_OPTIONS_RH_MASK,s={topic:t,qos:r},5===this.settings.protocolVersion&&(s.nl=i,s.rap=o,s.rh=n),c.subscriptions.push(s)}}},c.prototype._parseSuback=function(){var t=this.packet;if(this.packet.granted=[],this._parseMessageId()){if(5===this.settings.protocolVersion){var e=this._parseProperties();Object.getOwnPropertyNames(e).length&&(t.properties=e)}while(this._pos<this.packet.length)this.packet.granted.push(this._list.readUInt8(this._pos++))}},c.prototype._parseUnsubscribe=function(){var t=this.packet;if(t.unsubscriptions=[],this._parseMessageId()){if(5===this.settings.protocolVersion){var e=this._parseProperties();Object.getOwnPropertyNames(e).length&&(t.properties=e)}while(this._pos<t.length){var r;if(r=this._parseString(),null===r)return this._emitError(new Error("Cannot parse topic"));t.unsubscriptions.push(r)}}},c.prototype._parseUnsuback=function(){var t=this.packet;if(!this._parseMessageId())return this._emitError(new Error("Cannot parse messageId"));if(5===this.settings.protocolVersion){var e=this._parseProperties();Object.getOwnPropertyNames(e).length&&(t.properties=e),t.granted=[];while(this._pos<this.packet.length)this.packet.granted.push(this._list.readUInt8(this._pos++))}},c.prototype._parseConfirmation=function(){var t=this.packet;if(this._parseMessageId(),5===this.settings.protocolVersion&&t.length>2){t.reasonCode=this._parseByte();var e=this._parseProperties();Object.getOwnPropertyNames(e).length&&(t.properties=e)}return!0},c.prototype._parseDisconnect=function(){var t=this.packet;if(5===this.settings.protocolVersion){t.reasonCode=this._parseByte();var e=this._parseProperties();Object.getOwnPropertyNames(e).length&&(t.properties=e)}return!0},c.prototype._parseAuth=function(){var t=this.packet;if(5!==this.settings.protocolVersion)return this._emitError(new Error("Not supported auth packet for this version MQTT"));t.reasonCode=this._parseByte();var e=this._parseProperties();return Object.getOwnPropertyNames(e).length&&(t.properties=e),!0},c.prototype._parseMessageId=function(){var t=this.packet;return t.messageId=this._parseNum(),null!==t.messageId||(this._emitError(new Error("Cannot parse messageId")),!1)},c.prototype._parseString=function(t){var e,r=this._parseNum(),n=r+this._pos;return-1===r||n>this._list.length||n>this.packet.length?null:(e=this._list.toString("utf8",this._pos,n),this._pos+=r,e)},c.prototype._parseStringPair=function(){return{name:this._parseString(),value:this._parseString()}},c.prototype._parseBuffer=function(){var t,e=this._parseNum(),r=e+this._pos;return-1===e||r>this._list.length||r>this.packet.length?null:(t=this._list.slice(this._pos,r),this._pos+=e,t)},c.prototype._parseNum=function(){if(this._list.length-this._pos<2)return-1;var t=this._list.readUInt16BE(this._pos);return this._pos+=2,t},c.prototype._parse4ByteNum=function(){if(this._list.length-this._pos<4)return-1;var t=this._list.readUInt32BE(this._pos);return this._pos+=4,t},c.prototype._parseVarByteNum=function(t){var e,r=0,n=1,o=0,i=!0,s=this._pos?this._pos:0;while(r<5){if(e=this._list.readUInt8(s+r++),o+=n*(e&a.LENGTH_MASK),n*=128,0===(e&a.LENGTH_FIN_MASK))break;if(this._list.length<=r){i=!1;break}}return s&&(this._pos+=r),i=!!i&&(t?{bytes:r,value:o}:o),i},c.prototype._parseByte=function(){var t=this._list.readUInt8(this._pos);return this._pos++,t},c.prototype._parseByType=function(t){switch(t){case"byte":return 0!==this._parseByte();case"int8":return this._parseByte();case"int16":return this._parseNum();case"int32":return this._parse4ByteNum();case"var":return this._parseVarByteNum();case"string":return this._parseString();case"pair":return this._parseStringPair();case"binary":return this._parseBuffer()}},c.prototype._parseProperties=function(){var t=this._parseVarByteNum(),e=this._pos,r=e+t,n={};while(this._pos<r){var o=this._parseByte(),i=a.propertiesCodes[o];if(!i)return this._emitError(new Error("Unknown property")),!1;if("userProperties"!==i)n[i]=this._parseByType(a.propertiesTypes[i]);else{n[i]||(n[i]={});var s=this._parseByType(a.propertiesTypes[i]);if(n[i][s.name])if(Array.isArray(n[i][s.name]))n[i][s.name].push(s.value);else{var c=n[i][s.name];n[i][s.name]=[c],n[i][s.name].push(s.value)}else n[i][s.name]=s.value}}return n},c.prototype._newPacket=function(){return this.packet&&(this._list.consume(this.packet.length),this.emit("packet",this.packet)),this.packet=new s,this._pos=0,!0},c.prototype._emitError=function(t){this.error=t,this.emit("error",t)},t.exports=c},2031:function(t,e,r){"use strict";t.exports=r("14ab")()?Object.assign:r("f60e")},2160:function(t,e,r){"use strict";var n=r("62c4"),o={function:!0,object:!0};t.exports=function(t){return n(t)&&o[typeof t]||!1}},"29a2":function(t,e,r){"use strict";function n(t,e,r){var n=this;this._callback=t,this._args=r,this._interval=setInterval(t,e,this._args),this.reschedule=function(t){t||(t=n._interval),n._interval&&clearInterval(n._interval),n._interval=setInterval(n._callback,t,n._args)},this.clear=function(){n._interval&&(clearInterval(n._interval),n._interval=void 0)},this.destroy=function(){n._interval&&clearInterval(n._interval),n._callback=void 0,n._interval=void 0,n._args=void 0}}function o(){if("function"!==typeof arguments[0])throw new Error("callback needed");if("number"!==typeof arguments[1])throw new Error("interval needed");var t;if(arguments.length>0){t=new Array(arguments.length-2);for(var e=0;e<t.length;e++)t[e]=arguments[e+2]}return new n(arguments[0],arguments[1],t)}t.exports=o},"29b0":function(t,e,r){"use strict";t.exports=function(){var t=Number.isNaN;return"function"===typeof t&&(!t({})&&t(NaN)&&!t(34))}},3409:function(t,e,r){"use strict";e.parser=r("1fad"),e.generate=r("7f0f"),e.writeToStream=r("7135")},3473:function(t,e,r){"use strict";var n=r("91e3");t.exports=function(t){if(!n(t))throw new TypeError(t+" is not iterable");return t}},3527:function(t,e,r){"use strict";var n=r("724e"),o=r("d53b4"),i=r("96ae"),s=Array.prototype.indexOf,a=Object.prototype.hasOwnProperty,c=Math.abs,l=Math.floor;t.exports=function(t){var e,r,u,p;if(!n(t))return s.apply(this,arguments);for(r=o(i(this).length),u=arguments[1],u=isNaN(u)?0:u>=0?l(u):o(this.length)-l(c(u)),e=u;e<r;++e)if(a.call(this,e)&&(p=this[e],n(p)))return e;return-1}},"35e86":function(t,e,r){"use strict";t.exports={isString:function(t){return"string"===typeof t},isObject:function(t){return"object"===typeof t&&null!==t},isNull:function(t){return null===t},isNullOrUndefined:function(t){return null==t}}},"3d7a":function(t,e,r){},"3e15":function(t,e,r){"use strict";t.exports=function(){var t,e,r;if("function"!==typeof Map)return!1;try{t=new Map([["raz","one"],["dwa","two"],["trzy","three"]])}catch(n){return!1}return"[object Map]"===String(t)&&(3===t.size&&("function"===typeof t.clear&&("function"===typeof t.delete&&("function"===typeof t.entries&&("function"===typeof t.forEach&&("function"===typeof t.get&&("function"===typeof t.has&&("function"===typeof t.keys&&("function"===typeof t.set&&("function"===typeof t.values&&(e=t.entries(),r=e.next(),!1===r.done&&(!!r.value&&("raz"===r.value[0]&&"one"===r.value[1])))))))))))))}},4665:function(t,e,r){"use strict";var n=r("1a94"),o=r("6858"),i=Function.prototype.call;t.exports=function(t,e){var r={},s=arguments[2];return n(e),o(t,function(t,n,o,a){r[n]=i.call(e,s,t,n,o,a)}),r}},5:function(t,e){},"51e9":function(t,e,r){var n=r("0960"),o=r("3022"),i=r("8707").Buffer;function s(t){if(!(this instanceof s))return new s(t);if(this._bufs=[],this.length=0,"function"==typeof t){this._callback=t;var e=function(t){this._callback&&(this._callback(t),this._callback=null)}.bind(this);this.on("pipe",function(t){t.on("error",e)}),this.on("unpipe",function(t){t.removeListener("error",e)})}else this.append(t);n.call(this)}o.inherits(s,n),s.prototype._offset=function(t){var e,r=0,n=0;if(0===t)return[0,0];for(;n<this._bufs.length;n++){if(e=r+this._bufs[n].length,t<e||n==this._bufs.length-1)return[n,t-r];r=e}},s.prototype.append=function(t){var e=0;if(i.isBuffer(t))this._appendBuffer(t);else if(Array.isArray(t))for(;e<t.length;e++)this.append(t[e]);else if(t instanceof s)for(;e<t._bufs.length;e++)this.append(t._bufs[e]);else null!=t&&("number"==typeof t&&(t=t.toString()),this._appendBuffer(i.from(t)));return this},s.prototype._appendBuffer=function(t){this._bufs.push(t),this.length+=t.length},s.prototype._write=function(t,e,r){this._appendBuffer(t),"function"==typeof r&&r()},s.prototype._read=function(t){if(!this.length)return this.push(null);t=Math.min(t,this.length),this.push(this.slice(0,t)),this.consume(t)},s.prototype.end=function(t){n.prototype.end.call(this,t),this._callback&&(this._callback(null,this.slice()),this._callback=null)},s.prototype.get=function(t){return this.slice(t,t+1)[0]},s.prototype.slice=function(t,e){return"number"==typeof t&&t<0&&(t+=this.length),"number"==typeof e&&e<0&&(e+=this.length),this.copy(null,0,t,e)},s.prototype.copy=function(t,e,r,n){if(("number"!=typeof r||r<0)&&(r=0),("number"!=typeof n||n>this.length)&&(n=this.length),r>=this.length)return t||i.alloc(0);if(n<=0)return t||i.alloc(0);var o,s,a=!!t,c=this._offset(r),l=n-r,u=l,p=a&&e||0,h=c[1];if(0===r&&n==this.length){if(!a)return 1===this._bufs.length?this._bufs[0]:i.concat(this._bufs,this.length);for(s=0;s<this._bufs.length;s++)this._bufs[s].copy(t,p),p+=this._bufs[s].length;return t}if(u<=this._bufs[c[0]].length-h)return a?this._bufs[c[0]].copy(t,e,h,h+u):this._bufs[c[0]].slice(h,h+u);for(a||(t=i.allocUnsafe(l)),s=c[0];s<this._bufs.length;s++){if(o=this._bufs[s].length-h,!(u>o)){this._bufs[s].copy(t,p,h,h+u);break}this._bufs[s].copy(t,p,h),p+=o,u-=o,h&&(h=0)}return t},s.prototype.shallowSlice=function(t,e){t=t||0,e=e||this.length,t<0&&(t+=this.length),e<0&&(e+=this.length);var r=this._offset(t),n=this._offset(e),o=this._bufs.slice(r[0],n[0]+1);return 0==n[1]?o.pop():o[o.length-1]=o[o.length-1].slice(0,n[1]),0!=r[1]&&(o[0]=o[0].slice(r[1])),new s(o)},s.prototype.toString=function(t,e,r){return this.slice(e,r).toString(t)},s.prototype.consume=function(t){while(this._bufs.length){if(!(t>=this._bufs[0].length)){this._bufs[0]=this._bufs[0].slice(t),this.length-=t;break}t-=this._bufs[0].length,this.length-=this._bufs[0].length,this._bufs.shift()}return this},s.prototype.duplicate=function(){for(var t=0,e=new s;t<this._bufs.length;t++)e.append(this._bufs[t]);return e},s.prototype.destroy=function(){this._bufs.length=0,this.length=0,this.push(null)},function(){var t={readDoubleBE:8,readDoubleLE:8,readFloatBE:4,readFloatLE:4,readInt32BE:4,readInt32LE:4,readUInt32BE:4,readUInt32LE:4,readInt16BE:2,readInt16LE:2,readUInt16BE:2,readUInt16LE:2,readInt8:1,readUInt8:1};for(var e in t)(function(e){s.prototype[e]=function(r){return this.slice(r,r+t[e])[e](0)}})(e)}(),t.exports=s},"53a8":function(t,e){t.exports=n;var r=Object.prototype.hasOwnProperty;function n(){for(var t={},e=0;e<arguments.length;e++){var n=arguments[e];for(var o in n)r.call(n,o)&&(t[o]=n[o])}return t}},"546b":function(t,e,r){"use strict";t.exports=r("3e15")()?Map:r("0b24")},"553e":function(t,e,r){"use strict";(function(e,n){var o=r("e372").Transform,i=r("fb12"),s=r("b41e"),a=r("8707").Buffer;function c(t,e,r){var n=new o({objectMode:t.objectMode});return n._write=e,n._flush=r,n}function l(t,r,o){var l,u,p="browser"===e.title,h=!!n.WebSocket,f=p?v:g;r&&!Array.isArray(r)&&"object"===typeof r&&(o=r,r=null,("string"===typeof o.protocol||Array.isArray(o.protocol))&&(r=o.protocol)),o||(o={}),void 0===o.objectMode&&(o.objectMode=!(!0===o.binary||void 0===o.binary));var d=c(o,f,y);o.objectMode||(d._writev=x);var _=o.browserBufferSize||524288,m=o.browserBufferTimeout||1e3;"object"===typeof t?u=t:(u=h&&p?new s(t,r):new s(t,r,o),u.binaryType="arraybuffer"),u.readyState===u.OPEN?l=d:(l=l=i(void 0,void 0,o),o.objectMode||(l._writev=x),u.onopen=w),l.socket=u,u.onclose=S,u.onerror=k,u.onmessage=I,d.on("close",E);var b=!o.objectMode;function g(t,e,r){u.readyState===u.OPEN?(b&&"string"===typeof t&&(t=a.from(t,"utf8")),u.send(t,r)):r()}function v(t,e,r){if(u.bufferedAmount>_)setTimeout(v,m,t,e,r);else{b&&"string"===typeof t&&(t=a.from(t,"utf8"));try{u.send(t)}catch(n){return r(n)}r()}}function y(t){u.close(),t()}function w(){l.setReadable(d),l.setWritable(d),l.emit("connect")}function S(){l.end(),l.destroy()}function k(t){l.destroy(t)}function I(t){var e=t.data;e=e instanceof ArrayBuffer?a.from(e):a.from(e,"utf8"),d.push(e)}function E(){u.close()}function x(t,e){for(var r=new Array(t.length),n=0;n<t.length;n++)"string"===typeof t[n].chunk?r[n]=a.from(t[n],"utf8"):r[n]=t[n].chunk;this._write(a.concat(r),"binary",e)}return l}t.exports=l}).call(this,r("f28c"),r("c8ba"))},"566b":function(t,e,r){var n=r("d633");function o(t){var e=function(){return e.called?e.value:(e.called=!0,e.value=t.apply(this,arguments))};return e.called=!1,e}function i(t){var e=function(){if(e.called)throw new Error(e.onceError);return e.called=!0,e.value=t.apply(this,arguments)},r=t.name||"Function wrapped with `once`";return e.onceError=r+" shouldn't be called more than once",e.called=!1,e}t.exports=n(o),t.exports.strict=n(i),o.proto=o(function(){Object.defineProperty(Function.prototype,"once",{value:function(){return o(this)},configurable:!0}),Object.defineProperty(Function.prototype,"onceStrict",{value:function(){return i(this)},configurable:!0})})},"56c4":function(t,e,r){"use strict";t.exports=function(t){return t!==t}},"5a5c":function(t,e,r){"use strict";var n=Array.prototype.forEach,o=Object.create;t.exports=function(t){var e=o(null);return n.call(arguments,function(t){e[t]=!0}),e}},6:function(t,e){},6024:function(t,e,r){"use strict";var n,o=r("e0f6"),i=r("f973"),s=r("f508"),a=r("1c4a"),c=r("06a2"),l=Object.defineProperty;n=t.exports=function(t,e){if(!(this instanceof n))throw new TypeError("Constructor requires 'new'");c.call(this,t),e=e?i.call(e,"key+value")?"key+value":i.call(e,"key")?"key":"value":"value",l(this,"__kind__",s("",e))},o&&o(n,c),delete n.prototype.constructor,n.prototype=Object.create(c.prototype,{_resolve:s(function(t){return"value"===this.__kind__?this.__list__[t]:"key+value"===this.__kind__?[t,this.__list__[t]]:t})}),l(n.prototype,a.toStringTag,s("c","Array Iterator"))},"62c4":function(t,e,r){"use strict";var n=r("e76c")();t.exports=function(t){return t!==n&&null!==t}},6858:function(t,e,r){"use strict";t.exports=r("cecf")("forEach")},"692b1":function(t,e,r){"use strict";var n=Object.prototype.toString,o=n.call("");t.exports=function(t){return"string"===typeof t||t&&"object"===typeof t&&(t instanceof String||n.call(t)===o)||!1}},"6bc4":function(t,e,r){"use strict";var n=r("9e04"),o=r.n(n);o.a},7045:function(t,e,r){"use strict";var n=Object.prototype.toString,o=n.call(r("e76c"));t.exports=function(t){return"function"===typeof t&&n.call(t)===o}},7135:function(t,e,r){"use strict";var n=r("b289"),o=r("8707").Buffer,i=o.allocUnsafe(0),s=o.from([0]),a=r("f0cb"),c=r("966d").nextTick,l=a.cache,u=a.generateNumber,p=a.generateCache,h=a.genBufVariableByteInt,f=a.generate4ByteBuffer,d=R,_=!0;function m(t,e,r){switch(e.cork&&(e.cork(),c(b,e)),_&&(_=!1,p()),t.cmd){case"connect":return g(t,e,r);case"connack":return v(t,e,r);case"publish":return y(t,e,r);case"puback":case"pubrec":case"pubrel":case"pubcomp":return w(t,e,r);case"subscribe":return S(t,e,r);case"suback":return k(t,e,r);case"unsubscribe":return I(t,e,r);case"unsuback":return E(t,e,r);case"pingreq":case"pingresp":return x(t,e,r);case"disconnect":return O(t,e,r);case"auth":return P(t,e,r);default:return e.emit("error",new Error("Unknown command")),!1}}function b(t){t.uncork()}function g(t,e,r){var i=t||{},s=i.protocolId||"MQTT",a=i.protocolVersion||4,c=i.will,l=i.clean,u=i.keepalive||0,p=i.clientId||"",h=i.username,f=i.password,_=i.properties;void 0===l&&(l=!0);var m=0;if(!s||"string"!==typeof s&&!o.isBuffer(s))return e.emit("error",new Error("Invalid protocolId")),!1;if(m+=s.length+2,3!==a&&4!==a&&5!==a)return e.emit("error",new Error("Invalid protocol version")),!1;if(m+=1,"string"!==typeof p&&!o.isBuffer(p)||!p&&4!==a||!p&&!l){if(a<4)return e.emit("error",new Error("clientId must be supplied before 3.1.1")),!1;if(1*l===0)return e.emit("error",new Error("clientId must be given if cleanSession set to 0")),!1}else m+=p.length+2;if("number"!==typeof u||u<0||u>65535||u%1!==0)return e.emit("error",new Error("Invalid keepalive")),!1;if(m+=2,m+=1,5===a){var b=B(e,_);m+=b.length}if(c){if("object"!==typeof c)return e.emit("error",new Error("Invalid will")),!1;if(!c.topic||"string"!==typeof c.topic)return e.emit("error",new Error("Invalid will topic")),!1;if(m+=o.byteLength(c.topic)+2,m+=2,c.payload){if(!(c.payload.length>=0))return e.emit("error",new Error("Invalid will payload")),!1;"string"===typeof c.payload?m+=o.byteLength(c.payload):m+=c.payload.length}var g={};5===a&&(g=B(e,c.properties),m+=g.length)}var v=!1;if(null!=h){if(!$(h))return e.emit("error",new Error("Invalid username")),!1;v=!0,m+=o.byteLength(h)+2}if(null!=f){if(!v)return e.emit("error",new Error("Username is required to use password")),!1;if(!$(f))return e.emit("error",new Error("Invalid password")),!1;m+=D(f)+2}e.write(n.CONNECT_HEADER),C(e,m),N(e,s),e.write(4===a?n.VERSION4:5===a?n.VERSION5:n.VERSION3);var y=0;return y|=null!=h?n.USERNAME_MASK:0,y|=null!=f?n.PASSWORD_MASK:0,y|=c&&c.retain?n.WILL_RETAIN_MASK:0,y|=c&&c.qos?c.qos<<n.WILL_QOS_SHIFT:0,y|=c?n.WILL_FLAG_MASK:0,y|=l?n.CLEAN_SESSION_MASK:0,e.write(o.from([y])),d(e,u),5===a&&b.write(),N(e,p),c&&(5===a&&g.write(),A(e,c.topic),N(e,c.payload)),null!=h&&N(e,h),null!=f&&N(e,f),!0}function v(t,e,r){var i=r?r.protocolVersion:4,a=t||{},c=5===i?a.reasonCode:a.returnCode,l=a.properties,u=2;if("number"!==typeof c)return e.emit("error",new Error("Invalid return code")),!1;var p=null;return 5===i&&(p=B(e,l),u+=p.length),e.write(n.CONNACK_HEADER),C(e,u),e.write(a.sessionPresent?n.SESSIONPRESENT_HEADER:s),e.write(o.from([c])),null!=p&&p.write(),!0}function y(t,e,r){var s=r?r.protocolVersion:4,a=t||{},c=a.qos||0,l=a.retain?n.RETAIN_MASK:0,u=a.topic,p=a.payload||i,h=a.messageId,f=a.properties,_=0;if("string"===typeof u)_+=o.byteLength(u)+2;else{if(!o.isBuffer(u))return e.emit("error",new Error("Invalid topic")),!1;_+=u.length+2}if(o.isBuffer(p)?_+=p.length:_+=o.byteLength(p),c&&"number"!==typeof h)return e.emit("error",new Error("Invalid messageId")),!1;c&&(_+=2);var m=null;return 5===s&&(m=B(e,f),_+=m.length),e.write(n.PUBLISH_HEADER[c][a.dup?1:0][l?1:0]),C(e,_),d(e,D(u)),e.write(u),c>0&&d(e,h),null!=m&&m.write(),e.write(p)}function w(t,e,r){var i=r?r.protocolVersion:4,s=t||{},a=s.cmd||"puback",c=s.messageId,l=s.dup&&"pubrel"===a?n.DUP_MASK:0,u=0,p=s.reasonCode,h=s.properties,f=5===i?3:2;if("pubrel"===a&&(u=1),"number"!==typeof c)return e.emit("error",new Error("Invalid messageId")),!1;var _=null;if(5===i){if(_=U(e,h,r,f),!_)return!1;f+=_.length}return e.write(n.ACKS[a][u][l][0]),C(e,f),d(e,c),5===i&&e.write(o.from([p])),null!==_&&_.write(),!0}function S(t,e,r){var i=r?r.protocolVersion:4,s=t||{},a=s.dup?n.DUP_MASK:0,c=s.messageId,l=s.subscriptions,u=s.properties,p=0;if("number"!==typeof c)return e.emit("error",new Error("Invalid messageId")),!1;p+=2;var h=null;if(5===i&&(h=B(e,u),p+=h.length),"object"!==typeof l||!l.length)return e.emit("error",new Error("Invalid subscriptions")),!1;for(var f=0;f<l.length;f+=1){var _=l[f].topic,m=l[f].qos;if("string"!==typeof _)return e.emit("error",new Error("Invalid subscriptions - invalid topic")),!1;if("number"!==typeof m)return e.emit("error",new Error("Invalid subscriptions - invalid qos")),!1;if(5===i){var b=l[f].nl||!1;if("boolean"!==typeof b)return e.emit("error",new Error("Invalid subscriptions - invalid No Local")),!1;var g=l[f].rap||!1;if("boolean"!==typeof g)return e.emit("error",new Error("Invalid subscriptions - invalid Retain as Published")),!1;var v=l[f].rh||0;if("number"!==typeof v||v>2)return e.emit("error",new Error("Invalid subscriptions - invalid Retain Handling")),!1}p+=o.byteLength(_)+2+1}e.write(n.SUBSCRIBE_HEADER[1][a?1:0][0]),C(e,p),d(e,c),null!==h&&h.write();for(var y=!0,w=0;w<l.length;w++){var S,k=l[w],I=k.topic,E=k.qos,x=+k.nl,O=+k.rap,P=k.rh;A(e,I),S=n.SUBSCRIBE_OPTIONS_QOS[E],5===i&&(S|=x?n.SUBSCRIBE_OPTIONS_NL:0,S|=O?n.SUBSCRIBE_OPTIONS_RAP:0,S|=P?n.SUBSCRIBE_OPTIONS_RH[P]:0),y=e.write(o.from([S]))}return y}function k(t,e,r){var i=r?r.protocolVersion:4,s=t||{},a=s.messageId,c=s.granted,l=s.properties,u=0;if("number"!==typeof a)return e.emit("error",new Error("Invalid messageId")),!1;if(u+=2,"object"!==typeof c||!c.length)return e.emit("error",new Error("Invalid qos vector")),!1;for(var p=0;p<c.length;p+=1){if("number"!==typeof c[p])return e.emit("error",new Error("Invalid qos vector")),!1;u+=1}var h=null;if(5===i){if(h=U(e,l,r,u),!h)return!1;u+=h.length}return e.write(n.SUBACK_HEADER),C(e,u),d(e,a),null!==h&&h.write(),e.write(o.from(c))}function I(t,e,r){var i=r?r.protocolVersion:4,s=t||{},a=s.messageId,c=s.dup?n.DUP_MASK:0,l=s.unsubscriptions,u=s.properties,p=0;if("number"!==typeof a)return e.emit("error",new Error("Invalid messageId")),!1;if(p+=2,"object"!==typeof l||!l.length)return e.emit("error",new Error("Invalid unsubscriptions")),!1;for(var h=0;h<l.length;h+=1){if("string"!==typeof l[h])return e.emit("error",new Error("Invalid unsubscriptions")),!1;p+=o.byteLength(l[h])+2}var f=null;5===i&&(f=B(e,u),p+=f.length),e.write(n.UNSUBSCRIBE_HEADER[1][c?1:0][0]),C(e,p),d(e,a),null!==f&&f.write();for(var _=!0,m=0;m<l.length;m++)_=A(e,l[m]);return _}function E(t,e,r){var i=r?r.protocolVersion:4,s=t||{},a=s.messageId,c=s.dup?n.DUP_MASK:0,l=s.granted,u=s.properties,p=s.cmd,h=0,f=2;if("number"!==typeof a)return e.emit("error",new Error("Invalid messageId")),!1;if(5===i){if("object"!==typeof l||!l.length)return e.emit("error",new Error("Invalid qos vector")),!1;for(var _=0;_<l.length;_+=1){if("number"!==typeof l[_])return e.emit("error",new Error("Invalid qos vector")),!1;f+=1}}var m=null;if(5===i){if(m=U(e,u,r,f),!m)return!1;f+=m.length}return e.write(n.ACKS[p][h][c][0]),C(e,f),d(e,a),null!==m&&m.write(),5===i&&e.write(o.from(l)),!0}function x(t,e,r){return e.write(n.EMPTY[t.cmd])}function O(t,e,r){var i=r?r.protocolVersion:4,s=t||{},a=s.reasonCode,c=s.properties,l=5===i?1:0,u=null;if(5===i){if(u=U(e,c,r,l),!u)return!1;l+=u.length}return e.write(o.from([n.codes["disconnect"]<<4])),C(e,l),5===i&&e.write(o.from([a])),null!==u&&u.write(),!0}function P(t,e,r){var i=r?r.protocolVersion:4,s=t||{},a=s.reasonCode,c=s.properties,l=5===i?1:0;5!==i&&e.emit("error",new Error("Invalid mqtt version for auth packet"));var u=U(e,c,r,l);return!!u&&(l+=u.length,e.write(o.from([n.codes["auth"]<<4])),C(e,l),e.write(o.from([a])),null!==u&&u.write(),!0)}Object.defineProperty(m,"cacheNumbers",{get:function(){return d===R},set:function(t){t?(l&&0!==Object.keys(l).length||(_=!0),d=R):(_=!1,d=M)}});var T={};function C(t,e){var r=T[e];r||(r=h(e).data,e<16384&&(T[e]=r)),t.write(r)}function A(t,e){var r=o.byteLength(e);d(t,r),t.write(e,"utf8")}function j(t,e,r){A(t,e),A(t,r)}function R(t,e){return t.write(l[e])}function M(t,e){return t.write(u(e))}function q(t,e){return t.write(f(e))}function N(t,e){"string"===typeof e?A(t,e):e?(d(t,e.length),t.write(e)):d(t,0)}function B(t,e){if("object"!==typeof e||null!=e.length)return{length:1,write:function(){L(t,{},0)}};var r=0;function i(r){var i=n.propertiesTypes[r],s=e[r],a=0;switch(i){case"byte":if("boolean"!==typeof s)return t.emit("error",new Error("Invalid "+r)),!1;a+=2;break;case"int8":if("number"!==typeof s)return t.emit("error",new Error("Invalid "+r)),!1;a+=2;break;case"binary":if(s&&null===s)return t.emit("error",new Error("Invalid "+r)),!1;a+=1+o.byteLength(s)+2;break;case"int16":if("number"!==typeof s)return t.emit("error",new Error("Invalid "+r)),!1;a+=3;break;case"int32":if("number"!==typeof s)return t.emit("error",new Error("Invalid "+r)),!1;a+=5;break;case"var":if("number"!==typeof s)return t.emit("error",new Error("Invalid "+r)),!1;a+=1+h(s).length;break;case"string":if("string"!==typeof s)return t.emit("error",new Error("Invalid "+r)),!1;a+=3+o.byteLength(s.toString());break;case"pair":if("object"!==typeof s)return t.emit("error",new Error("Invalid "+r)),!1;a+=Object.getOwnPropertyNames(s).reduce(function(t,e){var r=s[e];return Array.isArray(r)?t+=r.reduce(function(t,r){return t+=3+o.byteLength(e.toString())+2+o.byteLength(r.toString()),t},0):t+=3+o.byteLength(e.toString())+2+o.byteLength(s[e].toString()),t},0);break;default:return t.emit("error",new Error("Invalid property "+r)),!1}return a}if(e)for(var s in e){var a=i(s);if(!a)return!1;r+=a}var c=h(r).length;return{length:c+r,write:function(){L(t,e,r)}}}function U(t,e,r,n){var o=["reasonString","userProperties"],i=r&&r.properties&&r.properties.maximumPacketSize?r.properties.maximumPacketSize:0,s=B(t,e);if(i)while(n+s.length>i){var a=o.shift();if(!a||!e[a])return!1;delete e[a],s=B(t,e)}return s}function L(t,e,r){for(var i in C(t,r),e)if(e.hasOwnProperty(i)&&null!==e[i]){var s=e[i],a=n.propertiesTypes[i];switch(a){case"byte":t.write(o.from([n.properties[i]])),t.write(o.from([+s]));break;case"int8":t.write(o.from([n.properties[i]])),t.write(o.from([s]));break;case"binary":t.write(o.from([n.properties[i]])),N(t,s);break;case"int16":t.write(o.from([n.properties[i]])),d(t,s);break;case"int32":t.write(o.from([n.properties[i]])),q(t,s);break;case"var":t.write(o.from([n.properties[i]])),C(t,s);break;case"string":t.write(o.from([n.properties[i]])),A(t,s);break;case"pair":Object.getOwnPropertyNames(s).forEach(function(e){var r=s[e];Array.isArray(r)?r.forEach(function(r){t.write(o.from([n.properties[i]])),j(t,e.toString(),r.toString())}):(t.write(o.from([n.properties[i]])),j(t,e.toString(),r.toString()))});break;default:return t.emit("error",new Error("Invalid property "+i)),!1}}}function D(t){return t?t instanceof o?t.length:o.byteLength(t):0}function $(t){return"string"===typeof t||t instanceof o}t.exports=m},"724e":function(t,e,r){"use strict";t.exports=r("29b0")()?Number.isNaN:r("56c4")},7373:function(t,e,r){"use strict";var n=r("62c4"),o=Object.keys;t.exports=function(t){return o(n(t)?Object(t):t)}},"7bdf":function(t,e,r){"use strict";t.exports=r("ecf9")()?Object.keys:r("7373")},"7f0f":function(t,e,r){"use strict";var n=r("8707").Buffer,o=r("7135"),i=r("faa1").EventEmitter,s=r("3fb5");function a(t,e){var r=new c;return o(t,r,e),r.concat()}function c(){this._array=new Array(20),this._i=0}s(c,i),c.prototype.write=function(t){return this._array[this._i++]=t,!0},c.prototype.concat=function(){var t,e,r=0,o=new Array(this._array.length),i=this._array,s=0;for(t=0;t<i.length&&void 0!==i[t];t++)"string"!==typeof i[t]?o[t]=i[t].length:o[t]=n.byteLength(i[t]),r+=o[t];for(e=n.allocUnsafe(r),t=0;t<i.length&&void 0!==i[t];t++)"string"!==typeof i[t]?(i[t].copy(e,s),s+=o[t]):(e.write(i[t],s),s+=o[t]);return e},t.exports=a},8311:function(t,e,r){"use strict";(function(e,n){var o,i,s,a=r("e372").Transform,c=r("fb12");function l(){var t=new a;return t._write=function(t,e,r){o.send({data:t.buffer,success:function(){r()},fail:function(t){r(new Error(t))}})},t._flush=function(t){o.close({success:function(){t()}})},t}function u(t){t.hostname||(t.hostname="localhost"),t.path||(t.path="/"),t.wsOptions||(t.wsOptions={})}function p(t,e){var r="wxs"===t.protocol?"wss":"ws",n=r+"://"+t.hostname+t.path;return t.port&&80!==t.port&&443!==t.port&&(n=r+"://"+t.hostname+":"+t.port+t.path),"function"===typeof t.transformWsUrl&&(n=t.transformWsUrl(n,t,e)),n}function h(){o.onOpen(function(){s.setReadable(i),s.setWritable(i),s.emit("connect")}),o.onMessage(function(t){var r=t.data;r=r instanceof ArrayBuffer?e.from(r):e.from(r,"utf8"),i.push(r)}),o.onClose(function(){s.end(),s.destroy()}),o.onError(function(t){s.destroy(new Error(t.errMsg))})}function f(t,e){if(e.hostname=e.hostname||e.host,!e.hostname)throw new Error("Could not determine host. Specify host manually.");var r="MQIsdp"===e.protocolId&&3===e.protocolVersion?"mqttv3.1":"mqtt";u(e);var a=p(e,t);o=wx.connectSocket({url:a,protocols:r}),i=l(),s=c.obj(),s._destroy=function(t,e){o.close({success:function(){e&&e(t)}})};var f=s.destroy;return s.destroy=function(){s.destroy=f;var t=this;n.nextTick(function(){o.close({fail:function(){t._destroy(new Error)}})})}.bind(s),h(),s}t.exports=f}).call(this,r("b639").Buffer,r("f28c"))},"8a50":function(t,e,r){"use strict";var n=r("e9bd"),o=r("692b1"),i=r("6024"),s=r("09d9"),a=r("3473"),c=r("1c4a").iterator;t.exports=function(t){return"function"===typeof a(t)[c]?t[c]():n(t)?new i(t):o(t)?new s(t):new i(t)}},"8fe5":function(t,e,r){"use strict";var n=r("1c4a").iterator,o=r("e9bd"),i=r("7045"),s=r("d53b4"),a=r("1a94"),c=r("96ae"),l=r("62c4"),u=r("692b1"),p=Array.isArray,h=Function.prototype.call,f={configurable:!0,enumerable:!0,writable:!0,value:null},d=Object.defineProperty;t.exports=function(t){var e,r,_,m,b,g,v,y,w,S,k=arguments[1],I=arguments[2];if(t=Object(c(t)),l(k)&&a(k),this&&this!==Array&&i(this))e=this;else{if(!k){if(o(t))return b=t.length,1!==b?Array.apply(null,t):(m=new Array(1),m[0]=t[0],m);if(p(t)){for(m=new Array(b=t.length),r=0;r<b;++r)m[r]=t[r];return m}}m=[]}if(!p(t))if(void 0!==(w=t[n])){v=a(w).call(t),e&&(m=new e),y=v.next(),r=0;while(!y.done)S=k?h.call(k,I,y.value,r):y.value,e?(f.value=S,d(m,r,f)):m[r]=S,y=v.next(),++r;b=r}else if(u(t)){for(b=t.length,e&&(m=new e),r=0,_=0;r<b;++r)S=t[r],r+1<b&&(g=S.charCodeAt(0),g>=55296&&g<=56319&&(S+=t[++r])),S=k?h.call(k,I,S,_):S,e?(f.value=S,d(m,_,f)):m[_]=S,++_;b=_}if(void 0===b)for(b=s(t.length),e&&(m=new e(b)),r=0;r<b;++r)S=k?h.call(k,I,t[r],r):t[r],e?(f.value=S,d(m,r,f)):m[r]=S;return e&&(f.value=null,m.length=b),m}},"91dd":function(t,e,r){"use strict";function n(t,e){return Object.prototype.hasOwnProperty.call(t,e)}t.exports=function(t,e,r,i){e=e||"&",r=r||"=";var s={};if("string"!==typeof t||0===t.length)return s;var a=/\+/g;t=t.split(e);var c=1e3;i&&"number"===typeof i.maxKeys&&(c=i.maxKeys);var l=t.length;c>0&&l>c&&(l=c);for(var u=0;u<l;++u){var p,h,f,d,_=t[u].replace(a,"%20"),m=_.indexOf(r);m>=0?(p=_.substr(0,m),h=_.substr(m+1)):(p=_,h=""),f=decodeURIComponent(p),d=decodeURIComponent(h),n(s,f)?o(s[f])?s[f].push(d):s[f]=[s[f],d]:s[f]=d}return s};var o=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)}},"91e3":function(t,e,r){"use strict";var n=r("e9bd"),o=r("62c4"),i=r("692b1"),s=r("1c4a").iterator,a=Array.isArray;t.exports=function(t){return!!o(t)&&(!!a(t)||(!!i(t)||(!!n(t)||"function"===typeof t[s])))}},"94ee":function(t,e,r){"use strict";var n,o,i,s,a=r("f508"),c=r("b380"),l=Object.create,u=Object.defineProperties,p=Object.defineProperty,h=Object.prototype,f=l(null);if("function"===typeof Symbol){n=Symbol;try{String(n()),s=!0}catch(_){}}var d=function(){var t=l(null);return function(e){var r,n,o=0;while(t[e+(o||"")])++o;return e+=o||"",t[e]=!0,r="@@"+e,p(h,r,a.gs(null,function(t){n||(n=!0,p(this,r,a(t)),n=!1)})),r}}();i=function(t){if(this instanceof i)throw new TypeError("Symbol is not a constructor");return o(t)},t.exports=o=function t(e){var r;if(this instanceof t)throw new TypeError("Symbol is not a constructor");return s?n(e):(r=l(i.prototype),e=void 0===e?"":String(e),u(r,{__description__:a("",e),__name__:a("",d(e))}))},u(o,{for:a(function(t){return f[t]?f[t]:f[t]=o(String(t))}),keyFor:a(function(t){var e;for(e in c(t),f)if(f[e]===t)return e}),hasInstance:a("",n&&n.hasInstance||o("hasInstance")),isConcatSpreadable:a("",n&&n.isConcatSpreadable||o("isConcatSpreadable")),iterator:a("",n&&n.iterator||o("iterator")),match:a("",n&&n.match||o("match")),replace:a("",n&&n.replace||o("replace")),search:a("",n&&n.search||o("search")),species:a("",n&&n.species||o("species")),split:a("",n&&n.split||o("split")),toPrimitive:a("",n&&n.toPrimitive||o("toPrimitive")),toStringTag:a("",n&&n.toStringTag||o("toStringTag")),unscopables:a("",n&&n.unscopables||o("unscopables"))}),u(i.prototype,{constructor:a(o),toString:a("",function(){return this.__name__})}),u(o.prototype,{toString:a(function(){return"Symbol ("+c(this).__description__+")"}),valueOf:a(function(){return c(this)})}),p(o.prototype,o.toPrimitive,a("",function(){var t=c(this);return"symbol"===typeof t?t:t.toString()})),p(o.prototype,o.toStringTag,a("c","Symbol")),p(i.prototype,o.toStringTag,a("c",o.prototype[o.toStringTag])),p(i.prototype,o.toPrimitive,a("c",o.prototype[o.toPrimitive]))},"96ae":function(t,e,r){"use strict";var n=r("62c4");t.exports=function(t){if(!n(t))throw new TypeError("Cannot use null or undefined");return t}},"986b":function(t,e,r){"use strict";var n,o=r("d66f"),i=r("f3a6"),s=r("1a94"),a=r("4665"),c=r("1a94"),l=r("96ae"),u=Function.prototype.bind,p=Object.defineProperty,h=Object.prototype.hasOwnProperty;n=function(t,e,r){var n,i=l(e)&&c(e.value);return n=o(e),delete n.writable,delete n.value,n.get=function(){return!r.overwriteDefinition&&h.call(this,t)?i:(e.value=u.call(i,r.resolveContext?r.resolveContext(this):this),p(this,t,e),this[t])},n},t.exports=function(t){var e=i(arguments[1]);return null!=e.resolveContext&&s(e.resolveContext),a(t,function(t,r){return n(r,t,e)})}},"9c0f":function(t,e,r){"use strict";t.exports=function(t){return"function"===typeof t}},"9d88":function(t,e,r){(function(t,n){var o;/*! https://mths.be/punycode v1.4.1 by @mathias */(function(i){e&&e.nodeType,t&&t.nodeType;var s="object"==typeof n&&n;s.global!==s&&s.window!==s&&s.self;var a,c=2147483647,l=36,u=1,p=26,h=38,f=700,d=72,_=128,m="-",b=/^xn--/,g=/[^\x20-\x7E]/,v=/[\x2E\u3002\uFF0E\uFF61]/g,y={overflow:"Overflow: input needs wider integers to process","not-basic":"Illegal input >= 0x80 (not a basic code point)","invalid-input":"Invalid input"},w=l-u,S=Math.floor,k=String.fromCharCode;function I(t){throw new RangeError(y[t])}function E(t,e){var r=t.length,n=[];while(r--)n[r]=e(t[r]);return n}function x(t,e){var r=t.split("@"),n="";r.length>1&&(n=r[0]+"@",t=r[1]),t=t.replace(v,".");var o=t.split("."),i=E(o,e).join(".");return n+i}function O(t){var e,r,n=[],o=0,i=t.length;while(o<i)e=t.charCodeAt(o++),e>=55296&&e<=56319&&o<i?(r=t.charCodeAt(o++),56320==(64512&r)?n.push(((1023&e)<<10)+(1023&r)+65536):(n.push(e),o--)):n.push(e);return n}function P(t){return E(t,function(t){var e="";return t>65535&&(t-=65536,e+=k(t>>>10&1023|55296),t=56320|1023&t),e+=k(t),e}).join("")}function T(t){return t-48<10?t-22:t-65<26?t-65:t-97<26?t-97:l}function C(t,e){return t+22+75*(t<26)-((0!=e)<<5)}function A(t,e,r){var n=0;for(t=r?S(t/f):t>>1,t+=S(t/e);t>w*p>>1;n+=l)t=S(t/w);return S(n+(w+1)*t/(t+h))}function j(t){var e,r,n,o,i,s,a,h,f,b,g=[],v=t.length,y=0,w=_,k=d;for(r=t.lastIndexOf(m),r<0&&(r=0),n=0;n<r;++n)t.charCodeAt(n)>=128&&I("not-basic"),g.push(t.charCodeAt(n));for(o=r>0?r+1:0;o<v;){for(i=y,s=1,a=l;;a+=l){if(o>=v&&I("invalid-input"),h=T(t.charCodeAt(o++)),(h>=l||h>S((c-y)/s))&&I("overflow"),y+=h*s,f=a<=k?u:a>=k+p?p:a-k,h<f)break;b=l-f,s>S(c/b)&&I("overflow"),s*=b}e=g.length+1,k=A(y-i,e,0==i),S(y/e)>c-w&&I("overflow"),w+=S(y/e),y%=e,g.splice(y++,0,w)}return P(g)}function R(t){var e,r,n,o,i,s,a,h,f,b,g,v,y,w,E,x=[];for(t=O(t),v=t.length,e=_,r=0,i=d,s=0;s<v;++s)g=t[s],g<128&&x.push(k(g));n=o=x.length,o&&x.push(m);while(n<v){for(a=c,s=0;s<v;++s)g=t[s],g>=e&&g<a&&(a=g);for(y=n+1,a-e>S((c-r)/y)&&I("overflow"),r+=(a-e)*y,e=a,s=0;s<v;++s)if(g=t[s],g<e&&++r>c&&I("overflow"),g==e){for(h=r,f=l;;f+=l){if(b=f<=i?u:f>=i+p?p:f-i,h<b)break;E=h-b,w=l-b,x.push(k(C(b+E%w,0))),h=S(E/w)}x.push(k(C(h,0))),i=A(r,y,n==o),r=0,++n}++r,++e}return x.join("")}function M(t){return x(t,function(t){return b.test(t)?j(t.slice(4).toLowerCase()):t})}function q(t){return x(t,function(t){return g.test(t)?"xn--"+R(t):t})}a={version:"1.4.1",ucs2:{decode:O,encode:P},decode:j,encode:R,toASCII:q,toUnicode:M},o=function(){return a}.call(e,r,e,t),void 0===o||(t.exports=o)})()}).call(this,r("62e4")(t),r("c8ba"))},"9df0":function(t,e,r){"use strict";var n=Object.create,o=Object.getPrototypeOf,i={};t.exports=function(){var t=Object.setPrototypeOf,e=arguments[0]||n;return"function"===typeof t&&o(t(e(null),i))===i}},"9e04":function(t,e,r){},a297:function(t,e,r){"use strict";t.exports=function(){var t=Math.sign;return"function"===typeof t&&(1===t(10)&&-1===t(-20))}},a671:function(t,e,r){"use strict";var n=r("96ae");t.exports=function(){return n(this).length=0,this}},a7c9:function(t,e){function r(){this.cmd=null,this.retain=!1,this.qos=0,this.dup=!1,this.length=-1,this.topic=null,this.payload=null}t.exports=r},ab52:function(t,e,r){var n=r("566b"),o=function(){},i=function(t){return t.setHeader&&"function"===typeof t.abort},s=function(t){return t.stdio&&Array.isArray(t.stdio)&&3===t.stdio.length},a=function(t,e,r){if("function"===typeof e)return a(t,null,e);e||(e={}),r=n(r||o);var c=t._writableState,l=t._readableState,u=e.readable||!1!==e.readable&&t.readable,p=e.writable||!1!==e.writable&&t.writable,h=function(){t.writable||f()},f=function(){p=!1,u||r.call(t)},d=function(){u=!1,p||r.call(t)},_=function(e){r.call(t,e?new Error("exited with error code: "+e):null)},m=function(e){r.call(t,e)},b=function(){return(!u||l&&l.ended)&&(!p||c&&c.ended)?void 0:r.call(t,new Error("premature close"))},g=function(){t.req.on("finish",f)};return i(t)?(t.on("complete",f),t.on("abort",b),t.req?g():t.on("request",g)):p&&!c&&(t.on("end",h),t.on("close",h)),s(t)&&t.on("exit",_),t.on("end",d),t.on("finish",f),!1!==e.error&&t.on("error",m),t.on("close",b),function(){t.removeListener("complete",f),t.removeListener("abort",b),t.removeListener("request",g),t.req&&t.req.removeListener("finish",f),t.removeListener("end",h),t.removeListener("close",h),t.removeListener("finish",f),t.removeListener("exit",_),t.removeListener("end",d),t.removeListener("error",m),t.removeListener("close",b)}};t.exports=a},ae84c:function(t,e,r){"use strict";function n(t){for(var e=t.split("/"),r=0;r<e.length;r++)if("+"!==e[r]){if("#"===e[r])return r===e.length-1;if(-1!==e[r].indexOf("+")||-1!==e[r].indexOf("#"))return!1}return!0}function o(t){if(0===t.length)return"empty_topic_list";for(var e=0;e<t.length;e++)if(!n(t[e]))return t[e];return null}t.exports={validateTopics:o}},b185:function(t,e,r){"use strict";t.exports=r("14cf")()?Array.from:r("8fe5")},b289:function(t,e,r){"use strict";var n=r("8707").Buffer,o=t.exports;for(var i in o.types={0:"reserved",1:"connect",2:"connack",3:"publish",4:"puback",5:"pubrec",6:"pubrel",7:"pubcomp",8:"subscribe",9:"suback",10:"unsubscribe",11:"unsuback",12:"pingreq",13:"pingresp",14:"disconnect",15:"auth"},o.codes={},o.types){var s=o.types[i];o.codes[s]=i}for(var a in o.CMD_SHIFT=4,o.CMD_MASK=240,o.DUP_MASK=8,o.QOS_MASK=3,o.QOS_SHIFT=1,o.RETAIN_MASK=1,o.LENGTH_MASK=127,o.LENGTH_FIN_MASK=128,o.SESSIONPRESENT_MASK=1,o.SESSIONPRESENT_HEADER=n.from([o.SESSIONPRESENT_MASK]),o.CONNACK_HEADER=n.from([o.codes["connack"]<<o.CMD_SHIFT]),o.USERNAME_MASK=128,o.PASSWORD_MASK=64,o.WILL_RETAIN_MASK=32,o.WILL_QOS_MASK=24,o.WILL_QOS_SHIFT=3,o.WILL_FLAG_MASK=4,o.CLEAN_SESSION_MASK=2,o.CONNECT_HEADER=n.from([o.codes["connect"]<<o.CMD_SHIFT]),o.properties={sessionExpiryInterval:17,willDelayInterval:24,receiveMaximum:33,maximumPacketSize:39,topicAliasMaximum:34,requestResponseInformation:25,requestProblemInformation:23,userProperties:38,authenticationMethod:21,authenticationData:22,payloadFormatIndicator:1,messageExpiryInterval:2,contentType:3,responseTopic:8,correlationData:9,maximumQoS:36,retainAvailable:37,assignedClientIdentifier:18,reasonString:31,wildcardSubscriptionAvailable:40,subscriptionIdentifiersAvailable:41,sharedSubscriptionAvailable:42,serverKeepAlive:19,responseInformation:26,serverReference:28,topicAlias:35,subscriptionIdentifier:11},o.propertiesCodes={},o.properties){var c=o.properties[a];o.propertiesCodes[c]=a}function l(t){return[0,1,2].map(function(e){return[0,1].map(function(r){return[0,1].map(function(i){var s=new n(1);return s.writeUInt8(o.codes[t]<<o.CMD_SHIFT|(r?o.DUP_MASK:0)|e<<o.QOS_SHIFT|i,0,!0),s})})})}o.propertiesTypes={sessionExpiryInterval:"int32",willDelayInterval:"int32",receiveMaximum:"int16",maximumPacketSize:"int32",topicAliasMaximum:"int16",requestResponseInformation:"byte",requestProblemInformation:"byte",userProperties:"pair",authenticationMethod:"string",authenticationData:"binary",payloadFormatIndicator:"byte",messageExpiryInterval:"int32",contentType:"string",responseTopic:"string",correlationData:"binary",maximumQoS:"int8",retainAvailable:"byte",assignedClientIdentifier:"string",reasonString:"string",wildcardSubscriptionAvailable:"byte",subscriptionIdentifiersAvailable:"byte",sharedSubscriptionAvailable:"byte",serverKeepAlive:"int16",responseInformation:"string",serverReference:"string",topicAlias:"int16",subscriptionIdentifier:"var"},o.PUBLISH_HEADER=l("publish"),o.SUBSCRIBE_HEADER=l("subscribe"),o.SUBSCRIBE_OPTIONS_QOS_MASK=3,o.SUBSCRIBE_OPTIONS_NL_MASK=1,o.SUBSCRIBE_OPTIONS_NL_SHIFT=2,o.SUBSCRIBE_OPTIONS_RAP_MASK=1,o.SUBSCRIBE_OPTIONS_RAP_SHIFT=3,o.SUBSCRIBE_OPTIONS_RH_MASK=3,o.SUBSCRIBE_OPTIONS_RH_SHIFT=4,o.SUBSCRIBE_OPTIONS_RH=[0,16,32],o.SUBSCRIBE_OPTIONS_NL=4,o.SUBSCRIBE_OPTIONS_RAP=8,o.SUBSCRIBE_OPTIONS_QOS=[0,1,2],o.UNSUBSCRIBE_HEADER=l("unsubscribe"),o.ACKS={unsuback:l("unsuback"),puback:l("puback"),pubcomp:l("pubcomp"),pubrel:l("pubrel"),pubrec:l("pubrec")},o.SUBACK_HEADER=n.from([o.codes["suback"]<<o.CMD_SHIFT]),o.VERSION3=n.from([3]),o.VERSION4=n.from([4]),o.VERSION5=n.from([5]),o.QOS=[0,1,2].map(function(t){return n.from([t])}),o.EMPTY={pingreq:n.from([o.codes["pingreq"]<<4,0]),pingresp:n.from([o.codes["pingresp"]<<4,0]),disconnect:n.from([o.codes["disconnect"]<<4,0])}},b380:function(t,e,r){"use strict";var n=r("1126");t.exports=function(t){if(!n(t))throw new TypeError(t+" is not a symbol");return t}},b383:function(t,e,r){"use strict";e.decode=e.parse=r("91dd"),e.encode=e.stringify=r("e099")},b41e:function(t,e){var r=null;"undefined"!==typeof WebSocket?r=WebSocket:"undefined"!==typeof MozWebSocket?r=MozWebSocket:"undefined"!==typeof window&&(r=window.WebSocket||window.MozWebSocket),t.exports=r},b779:function(t,e,r){"use strict";t.exports=function(){return"undefined"!==typeof Map&&"[object Map]"===Object.prototype.toString.call(new Map)}()},ba4b:function(t,e,r){"use strict";var n,o=Object.create;r("9df0")()||(n=r("e19c")),t.exports=function(){var t,e,r;return n?1!==n.level?o:(t={},e={},r={configurable:!1,enumerable:!1,writable:!0,value:void 0},Object.getOwnPropertyNames(Object.prototype).forEach(function(t){e[t]="__proto__"!==t?r:{configurable:!0,enumerable:!1,writable:!0,value:void 0}}),Object.defineProperties(t,e),Object.defineProperty(n,"nullPolyfill",{configurable:!1,enumerable:!1,writable:!1,value:t}),function(e,r){return o(null===e?t:e,r)}):o}()},ba61:function(t,e,r){"use strict";var n={object:!0,symbol:!0};t.exports=function(){var t;if("function"!==typeof Symbol)return!1;t=Symbol("test symbol");try{String(t)}catch(e){return!1}return!!n[typeof Symbol.iterator]&&(!!n[typeof Symbol.toPrimitive]&&!!n[typeof Symbol.toStringTag])}},bae6:function(t,e,r){"use strict";t.exports=r("a297")()?Math.sign:r("ef7a")},c351:function(t,e,r){"use strict";var n=r("e9bd"),o=r("1a94"),i=r("692b1"),s=r("8a50"),a=Array.isArray,c=Function.prototype.call,l=Array.prototype.some;t.exports=function(t,e){var r,u,p,h,f,d,_,m,b=arguments[2];if(a(t)||n(t)?r="array":i(t)?r="string":t=s(t),o(e),p=function(){h=!0},"array"!==r){if("string"!==r){u=t.next();while(!u.done){if(c.call(e,b,u.value,p),h)return;u=t.next()}}else for(d=t.length,f=0;f<d;++f)if(_=t[f],f+1<d&&(m=_.charCodeAt(0),m>=55296&&m<=56319&&(_+=t[++f])),c.call(e,b,_,p),h)break}else l.call(t,function(t){return c.call(e,b,t,p),h})}},c4c7:function(t,e,r){"use strict";(function(e){var n,o,i,s=r("e372").Transform,a=r("fb12"),c=r("1fb5"),l=!1;function u(){var t=new s;return t._write=function(t,e,r){n.sendSocketMessage({data:t.buffer,success:function(){r()},fail:function(){r(new Error)}})},t._flush=function(t){n.closeSocket({success:function(){t()}})},t}function p(t){t.hostname||(t.hostname="localhost"),t.path||(t.path="/"),t.wsOptions||(t.wsOptions={})}function h(t,e){var r="alis"===t.protocol?"wss":"ws",n=r+"://"+t.hostname+t.path;return t.port&&80!==t.port&&443!==t.port&&(n=r+"://"+t.hostname+":"+t.port+t.path),"function"===typeof t.transformWsUrl&&(n=t.transformWsUrl(n,t,e)),n}function f(){l||(l=!0,n.onSocketOpen(function(){i.setReadable(o),i.setWritable(o),i.emit("connect")}),n.onSocketMessage(function(t){if("string"===typeof t.data){var r=c.toByteArray(t.data),n=e.from(r);o.push(n)}else{var i=new FileReader;i.addEventListener("load",function(){var t=i.result;t=t instanceof ArrayBuffer?e.from(t):e.from(t,"utf8"),o.push(t)}),i.readAsArrayBuffer(t.data)}}),n.onSocketClose(function(){i.end(),i.destroy()}),n.onSocketError(function(t){i.destroy(t)}))}function d(t,e){if(e.hostname=e.hostname||e.host,!e.hostname)throw new Error("Could not determine host. Specify host manually.");var r="MQIsdp"===e.protocolId&&3===e.protocolVersion?"mqttv3.1":"mqtt";p(e);var s=h(e,t);return n=e.my,n.connectSocket({url:s,protocols:r}),o=u(),i=a.obj(),f(),i}t.exports=d}).call(this,r("b639").Buffer)},c5f4:function(t,e,r){"use strict";var n=r("bae6"),o=Math.abs,i=Math.floor;t.exports=function(t){return isNaN(t)?0:(t=Number(t),0!==t&&isFinite(t)?n(t)*i(o(t)):t)}},c682:function(t,e,r){"use strict";t.exports=r("5a5c")("key","value","key+value")},c9fc:function(t,e,r){"use strict";var n,o,i,s,a,c,l,u=r("f508"),p=r("1a94"),h=Function.prototype.apply,f=Function.prototype.call,d=Object.create,_=Object.defineProperty,m=Object.defineProperties,b=Object.prototype.hasOwnProperty,g={configurable:!0,enumerable:!1,writable:!0};n=function(t,e){var r;return p(e),b.call(this,"__ee__")?r=this.__ee__:(r=g.value=d(null),_(this,"__ee__",g),g.value=null),r[t]?"object"===typeof r[t]?r[t].push(e):r[t]=[r[t],e]:r[t]=e,this},o=function(t,e){var r,o;return p(e),o=this,n.call(this,t,r=function(){i.call(o,t,r),h.call(e,this,arguments)}),r.__eeOnceListener__=e,this},i=function(t,e){var r,n,o,i;if(p(e),!b.call(this,"__ee__"))return this;if(r=this.__ee__,!r[t])return this;if(n=r[t],"object"===typeof n)for(i=0;o=n[i];++i)o!==e&&o.__eeOnceListener__!==e||(2===n.length?r[t]=n[i?0:1]:n.splice(i,1));else n!==e&&n.__eeOnceListener__!==e||delete r[t];return this},s=function(t){var e,r,n,o,i;if(b.call(this,"__ee__")&&(o=this.__ee__[t],o))if("object"===typeof o){for(r=arguments.length,i=new Array(r-1),e=1;e<r;++e)i[e-1]=arguments[e];for(o=o.slice(),e=0;n=o[e];++e)h.call(n,this,i)}else switch(arguments.length){case 1:f.call(o,this);break;case 2:f.call(o,this,arguments[1]);break;case 3:f.call(o,this,arguments[1],arguments[2]);break;default:for(r=arguments.length,i=new Array(r-1),e=1;e<r;++e)i[e-1]=arguments[e];h.call(o,this,i)}},a={on:n,once:o,off:i,emit:s},c={on:u(n),once:u(o),off:u(i),emit:u(s)},l=m({},c),t.exports=e=function(t){return null==t?d(l):m(Object(t),c)},e.methods=a},cecf:function(t,e,r){"use strict";var n=r("1a94"),o=r("96ae"),i=Function.prototype.bind,s=Function.prototype.call,a=Object.keys,c=Object.prototype.propertyIsEnumerable;t.exports=function(t,e){return function(r,l){var u,p=arguments[2],h=arguments[3];return r=Object(o(r)),n(l),u=a(r),h&&u.sort("function"===typeof h?i.call(h,r):void 0),"function"!==typeof t&&(t=u[t]),s.call(t,u,function(t,n){return c.call(r,t)?s.call(l,p,r[t],t,r,n):e})}}},d53b4:function(t,e,r){"use strict";var n=r("c5f4"),o=Math.max;t.exports=function(t){return o(0,n(t))}},d633:function(t,e){function r(t,e){if(t&&e)return r(t)(e);if("function"!==typeof t)throw new TypeError("need wrapper function");return Object.keys(t).forEach(function(e){n[e]=t[e]}),n;function n(){for(var e=new Array(arguments.length),r=0;r<e.length;r++)e[r]=arguments[r];var n=t.apply(this,e),o=e[e.length-1];return"function"===typeof n&&n!==o&&Object.keys(o).forEach(function(t){n[t]=o[t]}),n}}t.exports=r},d66f:function(t,e,r){"use strict";var n=r("b185"),o=r("2031"),i=r("96ae");t.exports=function(t){var e=Object(i(t)),r=arguments[1],s=Object(arguments[2]);if(e!==t&&!r)return e;var a={};return r?n(r,function(e){(s.ensure||e in t)&&(a[e]=t[e])}):o(a,t),a}},d751:function(t,e,r){"use strict";var n=r("3d7a"),o=r.n(n);o.a},df86:function(t,e,r){"use strict";(function(e,n){var o=r("faa1"),i=r("ea08"),s=r("3409"),a=r("e372").Writable,c=r("3fb5"),l=r("29a2"),u=r("ae84c"),p=r("53a8"),h=e.setImmediate||function(t){n.nextTick(t)},f={keepalive:60,reschedulePings:!0,protocolId:"MQTT",protocolVersion:4,reconnectPeriod:1e3,connectTimeout:3e4,clean:!0,resubscribe:!0},d={0:"",1:"Unacceptable protocol version",2:"Identifier rejected",3:"Server unavailable",4:"Bad username or password",5:"Not authorized",16:"No matching subscribers",17:"No subscription existed",128:"Unspecified error",129:"Malformed Packet",130:"Protocol Error",131:"Implementation specific error",132:"Unsupported Protocol Version",133:"Client Identifier not valid",134:"Bad User Name or Password",135:"Not authorized",136:"Server unavailable",137:"Server busy",138:"Banned",139:"Server shutting down",140:"Bad authentication method",141:"Keep Alive timeout",142:"Session taken over",143:"Topic Filter invalid",144:"Topic Name invalid",145:"Packet identifier in use",146:"Packet Identifier not found",147:"Receive Maximum exceeded",148:"Topic Alias invalid",149:"Packet too large",150:"Message rate too high",151:"Quota exceeded",152:"Administrative action",153:"Payload format invalid",154:"Retain not supported",155:"QoS not supported",156:"Use another server",157:"Server moved",158:"Shared Subscriptions not supported",159:"Connection rate exceeded",160:"Maximum connect time",161:"Subscription Identifiers not supported",162:"Wildcard Subscriptions not supported"};function _(){return"mqttjs_"+Math.random().toString(16).substr(2,8)}function m(t,e,r){t.emit("packetsend",e);var n=s.writeToStream(e,t.stream,t.options);!n&&r?t.stream.once("drain",r):r&&r()}function b(t){t&&Object.keys(t).forEach(function(e){"function"===typeof t[e].cb&&(t[e].cb(new Error("Connection closed")),delete t[e])})}function g(t){t&&Object.keys(t).forEach(function(e){t[e].volatile&&"function"===typeof t[e].cb&&(t[e].cb(new Error("Connection closed")),delete t[e])})}function v(t,e,r,n){t.outgoingStore.put(e,function(o){if(o)return r&&r(o);n(),m(t,e,r)})}function y(){}function w(t,e){var r,n=this;if(!(this instanceof w))return new w(t,e);for(r in this.options=e||{},f)"undefined"===typeof this.options[r]?this.options[r]=f[r]:this.options[r]=e[r];this.options.clientId="string"===typeof e.clientId?e.clientId:_(),this.options.customHandleAcks=5===e.protocolVersion&&e.customHandleAcks?e.customHandleAcks:function(){arguments[3](0)},this.streamBuilder=t,this.outgoingStore=e.outgoingStore||new i,this.incomingStore=e.incomingStore||new i,this.queueQoSZero=void 0===e.queueQoSZero||e.queueQoSZero,this._resubscribeTopics={},this.messageIdToTopic={},this.pingTimer=null,this.connected=!1,this.disconnecting=!1,this.queue=[],this.connackTimer=null,this.reconnectTimer=null,this._storeProcessing=!1,this._packetIdsDuringStoreProcessing={},this.nextId=Math.max(1,Math.floor(65535*Math.random())),this.outgoing={},this._firstConnection=!0,this.on("close",function(){this.connected=!1,clearTimeout(this.connackTimer)}),this.on("connect",function(){var t=this.queue;function e(){var r=t.shift(),o=null;r&&(o=r.packet,n._sendPacket(o,function(t){r.cb&&r.cb(t),e()}))}e()}),this.on("close",function(){null!==n.pingTimer&&(n.pingTimer.clear(),n.pingTimer=null)}),this.on("close",this._setupReconnect),o.EventEmitter.call(this),this._setupStream()}c(w,o.EventEmitter),w.prototype._setupStream=function(){var t,e=this,r=new a,o=s.parser(this.options),i=null,c=[];function l(){if(c.length)n.nextTick(u);else{var t=i;i=null,t()}}function u(){var t=c.shift();if(t)e._handlePacket(t,l);else{var r=i;i=null,r&&r()}}if(this._clearReconnect(),this.stream=this.streamBuilder(this),o.on("packet",function(t){c.push(t)}),r._write=function(t,e,r){i=r,o.parse(t),u()},this.stream.pipe(r),this.stream.on("error",y),this.stream.on("close",function(){g(e.outgoing),e.emit("close")}),t=Object.create(this.options),t.cmd="connect",m(this,t),o.on("error",this.emit.bind(this,"error")),this.options.properties){if(!this.options.properties.authenticationMethod&&this.options.properties.authenticationData)return this.emit("error",new Error("Packet has no Authentication Method")),this;if(this.options.properties.authenticationMethod&&this.options.authPacket&&"object"===typeof this.options.authPacket){var h=p({cmd:"auth",reasonCode:0},this.options.authPacket);m(this,h)}}this.stream.setMaxListeners(1e3),clearTimeout(this.connackTimer),this.connackTimer=setTimeout(function(){e._cleanUp(!0)},this.options.connectTimeout)},w.prototype._handlePacket=function(t,e){var r=this.options;if(5===r.protocolVersion&&r.properties&&r.properties.maximumPacketSize&&r.properties.maximumPacketSize<t.length)return this.emit("error",new Error("exceeding packets size "+t.cmd)),this.end({reasonCode:149,properties:{reasonString:"Maximum packet size was exceeded"}}),this;switch(this.emit("packetreceive",t),t.cmd){case"publish":this._handlePublish(t,e);break;case"puback":case"pubrec":case"pubcomp":case"suback":case"unsuback":this._handleAck(t),e();break;case"pubrel":this._handlePubrel(t,e);break;case"connack":this._handleConnack(t),e();break;case"pingresp":this._handlePingresp(t),e();break;case"disconnect":this._handleDisconnect(t),e();break;default:break}},w.prototype._checkDisconnecting=function(t){return this.disconnecting&&(t?t(new Error("client disconnecting")):this.emit("error",new Error("client disconnecting"))),this.disconnecting},w.prototype.publish=function(t,e,r,n){var o,i=this.options;"function"===typeof r&&(n=r,r=null);var s={qos:0,retain:!1,dup:!1};if(r=p(s,r),this._checkDisconnecting(n))return this;switch(o={cmd:"publish",topic:t,payload:e,qos:r.qos,retain:r.retain,messageId:this._nextId(),dup:r.dup},5===i.protocolVersion&&(o.properties=r.properties,(!i.properties&&o.properties&&o.properties.topicAlias||r.properties&&i.properties&&(r.properties.topicAlias&&i.properties.topicAliasMaximum&&r.properties.topicAlias>i.properties.topicAliasMaximum||!i.properties.topicAliasMaximum&&r.properties.topicAlias))&&delete o.properties.topicAlias),r.qos){case 1:case 2:this.outgoing[o.messageId]={volatile:!1,cb:n||y},this._storeProcessing?(this._packetIdsDuringStoreProcessing[o.messageId]=!1,this._storePacket(o,void 0,r.cbStorePut)):this._sendPacket(o,void 0,r.cbStorePut);break;default:this._storeProcessing?this._storePacket(o,n,r.cbStorePut):this._sendPacket(o,n,r.cbStorePut);break}return this},w.prototype.subscribe=function(){for(var t,e=new Array(arguments.length),r=0;r<arguments.length;r++)e[r]=arguments[r];var n,o=[],i=e.shift(),s=i.resubscribe,a=e.pop()||y,c=e.pop(),l=this,f=this.options.protocolVersion;if(delete i.resubscribe,"string"===typeof i&&(i=[i]),"function"!==typeof a&&(c=a,a=y),n=u.validateTopics(i),null!==n)return h(a,new Error("Invalid topic "+n)),this;if(this._checkDisconnecting(a))return this;var d={qos:0};if(5===f&&(d.nl=!1,d.rap=!1,d.rh=0),c=p(d,c),Array.isArray(i)?i.forEach(function(t){if(!l._resubscribeTopics.hasOwnProperty(t)||l._resubscribeTopics[t].qos<c.qos||s){var e={topic:t,qos:c.qos};5===f&&(e.nl=c.nl,e.rap=c.rap,e.rh=c.rh,e.properties=c.properties),o.push(e)}}):Object.keys(i).forEach(function(t){if(!l._resubscribeTopics.hasOwnProperty(t)||l._resubscribeTopics[t].qos<i[t].qos||s){var e={topic:t,qos:i[t].qos};5===f&&(e.nl=i[t].nl,e.rap=i[t].rap,e.rh=i[t].rh,e.properties=c.properties),o.push(e)}}),t={cmd:"subscribe",subscriptions:o,qos:1,retain:!1,dup:!1,messageId:this._nextId()},c.properties&&(t.properties=c.properties),o.length){if(this.options.resubscribe){var _=[];o.forEach(function(t){if(l.options.reconnectPeriod>0){var e={qos:t.qos};5===f&&(e.nl=t.nl||!1,e.rap=t.rap||!1,e.rh=t.rh||0,e.properties=t.properties),l._resubscribeTopics[t.topic]=e,_.push(t.topic)}}),l.messageIdToTopic[t.messageId]=_}return this.outgoing[t.messageId]={volatile:!0,cb:function(t,e){if(!t)for(var r=e.granted,n=0;n<r.length;n+=1)o[n].qos=r[n];a(t,o)}},this._sendPacket(t),this}a(null,[])},w.prototype.unsubscribe=function(){for(var t={cmd:"unsubscribe",qos:1,messageId:this._nextId()},e=this,r=new Array(arguments.length),n=0;n<arguments.length;n++)r[n]=arguments[n];var o=r.shift(),i=r.pop()||y,s=r.pop();return"string"===typeof o&&(o=[o]),"function"!==typeof i&&(s=i,i=y),this._checkDisconnecting(i)?this:("string"===typeof o?t.unsubscriptions=[o]:"object"===typeof o&&o.length&&(t.unsubscriptions=o),this.options.resubscribe&&t.unsubscriptions.forEach(function(t){delete e._resubscribeTopics[t]}),"object"===typeof s&&s.properties&&(t.properties=s.properties),this.outgoing[t.messageId]={volatile:!0,cb:i},this._sendPacket(t),this)},w.prototype.end=function(){var t=this,e=arguments[0],r=arguments[1],n=arguments[2];function o(){t.disconnected=!0,t.incomingStore.close(function(){t.outgoingStore.close(function(){n&&n.apply(null,arguments),t.emit("end")})}),t._deferredReconnect&&t._deferredReconnect()}function i(){t._cleanUp(e,h.bind(null,o),r)}return null!=e&&"boolean"===typeof e||(n=r||y,r=e,e=!1,"object"!==typeof r&&(n=r,r=null,"function"!==typeof n&&(n=y))),"object"!==typeof r&&(n=r,r=null),n=n||y,this.disconnecting?this:(this._clearReconnect(),this.disconnecting=!0,!e&&Object.keys(this.outgoing).length>0?this.once("outgoingEmpty",setTimeout.bind(null,i,10)):i(),this)},w.prototype.removeOutgoingMessage=function(t){var e=this.outgoing[t]?this.outgoing[t].cb:null;return delete this.outgoing[t],this.outgoingStore.del({messageId:t},function(){e(new Error("Message removed"))}),this},w.prototype.reconnect=function(t){var e=this,r=function(){t?(e.options.incomingStore=t.incomingStore,e.options.outgoingStore=t.outgoingStore):(e.options.incomingStore=null,e.options.outgoingStore=null),e.incomingStore=e.options.incomingStore||new i,e.outgoingStore=e.options.outgoingStore||new i,e.disconnecting=!1,e.disconnected=!1,e._deferredReconnect=null,e._reconnect()};return this.disconnecting&&!this.disconnected?this._deferredReconnect=r:r(),this},w.prototype._reconnect=function(){this.emit("reconnect"),this._setupStream()},w.prototype._setupReconnect=function(){var t=this;!t.disconnecting&&!t.reconnectTimer&&t.options.reconnectPeriod>0&&(this.reconnecting||(this.emit("offline"),this.reconnecting=!0),t.reconnectTimer=setInterval(function(){t._reconnect()},t.options.reconnectPeriod))},w.prototype._clearReconnect=function(){this.reconnectTimer&&(clearInterval(this.reconnectTimer),this.reconnectTimer=null)},w.prototype._cleanUp=function(t,e){var r=arguments[2];if(e&&this.stream.on("close",e),t)0===this.options.reconnectPeriod&&this.options.clean&&b(this.outgoing),this.stream.destroy();else{var n=p({cmd:"disconnect"},r);this._sendPacket(n,h.bind(null,this.stream.end.bind(this.stream)))}this.disconnecting||(this._clearReconnect(),this._setupReconnect()),null!==this.pingTimer&&(this.pingTimer.clear(),this.pingTimer=null),e&&!this.connected&&(this.stream.removeListener("close",e),e())},w.prototype._sendPacket=function(t,e,r){if(r=r||y,this.connected){switch(this._shiftPingInterval(),t.cmd){case"publish":break;case"pubrel":return void v(this,t,e,r);default:return void m(this,t,e)}switch(t.qos){case 2:case 1:v(this,t,e,r);break;case 0:default:m(this,t,e);break}}else this._storePacket(t,e,r)},w.prototype._storePacket=function(t,e,r){r=r||y,0===(t.qos||0)&&this.queueQoSZero||"publish"!==t.cmd?this.queue.push({packet:t,cb:e}):t.qos>0?(e=this.outgoing[t.messageId]?this.outgoing[t.messageId].cb:null,this.outgoingStore.put(t,function(t){if(t)return e&&e(t);r()})):e&&e(new Error("No connection to broker"))},w.prototype._setupPingTimer=function(){var t=this;!this.pingTimer&&this.options.keepalive&&(this.pingResp=!0,this.pingTimer=l(function(){t._checkPing()},1e3*this.options.keepalive))},w.prototype._shiftPingInterval=function(){this.pingTimer&&this.options.keepalive&&this.options.reschedulePings&&this.pingTimer.reschedule(1e3*this.options.keepalive)},w.prototype._checkPing=function(){this.pingResp?(this.pingResp=!1,this._sendPacket({cmd:"pingreq"})):this._cleanUp(!0)},w.prototype._handlePingresp=function(){this.pingResp=!0},w.prototype._handleConnack=function(t){var e=this.options,r=e.protocolVersion,n=5===r?t.reasonCode:t.returnCode;if(clearTimeout(this.connackTimer),t.properties&&(t.properties.topicAliasMaximum&&(e.properties||(e.properties={}),e.properties.topicAliasMaximum=t.properties.topicAliasMaximum),t.properties.serverKeepAlive&&e.keepalive&&(e.keepalive=t.properties.serverKeepAlive,this._shiftPingInterval()),t.properties.maximumPacketSize&&(e.properties||(e.properties={}),e.properties.maximumPacketSize=t.properties.maximumPacketSize)),0===n)this.reconnecting=!1,this._onConnect(t);else if(n>0){var o=new Error("Connection refused: "+d[n]);o.code=n,this.emit("error",o)}},w.prototype._handlePublish=function(t,e){e="undefined"!==typeof e?e:y;var r=t.topic.toString(),n=t.payload,o=t.qos,i=t.messageId,s=this,a=this.options,c=[0,16,128,131,135,144,145,151,153];switch(o){case 2:a.customHandleAcks(r,n,t,function(r,n){return r instanceof Error||(n=r,r=null),r?s.emit("error",r):-1===c.indexOf(n)?s.emit("error",new Error("Wrong reason code for pubrec")):void(n?s._sendPacket({cmd:"pubrec",messageId:i,reasonCode:n},e):s.incomingStore.put(t,function(){s._sendPacket({cmd:"pubrec",messageId:i},e)}))});break;case 1:a.customHandleAcks(r,n,t,function(o,a){return o instanceof Error||(a=o,o=null),o?s.emit("error",o):-1===c.indexOf(a)?s.emit("error",new Error("Wrong reason code for puback")):(a||s.emit("message",r,n,t),void s.handleMessage(t,function(t){if(t)return e&&e(t);s._sendPacket({cmd:"puback",messageId:i,reasonCode:a},e)}))});break;case 0:this.emit("message",r,n,t),this.handleMessage(t,e);break;default:break}},w.prototype.handleMessage=function(t,e){e()},w.prototype._handleAck=function(t){var e,r=t.messageId,n=t.cmd,o=null,i=this.outgoing[r]?this.outgoing[r].cb:null,s=this;if(i){switch(n){case"pubcomp":case"puback":var a=t.reasonCode;a&&a>0&&16!==a&&(e=new Error("Publish error: "+d[a]),e.code=a,i(e,t)),delete this.outgoing[r],this.outgoingStore.del(t,i);break;case"pubrec":o={cmd:"pubrel",qos:2,messageId:r};var c=t.reasonCode;c&&c>0&&16!==c?(e=new Error("Publish error: "+d[c]),e.code=c,i(e,t)):this._sendPacket(o);break;case"suback":delete this.outgoing[r];for(var l=0;l<t.granted.length;l++)if(0!==(128&t.granted[l])){var u=this.messageIdToTopic[r];u&&u.forEach(function(t){delete s._resubscribeTopics[t]})}i(null,t);break;case"unsuback":delete this.outgoing[r],i(null);break;default:s.emit("error",new Error("unrecognized packet type"))}this.disconnecting&&0===Object.keys(this.outgoing).length&&this.emit("outgoingEmpty")}},w.prototype._handlePubrel=function(t,e){e="undefined"!==typeof e?e:y;var r=t.messageId,n=this,o={cmd:"pubcomp",messageId:r};n.incomingStore.get(t,function(t,r){t?n._sendPacket(o,e):(n.emit("message",r.topic,r.payload,r),n.handleMessage(r,function(t){if(t)return e(t);n.incomingStore.del(r,y),n._sendPacket(o,e)}))})},w.prototype._handleDisconnect=function(t){this.emit("disconnect",t)},w.prototype._nextId=function(){var t=this.nextId++;return 65536===this.nextId&&(this.nextId=1),t},w.prototype.getLastMessageId=function(){return 1===this.nextId?65535:this.nextId-1},w.prototype._resubscribe=function(t){var e=Object.keys(this._resubscribeTopics);if(!this._firstConnection&&(this.options.clean||5===this.options.protocolVersion&&!t.sessionPresent)&&e.length>0)if(this.options.resubscribe)if(5===this.options.protocolVersion)for(var r=0;r<e.length;r++){var n={};n[e[r]]=this._resubscribeTopics[e[r]],n.resubscribe=!0,this.subscribe(n,{properties:n[e[r]].properties})}else this._resubscribeTopics.resubscribe=!0,this.subscribe(this._resubscribeTopics);else this._resubscribeTopics={};this._firstConnection=!1},w.prototype._onConnect=function(t){if(this.disconnected)this.emit("connect",t);else{var e=this;this._setupPingTimer(),this._resubscribe(t),this.connected=!0,r()}function r(){var n=e.outgoingStore.createStream();function o(){e._storeProcessing=!1,e._packetIdsDuringStoreProcessing={}}function i(){n.destroy(),n=null,o()}function s(){if(n){e._storeProcessing=!0;var t,r=n.read(1);r?e._packetIdsDuringStoreProcessing[r.messageId]?s():e.disconnecting||e.reconnectTimer?n.destroy&&n.destroy():(t=e.outgoing[r.messageId]?e.outgoing[r.messageId].cb:null,e.outgoing[r.messageId]={volatile:!1,cb:function(e,r){t&&t(e,r),s()}},e._packetIdsDuringStoreProcessing[r.messageId]=!0,e._sendPacket(r)):n.once("readable",s)}}e.once("close",i),n.on("error",function(t){o(),e.removeListener("close",i),e.emit("error",t)}),n.on("end",function(){var n=!0;for(var s in e._packetIdsDuringStoreProcessing)if(!e._packetIdsDuringStoreProcessing[s]){n=!1;break}n?(o(),e.removeListener("close",i),e.emit("connect",t)):r()}),s()}},t.exports=w}).call(this,r("c8ba"),r("f28c"))},e099:function(t,e,r){"use strict";var n=function(t){switch(typeof t){case"string":return t;case"boolean":return t?"true":"false";case"number":return isFinite(t)?t:"";default:return""}};t.exports=function(t,e,r,a){return e=e||"&",r=r||"=",null===t&&(t=void 0),"object"===typeof t?i(s(t),function(s){var a=encodeURIComponent(n(s))+r;return o(t[s])?i(t[s],function(t){return a+encodeURIComponent(n(t))}).join(e):a+encodeURIComponent(n(t[s]))}).join(e):a?encodeURIComponent(n(a))+r+encodeURIComponent(n(t)):""};var o=Array.isArray||function(t){return"[object Array]"===Object.prototype.toString.call(t)};function i(t,e){if(t.map)return t.map(e);for(var r=[],n=0;n<t.length;n++)r.push(e(t[n],n));return r}var s=Object.keys||function(t){var e=[];for(var r in t)Object.prototype.hasOwnProperty.call(t,r)&&e.push(r);return e}},e0f6:function(t,e,r){"use strict";t.exports=r("9df0")()?Object.setPrototypeOf:r("e19c")},e19c:function(t,e,r){"use strict";var n,o=r("2160"),i=r("96ae"),s=Object.prototype.isPrototypeOf,a=Object.defineProperty,c={configurable:!0,enumerable:!1,writable:!0,value:void 0};n=function(t,e){if(i(t),null===e||o(e))return t;throw new TypeError("Prototype must be null or an object")},t.exports=function(t){var e,r;return t?(2===t.level?t.set?(r=t.set,e=function(t,e){return r.call(n(t,e),e),t}):e=function(t,e){return n(t,e).__proto__=e,t}:e=function t(e,r){var o;return n(e,r),o=s.call(t.nullPolyfill,e),o&&delete t.nullPolyfill.__proto__,null===r&&(r=t.nullPolyfill),e.__proto__=r,o&&a(t.nullPolyfill,"__proto__",c),e},Object.defineProperty(e,"level",{configurable:!1,enumerable:!1,writable:!1,value:t.level})):null}(function(){var t,e=Object.create(null),r={},n=Object.getOwnPropertyDescriptor(Object.prototype,"__proto__");if(n){try{t=n.set,t.call(e,r)}catch(o){}if(Object.getPrototypeOf(e)===r)return{set:t,level:2}}return e.__proto__=r,Object.getPrototypeOf(e)===r?{level:2}:(e={},e.__proto__=r,Object.getPrototypeOf(e)===r&&{level:1})}()),r("ba4b")},e76c:function(t,e,r){"use strict";t.exports=function(){}},e7fc:function(t,e,r){"use strict";(function(e){var n=r("df86"),o=r("ea08"),i=r("0b16"),s=r("53a8"),a={};function c(t){var e;t.auth&&(e=t.auth.match(/^(.+):(.+)$/),e?(t.username=e[1],t.password=e[2]):t.username=t.auth)}function l(t,e){if("object"!==typeof t||e||(e=t,t=null),e=e||{},t){var r=i.parse(t,!0);if(null!=r.port&&(r.port=Number(r.port)),e=s(r,e),null===e.protocol)throw new Error("Missing protocol");e.protocol=e.protocol.replace(/:$/,"")}if(c(e),e.query&&"string"===typeof e.query.clientId&&(e.clientId=e.query.clientId),e.cert&&e.key){if(!e.protocol)throw new Error("Missing secure protocol key");if(-1===["mqtts","wss","wxs","alis"].indexOf(e.protocol))switch(e.protocol){case"mqtt":e.protocol="mqtts";break;case"ws":e.protocol="wss";break;case"wx":e.protocol="wxs";break;case"ali":e.protocol="alis";break;default:throw new Error('Unknown protocol for secure connection: "'+e.protocol+'"!')}}if(!a[e.protocol]){var o=-1!==["mqtts","wss"].indexOf(e.protocol);e.protocol=["mqtt","mqtts","ws","wss","wx","wxs","ali","alis"].filter(function(t,e){return(!o||e%2!==0)&&"function"===typeof a[t]})[0]}if(!1===e.clean&&!e.clientId)throw new Error("Missing clientId for unclean clients");function l(t){return e.servers&&(t._reconnectCount&&t._reconnectCount!==e.servers.length||(t._reconnectCount=0),e.host=e.servers[t._reconnectCount].host,e.port=e.servers[t._reconnectCount].port,e.protocol=e.servers[t._reconnectCount].protocol?e.servers[t._reconnectCount].protocol:e.defaultProtocol,e.hostname=e.host,t._reconnectCount++),a[e.protocol](t,e)}return e.protocol&&(e.defaultProtocol=e.protocol),new n(l,e)}"browser"!==e.title?(a.mqtt=r("05ee"),a.tcp=r("05ee"),a.ssl=r("fe3c"),a.tls=r("fe3c"),a.mqtts=r("fe3c")):(a.wx=r("8311"),a.wxs=r("8311"),a.ali=r("c4c7"),a.alis=r("c4c7")),a.ws=r("fcb9"),a.wss=r("fcb9"),t.exports=l,t.exports.connect=l,t.exports.MqttClient=n,t.exports.Store=o}).call(this,r("f28c"))},e9bd:function(t,e,r){"use strict";var n=Object.prototype.toString,o=n.call(function(){return arguments}());t.exports=function(t){return n.call(t)===o}},ea08:function(t,e,r){"use strict";(function(e){var n=r("53a8"),o=r("e372").Readable,i={objectMode:!0},s={clean:!0},a=r("546b");function c(t){if(!(this instanceof c))return new c(t);this.options=t||{},this.options=n(s,t),this._inflights=new a}c.prototype.put=function(t,e){return this._inflights.set(t.messageId,t),e&&e(),this},c.prototype.createStream=function(){var t=new o(i),r=!1,n=[],s=0;return this._inflights.forEach(function(t,e){n.push(t)}),t._read=function(){!r&&s<n.length?this.push(n[s++]):this.push(null)},t.destroy=function(){if(!r){var t=this;r=!0,e.nextTick(function(){t.emit("close")})}},t},c.prototype.del=function(t,e){return t=this._inflights.get(t.messageId),t?(this._inflights.delete(t.messageId),e(null,t)):e&&e(new Error("missing packet")),this},c.prototype.get=function(t,e){return t=this._inflights.get(t.messageId),t?e(null,t):e&&e(new Error("missing packet")),this},c.prototype.close=function(t){this.options.clean&&(this._inflights=null),t&&t()},t.exports=c}).call(this,r("f28c"))},ecf9:function(t,e,r){"use strict";t.exports=function(){try{return Object.keys("primitive"),!0}catch(t){return!1}}},ef7a:function(t,e,r){"use strict";t.exports=function(t){return t=Number(t),isNaN(t)||0===t?t:t>0?1:-1}},f0cb:function(t,e,r){"use strict";var n=r("8707").Buffer,o=65536,i={};function s(t){var e=n.allocUnsafe(2);return e.writeUInt8(t>>8,0),e.writeUInt8(255&t,1),e}function a(){for(var t=0;t<o;t++)i[t]=s(t)}function c(t){return t>=0&&t<128?1:t>=128&&t<16384?2:t>=16384&&t<2097152?3:t>=2097152&&t<268435456?4:0}function l(t){var e=0,r=0,o=c(t),i=n.allocUnsafe(o);do{e=t%128|0,t=t/128|0,t>0&&(e|=128),i.writeUInt8(e,r++)}while(t>0);return{data:i,length:o}}function u(t){var e=n.allocUnsafe(4);return e.writeUInt32BE(t,0),e}t.exports={cache:i,generateCache:a,generateNumber:s,genBufVariableByteInt:l,generate4ByteBuffer:u}},f3a6:function(t,e,r){"use strict";var n=r("62c4"),o=Array.prototype.forEach,i=Object.create,s=function(t,e){var r;for(r in t)e[r]=t[r]};t.exports=function(t){var e=i(null);return o.call(arguments,function(t){n(t)&&s(Object(t),e)}),e}},f508:function(t,e,r){"use strict";var n,o=r("2031"),i=r("f3a6"),s=r("9c0f"),a=r("f973");n=t.exports=function(t,e){var r,n,s,c,l;return arguments.length<2||"string"!==typeof t?(c=e,e=t,t=null):c=arguments[2],null==t?(r=s=!0,n=!1):(r=a.call(t,"c"),n=a.call(t,"e"),s=a.call(t,"w")),l={value:e,configurable:r,enumerable:n,writable:s},c?o(i(c),l):l},n.gs=function(t,e,r){var n,c,l,u;return"string"!==typeof t?(l=r,r=e,e=t,t=null):l=arguments[3],null==e?e=void 0:s(e)?null==r?r=void 0:s(r)||(l=r,r=void 0):(l=e,e=r=void 0),null==t?(n=!0,c=!1):(n=a.call(t,"c"),c=a.call(t,"e")),u={get:e,set:r,configurable:n,enumerable:c},l?o(i(l),u):u}},f60e:function(t,e,r){"use strict";var n=r("7bdf"),o=r("96ae"),i=Math.max;t.exports=function(t,e){var r,s,a,c=i(arguments.length,2);for(t=Object(o(t)),a=function(n){try{t[n]=e[n]}catch(o){r||(r=o)}},s=1;s<c;++s)e=arguments[s],n(e).forEach(a);if(void 0!==r)throw r;return t}},f967:function(t,e,r){"use strict";var n=String.prototype.indexOf;t.exports=function(t){return n.call(this,t,arguments[1])>-1}},f973:function(t,e,r){"use strict";t.exports=r("18ec")()?String.prototype.contains:r("f967")},f9c1:function(t,e){function r(t){var e=t._readableState;return e?e.objectMode?t.read():t.read(n(e)):null}function n(t){return t.buffer.length?t.buffer.head?t.buffer.head.data.length:t.buffer[0].length:t.length}t.exports=r},fb12:function(t,e,r){(function(e,n){var o=r("e372"),i=r("ab52"),s=r("3fb5"),a=r("f9c1"),c=e.from&&e.from!==Uint8Array.from?e.from([0]):new e([0]),l=function(t,e){t._corked?t.once("uncork",e):e()},u=function(t,e){t._autoDestroy&&t.destroy(e)},p=function(t,e){return function(r){r?u(t,"premature close"===r.message?null:r):e&&!t._ended&&t.end()}},h=function(t,e){return t?t._writableState&&t._writableState.finished?e():t._writableState?t.end(e):(t.end(),void e()):e()},f=function(t){return new o.Readable({objectMode:!0,highWaterMark:16}).wrap(t)},d=function(t,e,r){if(!(this instanceof d))return new d(t,e,r);o.Duplex.call(this,r),this._writable=null,this._readable=null,this._readable2=null,this._autoDestroy=!r||!1!==r.autoDestroy,this._forwardDestroy=!r||!1!==r.destroy,this._forwardEnd=!r||!1!==r.end,this._corked=1,this._ondrain=null,this._drained=!1,this._forwarding=!1,this._unwrite=null,this._unread=null,this._ended=!1,this.destroyed=!1,t&&this.setWritable(t),e&&this.setReadable(e)};s(d,o.Duplex),d.obj=function(t,e,r){return r||(r={}),r.objectMode=!0,r.highWaterMark=16,new d(t,e,r)},d.prototype.cork=function(){1===++this._corked&&this.emit("cork")},d.prototype.uncork=function(){this._corked&&0===--this._corked&&this.emit("uncork")},d.prototype.setWritable=function(t){if(this._unwrite&&this._unwrite(),this.destroyed)t&&t.destroy&&t.destroy();else if(null!==t&&!1!==t){var e=this,r=i(t,{writable:!0,readable:!1},p(this,this._forwardEnd)),o=function(){var t=e._ondrain;e._ondrain=null,t&&t()},s=function(){e._writable.removeListener("drain",o),r()};this._unwrite&&n.nextTick(o),this._writable=t,this._writable.on("drain",o),this._unwrite=s,this.uncork()}else this.end()},d.prototype.setReadable=function(t){if(this._unread&&this._unread(),this.destroyed)t&&t.destroy&&t.destroy();else{if(null===t||!1===t)return this.push(null),void this.resume();var e=this,r=i(t,{writable:!1,readable:!0},p(this)),n=function(){e._forward()},o=function(){e.push(null)},s=function(){e._readable2.removeListener("readable",n),e._readable2.removeListener("end",o),r()};this._drained=!0,this._readable=t,this._readable2=t._readableState?t:f(t),this._readable2.on("readable",n),this._readable2.on("end",o),this._unread=s,this._forward()}},d.prototype._read=function(){this._drained=!0,this._forward()},d.prototype._forward=function(){if(!this._forwarding&&this._readable2&&this._drained){var t;this._forwarding=!0;while(this._drained&&null!==(t=a(this._readable2)))this.destroyed||(this._drained=this.push(t));this._forwarding=!1}},d.prototype.destroy=function(t){if(!this.destroyed){this.destroyed=!0;var e=this;n.nextTick(function(){e._destroy(t)})}},d.prototype._destroy=function(t){if(t){var e=this._ondrain;this._ondrain=null,e?e(t):this.emit("error",t)}this._forwardDestroy&&(this._readable&&this._readable.destroy&&this._readable.destroy(),this._writable&&this._writable.destroy&&this._writable.destroy()),this.emit("close")},d.prototype._write=function(t,e,r){return this.destroyed?r():this._corked?l(this,this._write.bind(this,t,e,r)):t===c?this._finish(r):this._writable?void(!1===this._writable.write(t)?this._ondrain=r:r()):r()},d.prototype._finish=function(t){var e=this;this.emit("preend"),l(this,function(){h(e._forwardEnd&&e._writable,function(){!1===e._writableState.prefinished&&(e._writableState.prefinished=!0),e.emit("prefinish"),l(e,t)})})},d.prototype.end=function(t,e,r){return"function"===typeof t?this.end(null,null,t):"function"===typeof e?this.end(t,null,e):(this._ended=!0,t&&this.write(t),this._writableState.ending||this.write(c),o.Writable.prototype.end.call(this,r))},t.exports=d}).call(this,r("b639").Buffer,r("f28c"))},fcb9:function(t,e,r){"use strict";(function(e){var n=r("553e"),o=r("0b16"),i=["rejectUnauthorized","ca","cert","key","pfx","passphrase"],s="browser"===e.title;function a(t,e){var r=t.protocol+"://"+t.hostname+":"+t.port+t.path;return"function"===typeof t.transformWsUrl&&(r=t.transformWsUrl(r,t,e)),r}function c(t){t.hostname||(t.hostname="localhost"),t.port||("wss"===t.protocol?t.port=443:t.port=80),t.path||(t.path="/"),t.wsOptions||(t.wsOptions={}),s||"wss"!==t.protocol||i.forEach(function(e){t.hasOwnProperty(e)&&!t.wsOptions.hasOwnProperty(e)&&(t.wsOptions[e]=t[e])})}function l(t,e){var r="MQIsdp"===e.protocolId&&3===e.protocolVersion?"mqttv3.1":"mqtt";c(e);var o=a(e,t);return n(o,[r],e.wsOptions)}function u(t,e){return l(t,e)}function p(t,e){if(e.hostname||(e.hostname=e.host),!e.hostname){if("undefined"===typeof document)throw new Error("Could not determine host. Specify host manually.");var r=o.parse(document.URL);e.hostname=r.hostname,e.port||(e.port=r.port)}return l(t,e)}t.exports=s?p:u}).call(this,r("f28c"))},fe3c:function(t,e,r){"use strict";var n=r(6);function o(t,e){var r;function o(n){e.rejectUnauthorized&&t.emit("error",n),r.end()}return e.port=e.port||8883,e.host=e.hostname||e.host||"localhost",e.rejectUnauthorized=!1!==e.rejectUnauthorized,delete e.path,r=n.connect(e),r.on("secureConnect",function(){e.rejectUnauthorized&&!r.authorized?r.emit("error",new Error("TLS not authorized")):r.removeListener("error",o)}),r.on("error",o),r}t.exports=o}}]);