/*!
 * @license Copyright 2021, Ably
 * 
 * Ably JavaScript Library v1.2.14
 * https://github.com/ably/ably-js
 * 
 * Ably Realtime Messaging
 * https://www.ably.com
 * 
 * Released under the Apache Licence v2.0
 */
!function(e,t){"object"==typeof exports&&"object"==typeof module?module.exports=t():"function"==typeof define&&define.amd?define([],t):"object"==typeof exports?exports.Ably=t():e.Ably=t()}(window,(function(){return function(e){var t={};function n(i){if(t[i])return t[i].exports;var r=t[i]={i:i,l:!1,exports:{}};return e[i].call(r.exports,r,r.exports,n),r.l=!0,r.exports}return n.m=e,n.c=t,n.d=function(e,t,i){n.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:i})},n.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},n.t=function(e,t){if(1&t&&(e=n(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var i=Object.create(null);if(n.r(i),Object.defineProperty(i,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var r in e)n.d(i,r,function(t){return e[t]}.bind(null,r));return i},n.n=function(e){var t=e&&e.__esModule?function(){return e.default}:function(){return e};return n.d(t,"a",t),t},n.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},n.p="",n(n.s=50)}([function(e,t,n){"use strict";(function(e){var i=n(3),r=function(){var t,n;function r(e,t){return("000"+e).slice(-2-(t||0))}"undefined"==typeof Window&&"undefined"==typeof WorkerGlobalScope||e.console&&e.console.log&&"function"==typeof e.console.log.apply?(t=function(){console.log.apply(console,arguments)},n=console.warn?function(){console.warn.apply(console,arguments)}:t):t=n=e.console&&e.console.log?function(){Function.prototype.apply.call(console.log,console,arguments)}:function(){};var o=1;function s(e){return i.a.logTimestamps?function(t){var n=new Date;e(r(n.getHours())+":"+r(n.getMinutes())+":"+r(n.getSeconds())+"."+r(n.getMilliseconds(),!0)+" "+t)}:e}var a=s(t),c=s(n);function u(e){}return u.LOG_NONE=0,u.LOG_ERROR=1,u.LOG_MAJOR=2,u.LOG_MINOR=3,u.LOG_MICRO=4,u.LOG_DEFAULT=1,u.LOG_DEBUG=4,u.logAction=function(e,t,n){u.shouldLog(e)&&(1===e?c:a)("Ably: "+t+": "+n)},u.deprecated=function(e,t){u.deprecatedWithMsg(e,"Please use '"+t+"' instead.")},u.deprecatedWithMsg=function(e,t){u.shouldLog(1)&&c("Ably: Deprecation warning - '"+e+"' is deprecated and will be removed from a future version. "+t)},u.shouldLog=function(e){return e<=o},u.setLog=function(e,t){void 0!==e&&(o=e),void 0!==t&&(a=c=t)},u}();t.a=r}).call(this,n(17))},function(e,t,n){"use strict";var i=n(3),r=n(4),o=n(5),s=Object.prototype.hasOwnProperty,a=function(){var e=i.a.msgpack;function t(){}function n(e){return Math.floor(Math.random()*e.length)}t.mixin=function(e){for(var t=1;t<arguments.length;t++){var n=arguments[t];if(!n)break;for(var i in n)s.call(n,i)&&(e[i]=n[i])}return e},t.copy=function(e){return t.mixin({},e)},t.isArray=Array.isArray||function(e){return"[object Array]"==Object.prototype.toString.call(e)},t.ensureArray=function(e){return t.isEmptyArg(e)?[]:t.isArray(e)?e:[e]},t.isObject=function(e){return"[object Object]"==Object.prototype.toString.call(e)},t.isEmpty=function(e){for(var t in e)return!1;return!0},t.isOnlyPropIn=function(e,t){for(var n in e)if(n!==t)return!1;return!0},t.isEmptyArg=function(e){return null==e},t.shallowClone=function(e){var t=new Object;for(var n in e)t[n]=e[n];return t},t.prototypicalClone=function(e,n){function i(){}i.prototype=e;var r=new i;return n&&t.mixin(r,n),r},t.inherits=i.a.inherits||function(e,n){e.super_=n,e.prototype=t.prototypicalClone(n.prototype,{constructor:e})},t.containsValue=function(e,t){for(var n in e)if(e[n]==t)return!0;return!1},t.intersect=function(e,n){return t.isArray(n)?t.arrIntersect(e,n):t.arrIntersectOb(e,n)},t.arrIntersect=function(e,n){for(var i=[],r=0;r<e.length;r++){var o=e[r];-1!=t.arrIndexOf(n,o)&&i.push(o)}return i},t.arrIntersectOb=function(e,t){for(var n=[],i=0;i<e.length;i++){var r=e[i];r in t&&n.push(r)}return n},t.arrSubtract=function(e,n){for(var i=[],r=0;r<e.length;r++){var o=e[r];-1==t.arrIndexOf(n,o)&&i.push(o)}return i},t.arrIndexOf=Array.prototype.indexOf?function(e,t,n){return e.indexOf(t,n)}:function(e,t,n){n=n||0;for(var i=e.length;n<i;n++)if(e[n]===t)return n;return-1},t.arrIn=function(e,n){return-1!==t.arrIndexOf(e,n)},t.arrDeleteValue=function(e,n){var i=t.arrIndexOf(e,n),r=-1!=i;return r&&e.splice(i,1),r},t.arrWithoutValue=function(e,n){var i=e.slice();return t.arrDeleteValue(i,n),i},t.keysArray=function(e,t){var n=[];for(var i in e)t&&!s.call(e,i)||n.push(i);return n},t.valuesArray=function(e,t){var n=[];for(var i in e)t&&!s.call(e,i)||n.push(e[i]);return n},t.forInOwnNonNullProps=function(e,t){for(var n in e)s.call(e,n)&&e[n]&&t(n)},t.arrForEach=Array.prototype.forEach?function(e,t){e.forEach(t)}:function(e,t){for(var n=e.length,i=0;i<n;i++)t(e[i],i,e)},t.safeArrForEach=function(e,n){return t.arrForEach(e.slice(),n)},t.arrMap=Array.prototype.map?function(e,t){return e.map(t)}:function(e,t){for(var n=[],i=e.length,r=0;r<i;r++)n.push(t(e[r],r,e));return n},t.arrFilter=Array.prototype.filter?function(e,t){return e.filter(t)}:function(e,t){for(var n=[],i=e.length,r=0;r<i;r++)t(e[r])&&n.push(e[r]);return n},t.arrEvery=Array.prototype.every?function(e,t){return e.every(t)}:function(e,t){for(var n=e.length,i=0;i<n;i++)if(!t(e[i],i,e))return!1;return!0},t.allSame=function(e,n){if(0===e.length)return!0;var i=e[0][n];return t.arrEvery(e,(function(e){return e[n]===i}))},t.nextTick=i.a.nextTick;var a={json:"application/json",jsonp:"application/javascript",xml:"application/xml",html:"text/html",msgpack:"application/x-msgpack"};return t.defaultGetHeaders=function(e){return{accept:a[e||"json"],"X-Ably-Version":r.a.apiVersion,"Ably-Agent":r.a.agent}},t.defaultPostHeaders=function(e){var t;return{accept:t=a[e||"json"],"content-type":t,"X-Ably-Version":r.a.apiVersion,"Ably-Agent":r.a.agent}},t.arrPopRandomElement=function(e){return e.splice(n(e),1)[0]},t.toQueryString=function(e){var t=[];if(e)for(var n in e)t.push(encodeURIComponent(n)+"="+encodeURIComponent(e[n]));return t.length?"?"+t.join("&"):""},t.parseQueryString=function(e){for(var t,n=/([^?&=]+)=?([^&]*)/g,i={};t=n.exec(e);)i[decodeURIComponent(t[1])]=decodeURIComponent(t[2]);return i},t.now=Date.now||function(){return(new Date).getTime()},t.inspect=i.a.inspect,t.isErrorInfo=function(e){return"ErrorInfo"==e.constructor.name},t.inspectError=function(e){return e&&(t.isErrorInfo(e)||"Error"==e.constructor.name||e instanceof Error)?e.toString():t.inspect(e)},t.inspectBody=function(e){return o.a.isBuffer(e)?e.toString():"string"==typeof e?e:i.a.inspect(e)},t.dataSizeBytes=function(e){if(o.a.isBuffer(e))return o.a.byteLength(e);if("string"==typeof e)return i.a.stringByteSize(e);throw new Error("Expected input of Utils.dataSizeBytes to be a buffer or string, but was: "+typeof e)},t.cheapRandStr=function(){return String(Math.random()).substr(2)},t.randomString=i.a.getRandomValues&&"undefined"!=typeof Uint8Array?function(e){var t=new Uint8Array(e);return i.a.getRandomValues(t),o.a.base64Encode(t)}:function(e){for(var t=o.a.base64CharSet,i=Math.round(4*e/3),r="",s=0;s<i;s++)r+=t[n(t)];return r},t.randomHexString=i.a.getRandomValues&&"undefined"!=typeof Uint8Array?function(e){var t=new Uint8Array(e);return i.a.getRandomValues(t),o.a.hexEncode(t)}:function(e){for(var t=o.a.hexCharSet,i=2*e,r="",s=0;s<i;s++)r+=t[n(t)];return r},t.arrChooseN=function(e,n){for(var i=Math.min(n,e.length),r=e.slice(),o=[],s=0;s<i;s++)o.push(t.arrPopRandomElement(r));return o},t.trim=String.prototype.trim?function(e){return e.trim()}:function(e){return e.replace(/^[\s\uFEFF\xA0]+|[\s\uFEFF\xA0]+$/g,"")},t.promisify=function(e,t,n){return new Promise((function(i,r){e[t].apply(e,Array.prototype.slice.call(n).concat((function(e,t){e?r(e):i(t)})))}))},t.decodeBody=function(t,n){return"msgpack"==n?e.decode(t):JSON.parse(String(t))},t.encodeBody=function(t,n){return"msgpack"==n?e.encode(t,!0):JSON.stringify(t)},t.allToLowerCase=function(e){return t.arrMap(e,(function(e){return e&&e.toLowerCase()}))},t.allToUpperCase=function(e){return t.arrMap(e,(function(e){return e&&e.toUpperCase()}))},t}();t.a=a},function(e,t,n){"use strict";var i=n(1),r=function(){function e(e,t,n,i){this.message=e,this.code=t,this.statusCode=n,this.cause=i,this.href=void 0}return e.prototype.toString=function(){var e="["+this.constructor.name;return this.message&&(e+=": "+this.message),this.statusCode&&(e+="; statusCode="+this.statusCode),this.code&&(e+="; code="+this.code),this.cause&&(e+="; cause="+i.a.inspectError(this.cause)),!this.href||this.message&&this.message.indexOf("help.ably.io")>-1||(e+="; see "+this.href+" "),e+="]"},e.fromValues=function(t){var n=i.a.mixin(new e,t);return t instanceof Error&&(n.message=t.message),n.code&&!n.href&&(n.href="https://help.ably.io/error/"+n.code),n},e}();t.a=r},function(e,t,n){"use strict";(function(e,i){var r=n(24);"undefined"==typeof Window&&"undefined"==typeof WorkerGlobalScope&&console.log("Warning: this distribution of Ably is intended for browsers. On nodejs, please use the 'ably' package on npm");var o,s=e.navigator&&e.navigator.userAgent.toString(),a={agent:"browser",logTimestamps:!0,userAgent:s,currentUrl:e.location&&e.location.href,noUpgrade:s&&s.match(/MSIE\s8\.0/),binaryType:"arraybuffer",WebSocket:e.WebSocket||e.MozWebSocket,xhrSupported:e.XMLHttpRequest&&"withCredentials"in new XMLHttpRequest,jsonpSupported:"undefined"!=typeof document,allowComet:(o=e.location,!e.WebSocket||!o||!o.origin||o.origin.indexOf("http")>-1),streamingSupported:!0,useProtocolHeartbeats:!0,createHmac:null,msgpack:r.a,supportsBinary:!!e.TextDecoder,preferBinary:!1,ArrayBuffer:e.ArrayBuffer,atob:e.atob,nextTick:void 0!==i?e.setImmediate.bind(e):function(e){setTimeout(e,0)},addEventListener:e.addEventListener,inspect:JSON.stringify,stringByteSize:function(t){return e.TextDecoder&&(new e.TextEncoder).encode(t).length||t.length},TextEncoder:e.TextEncoder,TextDecoder:e.TextDecoder,Promise:e.Promise,getRandomValues:function(e){if(void 0!==e)return function(t,n){e.getRandomValues(t),n&&n(null)}}(e.crypto||e.msCrypto)};t.a=a}).call(this,n(17),n(42).setImmediate)},function(e,t,n){"use strict";var i=n(3),r={internetUpUrl:"https://internet-up.ably-realtime.com/is-the-internet-up.txt",jsonpInternetUpUrl:"https://internet-up.ably-realtime.com/is-the-internet-up-0-9.js",defaultTransports:["xhr_polling","xhr_streaming","jsonp","web_socket"],baseTransportOrder:["xhr_polling","xhr_streaming","jsonp","web_socket"],transportPreferenceOrder:["jsonp","xhr_polling","xhr_streaming","web_socket"],upgradeTransports:["xhr_streaming","web_socket"]};i.a.noUpgrade&&(r.upgradeTransports=[]);var o=r,s=n(1),a=n(5),c=n(0),u=n(2);o.ENVIRONMENT="",o.REST_HOST="rest.ably.io",o.REALTIME_HOST="realtime.ably.io",o.FALLBACK_HOSTS=["A.ably-realtime.com","B.ably-realtime.com","C.ably-realtime.com","D.ably-realtime.com","E.ably-realtime.com"],o.PORT=80,o.TLS_PORT=443,o.TIMEOUTS={disconnectedRetryTimeout:15e3,suspendedRetryTimeout:3e4,httpRequestTimeout:15e3,channelRetryTimeout:15e3,fallbackRetryTimeout:6e5,connectionStateTtl:12e4,realtimeRequestTimeout:1e4,recvTimeout:9e4,preferenceConnectTimeout:6e3,parallelUpgradeDelay:6e3},o.httpMaxRetryCount=3,o.maxMessageSize=65536,o.errorReportingUrl="https://errors.ably.io/api/15/store/",o.errorReportingHeaders={"X-Sentry-Auth":"Sentry sentry_version=7, sentry_key=a04e33c8674c451f8a310fbec029acf5, sentry_client=ably-js/0.1","Content-Type":"application/json"},o.version="1.2.14",o.apiVersion="1.2";var l="ably-js/"+o.version;function h(e){if("string"!=typeof e)throw new u.a("host must be a string; was a "+typeof e,4e4,400);if(!e.length)throw new u.a("host must not be zero-length",4e4,400)}i.a.agent&&(l+=" "+i.a.agent),o.agent=l,o.getHost=function(e,t,n){return t=n?t==e.restHost&&e.realtimeHost||t||e.realtimeHost:t||e.restHost},o.getPort=function(e,t){return t||e.tls?e.tlsPort:e.port},o.getHttpScheme=function(e){return e.tls?"https://":"http://"},o.environmentFallbackHosts=function(e){return[e+"-a-fallback.ably-realtime.com",e+"-b-fallback.ably-realtime.com",e+"-c-fallback.ably-realtime.com",e+"-d-fallback.ably-realtime.com",e+"-e-fallback.ably-realtime.com"]},o.getFallbackHosts=function(e){var t=e.fallbackHosts,n=void 0!==e.httpMaxRetryCount?e.httpMaxRetryCount:o.httpMaxRetryCount;return t?s.a.arrChooseN(t,n):[]},o.getHosts=function(e){return[e.restHost].concat(o.getFallbackHosts(e))},o.objectifyOptions=function(e){return"string"==typeof e?-1==e.indexOf(":")?{token:e}:{key:e}:e},o.normaliseOptions=function(e){if(e.host&&(c.a.deprecated("host","restHost"),e.restHost=e.host),e.wsHost&&(c.a.deprecated("wsHost","realtimeHost"),e.realtimeHost=e.wsHost),e.queueEvents&&(c.a.deprecated("queueEvents","queueMessages"),e.queueMessages=e.queueEvents),e.fallbackHostsUseDefault){if(e.fallbackHosts){var t="fallbackHosts and fallbackHostsUseDefault cannot both be set";throw c.a.logAction(c.a.LOG_ERROR,"Defaults.normaliseOptions",t),new u.a(t,4e4,400)}if(e.port||e.tlsPort){t="fallbackHostsUseDefault cannot be set when port or tlsPort are set";throw c.a.logAction(c.a.LOG_ERROR,"Defaults.normaliseOptions",t),new u.a(t,4e4,400)}e.environment?c.a.deprecatedWithMsg("fallbackHostsUseDefault","There is no longer a need to set this when the environment option is also set since the library will now generate the correct fallback hosts using the environment option."):c.a.deprecated("fallbackHostsUseDefault","fallbackHosts: Ably.Defaults.FALLBACK_HOSTS"),e.fallbackHosts=o.FALLBACK_HOSTS}!0===e.recover&&(c.a.deprecated("{recover: true}","{recover: function(lastConnectionDetails, cb) { cb(true); }}"),e.recover=function(e,t){t(!0)}),"function"==typeof e.recover&&!0===e.closeOnUnload&&(c.a.logAction(c.a.LOG_ERROR,"Defaults.normaliseOptions","closeOnUnload was true and a session recovery function was set - these are mutually exclusive, so unsetting the latter"),e.recover=null),"closeOnUnload"in e||(e.closeOnUnload=!e.recover),e.transports&&s.a.arrIn(e.transports,"xhr")&&(c.a.deprecated('transports: ["xhr"]','transports: ["xhr_streaming"]'),s.a.arrDeleteValue(e.transports,"xhr"),e.transports.push("xhr_streaming")),"queueMessages"in e||(e.queueMessages=!0);var n=e.environment&&String(e.environment).toLowerCase()||o.ENVIRONMENT,r=!n||"production"===n;for(var l in e.fallbackHosts||e.restHost||e.realtimeHost||e.port||e.tlsPort||(e.fallbackHosts=r?o.FALLBACK_HOSTS:o.environmentFallbackHosts(n)),e.realtimeHost||(e.restHost?(c.a.logAction(c.a.LOG_WARN,"Defaults.normaliseOptions",'restHost is set to "'+e.restHost+'" but realtimeHost is not set, so setting realtimeHost to "'+e.restHost+'" too. If this is not what you want, please set realtimeHost explicitly.'),e.realtimeHost=e.restHost):e.realtimeHost=r?o.REALTIME_HOST:n+"-"+o.REALTIME_HOST),e.restHost||(e.restHost=r?o.REST_HOST:n+"-"+o.REST_HOST),s.a.arrForEach((e.fallbackHosts||[]).concat(e.restHost,e.realtimeHost),h),e.port=e.port||o.PORT,e.tlsPort=e.tlsPort||o.TLS_PORT,e.maxMessageSize=e.maxMessageSize||o.maxMessageSize,"tls"in e||(e.tls=!0),e.timeouts={},o.TIMEOUTS)e.timeouts[l]=e[l]||o.TIMEOUTS[l];(e.useBinaryProtocol="useBinaryProtocol"in e?i.a.supportsBinary&&e.useBinaryProtocol:i.a.preferBinary,e.clientId)&&((e.headers=e.headers||{})["X-Ably-ClientId"]=a.a.base64Encode(a.a.utf8Encode(e.clientId)));if("idempotentRestPublishing"in e||(e.idempotentRestPublishing=!0),e.promises&&!i.a.Promise&&(c.a.logAction(c.a.LOG_ERROR,"Defaults.normaliseOptions","{promises: true} was specified, but no Promise constructor found; disabling promises"),e.promises=!1),e.agents)for(var p in e.agents)o.agent+=" "+p+"/"+e.agents[p];return e};t.a=o},function(e,t,n){"use strict";var i=n(32),r=n(33),o=n(18),s=n(10),a=n.n(s),c=n(3),u=function(){var e=c.a.ArrayBuffer,t=c.a.atob,n=c.a.TextEncoder,s=c.a.TextDecoder,u="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";function l(e){return null!=e&&void 0!==e.sigBytes}function h(t){return null!=t&&t.constructor===e}function p(t){return e&&e.isView&&e.isView(t)}function f(){}f.base64CharSet=u,f.hexCharSet="0123456789abcdef";var d=f.isBuffer=function(e){return h(e)||l(e)||p(e)},g=f.toBuffer=function(t){if(!e)throw new Error("Can't convert to Buffer: browser does not support the necessary types");if(h(t))return new Uint8Array(t);if(p(t))return new Uint8Array(t.buffer);if(l(t)){for(var n=new e(t.sigBytes),i=new Uint8Array(n),r=0;r<t.sigBytes;r++)i[r]=t.words[r>>>2]>>>24-r%4*8&255;return i}throw new Error("BufferUtils.toBuffer expected an arraybuffer, typed array, or CryptoJS wordarray")};return f.toArrayBuffer=function(e){return h(e)?e:g(e).buffer},f.toWordArray=function(e){return p(e)&&(e=e.buffer),l(e)?e:a.a.create(e)},f.base64Encode=function(e){return l(e)?Object(o.stringify)(e):function(e){for(var t,n="",i=u,r=e.byteLength,o=r%3,s=r-o,a=0;a<s;a+=3)n+=i[(16515072&(t=e[a]<<16|e[a+1]<<8|e[a+2]))>>18]+i[(258048&t)>>12]+i[(4032&t)>>6]+i[63&t];return 1==o?n+=i[(252&(t=e[s]))>>2]+i[(3&t)<<4]+"==":2==o&&(n+=i[(64512&(t=e[s]<<8|e[s+1]))>>10]+i[(1008&t)>>4]+i[(15&t)<<2]+"="),n}(g(e))},f.base64Decode=function(n){return e&&t?function(e){for(var n=t(e),i=n.length,r=new Uint8Array(i),o=0;o<i;o++){var s=n.charCodeAt(o);r[o]=s}return r.buffer}(n):Object(o.parse)(n)},f.hexEncode=function(e){return e=f.toWordArray(e),Object(i.stringify)(e)},f.hexDecode=function(t){var n=Object(i.parse)(t);return e?f.toArrayBuffer(n):n},f.utf8Encode=function(e){return n?(new n).encode(e).buffer:Object(r.parse)(e)},f.utf8Decode=function(e){if(!d(e))throw new Error("Expected input of utf8decode to be an arraybuffer, typed array, or CryptoJS wordarray");return s&&!l(e)?(new s).decode(e):(e=f.toWordArray(e),Object(r.stringify)(e))},f.bufferCompare=function(e,t){if(!e)return-1;if(!t)return 1;e=f.toWordArray(e),t=f.toWordArray(t),e.clamp(),t.clamp();var n=e.sigBytes-t.sigBytes;if(0!=n)return n;e=e.words,t=t.words;for(var i=0;i<e.length;i++)if(0!=(n=e[i]-t[i]))return n;return 0},f.byteLength=function(e){return h(e)||p(e)?e.byteLength:l(e)?e.sigBytes:void 0},f.typedArrayToBuffer=function(e){return e.buffer},f}();t.a=u},function(e,t,n){"use strict";var i=n(1),r=n(4),o=function(){var e=function(){};function t(){}var n=Date.now||function(){return(new Date).getTime()};function o(e){var t=e.statusCode;return 408===t&&!e.code||400===t&&!e.code||t>=500&&t<=504}function s(e){var t=e.connection,n=t&&t.connectionManager.host;return n?[n].concat(r.a.getFallbackHosts(e.options)):r.a.getHosts(e.options)}return t._getHosts=s,t.methods=["get","delete","post","put","patch"],t.methodsWithoutBody=["get","delete"],t.methodsWithBody=i.a.arrSubtract(t.methods,t.methodsWithoutBody),i.a.arrForEach(t.methodsWithoutBody,(function(e){t[e]=function(n,i,r,o,s){t.do(e,n,i,r,null,o,s)},t[e+"Uri"]=function(n,i,r,o,s){t.doUri(e,n,i,r,null,o,s)}})),i.a.arrForEach(t.methodsWithBody,(function(e){t[e]=function(n,i,r,o,s,a){t.do(e,n,i,r,o,s,a)},t[e+"Uri"]=function(n,i,r,o,s,a){t.doUri(e,n,i,r,o,s,a)}})),t.do=function(i,r,a,c,u,l,h){h=h||e;var p="function"==typeof a?a:function(e){return r.baseUri(e)+a},f=(c&&c.accept,arguments),d=r._currentFallback;if(d){if(d.validUntil>n())return void t.Request(i,r,p(d.host),c,l,u,(function(e){if(e&&o(e))return r._currentFallback=null,void t.do.apply(t,f);h.apply(null,arguments)}));r._currentFallback=null}var g=s(r);if(1!=g.length){var m=function(e,s){var a=e.shift();t.doUri(i,r,p(a),c,u,l,(function(t){t&&o(t)&&e.length?m(e,!0):(s&&(r._currentFallback={host:a,validUntil:n()+r.options.timeouts.fallbackRetryTimeout}),h.apply(null,arguments))}))};m(g)}else t.doUri(i,r,p(g[0]),c,u,l,h)},t.doUri=function(e,n,i,r,o,s,a){t.Request(e,n,i,r,s,o,a)},t.supportsAuthHeaders=!1,t.supportsLinkHeaders=!1,t}();t.a=o},function(e,t,n){"use strict";var i=n(1),r=n(0),o=n(3),s=Object.prototype.hasOwnProperty,a=function(){function e(){this.any=[],this.events=Object.create(null),this.anyOnce=[],this.eventsOnce=Object.create(null)}function t(e,t,n){try{t.apply(e,n)}catch(e){r.a.logAction(r.a.LOG_ERROR,"EventEmitter.emit()","Unexpected listener exception: "+e+"; stack = "+(e&&e.stack))}}function n(e,t,r){var o,a,c,u;for(u=0;u<e.length;u++)if(o=e[u],r&&(o=o[r]),i.a.isArray(o)){for(;-1!==(a=i.a.arrIndexOf(o,t));)o.splice(a,1);r&&0===o.length&&delete e[u][r]}else if(i.a.isObject(o))for(c in o)s.call(o,c)&&i.a.isArray(o[c])&&n([o],t,c)}return e.prototype.on=function(e,t){if(1==arguments.length&&"function"==typeof e)this.any.push(e);else if(i.a.isEmptyArg(e))this.any.push(t);else if(i.a.isArray(e)){var n=this;i.a.arrForEach(e,(function(e){n.on(e,t)}))}else{var r=this.events[e]||(this.events[e]=[]);r.push(t)}},e.prototype.off=function(e,t){if(0==arguments.length||i.a.isEmptyArg(e)&&i.a.isEmptyArg(t))return this.any=[],this.events=Object.create(null),this.anyOnce=[],void(this.eventsOnce=Object.create(null));if(1==arguments.length&&"function"==typeof e&&(t=e,e=null),t&&i.a.isEmptyArg(e))n([this.any,this.events,this.anyOnce,this.eventsOnce],t);else{if(i.a.isArray(e)){var r=this;i.a.arrForEach(e,(function(e){r.off(e,t)}))}t?n([this.events,this.eventsOnce],t,e):(delete this.events[e],delete this.eventsOnce[e])}},e.prototype.listeners=function(e){if(e){var t=this.events[e]||[];return this.eventsOnce[e]&&Array.prototype.push.apply(t,this.eventsOnce[e]),t.length?t:null}return this.any.length?this.any:null},e.prototype.emit=function(e){var n=Array.prototype.slice.call(arguments,1),r={event:e},o=[];this.anyOnce.length&&(Array.prototype.push.apply(o,this.anyOnce),this.anyOnce=[]),this.any.length&&Array.prototype.push.apply(o,this.any);var s=this.eventsOnce[e];s&&(Array.prototype.push.apply(o,s),delete this.eventsOnce[e]);var a=this.events[e];a&&Array.prototype.push.apply(o,a),i.a.arrForEach(o,(function(e){t(r,e,n)}))},e.prototype.once=function(e,t){var n=arguments.length,r=this;if((0===n||1===n&&"function"!=typeof e)&&o.a.Promise)return new o.a.Promise((function(t){r.once(e,t)}));if(1==arguments.length&&"function"==typeof e)this.anyOnce.push(e);else if(i.a.isEmptyArg(e))this.anyOnce.push(t);else if(i.a.isArray(e)){var s=function(){var n=Array.prototype.slice.call(arguments);i.a.arrForEach(e,(function(e){r.off(e,s)})),t.apply(this,n)};i.a.arrForEach(e,(function(e){r.on(e,s)}))}else{var a=this.eventsOnce[e]||(this.eventsOnce[e]=[]);a.push(t)}},e.prototype.whenState=function(n,i,r){var s={event:n},a=this,c=Array.prototype.slice.call(arguments,3);if("string"!=typeof n||"string"!=typeof i)throw"whenState requires a valid event String argument";if("function"!=typeof r&&o.a.Promise)return new o.a.Promise((function(t){e.prototype.whenState.apply(a,[n,i,t].concat(c))}));n===i?t(s,r,c):this.once(n,r)},e}();t.a=a},function(e,t,n){"use strict";var i=n(1),r=n(2),o=n(9),s=n(11),a=function(){function e(){this.action=void 0,this.flags=void 0,this.id=void 0,this.timestamp=void 0,this.count=void 0,this.error=void 0,this.connectionId=void 0,this.connectionKey=void 0,this.connectionSerial=void 0,this.channel=void 0,this.channelSerial=void 0,this.msgSerial=void 0,this.messages=void 0,this.presence=void 0,this.auth=void 0,this.params=void 0}var t=e.Action={HEARTBEAT:0,ACK:1,NACK:2,CONNECT:3,CONNECTED:4,DISCONNECT:5,DISCONNECTED:6,CLOSE:7,CLOSED:8,ERROR:9,ATTACH:10,ATTACHED:11,DETACH:12,DETACHED:13,PRESENCE:14,MESSAGE:15,SYNC:16,AUTH:17};e.channelModes=["PRESENCE","PUBLISH","SUBSCRIBE","PRESENCE_SUBSCRIBE"],e.ActionName=[],i.a.arrForEach(i.a.keysArray(e.Action,!0),(function(n){e.ActionName[t[n]]=n}));var n={HAS_PRESENCE:1,HAS_BACKLOG:2,RESUMED:4,TRANSIENT:16,ATTACH_RESUME:32,PRESENCE:65536,PUBLISH:1<<17,SUBSCRIBE:1<<18,PRESENCE_SUBSCRIBE:1<<19},a=i.a.keysArray(n);function c(e){var t=[];if(e)for(var n=0;n<e.length;n++)t.push(e[n].toString());return"[ "+t.join(", ")+" ]"}n.MODE_ALL=n.PRESENCE|n.PUBLISH|n.SUBSCRIBE|n.PRESENCE_SUBSCRIBE,e.prototype.hasFlag=function(e){return(this.flags&n[e])>0},e.prototype.setFlag=function(e){return this.flags=this.flags|n[e]},e.prototype.getMode=function(){return this.flags&&this.flags&n.MODE_ALL},e.prototype.encodeModesToFlags=function(e){var t=this;i.a.arrForEach(e,(function(e){t.setFlag(e)}))},e.prototype.decodeModesFromFlags=function(){var t=[],n=this;return i.a.arrForEach(e.channelModes,(function(e){n.hasFlag(e)&&t.push(e)})),t.length>0?t:void 0},e.serialize=i.a.encodeBody,e.deserialize=function(t,n){var r=i.a.decodeBody(t,n);return e.fromDeserialized(r)},e.fromDeserialized=function(t){var n=t.error;n&&(t.error=r.a.fromValues(n));var a=t.messages;if(a)for(var c=0;c<a.length;c++)a[c]=o.a.fromValues(a[c]);var u=t.presence;if(u)for(c=0;c<u.length;c++)u[c]=s.a.fromValues(u[c],!0);return i.a.mixin(new e,t)},e.fromValues=function(t){return i.a.mixin(new e,t)};var u="id channel channelSerial connectionId connectionKey connectionSerial count msgSerial timestamp".split(" ");return e.stringify=function(t){var n,l="[ProtocolMessage";void 0!==t.action&&(l+="; action="+e.ActionName[t.action]||!1);for(var h=0;h<u.length;h++)n=u[h],void 0!==t[n]&&(l+="; "+n+"="+t[n]);if(t.messages&&(l+="; messages="+c(o.a.fromValuesArray(t.messages))),t.presence&&(l+="; presence="+c(s.a.fromValuesArray(t.presence))),t.error&&(l+="; error="+r.a.fromValues(t.error).toString()),t.auth&&t.auth.accessToken&&(l+="; token="+t.auth.accessToken),t.flags&&(l+="; flags="+i.a.arrFilter(a,(function(e){return t.hasFlag(e)})).join(",")),t.params){var p="";i.a.forInOwnNonNullProps(t.params,(function(e){p.length>0&&(p+="; "),p+=e+"="+t.params[e]})),p.length>0&&(l+="; params=["+p+"]")}return l+="]"},e.isDuplicate=function(e,n){if(e&&n&&(e.action===t.MESSAGE||e.action===t.PRESENCE)&&e.action===n.action&&e.channel===n.channel&&e.id===n.id){if(e.action===t.PRESENCE)return!0;if(e.messages.length===n.messages.length){for(var i=0;i<e.messages.length;i++){var r=e.messages[i],o=n.messages[i];if((r.extras&&r.extras.delta&&r.extras.delta.format)!==(o.extras&&o.extras.delta&&o.extras.delta.format))return!1}return!0}}return!1},e}();t.a=a},function(e,t,n){"use strict";var i=n(5),r=n(1),o=n(0),s=n(19),a=n(2),c=function(){function e(){this.name=void 0,this.id=void 0,this.timestamp=void 0,this.clientId=void 0,this.connectionId=void 0,this.connectionKey=void 0,this.data=void 0,this.encoding=void 0,this.extras=void 0,this.size=void 0}function t(e){if(e&&e.cipher&&!e.cipher.channelCipher){if(!s.a)throw new Error("Encryption not enabled; use ably.encryption.js instead");var t=s.a.getCipher(e.cipher);e.cipher=t.cipherParams,e.channelCipher=t.cipher}}function n(e){var t=0;return e.name&&(t+=e.name.length),e.clientId&&(t+=e.clientId.length),e.extras&&(t+=JSON.stringify(e.extras).length),e.data&&(t+=r.a.dataSizeBytes(e.data)),t}return e.prototype.toJSON=function(){var e={name:this.name,id:this.id,clientId:this.clientId,connectionId:this.connectionId,connectionKey:this.connectionKey,encoding:this.encoding,extras:this.extras},t=this.data;if(t&&i.a.isBuffer(t))if(arguments.length>0){var n=this.encoding;e.encoding=n?n+"/base64":"base64",t=i.a.base64Encode(t)}else t=i.a.toBuffer(t);return e.data=t,e},e.prototype.toString=function(){var e="[Message";return this.name&&(e+="; name="+this.name),this.id&&(e+="; id="+this.id),this.timestamp&&(e+="; timestamp="+this.timestamp),this.clientId&&(e+="; clientId="+this.clientId),this.connectionId&&(e+="; connectionId="+this.connectionId),this.encoding&&(e+="; encoding="+this.encoding),this.extras&&(e+="; extras ="+JSON.stringify(this.extras)),this.data&&("string"==typeof this.data?e+="; data="+this.data:i.a.isBuffer(this.data)?e+="; data (buffer)="+i.a.base64Encode(this.data):e+="; data (json)="+JSON.stringify(this.data)),this.extras&&(e+="; extras="+JSON.stringify(this.extras)),e+="]"},e.encrypt=function(e,t,n){var r=e.data,o=e.encoding,s=t.channelCipher;o=o?o+"/":"",i.a.isBuffer(r)||(r=i.a.utf8Encode(String(r)),o+="utf-8/"),s.encrypt(r,(function(t,i){t?n(t):(e.data=i,e.encoding=o+"cipher+"+s.algorithm,n(null,e))}))},e.encode=function(t,n,o){var s,c=t.data;if(!("string"==typeof c||i.a.isBuffer(c)||null==c)){if(!r.a.isObject(c)&&!r.a.isArray(c))throw new a.a("Data type is unsupported",40013,400);t.data=JSON.stringify(c),t.encoding=(s=t.encoding)?s+"/json":"json"}null!=n&&n.cipher?e.encrypt(t,n,o):o(null,t)},e.encodeArray=function(t,n,i){for(var r=0,o=0;o<t.length;o++)e.encode(t[o],n,(function(e,n){e?i(e):++r==t.length&&i(null,t)}))},e.serialize=r.a.encodeBody,e.decode=function(e,t){t&&t.channelOptions||(t={channelOptions:t,plugins:{},baseEncodedPreviousPayload:void 0});var n=e.data,r=e.encoding;if(r){var o,s=r.split("/"),c=s.length,u=e.data;try{for(;(o=c)>0;){var l=s[--c].match(/([\-\w]+)(\+([\w\-]+))?/);if(!l)break;var h=l[1];switch(h){case"base64":u=i.a.base64Decode(String(u)),o==s.length&&(n=u);continue;case"utf-8":u=i.a.utf8Decode(u);continue;case"json":u=JSON.parse(u);continue;case"cipher":if(null!=t.channelOptions&&t.channelOptions.cipher){var p=l[3],f=t.channelOptions.channelCipher;if(p!=f.algorithm)throw new Error("Unable to decrypt message with given cipher; incompatible cipher params");u=f.decrypt(u);continue}throw new Error("Unable to decrypt message; not an encrypted channel");case"vcdiff":if(!t.plugins||!t.plugins.vcdiff)throw new a.a("Missing Vcdiff decoder (https://github.com/ably-forks/vcdiff-decoder)",40019,400);if("undefined"==typeof Uint8Array)throw new a.a("Delta decoding not supported on this browser (need ArrayBuffer & Uint8Array)",40020,400);try{var d=t.baseEncodedPreviousPayload;"string"==typeof d&&(d=i.a.utf8Encode(d)),d=i.a.toBuffer(d),u=i.a.toBuffer(u),n=u=i.a.typedArrayToBuffer(t.plugins.vcdiff.decode(u,d))}catch(e){throw new a.a("Vcdiff delta decode failed with "+e,40018,400)}continue;default:throw new Error("Unknown encoding")}break}}catch(e){throw new a.a("Error processing the "+h+" encoding, decoder returned ‘"+e.message+"’",e.code||40013,400)}finally{e.encoding=o<=0?null:s.slice(0,o).join("/"),e.data=u}}t.baseEncodedPreviousPayload=n},e.fromResponseBody=function(t,n,i){i&&(t=r.a.decodeBody(t,i));for(var s=0;s<t.length;s++){var a=t[s]=e.fromValues(t[s]);try{e.decode(a,n)}catch(e){o.a.logAction(o.a.LOG_ERROR,"Message.fromResponseBody()",e.toString())}}return t},e.fromValues=function(t){return r.a.mixin(new e,t)},e.fromValuesArray=function(t){for(var n=t.length,i=new Array(n),r=0;r<n;r++)i[r]=e.fromValues(t[r]);return i},e.fromEncoded=function(n,i){var r=e.fromValues(n);t(i);try{e.decode(r,i)}catch(e){o.a.logAction(o.a.LOG_ERROR,"Message.fromEncoded()",e.toString())}return r},e.fromEncodedArray=function(n,i){return t(i),r.a.arrMap(n,(function(t){return e.fromEncoded(t,i)}))},e.getMessagesSize=function(e){for(var t,i=0,r=0;r<e.length;r++)i+=(t=e[r]).size||(t.size=n(t));return i},e}();t.a=c},function(e,t,n){var i;e.exports=(i=n(12),function(){if("function"==typeof ArrayBuffer){var e=i.lib.WordArray,t=e.init;(e.init=function(e){if(e instanceof ArrayBuffer&&(e=new Uint8Array(e)),(e instanceof Int8Array||"undefined"!=typeof Uint8ClampedArray&&e instanceof Uint8ClampedArray||e instanceof Int16Array||e instanceof Uint16Array||e instanceof Int32Array||e instanceof Uint32Array||e instanceof Float32Array||e instanceof Float64Array)&&(e=new Uint8Array(e.buffer,e.byteOffset,e.byteLength)),e instanceof Uint8Array){for(var n=e.byteLength,i=[],r=0;r<n;r++)i[r>>>2]|=e[r]<<24-r%4*8;t.call(this,i,n)}else t.apply(this,arguments)}).prototype=e}}(),i.lib.WordArray)},function(e,t,n){"use strict";var i=n(3),r=n(0),o=n(5),s=n(9),a=n(1),c=function(){i.a.msgpack;function e(e){return a.a.arrIndexOf(t.Actions,e)}function t(){this.action=void 0,this.id=void 0,this.timestamp=void 0,this.clientId=void 0,this.connectionId=void 0,this.data=void 0,this.encoding=void 0,this.size=void 0}return t.Actions=["absent","present","enter","leave","update"],t.prototype.isSynthesized=function(){return this.id.substring(this.connectionId.length,0)!==this.connectionId},t.prototype.parseId=function(){var e=this.id.split(":");return{connectionId:e[0],msgSerial:parseInt(e[1],10),index:parseInt(e[2],10)}},t.prototype.toJSON=function(){var t={clientId:this.clientId,action:e(this.action),encoding:this.encoding},n=this.data;if(n&&o.a.isBuffer(n))if(arguments.length>0){var i=this.encoding;t.encoding=i?i+"/base64":"base64",n=o.a.base64Encode(n)}else n=o.a.toBuffer(n);return t.data=n,t},t.prototype.toString=function(){var e="[PresenceMessage";return e+="; action="+this.action,this.id&&(e+="; id="+this.id),this.timestamp&&(e+="; timestamp="+this.timestamp),this.clientId&&(e+="; clientId="+this.clientId),this.connectionId&&(e+="; connectionId="+this.connectionId),this.encoding&&(e+="; encoding="+this.encoding),this.data&&("string"==typeof this.data?e+="; data="+this.data:o.a.isBuffer(this.data)?e+="; data (buffer)="+o.a.base64Encode(this.data):e+="; data (json)="+JSON.stringify(this.data)),e+="]"},t.encode=s.a.encode,t.decode=s.a.decode,t.fromResponseBody=function(e,n,i){i&&(e=a.a.decodeBody(e,i));for(var o=0;o<e.length;o++){var s=e[o]=t.fromValues(e[o],!0);try{t.decode(s,n)}catch(e){r.a.logAction(r.a.LOG_ERROR,"PresenceMessage.fromResponseBody()",e.toString())}}return e},t.fromValues=function(e,n){return n&&(e.action=t.Actions[e.action]),a.a.mixin(new t,e)},t.fromValuesArray=function(e){for(var n=e.length,i=new Array(n),r=0;r<n;r++)i[r]=t.fromValues(e[r]);return i},t.fromEncoded=function(e,n){var i=t.fromValues(e,!0);try{t.decode(i,n)}catch(e){r.a.logAction(r.a.LOG_ERROR,"PresenceMessage.fromEncoded()",e.toString())}return i},t.fromEncodedArray=function(e,n){return a.a.arrMap(e,(function(e){return t.fromEncoded(e,n)}))},t.getMessagesSize=s.a.getMessagesSize,t}();t.a=c},function(e,t,n){(function(t){var i;e.exports=(i=i||function(e,i){var r;if("undefined"!=typeof window&&window.crypto&&(r=window.crypto),!r&&"undefined"!=typeof window&&window.msCrypto&&(r=window.msCrypto),!r&&void 0!==t&&t.crypto&&(r=t.crypto),!r)try{r=n(45)}catch(e){}var o=function(){if(r){if("function"==typeof r.getRandomValues)try{return r.getRandomValues(new Uint32Array(1))[0]}catch(e){}if("function"==typeof r.randomBytes)try{return r.randomBytes(4).readInt32LE()}catch(e){}}throw new Error("Native crypto module could not be used to get secure random number.")},s=Object.create||function(){function e(){}return function(t){var n;return e.prototype=t,n=new e,e.prototype=null,n}}(),a={},c=a.lib={},u=c.Base={extend:function(e){var t=s(this);return e&&t.mixIn(e),t.hasOwnProperty("init")&&this.init!==t.init||(t.init=function(){t.$super.init.apply(this,arguments)}),t.init.prototype=t,t.$super=this,t},create:function(){var e=this.extend();return e.init.apply(e,arguments),e},init:function(){},mixIn:function(e){for(var t in e)e.hasOwnProperty(t)&&(this[t]=e[t]);e.hasOwnProperty("toString")&&(this.toString=e.toString)},clone:function(){return this.init.prototype.extend(this)}},l=c.WordArray=u.extend({init:function(e,t){e=this.words=e||[],this.sigBytes=null!=t?t:4*e.length},toString:function(e){return(e||p).stringify(this)},concat:function(e){var t=this.words,n=e.words,i=this.sigBytes,r=e.sigBytes;if(this.clamp(),i%4)for(var o=0;o<r;o++){var s=n[o>>>2]>>>24-o%4*8&255;t[i+o>>>2]|=s<<24-(i+o)%4*8}else for(o=0;o<r;o+=4)t[i+o>>>2]=n[o>>>2];return this.sigBytes+=r,this},clamp:function(){var t=this.words,n=this.sigBytes;t[n>>>2]&=4294967295<<32-n%4*8,t.length=e.ceil(n/4)},clone:function(){var e=u.clone.call(this);return e.words=this.words.slice(0),e},random:function(e){for(var t=[],n=0;n<e;n+=4)t.push(o());return new l.init(t,e)}}),h=a.enc={},p=h.Hex={stringify:function(e){for(var t=e.words,n=e.sigBytes,i=[],r=0;r<n;r++){var o=t[r>>>2]>>>24-r%4*8&255;i.push((o>>>4).toString(16)),i.push((15&o).toString(16))}return i.join("")},parse:function(e){for(var t=e.length,n=[],i=0;i<t;i+=2)n[i>>>3]|=parseInt(e.substr(i,2),16)<<24-i%8*4;return new l.init(n,t/2)}},f=h.Latin1={stringify:function(e){for(var t=e.words,n=e.sigBytes,i=[],r=0;r<n;r++){var o=t[r>>>2]>>>24-r%4*8&255;i.push(String.fromCharCode(o))}return i.join("")},parse:function(e){for(var t=e.length,n=[],i=0;i<t;i++)n[i>>>2]|=(255&e.charCodeAt(i))<<24-i%4*8;return new l.init(n,t)}},d=h.Utf8={stringify:function(e){try{return decodeURIComponent(escape(f.stringify(e)))}catch(e){throw new Error("Malformed UTF-8 data")}},parse:function(e){return f.parse(unescape(encodeURIComponent(e)))}},g=c.BufferedBlockAlgorithm=u.extend({reset:function(){this._data=new l.init,this._nDataBytes=0},_append:function(e){"string"==typeof e&&(e=d.parse(e)),this._data.concat(e),this._nDataBytes+=e.sigBytes},_process:function(t){var n,i=this._data,r=i.words,o=i.sigBytes,s=this.blockSize,a=o/(4*s),c=(a=t?e.ceil(a):e.max((0|a)-this._minBufferSize,0))*s,u=e.min(4*c,o);if(c){for(var h=0;h<c;h+=s)this._doProcessBlock(r,h);n=r.splice(0,c),i.sigBytes-=u}return new l.init(n,u)},clone:function(){var e=u.clone.call(this);return e._data=this._data.clone(),e},_minBufferSize:0}),m=(c.Hasher=g.extend({cfg:u.extend(),init:function(e){this.cfg=this.cfg.extend(e),this.reset()},reset:function(){g.reset.call(this),this._doReset()},update:function(e){return this._append(e),this._process(),this},finalize:function(e){return e&&this._append(e),this._doFinalize()},blockSize:16,_createHelper:function(e){return function(t,n){return new e.init(n).finalize(t)}},_createHmacHelper:function(e){return function(t,n){return new m.HMAC.init(e,n).finalize(t)}}}),a.algo={});return a}(Math),i)}).call(this,n(17))},function(e,t,n){"use strict";var i=n(2),r=n(1),o={disconnected:i.a.fromValues({statusCode:400,code:80003,message:"Connection to server temporarily unavailable"}),suspended:i.a.fromValues({statusCode:400,code:80002,message:"Connection to server unavailable"}),failed:i.a.fromValues({statusCode:400,code:8e4,message:"Connection failed or disconnected by server"}),closing:i.a.fromValues({statusCode:400,code:80017,message:"Connection closing"}),closed:i.a.fromValues({statusCode:400,code:80017,message:"Connection closed"}),unknownConnectionErr:i.a.fromValues({statusCode:500,code:50002,message:"Internal connection error"}),unknownChannelErr:i.a.fromValues({statusCode:500,code:50001,message:"Internal channel error"}),isRetriable:function(e){if(!e.statusCode||!e.code||e.statusCode>=500)return!0;var t=!1;return r.a.valuesArray(o).forEach((function(n){n.code&&n.code==e.code&&(t=!0)})),t}};t.a=o},function(e,t,n){"use strict";var i=n(0),r=n(3),o=n(1),s=n(6),a=n(22),c=n(5),u=n(2),l=function(){function e(){this.buffer=[]}e.prototype.append=function(e){return this.buffer.push(e),this},e.prototype.toString=function(){return this.buffer.join("")};var t={codex:"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",encode:function(i){for(var r=new e,o=t.codex,s=new n(i);s.moveNext();){var a=s.current;s.moveNext();var c=s.current;s.moveNext();var u=s.current,l=a>>2,h=(3&a)<<4|c>>4,p=(15&c)<<2|u>>6,f=63&u;isNaN(c)?p=f=64:isNaN(u)&&(f=64),r.append(o.charAt(l)+o.charAt(h)+o.charAt(p)+o.charAt(f))}return r.toString()},decode:function(t){for(var n=new e,r=new i(t);r.moveNext();){var o=r.current;if(o<128)n.append(String.fromCharCode(o));else if(o>191&&o<224){r.moveNext();var s=r.current;n.append(String.fromCharCode((31&o)<<6|63&s))}else{r.moveNext();s=r.current;r.moveNext();var a=r.current;n.append(String.fromCharCode((15&o)<<12|(63&s)<<6|63&a))}}return n.toString()}};function n(e){this._input=e,this._index=-1,this._buffer=[]}function i(e){this._input=e,this._index=-1,this._buffer=[]}return n.prototype={current:Number.NaN,moveNext:function(){if(this._buffer.length>0)return this.current=this._buffer.shift(),!0;if(this._index>=this._input.length-1)return this.current=Number.NaN,!1;var e=this._input.charCodeAt(++this._index);return 13==e&&10==this._input.charCodeAt(this._index+1)&&(e=10,this._index+=2),e<128?this.current=e:e>127&&e<2048?(this.current=e>>6|192,this._buffer.push(63&e|128)):(this.current=e>>12|224,this._buffer.push(e>>6&63|128),this._buffer.push(63&e|128)),!0}},i.prototype={current:64,moveNext:function(){if(this._buffer.length>0)return this.current=this._buffer.shift(),!0;if(this._index>=this._input.length-1)return this.current=64,!1;var e=t.codex.indexOf(this._input.charAt(++this._index)),n=t.codex.indexOf(this._input.charAt(++this._index)),i=t.codex.indexOf(this._input.charAt(++this._index)),r=t.codex.indexOf(this._input.charAt(++this._index)),o=e<<2|n>>4,s=(15&n)<<4|i>>2,a=(3&i)<<6|r;return this.current=o,64!=i&&this._buffer.push(s),64!=r&&this._buffer.push(a),!0}},t}(),h=n(38),p=n.n(h),f=n(18),d=function(){var e,t,n=Math.pow(2,17);function h(){}function d(){return("000000"+Math.floor(1e16*Math.random())).slice(-16)}function g(e){return o.a.isErrorInfo(e)?(e.code||(403===e.statusCode?e.code=40300:(e.code=40170,e.statusCode=401)),e):new u.a(o.a.inspectError(e),e.code||40170,e.statusCode||401)}function m(e){if(!e)return"";"string"==typeof e&&(e=JSON.parse(e));var t=Object.create(null),n=o.a.keysArray(e,!0);if(!n)return"";n.sort();for(var i=0;i<n.length;i++)t[n[i]]=e[n[i]].sort();return JSON.stringify(t)}function y(e){if(e.authCallback)i.a.logAction(i.a.LOG_MINOR,"Auth()","using token auth with authCallback");else if(e.authUrl)i.a.logAction(i.a.LOG_MINOR,"Auth()","using token auth with authUrl");else if(e.key)i.a.logAction(i.a.LOG_MINOR,"Auth()","using token auth with client-side signing");else{if(!e.tokenDetails){var t="authOptions must include valid authentication parameters";throw i.a.logAction(i.a.LOG_ERROR,"Auth()",t),new Error(t)}i.a.logAction(i.a.LOG_MINOR,"Auth()","using token auth with supplied token only")}}r.a.createHmac?(t=function(e){return Buffer.from(e,"ascii").toString("base64")},e=function(e,t){var n=r.a.createHmac("SHA256",t);return n.update(e),n.digest("base64")}):(t=l.encode,e=function(e,t){return Object(f.stringify)(p()(e,t))});var v=0;function O(t,n){if(this.client=t,this.tokenParams=n.defaultTokenParams||{},this.currentTokenRequestId=null,this.waitingForTokenRequest=null,function(e){return e.useTokenAuth||!function(e){return"useTokenAuth"in e&&!e.useTokenAuth}(e)&&(e.authCallback||e.authUrl||e.token||e.tokenDetails)}(n)){if(n.key&&!e){var r="client-side token request signing not supported";throw i.a.logAction(i.a.LOG_ERROR,"Auth()",r),new Error(r)}(function(e){return!e.key&&!e.authCallback&&!e.authUrl})(n)&&i.a.logAction(i.a.LOG_ERROR,"Auth()","Warning: library initialized with a token literal without any way to renew the token when it expires (no authUrl, authCallback, or key). See https://help.ably.io/error/40171 for help"),this._saveTokenOptions(n.defaultTokenParams,n),y(this.authOptions)}else{if(!n.key){r="No authentication options provided; need one of: key, authUrl, or authCallback (or for testing only, token or tokenDetails)";throw i.a.logAction(i.a.LOG_ERROR,"Auth()",r),new u.a(r,40160,401)}i.a.logAction(i.a.LOG_MINOR,"Auth()","anonymous, using basic auth"),this._saveBasicOptions(n)}}return O.prototype.authorize=function(e,t,n){if("function"!=typeof e||n?"function"!=typeof t||n||(n=t,t=null):(n=e,t=e=null),!n){if(this.client.options.promises)return o.a.promisify(this,"authorize",arguments);n=h}var r=this;if(t&&t.key&&this.authOptions.key!==t.key)throw new u.a("Unable to update auth options with incompatible key",40102,401);t&&"force"in t&&(i.a.logAction(i.a.LOG_ERROR,"Auth.authorize","Deprecation warning: specifying {force: true} in authOptions is no longer necessary, authorize() now always gets a new token. Please remove this, as in version 1.0 and later, having a non-null authOptions will overwrite stored library authOptions, which may not be what you want"),o.a.isOnlyPropIn(t,"force")&&(t=null)),this._forceNewToken(e,t,(function(e,t){if(e)return r.client.connection&&r.client.connection.connectionManager.actOnErrorFromAuthorize(e),void n(e);r.client.connection?r.client.connection.connectionManager.onAuthUpdated(t,n):n(null,t)}))},O.prototype.authorise=function(){i.a.deprecated("Auth.authorise","Auth.authorize"),this.authorize.apply(this,arguments)},O.prototype._forceNewToken=function(e,t,n){var i=this;this.tokenDetails=null,this._saveTokenOptions(e,t),y(this.authOptions),this._ensureValidAuthCredentials(!0,(function(e,t){delete i.tokenParams.timestamp,delete i.authOptions.queryTime,n(e,t)}))},O.prototype.requestToken=function(e,t,r){if("function"!=typeof e||r?"function"!=typeof t||r||(r=t,t=null):(r=e,t=e=null),!r&&this.client.options.promises)return o.a.promisify(this,"requestToken",arguments);t=t||this.authOptions,e=e||o.a.copy(this.tokenParams),r=r||h;var a,l=this.client;if(t.authCallback)i.a.logAction(i.a.LOG_MINOR,"Auth.requestToken()","using token auth with authCallback"),a=t.authCallback;else if(t.authUrl)i.a.logAction(i.a.LOG_MINOR,"Auth.requestToken()","using token auth with authUrl"),a=function(e,r){var a=o.a.mixin({accept:"application/json, text/plain"},t.authHeaders),h=t.authMethod&&"post"===t.authMethod.toLowerCase();if(!h){var p=t.authUrl.indexOf("?");if(p>-1){var f=o.a.parseQueryString(t.authUrl.slice(p));t.authUrl=t.authUrl.slice(0,p),t.authParams=o.a.mixin(f,t.authParams)}}var d=o.a.mixin({},t.authParams||{},e),g=function(e,t,s,a){var l;if(e?i.a.logAction(i.a.LOG_MICRO,"Auth.requestToken().tokenRequestCallback","Received Error: "+o.a.inspectError(e)):(l=s["content-type"],i.a.logAction(i.a.LOG_MICRO,"Auth.requestToken().tokenRequestCallback","Received; content-type: "+l+"; body: "+o.a.inspectBody(t))),e||a)return r(e,t);if(c.a.isBuffer(t)&&(t=t.toString()),l){var h=l.indexOf("application/json")>-1,p=l.indexOf("text/plain")>-1||l.indexOf("application/jwt")>-1;if(h||p){if(h){if(t.length>n)return void r(new u.a("authUrl response exceeded max permitted length",40170,401));try{t=JSON.parse(t)}catch(e){return void r(new u.a("Unexpected error processing authURL response; err = "+e.message,40170,401))}}r(null,t,l)}else r(new u.a("authUrl responded with unacceptable content-type "+l+", should be either text/plain, application/jwt or application/json",40170,401))}else r(new u.a("authUrl response is missing a content-type header",40170,401))};if(i.a.logAction(i.a.LOG_MICRO,"Auth.requestToken().tokenRequestCallback","Requesting token from "+t.authUrl+"; Params: "+JSON.stringify(d)+"; method: "+(h?"POST":"GET")),h){var m=a||{};m["content-type"]="application/x-www-form-urlencoded";var y=o.a.toQueryString(d).slice(1);s.a.postUri(l,t.authUrl,m,y,{},g)}else s.a.getUri(l,t.authUrl,a||{},d,g)};else{if(!t.key){var p="Need a new token, but authOptions does not include any way to request one (no authUrl, authCallback, or key)";return i.a.logAction(i.a.LOG_ERROR,"Auth()","library initialized with a token literal without any way to renew the token when it expires (no authUrl, authCallback, or key). See https://help.ably.io/error/40171 for help"),void r(new u.a(p,40171,403))}var f=this;i.a.logAction(i.a.LOG_MINOR,"Auth.requestToken()","using token auth with client-side signing"),a=function(e,n){f.createTokenRequest(e,t,n)}}"capability"in e&&(e.capability=m(e.capability));var d=function(e,n){var r="/keys/"+e.keyName+"/requestToken",a=o.a.defaultPostHeaders();t.requestHeaders&&o.a.mixin(a,t.requestHeaders),i.a.logAction(i.a.LOG_MICRO,"Auth.requestToken().requestToken","Sending POST to "+r+"; Token params: "+JSON.stringify(e)),e=JSON.stringify(e),s.a.post(l,(function(e){return l.baseUri(e)+r}),a,e,null,n)},y=!1,v=this.client.options.timeouts.realtimeRequestTimeout,O=setTimeout((function(){y=!0;var e="Token request callback timed out after "+v/1e3+" seconds";i.a.logAction(i.a.LOG_ERROR,"Auth.requestToken()",e),r(new u.a(e,40170,401))}),v);a(e,(function(e,s,a){if(!y){if(clearTimeout(O),e)return i.a.logAction(i.a.LOG_ERROR,"Auth.requestToken()","token request signing call returned error; err = "+o.a.inspectError(e)),void r(g(e));if("string"!=typeof s){if("object"!=typeof s){var c="Expected token request callback to call back with a token string or token request/details object, but got a "+typeof s;return i.a.logAction(i.a.LOG_ERROR,"Auth.requestToken()",c),void r(new u.a(c,40170,401))}var l=JSON.stringify(s).length;if(l>n&&!t.suppressMaxLengthCheck)r(new u.a("Token request/details object exceeded max permitted stringified size (was "+l+" bytes)",40170,401));else if("issued"in s)r(null,s);else{if(!("keyName"in s)){c="Expected token request callback to call back with a token string, token request object, or token details object";return i.a.logAction(i.a.LOG_ERROR,"Auth.requestToken()",c),void r(new u.a(c,40170,401))}d(s,(function(e,t,n,s){if(e)return i.a.logAction(i.a.LOG_ERROR,"Auth.requestToken()","token request API call returned error; err = "+o.a.inspectError(e)),void r(g(e));s||(t=JSON.parse(t)),i.a.logAction(i.a.LOG_MINOR,"Auth.getToken()","token received"),r(null,t)}))}}else 0===s.length?r(new u.a("Token string is empty",40170,401)):s.length>n?r(new u.a("Token string exceeded max permitted length (was "+s.length+" bytes)",40170,401)):"undefined"===s||"null"===s?r(new u.a("Token string was literal null/undefined",40170,401)):"{"!==s[0]||a&&a.indexOf("application/jwt")>-1?r(null,{token:s}):r(new u.a("Token was double-encoded; make sure you're not JSON-encoding an already encoded token request or details",40170,401))}}))},O.prototype.createTokenRequest=function(t,n,r){if("function"!=typeof t||r?"function"!=typeof n||r||(r=n,n=null):(r=t,n=t=null),!r&&this.client.options.promises)return o.a.promisify(this,"createTokenRequest",arguments);n=n||this.authOptions,t=t||o.a.copy(this.tokenParams);var s=n.key;if(s){var a=s.split(":"),c=a[0],l=a[1];if(l)if(""!==t.clientId){"capability"in t&&(t.capability=m(t.capability));var h,p=o.a.mixin({keyName:c},t),f=t.clientId||"",g=t.ttl||"",y=t.capability||"",v=this;h=function(){var t=p.nonce||(p.nonce=d()),n=p.timestamp,o=p.keyName+"\n"+g+"\n"+y+"\n"+f+"\n"+n+"\n"+t+"\n";p.mac=p.mac||e(o,l),i.a.logAction(i.a.LOG_MINOR,"Auth.getTokenRequest()","generated signed request"),r(null,p)},p.timestamp?h():v.getTimestamp(n&&n.queryTime,(function(e,t){e?r(e):(p.timestamp=t,h())}))}else r(new u.a("clientId can’t be an empty string",40012,400));else r(new u.a("Invalid key specified",40101,403))}else r(new u.a("No key specified",40101,403))},O.prototype.getAuthParams=function(e){"basic"==this.method?e(null,{key:this.key}):this._ensureValidAuthCredentials(!1,(function(t,n){t?e(t):e(null,{access_token:n.token})}))},O.prototype.getAuthHeaders=function(e){"basic"==this.method?e(null,{authorization:"Basic "+this.basicKey}):this._ensureValidAuthCredentials(!1,(function(n,i){n?e(n):e(null,{authorization:"Bearer "+t(i.token)})}))},O.prototype.getTimestamp=function(e,t){this.isTimeOffsetSet()||!e&&!this.authOptions.queryTime?t(null,this.getTimestampUsingOffset()):this.client.time(t)},O.prototype.getTimestampUsingOffset=function(){return o.a.now()+(this.client.serverTimeOffset||0)},O.prototype.isTimeOffsetSet=function(){return null!==this.client.serverTimeOffset},O.prototype._saveBasicOptions=function(e){this.method="basic",this.key=e.key,this.basicKey=t(e.key),this.authOptions=e||{},"clientId"in e&&this._userSetClientId(e.clientId)},O.prototype._saveTokenOptions=function(e,t){this.method="token",e&&(this.tokenParams=e),t&&(t.token&&(t.tokenDetails="string"==typeof t.token?{token:t.token}:t.token),t.tokenDetails&&(this.tokenDetails=t.tokenDetails),"clientId"in t&&this._userSetClientId(t.clientId),this.authOptions=t)},O.prototype._ensureValidAuthCredentials=function(e,t){var n=this,r=this.tokenDetails;if(r){if(this._tokenClientIdMismatch(r.clientId))return void t(new u.a("Mismatch between clientId in token ("+r.clientId+") and current clientId ("+this.clientId+")",40102,403));if(!this.isTimeOffsetSet()||!r.expires||r.expires>=this.getTimestampUsingOffset())return i.a.logAction(i.a.LOG_MINOR,"Auth.getToken()","using cached token; expires = "+r.expires),void t(null,r);i.a.logAction(i.a.LOG_MINOR,"Auth.getToken()","deleting expired token"),this.tokenDetails=null}if((this.waitingForTokenRequest||(this.waitingForTokenRequest=Object(a.a)())).push(t),null===this.currentTokenRequestId||e){var o=this.currentTokenRequestId=v++;this.requestToken(this.tokenParams,this.authOptions,(function(e,t){if(n.currentTokenRequestId>o)i.a.logAction(i.a.LOG_MINOR,"Auth._ensureValidAuthCredentials()","Discarding token request response; overtaken by newer one");else{n.currentTokenRequestId=null;var r=n.waitingForTokenRequest||h;n.waitingForTokenRequest=null,e?r(e):r(null,n.tokenDetails=t)}}))}},O.prototype._userSetClientId=function(e){if("string"!=typeof e&&null!==e)throw new u.a("clientId must be either a string or null",40012,400);if("*"===e)throw new u.a('Can’t use "*" as a clientId as that string is reserved. (To change the default token request behaviour to use a wildcard clientId, instantiate the library with {defaultTokenParams: {clientId: "*"}}), or if calling authorize(), pass it in as a tokenParam: authorize({clientId: "*"}, authOptions)',40012,400);var t=this._uncheckedSetClientId(e);if(t)throw t},O.prototype._uncheckedSetClientId=function(e){if(this._tokenClientIdMismatch(e)){var t="Unexpected clientId mismatch: client has "+this.clientId+", requested "+e,n=new u.a(t,40102,401);return i.a.logAction(i.a.LOG_ERROR,"Auth._uncheckedSetClientId()",t),n}return this.clientId=this.tokenParams.clientId=e,null},O.prototype._tokenClientIdMismatch=function(e){return this.clientId&&"*"!==this.clientId&&e&&"*"!==e&&this.clientId!==e},O.isTokenErr=function(e){return e.code&&e.code>=40140&&e.code<40150},O}();t.a=d},function(e,t,n){"use strict";var i=n(1),r=n(8),o=n(20),s=n(0),a=n(4),c=n(13),u=n(14),l=n(2),h=function(){function e(e){return function(e){return!!e.code&&(!u.a.isTokenErr(e)&&(!!i.a.arrIn([80015,80017,80030],e.code)||e.code>=4e4&&e.code<5e4))}(e)?[r.a.fromValues({action:r.a.Action.ERROR,error:e})]:[r.a.fromValues({action:r.a.Action.DISCONNECTED,error:e})]}function t(e,t,n){n.format=void 0,n.heartbeats=!0,o.a.call(this,e,t,n),this.stream=!("stream"in n)||n.stream,this.sendRequest=null,this.recvRequest=null,this.pendingCallback=null,this.pendingItems=null}return i.a.inherits(t,o.a),t.REQ_SEND=0,t.REQ_RECV=1,t.REQ_RECV_POLL=2,t.REQ_RECV_STREAM=3,t.prototype.connect=function(){s.a.logAction(s.a.LOG_MINOR,"CometTransport.connect()","starting"),o.a.prototype.connect.call(this);var t=this,n=this.params,r=n.options,c=a.a.getHost(r,n.host),u=a.a.getPort(r),h=r.tls?"https://":"http://";this.baseUri=h+c+":"+u+"/comet/";var p=this.baseUri+"connect";s.a.logAction(s.a.LOG_MINOR,"CometTransport.connect()","uri: "+p),this.auth.getAuthParams((function(n,r){if(n)t.disconnect(n);else if(!t.isDisposed){t.authParams=r;var o=t.params.getConnectParams(r);"stream"in o&&(t.stream=o.stream),s.a.logAction(s.a.LOG_MINOR,"CometTransport.connect()","connectParams:"+i.a.toQueryString(o));var a=!1,c=t.recvRequest=t.createRequest(p,null,o,null,t.stream?3:1);c.on("data",(function(e){t.recvRequest&&(a||(a=!0,t.emit("preconnect")),t.onData(e))})),c.on("complete",(function(n,r,o){t.recvRequest||(n=n||new l.a("Request cancelled",80003,400)),t.recvRequest=null,a||n||(a=!0,t.emit("preconnect")),t.onActivity(),n?n.code?t.onData(e(n)):t.disconnect(n):i.a.nextTick((function(){t.recv()}))})),c.exec()}}))},t.prototype.requestClose=function(){s.a.logAction(s.a.LOG_MINOR,"CometTransport.requestClose()"),this._requestCloseOrDisconnect(!0)},t.prototype.requestDisconnect=function(){s.a.logAction(s.a.LOG_MINOR,"CometTransport.requestDisconnect()"),this._requestCloseOrDisconnect(!1)},t.prototype._requestCloseOrDisconnect=function(e){var t=e?this.closeUri:this.disconnectUri;if(t){var n=this,r=this.createRequest(t,null,this.authParams,null,0);r.on("complete",(function(t){t&&(s.a.logAction(s.a.LOG_ERROR,"CometTransport.request"+(e?"Close()":"Disconnect()"),"request returned err = "+i.a.inspectError(t)),n.finish("disconnected",t))})),r.exec()}},t.prototype.dispose=function(){if(s.a.logAction(s.a.LOG_MINOR,"CometTransport.dispose()",""),!this.isDisposed){this.isDisposed=!0,this.recvRequest&&(s.a.logAction(s.a.LOG_MINOR,"CometTransport.dispose()","aborting recv request"),this.recvRequest.abort(),this.recvRequest=null),this.finish("disconnected",c.a.disconnected);var e=this;i.a.nextTick((function(){e.emit("disposed")}))}},t.prototype.onConnect=function(e){if(!this.isDisposed){var t=e.connectionKey;o.a.prototype.onConnect.call(this,e);var n=this.baseUri+t;s.a.logAction(s.a.LOG_MICRO,"CometTransport.onConnect()","baseUri = "+n+"; connectionKey = "+e.connectionKey),this.sendUri=n+"/send",this.recvUri=n+"/recv",this.closeUri=n+"/close",this.disconnectUri=n+"/disconnect"}},t.prototype.send=function(e){if(this.sendRequest)return this.pendingItems=this.pendingItems||[],void this.pendingItems.push(e);var t=this.pendingItems||[];t.push(e),this.pendingItems=null,this.sendItems(t)},t.prototype.sendAnyPending=function(){var e=this.pendingItems;e&&(this.pendingItems=null,this.sendItems(e))},t.prototype.sendItems=function(t){var n=this,r=this.sendRequest=n.createRequest(n.sendUri,null,n.authParams,this.encodeRequest(t),0);r.on("complete",(function(t,r){t&&s.a.logAction(s.a.LOG_ERROR,"CometTransport.sendItems()","on complete: err = "+i.a.inspectError(t)),n.sendRequest=null,t?t.code?n.onData(e(t)):n.disconnect(t):(r&&n.onData(r),n.pendingItems&&i.a.nextTick((function(){n.sendRequest||n.sendAnyPending()})))})),r.exec()},t.prototype.recv=function(){if(!this.recvRequest&&this.isConnected){var t=this,n=this.recvRequest=this.createRequest(this.recvUri,null,this.authParams,null,t.stream?3:2);n.on("data",(function(e){t.onData(e)})),n.on("complete",(function(n){t.recvRequest=null,t.onActivity(),n?n.code?t.onData(e(n)):t.disconnect(n):i.a.nextTick((function(){t.recv()}))})),n.exec()}},t.prototype.onData=function(e){try{var t=this.decodeResponse(e);if(t&&t.length)for(var n=0;n<t.length;n++)this.onProtocolMessage(r.a.fromDeserialized(t[n]))}catch(e){s.a.logAction(s.a.LOG_ERROR,"CometTransport.onData()","Unexpected exception handing channel event: "+e.stack)}},t.prototype.encodeRequest=function(e){return JSON.stringify(e)},t.prototype.decodeResponse=function(e){return"string"==typeof e&&(e=JSON.parse(e)),e},t.prototype.onAuthUpdated=function(e){this.authParams={access_token:e.token}},t}();t.a=h},function(e,t,n){"use strict";(function(e){var i=n(1),r=function(){var t,n,r="ablyjs-storage-test";try{e.sessionStorage.setItem(r,r),e.sessionStorage.removeItem(r),t=!0}catch(e){t=!1}try{e.localStorage.setItem(r,r),e.localStorage.removeItem(r),n=!0}catch(e){n=!1}function o(){}function s(t){return t?e.sessionStorage:e.localStorage}function a(e,t,n,r){var o={value:t};return n&&(o.expires=i.a.now()+n),s(r).setItem(e,JSON.stringify(o))}function c(e,t){var n=s(t).getItem(e);if(!n)return null;var r=JSON.parse(n);return r.expires&&r.expires<i.a.now()?(s(t).removeItem(e),null):r.value}function u(e,t){return s(t).removeItem(e)}return n&&(o.set=function(e,t,n){return a(e,t,n,!1)},o.get=function(e){return c(e,!1)},o.remove=function(e){return u(e,!1)}),t&&(o.setSession=function(e,t,n){return a(e,t,n,!0)},o.getSession=function(e){return c(e,!0)},o.removeSession=function(e){return u(e,!0)}),o}();t.a=r}).call(this,n(17))},function(e,t){var n;n=function(){return this}();try{n=n||new Function("return this")()}catch(e){"object"==typeof window&&(n=window)}e.exports=n},function(e,t,n){var i,r,o;e.exports=(o=n(12),r=(i=o).lib.WordArray,i.enc.Base64={stringify:function(e){var t=e.words,n=e.sigBytes,i="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=";e.clamp();for(var r=[],o=0;o<n;o+=3)for(var s=(t[o>>>2]>>>24-o%4*8&255)<<16|(t[o+1>>>2]>>>24-(o+1)%4*8&255)<<8|t[o+2>>>2]>>>24-(o+2)%4*8&255,a=0;a<4&&o+.75*a<n;a++)r.push(i.charAt(s>>>6*(3-a)&63));var c=i.charAt(64);if(c)for(;r.length%4;)r.push(c);return r.join("")},parse:function(e){var t=e.length,n="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",i=this._reverseMap;if(!i){i=this._reverseMap=[];for(var o=0;o<n.length;o++)i[n.charCodeAt(o)]=o}var s=n.charAt(64);if(s){var a=e.indexOf(s);-1!==a&&(t=a)}return function(e,t,n){for(var i=[],o=0,s=0;s<t;s++)if(s%4){var a=n[e.charCodeAt(s-1)]<<s%4*2,c=n[e.charCodeAt(s)]>>>6-s%4*2,u=a|c;i[o>>>2]|=u<<24-o%4*8,o++}return r.create(i,o)}(e,t,i)}},o.enc.Base64)},function(e,t,n){"use strict";var i=n(10),r=n.n(i),o=n(18),s=n(28),a=n.n(s),c=n(3),u=n(0),l=n(5),h=function(){var e;if(c.a.getRandomWordArray)e=c.a.getRandomWordArray;else if("undefined"!=typeof Uint32Array&&c.a.getRandomValues){var t=new Uint32Array(4);e=function(e,n){var i=e/4,r=4==i?t:new Uint32Array(i);c.a.getRandomValues(r,(function(e){n(e,l.a.toWordArray(r))}))}}else e=function(e,t){u.a.logAction(u.a.LOG_MAJOR,"Ably.Crypto.generateRandom()","Warning: the browser you are using does not support secure cryptographically secure randomness generation; falling back to insecure Math.random()");for(var n=e/4,i=new Array(n),o=0;o<n;o++)i[o]=Math.floor(4294967296*Math.random())-2147483648;t(null,r.a.create(i))};function n(e){if("aes"===e.algorithm&&"cbc"===e.mode){if(128===e.keyLength||256===e.keyLength)return;throw new Error("Unsupported key length "+e.keyLength+" for aes-cbc encryption. Encryption key must be 128 or 256 bits (16 or 32 ASCII characters)")}}function i(e){return e.replace("_","/").replace("-","+")}r.a.create([0,0,0,0]);var s=[r.a.create([269488144,269488144,269488144,269488144],16),r.a.create([16777216],1),r.a.create([33685504],2),r.a.create([50529024],3),r.a.create([67372036],4),r.a.create([84215045,83886080],5),r.a.create([101058054,101056512],6),r.a.create([117901063,117901056],7),r.a.create([134744072,134744072],8),r.a.create([151587081,151587081,150994944],9),r.a.create([168430090,168430090,168427520],10),r.a.create([185273099,185273099,185273088],11),r.a.create([202116108,202116108,202116108],12),r.a.create([218959117,218959117,218959117,218103808],13),r.a.create([235802126,235802126,235802126,235798528],14),r.a.create([252645135,252645135,252645135,252645135],15),r.a.create([269488144,269488144,269488144,269488144],16)];function h(){}function p(){this.algorithm=null,this.keyLength=null,this.mode=null,this.key=null}function f(e,t,n){this.algorithm=e.algorithm+"-"+String(e.keyLength)+"-"+e.mode,this.cjsAlgorithm=e.algorithm.toUpperCase().replace(/-\d+$/,""),this.key=l.a.toWordArray(e.key),n&&(this.iv=l.a.toWordArray(n).clone()),this.blockLengthWords=t}return h.CipherParams=p,h.getDefaultParams=function(e){var t;if("function"!=typeof e&&"string"!=typeof e){if(!e.key)throw new Error("Crypto.getDefaultParams: a key is required");t="string"==typeof e.key?Object(o.parse)(i(e.key)):l.a.toWordArray(e.key);var r=new p;if(r.key=t,r.algorithm=e.algorithm||"aes",r.keyLength=32*t.words.length,r.mode=e.mode||"cbc",e.keyLength&&e.keyLength!==r.keyLength)throw new Error("Crypto.getDefaultParams: a keyLength of "+e.keyLength+" was specified, but the key actually has length "+r.keyLength);return n(r),r}if(u.a.deprecated("Crypto.getDefaultParams(key, callback)","Crypto.getDefaultParams({key: key})"),"function"==typeof e)h.generateRandomKey((function(t){e(null,h.getDefaultParams({key:t}))}));else{if("function"!=typeof arguments[1])throw new Error("Invalid arguments for Crypto.getDefaultParams");arguments[1](null,h.getDefaultParams({key:e}))}},h.generateRandomKey=function(t,n){1==arguments.length&&"function"==typeof t&&(n=t,t=void 0),e((t||256)/8,n)},h.getCipher=function(e){var t=e instanceof p?e:h.getDefaultParams(e);return{cipherParams:t,cipher:new f(t,4,e.iv)}},f.prototype.encrypt=function(t,n){u.a.logAction(u.a.LOG_MICRO,"CBCCipher.encrypt()","");var i=(t=l.a.toWordArray(t)).sigBytes,r=function(e){return e+16&-16}(i),o=this,c=function(){o.getIv((function(e,a){if(e)n(e);else{var c=o.encryptCipher.process(t.concat(s[r-i])),u=a.concat(c);n(null,u)}}))};this.encryptCipher?c():this.iv?(this.encryptCipher=a.a.algo[this.cjsAlgorithm].createEncryptor(this.key,{iv:this.iv}),c()):e(16,(function(e,t){e?n(e):(o.encryptCipher=a.a.algo[o.cjsAlgorithm].createEncryptor(o.key,{iv:t}),o.iv=t,c())}))},f.prototype.decrypt=function(e){u.a.logAction(u.a.LOG_MICRO,"CBCCipher.decrypt()",""),e=l.a.toWordArray(e);var t=this.blockLengthWords,n=e.words,i=r.a.create(n.slice(0,t)),o=r.a.create(n.slice(t)),s=a.a.algo[this.cjsAlgorithm].createDecryptor(this.key,{iv:i}),c=s.process(o),h=s.finalize();return s.reset(),h&&h.sigBytes&&c.concat(h),c},f.prototype.getIv=function(t){if(this.iv){var n=this.iv;return this.iv=null,void t(null,n)}var i=this;e(16,(function(e,n){e?t(e):t(null,i.encryptCipher.process(n))}))},h}();t.a=h},function(e,t,n){"use strict";var i=n(8),r=n(1),o=n(7),s=n(0),a=n(13),c=n(2),u=function(){var e=i.a.Action,t=i.a.fromValues({action:e.CLOSE}),n=i.a.fromValues({action:e.DISCONNECT});function u(e,t,n){o.a.call(this),this.connectionManager=e,e.registerProposedTransport(this),this.auth=t,this.params=n,this.timeouts=n.options.timeouts,this.format=n.format,this.isConnected=!1,this.isFinished=!1,this.isDisposed=!1,this.maxIdleInterval=null,this.idleTimer=null,this.lastActivity=null}return r.a.inherits(u,o.a),u.prototype.connect=function(){},u.prototype.close=function(){this.isConnected&&this.requestClose(),this.finish("closed",a.a.closed)},u.prototype.disconnect=function(e){this.isConnected&&this.requestDisconnect(),this.finish("disconnected",e||a.a.disconnected)},u.prototype.fail=function(e){this.isConnected&&this.requestDisconnect(),this.finish("failed",e||a.a.failed)},u.prototype.finish=function(e,t){this.isFinished||(this.isFinished=!0,this.isConnected=!1,this.maxIdleInterval=null,clearTimeout(this.idleTimer),this.idleTimer=null,this.emit(e,t),this.dispose())},u.prototype.onProtocolMessage=function(t){switch(s.a.shouldLog(s.a.LOG_MICRO)&&s.a.logAction(s.a.LOG_MICRO,"Transport.onProtocolMessage()","received on "+this.shortName+": "+i.a.stringify(t)+"; connectionId = "+this.connectionManager.connectionId),this.onActivity(),t.action){case e.HEARTBEAT:s.a.logAction(s.a.LOG_MICRO,"Transport.onProtocolMessage()",this.shortName+" heartbeat; connectionId = "+this.connectionManager.connectionId),this.emit("heartbeat",t.id);break;case e.CONNECTED:this.onConnect(t),this.emit("connected",t.error,t.connectionId,t.connectionDetails,t);break;case e.CLOSED:this.onClose(t);break;case e.DISCONNECTED:this.onDisconnect(t);break;case e.ACK:this.emit("ack",t.msgSerial,t.count);break;case e.NACK:this.emit("nack",t.msgSerial,t.count,t.error);break;case e.SYNC:if(void 0!==t.connectionId){this.emit("sync",t.connectionId,t);break}this.connectionManager.onChannelMessage(t,this);break;case e.AUTH:this.auth.authorize((function(e){e&&s.a.logAction(s.a.LOG_ERROR,"Transport.onProtocolMessage()","Ably requested re-authentication, but unable to obtain a new token: "+r.a.inspectError(e))}));break;case e.ERROR:if(s.a.logAction(s.a.LOG_MINOR,"Transport.onProtocolMessage()","received error action; connectionId = "+this.connectionManager.connectionId+"; err = "+r.a.inspect(t.error)+(t.channel?", channel: "+t.channel:"")),void 0===t.channel){this.onFatalError(t);break}this.connectionManager.onChannelMessage(t,this);break;default:this.connectionManager.onChannelMessage(t,this)}},u.prototype.onConnect=function(e){this.isConnected=!0;var t=e.connectionDetails.maxIdleInterval;t&&(this.maxIdleInterval=t+this.timeouts.realtimeRequestTimeout,this.onActivity())},u.prototype.onDisconnect=function(e){var t=e&&e.error;s.a.logAction(s.a.LOG_MINOR,"Transport.onDisconnect()","err = "+r.a.inspectError(t)),this.finish("disconnected",t)},u.prototype.onFatalError=function(e){var t=e&&e.error;s.a.logAction(s.a.LOG_MINOR,"Transport.onFatalError()","err = "+r.a.inspectError(t)),this.finish("failed",t)},u.prototype.onClose=function(e){var t=e&&e.error;s.a.logAction(s.a.LOG_MINOR,"Transport.onClose()","err = "+r.a.inspectError(t)),this.finish("closed",t)},u.prototype.requestClose=function(){s.a.logAction(s.a.LOG_MINOR,"Transport.requestClose()",""),this.send(t)},u.prototype.requestDisconnect=function(){s.a.logAction(s.a.LOG_MINOR,"Transport.requestDisconnect()",""),this.send(n)},u.prototype.ping=function(e){var t={action:i.a.Action.HEARTBEAT};e&&(t.id=e),this.send(i.a.fromValues(t))},u.prototype.dispose=function(){s.a.logAction(s.a.LOG_MINOR,"Transport.dispose()",""),this.isDisposed=!0,this.off()},u.prototype.onActivity=function(){this.maxIdleInterval&&(this.lastActivity=this.connectionManager.lastActivity=r.a.now(),this.setIdleTimer(this.maxIdleInterval+100))},u.prototype.setIdleTimer=function(e){var t=this;this.idleTimer||(this.idleTimer=setTimeout((function(){t.onIdleTimerExpire()}),e))},u.prototype.onIdleTimerExpire=function(){this.idleTimer=null;var e=r.a.now()-this.lastActivity,t=this.maxIdleInterval-e;if(t<=0){var n="No activity seen from realtime in "+e+"ms; assuming connection has dropped";s.a.logAction(s.a.LOG_ERROR,"Transport.onIdleTimerExpire()",n),this.disconnect(new c.a(n,80003,408))}else this.setIdleTimer(t+100)},u.prototype.onAuthUpdated=function(){},u}();t.a=u},function(e,t,n){"use strict";var i=function(e,t,n,i){this.previous=e,this.current=t,n&&(this.retryIn=n),i&&(this.reason=i)};t.a=i},function(e,t,n){"use strict";var i=n(0),r=function(e){e=e||[];var t=function(){for(var t=0;t<e.length;t++){var n=e[t];if(n)try{n.apply(null,arguments)}catch(e){i.a.logAction(i.a.LOG_ERROR,"Multicaster multiple callback handler","Unexpected exception: "+e+"; stack = "+e.stack)}}};return t.push=function(){Array.prototype.push.apply(e,arguments)},t};t.a=r},function(e,t,n){"use strict";var i=n(1),r=n(3),o=n(4),s=n(0),a=n(6),c=function(){function e(){}e.levels=["fatal","error","warning","info","debug"];return e.report=function(e,t,n,c){var u={event_id:i.a.randomHexString(16),tags:i.a.mixin({ablyAgent:o.a.agent},c),platform:"javascript",level:e,release:o.a.version,fingerprint:n&&[n],message:t,request:{headers:{"User-Agent":r.a.userAgent},url:r.a.currentUrl}};s.a.logAction(s.a.LOG_MICRO,"ErrorReporter","POSTing to error reporter: "+t),a.a.postUri(null,o.a.errorReportingUrl,o.a.errorReportingHeaders,JSON.stringify(u),{},(function(e,t){s.a.logAction(s.a.LOG_MICRO,"ErrorReporter","POSTing to error reporter resulted in: "+(e?i.a.inspectError(e):i.a.inspectBody(t)))}))},e}();t.a=c},function(e,t,n){"use strict";var i=function(){var e={};function t(e,t,n){e.byteLength;for(var i=0,r=n.length;i<r;i++){var o=n.charCodeAt(i);if(o<128)e.setUint8(t++,o>>>0&127|0);else if(o<2048)e.setUint8(t++,o>>>6&31|192),e.setUint8(t++,o>>>0&63|128);else if(o<65536)e.setUint8(t++,o>>>12&15|224),e.setUint8(t++,o>>>6&63|128),e.setUint8(t++,o>>>0&63|128);else{if(!(o<1114112))throw new Error("bad codepoint "+o);e.setUint8(t++,o>>>18&7|240),e.setUint8(t++,o>>>12&63|128),e.setUint8(t++,o>>>6&63|128),e.setUint8(t++,o>>>0&63|128)}}}function n(e,t,n){for(var i="",r=t,o=t+n;r<o;r++){var s=e.getUint8(r);if(0!=(128&s))if(192!=(224&s))if(224!=(240&s)){if(240!=(248&s))throw new Error("Invalid byte "+s.toString(16));i+=String.fromCharCode((7&s)<<18|(63&e.getUint8(++r))<<12|(63&e.getUint8(++r))<<6|(63&e.getUint8(++r))<<0)}else i+=String.fromCharCode((15&s)<<12|(63&e.getUint8(++r))<<6|(63&e.getUint8(++r))<<0);else i+=String.fromCharCode((15&s)<<6|63&e.getUint8(++r));else i+=String.fromCharCode(s)}return i}function i(e){for(var t=0,n=0,i=e.length;n<i;n++){var r=e.charCodeAt(n);if(r<128)t+=1;else if(r<2048)t+=2;else if(r<65536)t+=3;else{if(!(r<1114112))throw new Error("bad codepoint "+r);t+=4}}return t}e.inspect=function(e){if(void 0===e)return"undefined";var t,n;e instanceof ArrayBuffer?(n="ArrayBuffer",t=new DataView(e)):e instanceof DataView&&(n="DataView",t=e);if(!t)return JSON.stringify(e);for(var i=[],r=0;r<e.byteLength;r++){if(r>20){i.push("...");break}var o=t.getUint8(r).toString(16);1===o.length&&(o="0"+o),i.push(o)}return"<"+n+" "+i.join(" ")+">"},e.utf8Write=t,e.utf8Read=n,e.utf8ByteCount=i,e.encode=function(e,n){var r=function e(t,n){var r=typeof t;if("string"===r){if((s=i(t))<32)return 1+s;if(s<256)return 2+s;if(s<65536)return 3+s;if(s<4294967296)return 5+s}ArrayBuffer.isView&&ArrayBuffer.isView(t)&&(t=t.buffer);if(t instanceof ArrayBuffer){if((s=t.byteLength)<256)return 2+s;if(s<65536)return 3+s;if(s<4294967296)return 5+s}if("number"===r){if(Math.floor(t)!==t)return 9;if(t>=0){if(t<128)return 1;if(t<256)return 2;if(t<65536)return 3;if(t<4294967296)return 5;if(t<0x10000000000000000)return 9;throw new Error("Number too big 0x"+t.toString(16))}if(t>=-32)return 1;if(t>=-128)return 2;if(t>=-32768)return 3;if(t>=-2147483648)return 5;if(t>=-0x8000000000000000)return 9;throw new Error("Number too small -0x"+t.toString(16).substr(1))}if("boolean"===r)return 1;if(null===t)return n?0:1;if(void 0===t)return n?0:3;if("function"==typeof t.toJSON)return e(t.toJSON(),n);if("object"===r){var s,a=0;if(Array.isArray(t)){s=t.length;for(var c=0;c<s;c++)a+=e(t[c],n)}else{var u=o(t,n);s=u.length;for(c=0;c<s;c++){var l=u[c];a+=e(l)+e(t[l],n)}}if(s<16)return 1+a;if(s<65536)return 3+a;if(s<4294967296)return 5+a;throw new Error("Array or object too long 0x"+s.toString(16))}if("function"===r)return 0;throw new Error("Unknown type "+r)}(e,n);if(0!=r){var s=new ArrayBuffer(r);return function e(n,r,s,a){var c=typeof n;if("string"===c){if((u=i(n))<32)return r.setUint8(s,160|u),t(r,s+1,n),1+u;if(u<256)return r.setUint8(s,217),r.setUint8(s+1,u),t(r,s+2,n),2+u;if(u<65536)return r.setUint8(s,218),r.setUint16(s+1,u),t(r,s+3,n),3+u;if(u<4294967296)return r.setUint8(s,219),r.setUint32(s+1,u),t(r,s+5,n),5+u}ArrayBuffer.isView&&ArrayBuffer.isView(n)&&(n=n.buffer);if(n instanceof ArrayBuffer){if((u=n.byteLength)<256)return r.setUint8(s,196),r.setUint8(s+1,u),new Uint8Array(r.buffer).set(new Uint8Array(n),s+2),2+u;if(u<65536)return r.setUint8(s,197),r.setUint16(s+1,u),new Uint8Array(r.buffer).set(new Uint8Array(n),s+3),3+u;if(u<4294967296)return r.setUint8(s,198),r.setUint32(s+1,u),new Uint8Array(r.buffer).set(new Uint8Array(n),s+5),5+u}if("number"===c){if(Math.floor(n)!==n)return r.setUint8(s,203),r.setFloat64(s+1,n),9;if(n>=0){if(n<128)return r.setUint8(s,n),1;if(n<256)return r.setUint8(s,204),r.setUint8(s+1,n),2;if(n<65536)return r.setUint8(s,205),r.setUint16(s+1,n),3;if(n<4294967296)return r.setUint8(s,206),r.setUint32(s+1,n),5;if(n<0x10000000000000000)return r.setUint8(s,207),function(e,t,n){n<0x10000000000000000?(e.setUint32(t,Math.floor(2.3283064365386963e-10*n)),e.setInt32(t+4,-1&n)):(e.setUint32(t,4294967295),e.setUint32(t+4,4294967295))}(r,s+1,n),9;throw new Error("Number too big 0x"+n.toString(16))}if(n>=-32)return r.setInt8(s,n),1;if(n>=-128)return r.setUint8(s,208),r.setInt8(s+1,n),2;if(n>=-32768)return r.setUint8(s,209),r.setInt16(s+1,n),3;if(n>=-2147483648)return r.setUint8(s,210),r.setInt32(s+1,n),5;if(n>=-0x8000000000000000)return r.setUint8(s,211),function(e,t,n){n<0x8000000000000000?(e.setInt32(t,Math.floor(2.3283064365386963e-10*n)),e.setInt32(t+4,-1&n)):(e.setUint32(t,2147483647),e.setUint32(t+4,2147483647))}(r,s+1,n),9;throw new Error("Number too small -0x"+(-n).toString(16).substr(1))}if("undefined"===c)return a?0:(r.setUint8(s,212),r.setUint8(s+1,0),r.setUint8(s+2,0),3);if(null===n)return a?0:(r.setUint8(s,192),1);if("boolean"===c)return r.setUint8(s,n?195:194),1;if("function"==typeof n.toJSON)return e(n.toJSON(),r,s,a);if("object"===c){var u,l=0,h=Array.isArray(n);if(h)u=n.length;else{var p=o(n,a);u=p.length}if(u<16?(r.setUint8(s,u|(h?144:128)),l=1):u<65536?(r.setUint8(s,h?220:222),r.setUint16(s+1,u),l=3):u<4294967296&&(r.setUint8(s,h?221:223),r.setUint32(s+1,u),l=5),h)for(var f=0;f<u;f++)l+=e(n[f],r,s+l,a);else for(f=0;f<u;f++){var d=p[f];l+=e(d,r,s+l),l+=e(n[d],r,s+l,a)}return l}if("function"===c)return 0;throw new Error("Unknown type "+c)}(e,new DataView(s),0,n),s}},e.decode=function(e){var t=new r(new DataView(e)),n=t.parse();if(t.offset!==e.byteLength)throw new Error(e.byteLength-t.offset+" trailing bytes");return n};function r(e,t){this.offset=t||0,this.view=e}function o(e,t){var n=[];for(var i in e)e.hasOwnProperty(i)&&n.push(i);return n.filter((function(n){var i=e[n];return!(t&&null==i||"function"===typeof i&&!i.toJSON)}))}return r.prototype.map=function(e){for(var t={},n=0;n<e;n++){t[this.parse()]=this.parse()}return t},r.prototype.bin=r.prototype.buf=function(e){var t=new ArrayBuffer(e);return new Uint8Array(t).set(new Uint8Array(this.view.buffer,this.offset,e),0),this.offset+=e,t},r.prototype.str=function(e){var t=n(this.view,this.offset,e);return this.offset+=e,t},r.prototype.array=function(e){for(var t=new Array(e),n=0;n<e;n++)t[n]=this.parse();return t},r.prototype.ext=function(e){var t={};return t.type=this.view.getInt8(this.offset),this.offset++,t.data=this.buf(e),this.offset+=e,t},r.prototype.parse=function(){var e,t,n,i,r=this.view.getUint8(this.offset);if(0==(128&r))return this.offset++,r;if(128==(240&r))return t=15&r,this.offset++,this.map(t);if(144==(240&r))return t=15&r,this.offset++,this.array(t);if(160==(224&r))return t=31&r,this.offset++,this.str(t);if(224==(224&r))return e=this.view.getInt8(this.offset),this.offset++,e;switch(r){case 192:return this.offset++,null;case 193:return void this.offset++;case 194:return this.offset++,!1;case 195:return this.offset++,!0;case 196:return t=this.view.getUint8(this.offset+1),this.offset+=2,this.bin(t);case 197:return t=this.view.getUint16(this.offset+1),this.offset+=3,this.bin(t);case 198:return t=this.view.getUint32(this.offset+1),this.offset+=5,this.bin(t);case 199:return t=this.view.getUint8(this.offset+1),this.offset+=2,this.ext(t);case 200:return t=this.view.getUint16(this.offset+1),this.offset+=3,this.ext(t);case 201:return t=this.view.getUint32(this.offset+1),this.offset+=5,this.ext(t);case 202:return e=this.view.getFloat32(this.offset+1),this.offset+=5,e;case 203:return e=this.view.getFloat64(this.offset+1),this.offset+=9,e;case 204:return e=this.view.getUint8(this.offset+1),this.offset+=2,e;case 205:return e=this.view.getUint16(this.offset+1),this.offset+=3,e;case 206:return e=this.view.getUint32(this.offset+1),this.offset+=5,e;case 207:return n=this.view,i=(i=this.offset+1)||0,e=4294967296*n.getUint32(i)+n.getUint32(i+4),this.offset+=9,e;case 208:return e=this.view.getInt8(this.offset+1),this.offset+=2,e;case 209:return e=this.view.getInt16(this.offset+1),this.offset+=3,e;case 210:return e=this.view.getInt32(this.offset+1),this.offset+=5,e;case 211:return e=function(e,t){return t=t||0,4294967296*e.getInt32(t)+e.getUint32(t+4)}(this.view,this.offset+1),this.offset+=9,e;case 212:return t=1,this.offset++,this.ext(t);case 213:return t=2,this.offset++,this.ext(t);case 214:return t=4,this.offset++,this.ext(t);case 215:return t=8,this.offset++,this.ext(t);case 216:return t=16,this.offset++,this.ext(t);case 217:return t=this.view.getUint8(this.offset+1),this.offset+=2,this.str(t);case 218:return t=this.view.getUint16(this.offset+1),this.offset+=3,this.str(t);case 219:return t=this.view.getUint32(this.offset+1),this.offset+=5,this.str(t);case 220:return t=this.view.getUint16(this.offset+1),this.offset+=3,this.array(t);case 221:return t=this.view.getUint32(this.offset+1),this.offset+=5,this.array(t);case 222:return t=this.view.getUint16(this.offset+1),this.offset+=3,this.map(t);case 223:return t=this.view.getUint32(this.offset+1),this.offset+=5,this.map(t)}throw new Error("Unknown type 0x"+r.toString(16))},e}();t.a=i},function(e,t,n){"use strict";(function(e){var i=n(8),r=n(1),o=n(34),s=n(4),a=n(3),c=n(7),u=n(26),l=n(0),h=n(21),p=n(13),f=n(2),d=n(14),g=n(6),m=n(9),y=n(22),v=n(23),O=n(16),R=n(41),A=n(40),b=function(){var t=!(void 0===O.a||!O.a.get),n=!(void 0===O.a||!O.a.getSession),b=i.a.Action,C=o.a.PendingMessage,w=function(){},S=s.a.transportPreferenceOrder,T=S[S.length-1];function _(e,t,n,i){this.options=e,this.host=t,this.mode=n,this.connectionKey=i,this.format=e.useBinaryProtocol?"msgpack":"json",this.connectionSerial=void 0,this.timeSerial=void 0}function I(e,t){c.a.call(this),this.realtime=e,this.options=t;var i=t.timeouts,o=this,h=i.preferenceConnectTimeout+i.realtimeRequestTimeout;if(this.states={initialized:{state:"initialized",terminal:!1,queueEvents:!0,sendEvents:!1,failState:"disconnected"},connecting:{state:"connecting",terminal:!1,queueEvents:!0,sendEvents:!1,retryDelay:h,failState:"disconnected"},connected:{state:"connected",terminal:!1,queueEvents:!1,sendEvents:!0,failState:"disconnected"},synchronizing:{state:"connected",terminal:!1,queueEvents:!0,sendEvents:!1,forceQueueEvents:!0,failState:"disconnected"},disconnected:{state:"disconnected",terminal:!1,queueEvents:!0,sendEvents:!1,retryDelay:i.disconnectedRetryTimeout,failState:"disconnected"},suspended:{state:"suspended",terminal:!1,queueEvents:!1,sendEvents:!1,retryDelay:i.suspendedRetryTimeout,failState:"suspended"},closing:{state:"closing",terminal:!1,queueEvents:!1,sendEvents:!1,retryDelay:i.realtimeRequestTimeout,failState:"closed"},closed:{state:"closed",terminal:!0,queueEvents:!1,sendEvents:!1,failState:"closed"},failed:{state:"failed",terminal:!0,queueEvents:!1,sendEvents:!1,failState:"failed"}},this.state=this.states.initialized,this.errorReason=null,this.queuedMessages=new u.a,this.msgSerial=0,this.connectionDetails=void 0,this.connectionId=void 0,this.connectionKey=void 0,this.timeSerial=void 0,this.connectionSerial=void 0,this.connectionStateTtl=i.connectionStateTtl,this.maxIdleInterval=null,this.transports=r.a.intersect(t.transports||s.a.defaultTransports,I.supportedTransports),this.baseTransport=r.a.intersect(s.a.baseTransportOrder,this.transports)[0],this.upgradeTransports=r.a.intersect(this.transports,s.a.upgradeTransports),this.transportPreference=null,this.httpHosts=s.a.getHosts(t),this.activeProtocol=null,this.proposedTransports=[],this.pendingTransports=[],this.host=null,this.lastAutoReconnectAttempt=null,this.lastActivity=null,this.mostRecentMsg=null,this.forceFallbackHost=!1,this.connectCounter=0,l.a.logAction(l.a.LOG_MINOR,"Realtime.ConnectionManager()","started"),l.a.logAction(l.a.LOG_MICRO,"Realtime.ConnectionManager()","requested transports = ["+(t.transports||s.a.defaultTransports)+"]"),l.a.logAction(l.a.LOG_MICRO,"Realtime.ConnectionManager()","available transports = ["+this.transports+"]"),l.a.logAction(l.a.LOG_MICRO,"Realtime.ConnectionManager()","http hosts = ["+this.httpHosts+"]"),!this.transports.length){var p="no requested transports available";throw l.a.logAction(l.a.LOG_ERROR,"realtime.ConnectionManager()",p),new Error(p)}var f=a.a.addEventListener;f&&(n&&"function"==typeof t.recover&&f("beforeunload",this.persistConnection.bind(this)),!0===t.closeOnUnload&&f("beforeunload",(function(){l.a.logAction(l.a.LOG_MAJOR,"Realtime.ConnectionManager()","beforeunload event has triggered the connection to close as closeOnUnload is true"),o.requestState({state:"closing"})})),f("online",(function(){o.state!=o.states.disconnected&&o.state!=o.states.suspended||(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager caught browser ‘online’ event","reattempting connection"),o.requestState({state:"connecting"}))})),f("offline",(function(){o.state==o.states.connected&&(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager caught browser ‘offline’ event","disconnecting active transport"),o.disconnectAllTransports())})))}return _.prototype.getConnectParams=function(e){var t=e?r.a.copy(e):{},n=this.options;switch(this.mode){case"upgrade":t.upgrade=this.connectionKey;break;case"resume":t.resume=this.connectionKey,void 0!==this.timeSerial?t.timeSerial=this.timeSerial:void 0!==this.connectionSerial&&(t.connectionSerial=this.connectionSerial);break;case"recover":var i=n.recover.split(":");if(i){t.recover=i[0];var o=i[1];isNaN(o)?t.timeSerial=o:t.connectionSerial=o}}return void 0!==n.clientId&&(t.clientId=n.clientId),!1===n.echoMessages&&(t.echo="false"),void 0!==this.format&&(t.format=this.format),void 0!==this.stream&&(t.stream=this.stream),void 0!==this.heartbeats&&(t.heartbeats=this.heartbeats),t.v=s.a.apiVersion,t.agent=s.a.agent,void 0!==n.transportParams&&r.a.mixin(t,n.transportParams),t},_.prototype.toString=function(){var e="[mode="+this.mode;return this.host&&(e+=",host="+this.host),this.connectionKey&&(e+=",connectionKey="+this.connectionKey),void 0!==this.connectionSerial&&(e+=",connectionSerial="+this.connectionSerial),this.timeSerial&&(e+=",timeSerial="+this.timeSerial),this.format&&(e+=",format="+this.format),e+="]"},r.a.inherits(I,c.a),I.supportedTransports={},Object(A.a)(I),r.a.arrForEach(R.a,(function(e){e(I)})),I.prototype.createTransportParams=function(e,t){var n=new _(this.options,e,t,this.connectionKey);return this.timeSerial?n.timeSerial=this.timeSerial:void 0!==this.connectionSerial&&(n.connectionSerial=this.connectionSerial),n},I.prototype.getTransportParams=function(e){var t=this;!function(e){if(t.connectionKey)e("resume");else if("string"!=typeof t.options.recover){var i=t.options.recover,r=n&&O.a.getSession("ably-connection-recovery");if(r&&"function"==typeof i)return l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.getTransportParams()","Calling clientOptions-provided recover function with last session data"),void i(r,(function(n){n?(t.options.recover=r.recoveryKey,e("recover")):e("clean")}));e("clean")}else e("recover")}((function(n){var i=t.createTransportParams(null,n);if("recover"===n){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.getTransportParams()","Transport recovery mode = recover; recoveryKey = "+t.options.recover);var r=t.options.recover.split(":");r&&r[2]&&(t.msgSerial=r[2])}else l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.getTransportParams()","Transport params = "+i.toString());e(i)}))},I.prototype.tryATransport=function(e,t,n){var i=this;e.host;l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.tryATransport()","trying "+t),I.supportedTransports[t].tryConnect(this,this.realtime.auth,e,(function(r,o){var s=i.state;return s==i.states.closing||s==i.states.closed||s==i.states.failed?(o&&(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.tryATransport()","connection "+s.state+" while we were attempting the transport; closing "+o),o.close()),void n(!0)):r?(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.tryATransport()","transport "+t+" "+r.event+", err: "+r.error.toString()),void(!d.a.isTokenErr(r.error)||i.errorReason&&d.a.isTokenErr(i.errorReason)?"failed"===r.event?(i.notifyState({state:"failed",error:r.error}),n(!0)):"disconnected"===r.event&&(p.a.isRetriable(r.error)?n(!1):(i.notifyState({state:i.states.connecting.failState,error:r.error}),n(!0))):(i.errorReason=r.error,i.realtime.auth._forceNewToken(null,null,(function(r){r?i.actOnErrorFromAuthorize(r):i.tryATransport(e,t,n)}))))):(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.tryATransport()","viable transport "+t+"; setting pending"),i.setTransportPending(o,e),void n(null,o))}))},I.prototype.setTransportPending=function(e,t){var n=t.mode;l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.setTransportPending()","transport = "+e+"; mode = "+n),r.a.arrDeleteValue(this.proposedTransports,e),this.pendingTransports.push(e);var i=this;e.once("connected",(function(o,s,a,c){"upgrade"==n&&i.activeProtocol?e.shortName!==T&&r.a.arrIn(i.getUpgradePossibilities(),T)?setTimeout((function(){i.scheduleTransportActivation(o,e,s,a,c)}),i.options.timeouts.parallelUpgradeDelay):i.scheduleTransportActivation(o,e,s,a,c):(i.activateTransport(o,e,s,a,c),r.a.nextTick((function(){i.connectImpl(t)}))),"recover"===n&&i.options.recover&&(i.options.recover=null,i.unpersistConnection())})),e.on(["disconnected","closed","failed"],(function(t){i.deactivateTransport(e,this.event,t)})),this.emit("transport.pending",e)},I.prototype.scheduleTransportActivation=function(e,t,n,i,o){var s,a,c=this,u=this.activeProtocol&&this.activeProtocol.getTransport(),h=function(){t.disconnect(),r.a.arrDeleteValue(c.pendingTransports,t)};return this.state!==this.states.connected&&this.state!==this.states.connecting?(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Current connection state ("+this.state.state+(this.state===this.states.synchronizing?", but with an upgrade already in progress":"")+") is not valid to upgrade in; abandoning upgrade to "+t.shortName),void h()):!u||(s=t,a=u,r.a.arrIndexOf(S,s.shortName)>r.a.arrIndexOf(S,a.shortName))?(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Scheduling transport upgrade; transport = "+t),void this.realtime.channels.onceNopending((function(r){var s;if(r)l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.scheduleTransportActivation()","Unable to activate transport; transport = "+t+"; err = "+r);else{if(!t.isConnected)return l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Proposed transport "+t.shortName+"is no longer connected; abandoning upgrade"),void h();if(c.state===c.states.connected)l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.scheduleTransportActivation()","Currently connected, so temporarily pausing events until the upgrade is complete"),c.state=c.states.synchronizing,s=c.activeProtocol;else if(c.state!==c.states.connecting)return l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Current connection state ("+c.state.state+(c.state===c.states.synchronizing?", but with an upgrade already in progress":"")+") is not valid to upgrade in; abandoning upgrade to "+t.shortName),void h();var a=n!==c.connectionId,u=a?o:c;a&&l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.scheduleTransportActivation()","Upgrade resulted in new connectionId; resetting library connection position from "+(c.timeSerial||c.connectionSerial)+" to "+(u.timeSerial||u.connectionSerial)+"; upgrade error was "+e),l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Syncing transport; transport = "+t),c.sync(t,u,(function(n,r,o){if(n)c.state===c.states.synchronizing&&(l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.scheduleTransportActivation()","Unexpected error attempting to sync transport; transport = "+t+"; err = "+n),c.disconnectAllTransports());else{var a=function(){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Activating transport; transport = "+t),c.activateTransport(e,t,r,i,o),c.state===c.states.synchronizing?(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.scheduleTransportActivation()","Pre-upgrade protocol idle, sending queued messages on upgraded transport; transport = "+t),c.state=c.states.connected):l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Pre-upgrade protocol idle, but state is now "+c.state.state+", so leaving unchanged"),c.state.sendEvents&&c.sendQueuedMessages()};s?s.onceIdle(a):a()}}))}}))):(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.scheduleTransportActivation()","Proposed transport "+t.shortName+" is no better than current active transport "+u.shortName+" - abandoning upgrade"),void h())},I.prototype.activateTransport=function(e,t,n,i,s){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.activateTransport()","transport = "+t),e&&l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.activateTransport()","error = "+e),n&&l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.activateTransport()","connectionId =  "+n),i&&l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.activateTransport()","connectionDetails =  "+JSON.stringify(i)),s&&l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.activateTransport()","serial =  "+(s.timeSerial||s.connectionSerial)),this.persistTransportPreference(t);var a=this.state,c=this.states.connected.state;if(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.activateTransport()","current state = "+a.state),a.state==this.states.closing.state||a.state==this.states.closed.state||a.state==this.states.failed.state)return l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.activateTransport()","Disconnecting transport and abandoning"),t.disconnect(),!1;if(r.a.arrDeleteValue(this.pendingTransports,t),!t.isConnected)return l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.activateTransport()","Declining to activate transport "+t+" since it appears to no longer be connected"),!1;var u=this.activeProtocol;this.activeProtocol=new o.a(t),this.host=t.params.host;var p=i.connectionKey;p&&this.connectionKey!=p&&this.setConnection(n,i,s,!!e),this.onConnectionDetailsUpdate(i,t);var f=this;if(r.a.nextTick((function(){t.on("connected",(function(e,n,i){f.onConnectionDetailsUpdate(i,t),f.emit("update",new h.a(c,c,null,e))}))})),a.state===this.states.connected.state?e&&(this.errorReason=this.realtime.connection.errorReason=e,this.emit("update",new h.a(c,c,null,e))):(this.notifyState({state:"connected",error:e}),this.errorReason=this.realtime.connection.errorReason=e||null),this.emit("transport.active",t),u)if(u.messageQueue.count()>0&&l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.activateTransport()","Previous active protocol (for transport "+u.transport.shortName+", new one is "+t.shortName+") finishing with "+u.messageQueue.count()+" messages still pending"),u.transport===t){var d="Assumption violated: activating a transport that was also the transport for the previous active protocol; transport = "+t.shortName+"; stack = "+(new Error).stack;l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.activateTransport()",d),v.a.report("error",d,"transport-previously-active")}else u.finish();return r.a.safeArrForEach(this.pendingTransports,(function(e){if(e===t){var n="Assumption violated: activating a transport that is still marked as a pending transport; transport = "+t.shortName+"; stack = "+(new Error).stack;l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.activateTransport()",n),v.a.report("error",n,"transport-activating-pending"),r.a.arrDeleteValue(f.pendingTransports,t)}else e.disconnect()})),r.a.safeArrForEach(this.proposedTransports,(function(e){if(e===t){var n="Assumption violated: activating a transport that is still marked as a proposed transport; transport = "+t.shortName+"; stack = "+(new Error).stack;l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.activateTransport()",n),v.a.report("error",n,"transport-activating-proposed"),r.a.arrDeleteValue(f.proposedTransports,t)}else e.dispose()})),!0},I.prototype.deactivateTransport=function(e,t,n){var i=this.activeProtocol,o=i&&i.getTransport()===e,s=r.a.arrDeleteValue(this.pendingTransports,e),a=r.a.arrDeleteValue(this.proposedTransports,e),c=this.noTransportsScheduledForActivation();if(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.deactivateTransport()","transport = "+e),l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.deactivateTransport()","state = "+t+(o?"; was active":s?"; was pending":a?"; was proposed":"")+(c?"":"; another transport is scheduled for activation")),n&&n.message&&l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.deactivateTransport()","reason =  "+n.message),o&&(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.deactivateTransport()","Getting, clearing, and requeuing "+this.activeProtocol.messageQueue.count()+" pending messages"),this.queuePendingMessages(i.getPendingMessages()),r.a.nextTick((function(){i.clearPendingMessages()})),this.activeProtocol=this.host=null,clearTimeout(this.channelResumeCheckTimer)),this.emit("transport.inactive",e),o&&c||o&&"failed"===t||"closed"===t||null===i&&s&&0===this.pendingTransports.length){if("disconnected"===t&&n&&n.statusCode>500&&this.httpHosts.length>1)return this.unpersistTransportPreference(),this.forceFallbackHost=!0,void this.notifyState({state:t,error:n,retryImmediately:!0});var u="failed"===t&&d.a.isTokenErr(n)?"disconnected":t;this.notifyState({state:u,error:n})}else o&&"disconnected"===t&&this.state!==this.states.synchronizing&&(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.deactivateTransport()","wasActive but another transport is connected and scheduled for activation, so going into the connecting state until it activates"),this.startSuspendTimer(),this.startTransitionTimer(this.states.connecting),this.notifyState({state:"connecting",error:n}))},I.prototype.noTransportsScheduledForActivation=function(){return r.a.isEmpty(this.pendingTransports)||this.pendingTransports.every((function(e){return!e.isConnected}))},I.prototype.sync=function(e,t,n){var r=setTimeout((function(){e.off("sync"),n(new f.a("Timeout waiting for sync response",5e4,500))}),this.options.timeouts.realtimeRequestTimeout),o=i.a.fromValues({action:b.SYNC,connectionKey:this.connectionKey});t.timeSerial?o.timeSerial=t.timeSerial:void 0!==t.connectionSerial&&(o.connectionSerial=t.connectionSerial),e.send(o),e.once("sync",(function(e,t){clearTimeout(r),n(null,e,t)}))},I.prototype.setConnection=function(e,t,n,i){var o=this,s=this.connectionid,a=s&&s!==e;(a||!s&&i)&&(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.setConnection()","Resetting msgSerial"),this.msgSerial=0),this.connectionId!==e?(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.setConnection()","New connectionId; reattaching any attached channels"),r.a.nextTick((function(){o.realtime.channels.reattach()}))):this.options.checkChannelsOnResume&&(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.setConnection()","Same connectionId; checkChannelsOnResume is enabled"),clearTimeout(this.channelResumeCheckTimer),this.realtime.channels.resetAttachedMsgIndicators(),this.channelResumeCheckTimer=setTimeout((function(){o.realtime.channels.checkAttachedMsgIndicators(e)}),3e4)),this.realtime.connection.id=this.connectionId=e,this.realtime.connection.key=this.connectionKey=t.connectionKey;var c=a||!s;this.setConnectionSerial(n,c)},I.prototype.clearConnection=function(){this.realtime.connection.id=this.connectionId=void 0,this.realtime.connection.key=this.connectionKey=void 0,this.clearConnectionSerial(),this.msgSerial=0,this.unpersistConnection()},I.prototype.setConnectionSerial=function(e,t){var n=e.timeSerial,i=e.connectionSerial;if(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.setConnectionSerial()","Updating connection serial; serial = "+i+"; timeSerial = "+n+"; force = "+t+"; previous = "+this.connectionSerial),void 0!==n)return n<=this.timeSerial&&!t?(l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.setConnectionSerial()","received message with timeSerial "+n+", but current timeSerial is "+this.timeSerial+"; assuming message is a duplicate and discarding it"),!0):(this.realtime.connection.timeSerial=this.timeSerial=n,void this.setRecoveryKey());if(void 0!==i){if(i<=this.connectionSerial&&!t)return l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.setConnectionSerial()","received message with connectionSerial "+i+", but current connectionSerial is "+this.connectionSerial+"; assuming message is a duplicate and discarding it"),!0;this.realtime.connection.serial=this.connectionSerial=i,this.setRecoveryKey()}},I.prototype.clearConnectionSerial=function(){this.realtime.connection.serial=this.connectionSerial=void 0,this.realtime.connection.timeSerial=this.timeSerial=void 0,this.clearRecoveryKey()},I.prototype.setRecoveryKey=function(){this.realtime.connection.recoveryKey=this.connectionKey+":"+(this.timeSerial||this.connectionSerial)+":"+this.msgSerial},I.prototype.clearRecoveryKey=function(){this.realtime.connection.recoveryKey=null},I.prototype.checkConnectionStateFreshness=function(){if(this.lastActivity&&this.connectionId){var e=r.a.now()-this.lastActivity;e>this.connectionStateTtl+this.maxIdleInterval&&(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.checkConnectionStateFreshness()","Last known activity from realtime was "+e+"ms ago; discarding connection state"),this.clearConnection(),this.states.connecting.failState="suspended",this.states.connecting.queueEvents=!1)}},I.prototype.persistConnection=function(){if(n){var t=this.realtime.connection.recoveryKey;t&&(i={recoveryKey:t,disconnectedAt:r.a.now(),location:e.location,clientId:this.realtime.auth.clientId},this.connectionStateTtl,n&&O.a.setSession("ably-connection-recovery",i))}var i},I.prototype.unpersistConnection=function(){n&&O.a.removeSession("ably-connection-recovery")},I.prototype.getError=function(){return this.errorReason||this.getStateError()},I.prototype.getStateError=function(){return p.a[this.state.state]},I.prototype.activeState=function(){return this.state.queueEvents||this.state.sendEvents},I.prototype.enactStateChange=function(e){var t="failed"===e.current?l.a.LOG_ERROR:l.a.LOG_MAJOR;l.a.logAction(t,"Connection state",e.current+(e.reason?"; reason: "+e.reason:"")),l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.enactStateChange","setting new state: "+e.current+"; reason = "+(e.reason&&e.reason.message));var n=this.state=this.states[e.current];e.reason&&(this.errorReason=e.reason,this.realtime.connection.errorReason=e.reason),(n.terminal||"suspended"===n.state)&&this.clearConnection(),this.emit("connectionstate",e)},I.prototype.startTransitionTimer=function(e){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.startTransitionTimer()","transitionState: "+e.state),this.transitionTimer&&(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.startTransitionTimer()","clearing already-running timer"),clearTimeout(this.transitionTimer));var t=this;this.transitionTimer=setTimeout((function(){t.transitionTimer&&(t.transitionTimer=null,l.a.logAction(l.a.LOG_MINOR,"ConnectionManager "+e.state+" timer expired","requesting new state: "+e.failState),t.notifyState({state:e.failState}))}),e.retryDelay)},I.prototype.cancelTransitionTimer=function(){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.cancelTransitionTimer()",""),this.transitionTimer&&(clearTimeout(this.transitionTimer),this.transitionTimer=null)},I.prototype.startSuspendTimer=function(){var e=this;this.suspendTimer||(this.suspendTimer=setTimeout((function(){e.suspendTimer&&(e.suspendTimer=null,l.a.logAction(l.a.LOG_MINOR,"ConnectionManager suspend timer expired","requesting new state: suspended"),e.states.connecting.failState="suspended",e.states.connecting.queueEvents=!1,e.notifyState({state:"suspended"}))}),this.connectionStateTtl))},I.prototype.checkSuspendTimer=function(e){"disconnected"!==e&&"suspended"!==e&&"connecting"!==e&&this.cancelSuspendTimer()},I.prototype.cancelSuspendTimer=function(){this.states.connecting.failState="disconnected",this.states.connecting.queueEvents=!0,this.suspendTimer&&(clearTimeout(this.suspendTimer),this.suspendTimer=null)},I.prototype.startRetryTimer=function(e){var t=this;this.retryTimer=setTimeout((function(){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager retry timer expired","retrying"),t.retryTimer=null,t.requestState({state:"connecting"})}),e)},I.prototype.cancelRetryTimer=function(){this.retryTimer&&(clearTimeout(this.retryTimer),this.retryTimer=null)},I.prototype.notifyState=function(e){var t=e.state,n=this,i="disconnected"===t&&(this.state===this.states.connected||this.state===this.states.synchronizing||e.retryImmediately||this.state===this.states.connecting&&e.error&&d.a.isTokenErr(e.error)&&!(this.errorReason&&d.a.isTokenErr(this.errorReason)));if(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.notifyState()","new state: "+t+(i?"; will retry connection immediately":"")),t!=this.state.state&&(this.cancelTransitionTimer(),this.cancelRetryTimer(),this.checkSuspendTimer(e.state),!this.state.terminal)){var o=this.states[e.state],s=new h.a(this.state.state,o.state,o.retryDelay,e.error||p.a[o.state]);if(i){var a=function(){n.state===n.states.disconnected&&(n.lastAutoReconnectAttempt=r.a.now(),n.requestState({state:"connecting"}))},c=this.lastAutoReconnectAttempt&&r.a.now()-this.lastAutoReconnectAttempt+1;c&&c<1e3?(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.notifyState()","Last reconnect attempt was only "+c+"ms ago, waiting another "+(1e3-c)+"ms before trying again"),setTimeout(a,1e3-c)):r.a.nextTick(a)}else"disconnected"!==t&&"suspended"!==t||this.startRetryTimer(o.retryDelay);("disconnected"===t&&!i||"suspended"===t||o.terminal)&&r.a.nextTick((function(){n.disconnectAllTransports()})),"connected"!=t||this.activeProtocol||l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.notifyState()","Broken invariant: attempted to go into connected state, but there is no active protocol"),this.enactStateChange(s),this.state.sendEvents?this.sendQueuedMessages():this.state.queueEvents||(this.realtime.channels.propogateConnectionInterruption(t,s.reason),this.failQueuedMessages(s.reason))}},I.prototype.requestState=function(e){var t=e.state,n=this;if(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.requestState()","requested state: "+t+"; current state: "+this.state.state),t!=this.state.state&&(this.cancelTransitionTimer(),this.cancelRetryTimer(),this.checkSuspendTimer(t),!("connecting"==t&&"connected"==this.state.state||"closing"==t&&"closed"==this.state.state))){var i=this.states[t],o=new h.a(this.state.state,i.state,null,e.error||p.a[i.state]);this.enactStateChange(o),"connecting"==t&&r.a.nextTick((function(){n.startConnect()})),"closing"==t&&this.closeImpl()}},I.prototype.startConnect=function(){if(this.state===this.states.connecting){var e=this.realtime.auth,t=this,n=++this.connectCounter,i=function(){t.checkConnectionStateFreshness(),t.getTransportParams((function(e){n===t.connectCounter&&t.connectImpl(e,n)}))};if(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.startConnect()","starting connection"),this.startSuspendTimer(),this.startTransitionTimer(this.states.connecting),"basic"===e.method)i();else{var r=function(e){n===t.connectCounter&&(e?t.actOnErrorFromAuthorize(e):i())};this.errorReason&&d.a.isTokenErr(this.errorReason)?e._forceNewToken(null,null,r):e._ensureValidAuthCredentials(!1,r)}}else l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.startConnect()","Must be in connecting state to connect, but was "+this.state.state)},I.prototype.connectImpl=function(e,t){var n=this.state.state;n!==this.states.connecting.state&&n!==this.states.connected.state?l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.connectImpl()","Must be in connecting state to connect (or connected to upgrade), but was "+n):this.pendingTransports.length?l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.connectImpl()","Transports "+this.pendingTransports[0].toString()+" currently pending; taking no action"):n==this.states.connected.state?this.upgradeIfNeeded(e):this.transports.length>1&&this.getTransportPreference()?this.connectPreference(e):this.connectBase(e,t)},I.prototype.connectPreference=function(e){var t=this.getTransportPreference(),n=this,i=!1;r.a.arrIn(this.transports,t)||(this.unpersistTransportPreference(),this.connectImpl(e)),l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.connectPreference()","Trying to connect with stored transport preference "+t);var o=setTimeout((function(){i=!0,n.state.state!==n.states.connected.state&&(l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.connectPreference()","Shortcircuit connection attempt with "+t+" failed; clearing preference and trying from scratch"),n.disconnectAllTransports(),n.unpersistTransportPreference()),n.connectImpl(e)}),this.options.timeouts.preferenceConnectTimeout);e.host=n.httpHosts[0],n.tryATransport(e,t,(function(t,s){clearTimeout(o),i&&s?(s.off(),s.disconnect(),r.a.arrDeleteValue(this.pendingTransports,s)):s||t||(n.unpersistTransportPreference(),n.connectImpl(e))}))},I.prototype.connectBase=function(e,t){var n=this,i=function(e){n.notifyState({state:n.states.connecting.failState,error:e})},o=this.httpHosts.slice(),s=function(e,i){t===n.connectCounter&&(i||e||c())};l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.connectBase()","Trying to connect with base transport "+this.baseTransport);var a=o.shift();if(a){if(e.host=a,this.forceFallbackHost&&o.length)return this.forceFallbackHost=!1,void c();this.tryATransport(e,this.baseTransport,s)}else i(new f.a("Unable to connect (no available host)",80003,404));function c(){o.length?g.a.checkConnectivity((function(a,c){t===n.connectCounter&&(a?i(a):c?(e.host=r.a.arrPopRandomElement(o),n.tryATransport(e,n.baseTransport,s)):i(new f.a("Unable to connect (network unreachable)",80003,404)))})):i(new f.a("Unable to connect (and no more fallback hosts to try)",80003,404))}},I.prototype.getUpgradePossibilities=function(){var e=this.activeProtocol.getTransport().shortName,t=r.a.arrIndexOf(this.upgradeTransports,e);return this.upgradeTransports.slice(t+1)},I.prototype.upgradeIfNeeded=function(e){var t=this.getUpgradePossibilities(),n=this;l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.upgradeIfNeeded()","upgrade possibilities: "+r.a.inspect(t)),t.length&&r.a.arrForEach(t,(function(t){var i=n.createTransportParams(e.host,"upgrade");n.tryATransport(i,t,w)}))},I.prototype.closeImpl=function(){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.closeImpl()","closing connection"),this.cancelSuspendTimer(),this.startTransitionTimer(this.states.closing),r.a.safeArrForEach(this.pendingTransports,(function(e){l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.closeImpl()","Closing pending transport: "+e),e&&e.close()})),r.a.safeArrForEach(this.proposedTransports,(function(e){l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.closeImpl()","Disposing of proposed transport: "+e),e&&e.dispose()})),this.activeProtocol&&(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.closeImpl()","Closing active transport: "+this.activeProtocol.getTransport()),this.activeProtocol.getTransport().close()),this.notifyState({state:"closed"})},I.prototype.onAuthUpdated=function(e,t){var n=this;switch(this.state.state){case"connected":if(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.onAuthUpdated()","Sending AUTH message on active transport"),(this.pendingTransports.length||this.proposedTransports.length)&&n.state!==n.states.synchronizing){this.disconnectAllTransports(!0);var o=this.activeProtocol.getTransport().params;r.a.nextTick((function(){"connected"===n.state.state&&n.upgradeIfNeeded(o)}))}this.activeProtocol.getTransport().onAuthUpdated(e);var s=i.a.fromValues({action:b.AUTH,auth:{accessToken:e.token}});this.send(s);var a=function(){n.off(c),t(null,e)},c=function(e){"failed"===e.current&&(n.off(a),n.off(c),t(e.reason||n.getStateError()))};this.once("connectiondetails",a),this.on("connectionstate",c);break;case"connecting":l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.onAuthUpdated()","Aborting current connection attempts in order to start again with the new auth details"),this.disconnectAllTransports();default:l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.onAuthUpdated()","Connection state is "+this.state.state+"; waiting until either connected or failed");var u=function(i){switch(i.current){case"connected":n.off(u),t(null,e);break;case"failed":case"closed":case"suspended":n.off(u),t(i.reason||n.getStateError())}};n.on("connectionstate",u),"connecting"===this.state.state?n.startConnect():n.requestState({state:"connecting"})}},I.prototype.disconnectAllTransports=function(e){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.disconnectAllTransports()","Disconnecting all transports"+(e?" except the active transport":"")),this.connectCounter++,r.a.safeArrForEach(this.pendingTransports,(function(e){l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.disconnectAllTransports()","Disconnecting pending transport: "+e),e&&e.disconnect()})),this.pendingTransports=[],r.a.safeArrForEach(this.proposedTransports,(function(e){l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.disconnectAllTransports()","Disposing of proposed transport: "+e),e&&e.dispose()})),this.proposedTransports=[],this.activeProtocol&&!e&&(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.disconnectAllTransports()","Disconnecting active transport: "+this.activeProtocol.getTransport()),this.activeProtocol.getTransport().disconnect())},I.prototype.send=function(e,t,n){n=n||w;var r=this.state;if(r.sendEvents)return l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.send()","sending event"),void this.sendImpl(new C(e,n));if(!(t&&r.queueEvents||r.forceQueueEvents)){var o="rejecting event, queueEvent was "+t+", state was "+r.state;return l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.send()",o),void n(this.errorReason||new f.a(o,9e4,400))}l.a.shouldLog(l.a.LOG_MICRO)&&l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.send()","queueing msg; "+i.a.stringify(e)),this.queue(e,n)},I.prototype.sendImpl=function(e){var t=e.message;e.ackRequired&&!e.sendAttempted&&(t.msgSerial=this.msgSerial++,this.setRecoveryKey());try{this.activeProtocol.send(e)}catch(e){l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.sendImpl()","Unexpected exception in transport.send(): "+e.stack)}},I.prototype.queue=function(e,t){l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.queue()","queueing event");var n=this.queuedMessages.last(),i=this.options.maxMessageSize;n&&!n.sendAttempted&&function(e,t,n){var i;if(e.channel!==t.channel)return!1;if((i=e.action)!==b.PRESENCE&&i!==b.MESSAGE)return!1;if(i!==t.action)return!1;var o=i===b.PRESENCE?"presence":"messages",s=e[o].concat(t[o]);return!(m.a.getMessagesSize(s)>n)&&(!!r.a.allSame(s,"clientId")&&(!!r.a.arrEvery(s,(function(e){return!e.id}))&&(e[o]=s,!0)))}(n.message,e,i)?(n.merged||(n.callback=Object(y.a)([n.callback]),n.merged=!0),n.callback.push(t)):this.queuedMessages.push(new C(e,t))},I.prototype.sendQueuedMessages=function(){var e;for(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.sendQueuedMessages()","sending "+this.queuedMessages.count()+" queued messages");e=this.queuedMessages.shift();)this.sendImpl(e)},I.prototype.queuePendingMessages=function(e){e&&e.length&&(l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.queuePendingMessages()","queueing "+e.length+" pending messages"),this.queuedMessages.prepend(e))},I.prototype.failQueuedMessages=function(e){var t=this.queuedMessages.count();t>0&&(l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.failQueuedMessages()","failing "+t+" queued messages, err = "+r.a.inspectError(e)),this.queuedMessages.completeAllMessages(e))},I.prototype.onChannelMessage=function(e,t){var n=this.activeProtocol&&t===this.activeProtocol.getTransport(),o=r.a.arrIn(this.pendingTransports,t)&&this.state==this.states.synchronizing,s=e.action===b.MESSAGE||e.action===b.PRESENCE;if(n||o){if(s){if(this.setConnectionSerial(e))return;if(i.a.isDuplicate(e,this.mostRecentMsg))return void l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.onChannelMessage()","received message with different connectionSerial, but same message id as a previous; discarding; id = "+e.id);this.mostRecentMsg=e}this.realtime.channels.onChannelMessage(e)}else r.a.arrIndexOf([b.ACK,b.NACK,b.ERROR],e.action)>-1?this.realtime.channels.onChannelMessage(e):l.a.logAction(l.a.LOG_MICRO,"ConnectionManager.onChannelMessage()","received message "+JSON.stringify(e)+"on defunct transport; discarding")},I.prototype.ping=function(e,t){if(e){l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.ping()","transport = "+e);var n=r.a.now(),i=r.a.cheapRandStr(),o=function(a){if(a===i){e.off("heartbeat",o),clearTimeout(s);var c=r.a.now()-n;t(null,c)}},s=setTimeout((function(){e.off("heartbeat",o),t(new f.a("Timeout waiting for heartbeat response",5e4,500))}),this.options.timeouts.realtimeRequestTimeout);return e.on("heartbeat",o),void e.ping(i)}if("connected"===this.state.state){var a=!1,c=this,u=function(){a||(a=!0,r.a.nextTick((function(){c.ping(null,t)})))};this.on("transport.active",u),this.ping(this.activeProtocol.getTransport(),(function(e,n){c.off("transport.active",u),a||(a=!0,t(e,n))}))}else t(new f.a("Unable to ping service; not connected",4e4,400))},I.prototype.abort=function(e){this.activeProtocol.getTransport().fail(e)},I.prototype.registerProposedTransport=function(e){this.proposedTransports.push(e)},I.prototype.getTransportPreference=function(){return this.transportPreference||t&&O.a.get("ably-transport-preference")},I.prototype.persistTransportPreference=function(e){r.a.arrIn(s.a.upgradeTransports,e.shortName)&&(this.transportPreference=e.shortName,t&&O.a.set("ably-transport-preference",e.shortName))},I.prototype.unpersistTransportPreference=function(){this.transportPreference=null,t&&O.a.remove("ably-transport-preference")},I.prototype.actOnErrorFromAuthorize=function(e){if(40171===e.code)this.notifyState({state:"failed",error:e});else if(403===e.statusCode){var t="Client configured authentication provider returned 403; failing the connection";l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.actOnErrorFromAuthorize()",t),this.notifyState({state:"failed",error:new f.a(t,80019,403,e)})}else{t="Client configured authentication provider request failed";l.a.logAction(l.a.LOG_MINOR,"ConnectionManager.actOnErrorFromAuthorize",t),this.notifyState({state:this.state.failState,error:new f.a(t,80019,401,e)})}},I.prototype.onConnectionDetailsUpdate=function(e,t){if(e){this.connectionDetails=e,e.maxMessageSize&&(this.options.maxMessageSize=e.maxMessageSize);var n=e.clientId;if(n){var i=this.realtime.auth._uncheckedSetClientId(n);if(i)return l.a.logAction(l.a.LOG_ERROR,"ConnectionManager.onConnectionDetailsUpdate()",i.message),void t.fail(i)}var r=e.connectionStateTtl;r&&(this.connectionStateTtl=r),this.maxIdleInterval=e.maxIdleInterval,this.emit("connectiondetails",e)}},I}();t.a=b}).call(this,n(17))},function(e,t,n){"use strict";var i=n(1),r=n(7),o=n(0),s=function(){function e(){r.a.call(this),this.messages=[]}return i.a.inherits(e,r.a),e.prototype.count=function(){return this.messages.length},e.prototype.push=function(e){this.messages.push(e)},e.prototype.shift=function(){return this.messages.shift()},e.prototype.last=function(){return this.messages[this.messages.length-1]},e.prototype.copyAll=function(){return this.messages.slice()},e.prototype.append=function(e){this.messages.push.apply(this.messages,e)},e.prototype.prepend=function(e){this.messages.unshift.apply(this.messages,e)},e.prototype.completeMessages=function(e,t,n){o.a.logAction(o.a.LOG_MICRO,"MessageQueue.completeMessages()","serial = "+e+"; count = "+t),n=n||null;var i=this.messages,r=i[0];if(r){var s=r.message.msgSerial,a=e+t;if(a>s)for(var c=i.splice(0,a-s),u=0;u<c.length;u++)c[u].callback(n);0==i.length&&this.emit("idle")}},e.prototype.completeAllMessages=function(e){this.completeMessages(0,Number.MAX_SAFE_INTEGER||Number.MAX_VALUE,e)},e.prototype.clear=function(){o.a.logAction(o.a.LOG_MICRO,"MessageQueue.clear()","clearing "+this.messages.length+" messages"),this.messages=[],this.emit("idle")},e}();t.a=s},function(e,t,n){"use strict";(function(e){var i=n(1),r=n(7),o=n(3),s=n(2),a=n(6),c=n(0),u=n(4),l=n(5),h=n(35),p=function(){var t=function(){},n=0,p={};var f=void 0!==e&&e.XDomainRequest;function d(){var e,t;return f&&(e=(t=navigator.userAgent.toString().match(/MSIE\s([\d.]+)/))&&Number(t[1]))&&10===e}function g(e,t,o,s,a,c,u){r.a.call(this),(o=o||{}).rnd=i.a.cheapRandStr(),d()&&!o.envelope&&(o.envelope="json"),this.uri=e+i.a.toQueryString(o),this.headers=t||{},this.body=s,this.method=u?u.toUpperCase():i.a.isEmptyArg(s)?"GET":"POST",this.requestMode=a,this.timeouts=c,this.timedOut=!1,this.requestComplete=!1,p[this.id=String(++n)]=this}i.a.inherits(g,r.a);var m=g.createRequest=function(e,t,n,r,o,s,a){return s=s||u.a.TIMEOUTS,new g(e,t,i.a.copy(n),r,o,s,a)};return g.prototype.complete=function(e,t,n,i,r){this.requestComplete||(this.requestComplete=!0,!e&&t&&this.emit("data",t),this.emit("complete",e,t,n,i,r),this.dispose())},g.prototype.abort=function(){this.dispose()},g.prototype.exec=function(){var e=0==this.requestMode?this.timeouts.httpRequestTimeout:this.timeouts.recvTimeout,t=this,n=this.timer=setTimeout((function(){t.timedOut=!0,u.abort()}),e),r=this.body,o=this.method,a=this.headers,u=this.xhr=new XMLHttpRequest,h=a.accept,p="text";(h?0===h.indexOf("application/x-msgpack")&&(p="arraybuffer"):a.accept="application/json",r)&&((a["content-type"]||(a["content-type"]="application/json")).indexOf("application/json")>-1&&"string"!=typeof r&&(r=JSON.stringify(r)));for(var f in u.open(o,this.uri,!0),u.responseType=p,"authorization"in a&&(u.withCredentials=!0),a)u.setRequestHeader(f,a[f]);var d=function(e,n,i,r){var o=n+" (event type: "+e.type+")"+(t.xhr.statusText?", current statusText is "+t.xhr.statusText:"");c.a.logAction(c.a.LOG_ERROR,"Request.on"+e.type+"()",o),t.complete(new s.a(o,i,r))};u.onerror=function(e){d(e,"XHR error occurred",null,400)},u.onabort=function(e){t.timedOut?d(e,"Request aborted due to request timeout expiring",null,408):d(e,"Request cancelled",null,400)},u.ontimeout=function(e){d(e,"Request timed out",null,408)};var g,m,y,v,O=0,R=!1;function A(){try{var e,n,r=function(e,t){return e.getResponseHeader&&e.getResponseHeader(t)}(u,"content-type");(r?r.indexOf("application/json")>=0:"text"==u.responseType)?((n="arraybuffer"===u.responseType?l.a.utf8Decode(u.response):String(u.responseText)).length&&(n=JSON.parse(n)),R=!0):n=u.response,void 0!==n.response?(m=n.statusCode,v=m<400,e=n.headers,n=n.response):e=function(e){for(var t=i.a.trim(e.getAllResponseHeaders()).split("\r\n"),n={},r=0;r<t.length;r++){var o=i.a.arrMap(t[r].split(":"),i.a.trim);n[o[0].toLowerCase()]=o[1]}return n}(u)}catch(e){return void t.complete(new s.a("Malformed response body from server: "+e.message,null,400))}if(v||i.a.isArray(n))t.complete(null,n,e,R,m);else{var o=e["x-ably-errorcode"]&&n.error&&s.a.fromValues(n.error);o||(o=new s.a("Error response received from server: "+m+" body was: "+i.a.inspect(n),null,m)),t.complete(o,n,e,R,m)}}function b(){for(var e,t,n=(y=u.responseText).length-1;O<n&&(e=y.indexOf("\n",O))>-1;)t=y.slice(O,e),O=e+1,C(t)}function C(e){try{e=JSON.parse(e)}catch(e){return void t.complete(new s.a("Malformed response body from server: "+e.message,null,400))}t.emit("data",e)}u.onreadystatechange=function(){var e=u.readyState;e<3||0!==u.status&&(void 0===m&&(1223===(m=u.status)&&(m=204),clearTimeout(n),v=m<400,204!=m?g=3==t.requestMode&&v&&function(e){return e.getResponseHeader&&(e.getResponseHeader("transfer-encoding")||!e.getResponseHeader("content-length"))}(u):t.complete(null,null,null,null,m)),3==e&&g?b():4==e&&(g?(b(),t.streamComplete=!0,i.a.nextTick((function(){t.complete()}))):A()))},u.send(r)},g.prototype.dispose=function(){var e=this.xhr;if(e){e.onreadystatechange=e.onerror=e.onabort=e.ontimeout=t,this.xhr=null;var n=this.timer;n&&(clearTimeout(n),this.timer=null),this.requestComplete||e.abort()}delete p[this.id]},o.a.xhrSupported&&("object"==typeof h.a&&h.a.addUnloadListener((function(){for(var e in p)p[e].dispose()})),void 0!==a.a&&(a.a.supportsAuthHeaders=!0,a.a.Request=function(e,t,n,i,r,o,s){var a=m(n,i,r,o,0,t&&t.options.timeouts,e);return a.once("complete",s),a.exec(),a},a.a.checkConnectivity=function(e){var t=u.a.internetUpUrl;c.a.logAction(c.a.LOG_MICRO,"(XHRRequest)Http.checkConnectivity()","Sending; "+t),a.a.getUri(null,t,null,null,(function(t,n){var i=!t&&"yes"==n.replace(/\n/,"");c.a.logAction(c.a.LOG_MICRO,"(XHRRequest)Http.checkConnectivity()","Result: "+i),e(null,i)}))})),g}();t.a=p}).call(this,n(17))},function(e,t,n){var i;e.exports=(i=n(12),n(10),n(46),n(18),n(37),n(36),n(29),n(30),n(31),n(47),n(48),i)},function(e,t,n){var i,r,o,s;e.exports=(i=n(12),o=(r=i).lib.Base,s=r.enc.Utf8,void(r.algo.HMAC=o.extend({init:function(e,t){e=this._hasher=new e.init,"string"==typeof t&&(t=s.parse(t));var n=e.blockSize,i=4*n;t.sigBytes>i&&(t=e.finalize(t)),t.clamp();for(var r=this._oKey=t.clone(),o=this._iKey=t.clone(),a=r.words,c=o.words,u=0;u<n;u++)a[u]^=1549556828,c[u]^=909522486;r.sigBytes=o.sigBytes=i,this.reset()},reset:function(){var e=this._hasher;e.reset(),e.update(this._iKey)},update:function(e){return this._hasher.update(e),this},finalize:function(e){var t=this._hasher,n=t.finalize(e);return t.reset(),t.finalize(this._oKey.clone().concat(n))}})))},function(e,t,n){var i,r,o,s,a,c,u,l;e.exports=(l=n(12),n(37),n(29),r=(i=l).lib,o=r.Base,s=r.WordArray,a=i.algo,c=a.MD5,u=a.EvpKDF=o.extend({cfg:o.extend({keySize:4,hasher:c,iterations:1}),init:function(e){this.cfg=this.cfg.extend(e)},compute:function(e,t){for(var n,i=this.cfg,r=i.hasher.create(),o=s.create(),a=o.words,c=i.keySize,u=i.iterations;a.length<c;){n&&r.update(n),n=r.update(e).finalize(t),r.reset();for(var l=1;l<u;l++)n=r.finalize(n),r.reset();o.concat(n)}return o.sigBytes=4*c,o}}),i.EvpKDF=function(e,t,n){return u.create(n).compute(e,t)},l.EvpKDF)},function(e,t,n){var i,r,o,s,a,c,u,l,h,p,f,d,g,m,y,v,O,R,A;e.exports=(i=n(12),n(30),void(i.lib.Cipher||(r=i,o=r.lib,s=o.Base,a=o.WordArray,c=o.BufferedBlockAlgorithm,u=r.enc,u.Utf8,l=u.Base64,h=r.algo.EvpKDF,p=o.Cipher=c.extend({cfg:s.extend(),createEncryptor:function(e,t){return this.create(this._ENC_XFORM_MODE,e,t)},createDecryptor:function(e,t){return this.create(this._DEC_XFORM_MODE,e,t)},init:function(e,t,n){this.cfg=this.cfg.extend(n),this._xformMode=e,this._key=t,this.reset()},reset:function(){c.reset.call(this),this._doReset()},process:function(e){return this._append(e),this._process()},finalize:function(e){return e&&this._append(e),this._doFinalize()},keySize:4,ivSize:4,_ENC_XFORM_MODE:1,_DEC_XFORM_MODE:2,_createHelper:function(){function e(e){return"string"==typeof e?A:O}return function(t){return{encrypt:function(n,i,r){return e(i).encrypt(t,n,i,r)},decrypt:function(n,i,r){return e(i).decrypt(t,n,i,r)}}}}()}),o.StreamCipher=p.extend({_doFinalize:function(){return this._process(!0)},blockSize:1}),f=r.mode={},d=o.BlockCipherMode=s.extend({createEncryptor:function(e,t){return this.Encryptor.create(e,t)},createDecryptor:function(e,t){return this.Decryptor.create(e,t)},init:function(e,t){this._cipher=e,this._iv=t}}),g=f.CBC=function(){var e=d.extend();function t(e,t,n){var i,r=this._iv;r?(i=r,this._iv=void 0):i=this._prevBlock;for(var o=0;o<n;o++)e[t+o]^=i[o]}return e.Encryptor=e.extend({processBlock:function(e,n){var i=this._cipher,r=i.blockSize;t.call(this,e,n,r),i.encryptBlock(e,n),this._prevBlock=e.slice(n,n+r)}}),e.Decryptor=e.extend({processBlock:function(e,n){var i=this._cipher,r=i.blockSize,o=e.slice(n,n+r);i.decryptBlock(e,n),t.call(this,e,n,r),this._prevBlock=o}}),e}(),m=(r.pad={}).Pkcs7={pad:function(e,t){for(var n=4*t,i=n-e.sigBytes%n,r=i<<24|i<<16|i<<8|i,o=[],s=0;s<i;s+=4)o.push(r);var c=a.create(o,i);e.concat(c)},unpad:function(e){var t=255&e.words[e.sigBytes-1>>>2];e.sigBytes-=t}},o.BlockCipher=p.extend({cfg:p.cfg.extend({mode:g,padding:m}),reset:function(){var e;p.reset.call(this);var t=this.cfg,n=t.iv,i=t.mode;this._xformMode==this._ENC_XFORM_MODE?e=i.createEncryptor:(e=i.createDecryptor,this._minBufferSize=1),this._mode&&this._mode.__creator==e?this._mode.init(this,n&&n.words):(this._mode=e.call(i,this,n&&n.words),this._mode.__creator=e)},_doProcessBlock:function(e,t){this._mode.processBlock(e,t)},_doFinalize:function(){var e,t=this.cfg.padding;return this._xformMode==this._ENC_XFORM_MODE?(t.pad(this._data,this.blockSize),e=this._process(!0)):(e=this._process(!0),t.unpad(e)),e},blockSize:4}),y=o.CipherParams=s.extend({init:function(e){this.mixIn(e)},toString:function(e){return(e||this.formatter).stringify(this)}}),v=(r.format={}).OpenSSL={stringify:function(e){var t=e.ciphertext,n=e.salt;return(n?a.create([1398893684,1701076831]).concat(n).concat(t):t).toString(l)},parse:function(e){var t,n=l.parse(e),i=n.words;return 1398893684==i[0]&&1701076831==i[1]&&(t=a.create(i.slice(2,4)),i.splice(0,4),n.sigBytes-=16),y.create({ciphertext:n,salt:t})}},O=o.SerializableCipher=s.extend({cfg:s.extend({format:v}),encrypt:function(e,t,n,i){i=this.cfg.extend(i);var r=e.createEncryptor(n,i),o=r.finalize(t),s=r.cfg;return y.create({ciphertext:o,key:n,iv:s.iv,algorithm:e,mode:s.mode,padding:s.padding,blockSize:e.blockSize,formatter:i.format})},decrypt:function(e,t,n,i){return i=this.cfg.extend(i),t=this._parse(t,i.format),e.createDecryptor(n,i).finalize(t.ciphertext)},_parse:function(e,t){return"string"==typeof e?t.parse(e,this):e}}),R=(r.kdf={}).OpenSSL={execute:function(e,t,n,i){i||(i=a.random(8));var r=h.create({keySize:t+n}).compute(e,i),o=a.create(r.words.slice(t),4*n);return r.sigBytes=4*t,y.create({key:r,iv:o,salt:i})}},A=o.PasswordBasedCipher=O.extend({cfg:O.cfg.extend({kdf:R}),encrypt:function(e,t,n,i){var r=(i=this.cfg.extend(i)).kdf.execute(n,e.keySize,e.ivSize);i.iv=r.iv;var o=O.encrypt.call(this,e,t,r.key,i);return o.mixIn(r),o},decrypt:function(e,t,n,i){i=this.cfg.extend(i),t=this._parse(t,i.format);var r=i.kdf.execute(n,e.keySize,e.ivSize,t.salt);return i.iv=r.iv,O.decrypt.call(this,e,t,r.key,i)}}))))},function(e,t,n){var i;e.exports=(i=n(12),i.enc.Hex)},function(e,t,n){var i;e.exports=(i=n(12),i.enc.Utf8)},function(e,t,n){"use strict";var i=n(8),r=n(1),o=n(7),s=n(0),a=n(26),c=n(2),u=function(){var e=i.a.Action;function t(e){o.a.call(this),this.transport=e,this.messageQueue=new a.a;var t=this;e.on("ack",(function(e,n){t.onAck(e,n)})),e.on("nack",(function(e,n,i){t.onNack(e,n,i)}))}return r.a.inherits(t,o.a),t.prototype.onAck=function(e,t){s.a.logAction(s.a.LOG_MICRO,"Protocol.onAck()","serial = "+e+"; count = "+t),this.messageQueue.completeMessages(e,t)},t.prototype.onNack=function(e,t,n){s.a.logAction(s.a.LOG_ERROR,"Protocol.onNack()","serial = "+e+"; count = "+t+"; err = "+r.a.inspectError(n)),n||(n=new c.a("Unable to send message; channel not responding",50001,500)),this.messageQueue.completeMessages(e,t,n)},t.prototype.onceIdle=function(e){var t=this.messageQueue;0!==t.count()?t.once("idle",e):e()},t.prototype.send=function(e){e.ackRequired&&this.messageQueue.push(e),s.a.shouldLog(s.a.LOG_MICRO)&&s.a.logAction(s.a.LOG_MICRO,"Protocol.send()","sending msg; "+i.a.stringify(e.message)),e.sendAttempted=!0,this.transport.send(e.message)},t.prototype.getTransport=function(){return this.transport},t.prototype.getPendingMessages=function(){return this.messageQueue.copyAll()},t.prototype.clearPendingMessages=function(){return this.messageQueue.clear()},t.prototype.finish=function(){var e=this.transport;this.onceIdle((function(){e.disconnect()}))},t.PendingMessage=function(t,n){this.message=t,this.callback=n,this.merged=!1;var i=t.action;this.sendAttempted=!1,this.ackRequired=i==e.MESSAGE||i==e.PRESENCE},t}();t.a=u},function(e,t,n){"use strict";(function(e){var n=function(){function t(){}return t.addListener=function(e,t,n){e.addEventListener?e.addEventListener(t,n,!1):e.attachEvent("on"+t,(function(){n.apply(e,arguments)}))},t.removeListener=function(e,t,n){e.removeEventListener?e.removeEventListener(t,n,!1):e.detachEvent("on"+t,(function(){n.apply(e,arguments)}))},t.addMessageListener=function(e,n){t.addListener(e,"message",n)},t.removeMessageListener=function(e,n){t.removeListener(e,"message",n)},t.addUnloadListener=function(n){t.addListener(e,"unload",n)},t}();t.a=n}).call(this,n(17))},function(e,t,n){var i;e.exports=(i=n(12),function(e){var t=i,n=t.lib,r=n.WordArray,o=n.Hasher,s=t.algo,a=[],c=[];!function(){function t(t){for(var n=e.sqrt(t),i=2;i<=n;i++)if(!(t%i))return!1;return!0}function n(e){return 4294967296*(e-(0|e))|0}for(var i=2,r=0;r<64;)t(i)&&(r<8&&(a[r]=n(e.pow(i,.5))),c[r]=n(e.pow(i,1/3)),r++),i++}();var u=[],l=s.SHA256=o.extend({_doReset:function(){this._hash=new r.init(a.slice(0))},_doProcessBlock:function(e,t){for(var n=this._hash.words,i=n[0],r=n[1],o=n[2],s=n[3],a=n[4],l=n[5],h=n[6],p=n[7],f=0;f<64;f++){if(f<16)u[f]=0|e[t+f];else{var d=u[f-15],g=(d<<25|d>>>7)^(d<<14|d>>>18)^d>>>3,m=u[f-2],y=(m<<15|m>>>17)^(m<<13|m>>>19)^m>>>10;u[f]=g+u[f-7]+y+u[f-16]}var v=i&r^i&o^r&o,O=(i<<30|i>>>2)^(i<<19|i>>>13)^(i<<10|i>>>22),R=p+((a<<26|a>>>6)^(a<<21|a>>>11)^(a<<7|a>>>25))+(a&l^~a&h)+c[f]+u[f];p=h,h=l,l=a,a=s+R|0,s=o,o=r,r=i,i=R+(O+v)|0}n[0]=n[0]+i|0,n[1]=n[1]+r|0,n[2]=n[2]+o|0,n[3]=n[3]+s|0,n[4]=n[4]+a|0,n[5]=n[5]+l|0,n[6]=n[6]+h|0,n[7]=n[7]+p|0},_doFinalize:function(){var t=this._data,n=t.words,i=8*this._nDataBytes,r=8*t.sigBytes;return n[r>>>5]|=128<<24-r%32,n[14+(r+64>>>9<<4)]=e.floor(i/4294967296),n[15+(r+64>>>9<<4)]=i,t.sigBytes=4*n.length,this._process(),this._hash},clone:function(){var e=o.clone.call(this);return e._hash=this._hash.clone(),e}});t.SHA256=o._createHelper(l),t.HmacSHA256=o._createHmacHelper(l)}(Math),i.SHA256)},function(e,t,n){var i,r,o,s,a,c,u,l;e.exports=(l=n(12),r=(i=l).lib,o=r.WordArray,s=r.Hasher,a=i.algo,c=[],u=a.SHA1=s.extend({_doReset:function(){this._hash=new o.init([1732584193,4023233417,2562383102,271733878,3285377520])},_doProcessBlock:function(e,t){for(var n=this._hash.words,i=n[0],r=n[1],o=n[2],s=n[3],a=n[4],u=0;u<80;u++){if(u<16)c[u]=0|e[t+u];else{var l=c[u-3]^c[u-8]^c[u-14]^c[u-16];c[u]=l<<1|l>>>31}var h=(i<<5|i>>>27)+a+c[u];h+=u<20?1518500249+(r&o|~r&s):u<40?1859775393+(r^o^s):u<60?(r&o|r&s|o&s)-1894007588:(r^o^s)-899497514,a=s,s=o,o=r<<30|r>>>2,r=i,i=h}n[0]=n[0]+i|0,n[1]=n[1]+r|0,n[2]=n[2]+o|0,n[3]=n[3]+s|0,n[4]=n[4]+a|0},_doFinalize:function(){var e=this._data,t=e.words,n=8*this._nDataBytes,i=8*e.sigBytes;return t[i>>>5]|=128<<24-i%32,t[14+(i+64>>>9<<4)]=Math.floor(n/4294967296),t[15+(i+64>>>9<<4)]=n,e.sigBytes=4*t.length,this._process(),this._hash},clone:function(){var e=s.clone.call(this);return e._hash=this._hash.clone(),e}}),i.SHA1=s._createHelper(u),i.HmacSHA1=s._createHmacHelper(u),l.SHA1)},function(e,t,n){var i;e.exports=(i=n(12),n(36),n(29),i.HmacSHA256)},function(e,t,n){"use strict";(function(e){var i=n(1),r=n(15),o=n(3),s=n(7),a=n(6),c=n(2),u=n(4),l=n(0);t.a=function(t){var n=function(){},h=e._ablyjs_jsonp={};h._=function(e){return h["_"+e]||n};var p=1,f=null;function d(e,t,n){n.stream=!1,r.a.call(this,e,t,n),this.shortName="jsonp"}i.a.inherits(d,r.a),d.isAvailable=function(){return o.a.jsonpSupported&&o.a.allowComet},d.isAvailable()&&(t.supportedTransports.jsonp=d),o.a.jsonpSupported&&(f=document.getElementsByTagName("head")[0]);var g=null;e.JSONPTransport=d,d.tryConnect=function(e,t,n,i){var r=new d(e,t,n),o=function(e){i({event:this.event,error:e})};r.on(["failed","disconnected"],o),r.on("preconnect",(function(){l.a.logAction(l.a.LOG_MINOR,"JSONPTransport.tryConnect()","viable transport "+r),r.off(["failed","disconnected"],o),i(null,r)})),r.connect()},d.prototype.toString=function(){return"JSONPTransport; uri="+this.baseUri+"; isConnected="+this.isConnected};var m=d.prototype.createRequest=function(e,t,n,r,o,s,a){return s=this&&this.timeouts||s||u.a.TIMEOUTS,new y(void 0,e,t,i.a.copy(n),r,o,s,a)};function y(e,t,n,r,o,a,c,u){s.a.call(this),void 0===e&&(e=p++),this.id=e,this.uri=t,this.params=r||{},this.params.rnd=i.a.cheapRandStr(),n&&(n["X-Ably-Version"]&&(this.params.v=n["X-Ably-Version"]),n["Ably-Agent"]&&(this.params.agent=n["Ably-Agent"])),this.body=o,this.method=u,this.requestMode=a,this.timeouts=c,this.requestComplete=!1}return i.a.inherits(y,s.a),y.prototype.exec=function(){var e=this.id,t=this.body,n=this.method,o=this.uri,s=this.params,a=this;s.callback="_ablyjs_jsonp._("+e+")",s.envelope="jsonp",t&&(s.body=t),n&&"get"!==n&&(s.method=n);var u=this.script=document.createElement("script"),p=o+i.a.toQueryString(s);u.src=p,u.src.split("/").slice(-1)[0]!==p.split("/").slice(-1)[0]&&l.a.logAction(l.a.LOG_ERROR,"JSONP Request.exec()","Warning: the browser appears to have truncated the script URI. This will likely result in the request failing due to an unparseable body param"),u.async=!0,u.type="text/javascript",u.charset="UTF-8",u.onerror=function(e){a.complete(new c.a("JSONP script error (event: "+i.a.inspect(e)+")",null,400))},h["_"+e]=function(e){if(e.statusCode){var t=e.response;if(204==e.statusCode)a.complete(null,null,null,e.statusCode);else if(t)if(e.statusCode<400||i.a.isArray(t))a.complete(null,t,e.headers,e.statusCode);else{var n=t.error||new c.a("Error response received from server",null,e.statusCode);a.complete(n)}else a.complete(new c.a("Invalid server response: no envelope detected",null,500))}else a.complete(null,e)};var d=this.requestMode==r.a.REQ_SEND?this.timeouts.httpRequestTimeout:this.timeouts.recvTimeout;this.timer=setTimeout((function(){a.abort()}),d),f.insertBefore(u,f.firstChild)},y.prototype.complete=function(e,t,n,i){var r;(n=n||{},this.requestComplete)||(this.requestComplete=!0,t&&(r="string"==typeof t?"text/plain":"application/json",n["content-type"]=r,this.emit("data",t)),this.emit("complete",e,t,n,!0,i),this.dispose())},y.prototype.abort=function(){this.dispose()},y.prototype.dispose=function(){var e=this.timer;e&&(clearTimeout(e),this.timer=null);var t=this.script;t.parentNode&&t.parentNode.removeChild(t),delete h[this.id],this.emit("disposed")},o.a.jsonpSupported&&!a.a.Request&&(a.a.Request=function(e,t,n,o,s,a,c){var u=m(n,o,s,a,r.a.REQ_SEND,t&&t.options.timeouts,e);return u.once("complete",c),i.a.nextTick((function(){u.exec()})),u},a.a.checkConnectivity=function(e){var t=u.a.jsonpInternetUpUrl;if(g)g.push(e);else{g=[e],l.a.logAction(l.a.LOG_MICRO,"(JSONP)Http.checkConnectivity()","Sending; "+t);var n=new y("isTheInternetUp",t,null,null,null,r.a.REQ_SEND,u.a.TIMEOUTS);n.once("complete",(function(e,t){var n=!e&&t;l.a.logAction(l.a.LOG_MICRO,"(JSONP)Http.checkConnectivity()","Result: "+n);for(var i=0;i<g.length;i++)g[i](null,n);g=null})),i.a.nextTick((function(){n.exec()}))}}),d}}).call(this,n(17))},function(e,t,n){"use strict";var i=n(3),r=n(1),o=n(20),s=n(4),a=n(0),c=n(8),u=n(2);t.a=function(e){var t=i.a.WebSocket;function n(e,t,n){this.shortName="web_socket",n.heartbeats=i.a.useProtocolHeartbeats,o.a.call(this,e,t,n),this.wsHost=s.a.getHost(n.options,n.host,!0)}return r.a.inherits(n,o.a),n.isAvailable=function(){return!!t},n.isAvailable()&&(e.supportedTransports.web_socket=n),n.tryConnect=function(e,t,i,r){var o=new n(e,t,i),s=function(e){r({event:this.event,error:e})};o.on(["failed","disconnected"],s),o.on("wsopen",(function(){a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.tryConnect()","viable transport "+o),o.off(["failed","disconnected"],s),r(null,o)})),o.connect()},n.prototype.createWebSocket=function(e,n){return this.uri=e+r.a.toQueryString(n),new t(this.uri)},n.prototype.toString=function(){return"WebSocketTransport; uri="+this.uri},n.prototype.connect=function(){a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.connect()","starting"),o.a.prototype.connect.call(this);var e=this,t=this.params,n=t.options,r=(n.tls?"wss://":"ws://")+this.wsHost+":"+s.a.getPort(n)+"/";a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.connect()","uri: "+r),this.auth.getAuthParams((function(n,o){if(!e.isDisposed){var s="";for(var c in o)s+=" "+c+": "+o[c]+";";if(a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.connect()","authParams:"+s+" err: "+n),n)e.disconnect(n);else{var u=t.getConnectParams(o);try{var l=e.wsConnection=e.createWebSocket(r,u);l.binaryType=i.a.binaryType,l.onopen=function(){e.onWsOpen()},l.onclose=function(t){e.onWsClose(t)},l.onmessage=function(t){e.onWsData(t.data)},l.onerror=function(t){e.onWsError(t)},l.on&&l.on("ping",(function(){e.onActivity()}))}catch(t){a.a.logAction(a.a.LOG_ERROR,"WebSocketTransport.connect()","Unexpected exception creating websocket: err = "+(t.stack||t.message)),e.disconnect(t)}}}}))},n.prototype.send=function(e){var t=this.wsConnection;if(t)try{t.send(c.a.serialize(e,this.params.format))}catch(e){var n="Exception from ws connection when trying to send: "+r.a.inspectError(e);a.a.logAction(a.a.LOG_ERROR,"WebSocketTransport.send()",n),this.finish("disconnected",new u.a(n,5e4,500))}else a.a.logAction(a.a.LOG_ERROR,"WebSocketTransport.send()","No socket connection")},n.prototype.onWsData=function(e){a.a.logAction(a.a.LOG_MICRO,"WebSocketTransport.onWsData()","data received; length = "+e.length+"; type = "+typeof e);try{this.onProtocolMessage(c.a.deserialize(e,this.format))}catch(e){a.a.logAction(a.a.LOG_ERROR,"WebSocketTransport.onWsData()","Unexpected exception handing channel message: "+e.stack)}},n.prototype.onWsOpen=function(){a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.onWsOpen()","opened WebSocket"),this.emit("wsopen")},n.prototype.onWsClose=function(e){var t,n;if("object"==typeof e?(t=e.wasClean,n=e.code):t=1e3==(n=e),delete this.wsConnection,t){a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.onWsClose()","Cleanly closed WebSocket");var i=new u.a("Websocket closed",80003,400);this.finish("disconnected",i)}else{var r="Unclean disconnection of WebSocket ; code = "+n;i=new u.a(r,80003,400);a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.onWsClose()",r),this.finish("disconnected",i)}this.emit("disposed")},n.prototype.onWsError=function(e){a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.onError()","Error from WebSocket: "+e.message);var t=this;r.a.nextTick((function(){t.disconnect(e)}))},n.prototype.dispose=function(){a.a.logAction(a.a.LOG_MINOR,"WebSocketTransport.dispose()",""),this.isDisposed=!0;var e=this.wsConnection;e&&(e.onmessage=function(){},delete this.wsConnection,r.a.nextTick((function(){a.a.logAction(a.a.LOG_MICRO,"WebSocketTransport.dispose()","closing websocket"),e.close()})))},n}},function(e,t,n){"use strict";var i=n(39),r=n(1),o=n(0),s=n(3),a=n(15),c=n(27),u=function(e){function t(e,t,n){n.stream=!1,a.a.call(this,e,t,n),this.shortName="xhr_polling"}return r.a.inherits(t,a.a),t.isAvailable=function(){return s.a.xhrSupported&&s.a.allowComet},t.tryConnect=function(e,n,i,r){var s=new t(e,n,i),a=function(e){r({event:this.event,error:e})};s.on(["failed","disconnected"],a),s.on("preconnect",(function(){o.a.logAction(o.a.LOG_MINOR,"XHRPollingTransport.tryConnect()","viable transport "+s),s.off(["failed","disconnected"],a),r(null,s)})),s.connect()},t.prototype.toString=function(){return"XHRPollingTransport; uri="+this.baseUri+"; isConnected="+this.isConnected},t.prototype.createRequest=function(e,t,n,i,r){return c.a.createRequest(e,t,n,i,r,this.timeouts)},void 0!==e&&t.isAvailable()&&(e.supportedTransports.xhr_polling=t),t},l=function(e){function t(e,t,n){a.a.call(this,e,t,n),this.shortName="xhr_streaming"}return r.a.inherits(t,a.a),t.isAvailable=function(){return s.a.xhrSupported&&s.a.streamingSupported&&s.a.allowComet},t.tryConnect=function(e,n,i,r){var s=new t(e,n,i),a=function(e){r({event:this.event,error:e})};s.on(["failed","disconnected"],a),s.on("preconnect",(function(){o.a.logAction(o.a.LOG_MINOR,"XHRStreamingTransport.tryConnect()","viable transport "+s),s.off(["failed","disconnected"],a),r(null,s)})),s.connect()},t.prototype.toString=function(){return"XHRStreamingTransport; uri="+this.baseUri+"; isConnected="+this.isConnected},t.prototype.createRequest=function(e,t,n,i,r){return c.a.createRequest(e,t,n,i,r,this.timeouts)},void 0!==e&&t.isAvailable()&&(e.supportedTransports.xhr_streaming=t),t};t.a=[i.a,u,l]},function(e,t,n){(function(e){var i=void 0!==e&&e||"undefined"!=typeof self&&self||window,r=Function.prototype.apply;function o(e,t){this._id=e,this._clearFn=t}t.setTimeout=function(){return new o(r.call(setTimeout,i,arguments),clearTimeout)},t.setInterval=function(){return new o(r.call(setInterval,i,arguments),clearInterval)},t.clearTimeout=t.clearInterval=function(e){e&&e.close()},o.prototype.unref=o.prototype.ref=function(){},o.prototype.close=function(){this._clearFn.call(i,this._id)},t.enroll=function(e,t){clearTimeout(e._idleTimeoutId),e._idleTimeout=t},t.unenroll=function(e){clearTimeout(e._idleTimeoutId),e._idleTimeout=-1},t._unrefActive=t.active=function(e){clearTimeout(e._idleTimeoutId);var t=e._idleTimeout;t>=0&&(e._idleTimeoutId=setTimeout((function(){e._onTimeout&&e._onTimeout()}),t))},n(43),t.setImmediate="undefined"!=typeof self&&self.setImmediate||void 0!==e&&e.setImmediate||this&&this.setImmediate,t.clearImmediate="undefined"!=typeof self&&self.clearImmediate||void 0!==e&&e.clearImmediate||this&&this.clearImmediate}).call(this,n(17))},function(e,t,n){(function(e,t){!function(e,n){"use strict";if(!e.setImmediate){var i,r,o,s,a,c=1,u={},l=!1,h=e.document,p=Object.getPrototypeOf&&Object.getPrototypeOf(e);p=p&&p.setTimeout?p:e,"[object process]"==={}.toString.call(e.process)?i=function(e){t.nextTick((function(){d(e)}))}:!function(){if(e.postMessage&&!e.importScripts){var t=!0,n=e.onmessage;return e.onmessage=function(){t=!1},e.postMessage("","*"),e.onmessage=n,t}}()?e.MessageChannel?((o=new MessageChannel).port1.onmessage=function(e){d(e.data)},i=function(e){o.port2.postMessage(e)}):h&&"onreadystatechange"in h.createElement("script")?(r=h.documentElement,i=function(e){var t=h.createElement("script");t.onreadystatechange=function(){d(e),t.onreadystatechange=null,r.removeChild(t),t=null},r.appendChild(t)}):i=function(e){setTimeout(d,0,e)}:(s="setImmediate$"+Math.random()+"$",a=function(t){t.source===e&&"string"==typeof t.data&&0===t.data.indexOf(s)&&d(+t.data.slice(s.length))},e.addEventListener?e.addEventListener("message",a,!1):e.attachEvent("onmessage",a),i=function(t){e.postMessage(s+t,"*")}),p.setImmediate=function(e){"function"!=typeof e&&(e=new Function(""+e));for(var t=new Array(arguments.length-1),n=0;n<t.length;n++)t[n]=arguments[n+1];var r={callback:e,args:t};return u[c]=r,i(c),c++},p.clearImmediate=f}function f(e){delete u[e]}function d(e){if(l)setTimeout(d,0,e);else{var t=u[e];if(t){l=!0;try{!function(e){var t=e.callback,n=e.args;switch(n.length){case 0:t();break;case 1:t(n[0]);break;case 2:t(n[0],n[1]);break;case 3:t(n[0],n[1],n[2]);break;default:t.apply(void 0,n)}}(t)}finally{f(e),l=!1}}}}}("undefined"==typeof self?void 0===e?this:e:self)}).call(this,n(17),n(44))},function(e,t){var n,i,r=e.exports={};function o(){throw new Error("setTimeout has not been defined")}function s(){throw new Error("clearTimeout has not been defined")}function a(e){if(n===setTimeout)return setTimeout(e,0);if((n===o||!n)&&setTimeout)return n=setTimeout,setTimeout(e,0);try{return n(e,0)}catch(t){try{return n.call(null,e,0)}catch(t){return n.call(this,e,0)}}}!function(){try{n="function"==typeof setTimeout?setTimeout:o}catch(e){n=o}try{i="function"==typeof clearTimeout?clearTimeout:s}catch(e){i=s}}();var c,u=[],l=!1,h=-1;function p(){l&&c&&(l=!1,c.length?u=c.concat(u):h=-1,u.length&&f())}function f(){if(!l){var e=a(p);l=!0;for(var t=u.length;t;){for(c=u,u=[];++h<t;)c&&c[h].run();h=-1,t=u.length}c=null,l=!1,function(e){if(i===clearTimeout)return clearTimeout(e);if((i===s||!i)&&clearTimeout)return i=clearTimeout,clearTimeout(e);try{i(e)}catch(t){try{return i.call(null,e)}catch(t){return i.call(this,e)}}}(e)}}function d(e,t){this.fun=e,this.array=t}function g(){}r.nextTick=function(e){var t=new Array(arguments.length-1);if(arguments.length>1)for(var n=1;n<arguments.length;n++)t[n-1]=arguments[n];u.push(new d(e,t)),1!==u.length||l||a(f)},d.prototype.run=function(){this.fun.apply(null,this.array)},r.title="browser",r.browser=!0,r.env={},r.argv=[],r.version="",r.versions={},r.on=g,r.addListener=g,r.once=g,r.off=g,r.removeListener=g,r.removeAllListeners=g,r.emit=g,r.prependListener=g,r.prependOnceListener=g,r.listeners=function(e){return[]},r.binding=function(e){throw new Error("process.binding is not supported")},r.cwd=function(){return"/"},r.chdir=function(e){throw new Error("process.chdir is not supported")},r.umask=function(){return 0}},function(e,t){},function(e,t,n){var i;e.exports=(i=n(12),function(){var e=i,t=e.lib.WordArray,n=e.enc;function r(e){return e<<8&4278255360|e>>>8&16711935}n.Utf16=n.Utf16BE={stringify:function(e){for(var t=e.words,n=e.sigBytes,i=[],r=0;r<n;r+=2){var o=t[r>>>2]>>>16-r%4*8&65535;i.push(String.fromCharCode(o))}return i.join("")},parse:function(e){for(var n=e.length,i=[],r=0;r<n;r++)i[r>>>1]|=e.charCodeAt(r)<<16-r%2*16;return t.create(i,2*n)}},n.Utf16LE={stringify:function(e){for(var t=e.words,n=e.sigBytes,i=[],o=0;o<n;o+=2){var s=r(t[o>>>2]>>>16-o%4*8&65535);i.push(String.fromCharCode(s))}return i.join("")},parse:function(e){for(var n=e.length,i=[],o=0;o<n;o++)i[o>>>1]|=r(e.charCodeAt(o)<<16-o%2*16);return t.create(i,2*n)}}}(),i.enc.Utf16)},function(e,t,n){var i,r,o,s;e.exports=(s=n(12),n(31),r=(i=s).lib.CipherParams,o=i.enc.Hex,i.format.Hex={stringify:function(e){return e.ciphertext.toString(o)},parse:function(e){var t=o.parse(e);return r.create({ciphertext:t})}},s.format.Hex)},function(e,t,n){var i;e.exports=(i=n(12),n(18),n(49),n(30),n(31),function(){var e=i,t=e.lib.BlockCipher,n=e.algo,r=[],o=[],s=[],a=[],c=[],u=[],l=[],h=[],p=[],f=[];!function(){for(var e=[],t=0;t<256;t++)e[t]=t<128?t<<1:t<<1^283;var n=0,i=0;for(t=0;t<256;t++){var d=i^i<<1^i<<2^i<<3^i<<4;d=d>>>8^255&d^99,r[n]=d,o[d]=n;var g=e[n],m=e[g],y=e[m],v=257*e[d]^16843008*d;s[n]=v<<24|v>>>8,a[n]=v<<16|v>>>16,c[n]=v<<8|v>>>24,u[n]=v,v=16843009*y^65537*m^257*g^16843008*n,l[d]=v<<24|v>>>8,h[d]=v<<16|v>>>16,p[d]=v<<8|v>>>24,f[d]=v,n?(n=g^e[e[e[y^g]]],i^=e[e[i]]):n=i=1}}();var d=[0,1,2,4,8,16,32,64,128,27,54],g=n.AES=t.extend({_doReset:function(){if(!this._nRounds||this._keyPriorReset!==this._key){for(var e=this._keyPriorReset=this._key,t=e.words,n=e.sigBytes/4,i=4*((this._nRounds=n+6)+1),o=this._keySchedule=[],s=0;s<i;s++)s<n?o[s]=t[s]:(u=o[s-1],s%n?n>6&&s%n==4&&(u=r[u>>>24]<<24|r[u>>>16&255]<<16|r[u>>>8&255]<<8|r[255&u]):(u=r[(u=u<<8|u>>>24)>>>24]<<24|r[u>>>16&255]<<16|r[u>>>8&255]<<8|r[255&u],u^=d[s/n|0]<<24),o[s]=o[s-n]^u);for(var a=this._invKeySchedule=[],c=0;c<i;c++){if(s=i-c,c%4)var u=o[s];else u=o[s-4];a[c]=c<4||s<=4?u:l[r[u>>>24]]^h[r[u>>>16&255]]^p[r[u>>>8&255]]^f[r[255&u]]}}},encryptBlock:function(e,t){this._doCryptBlock(e,t,this._keySchedule,s,a,c,u,r)},decryptBlock:function(e,t){var n=e[t+1];e[t+1]=e[t+3],e[t+3]=n,this._doCryptBlock(e,t,this._invKeySchedule,l,h,p,f,o),n=e[t+1],e[t+1]=e[t+3],e[t+3]=n},_doCryptBlock:function(e,t,n,i,r,o,s,a){for(var c=this._nRounds,u=e[t]^n[0],l=e[t+1]^n[1],h=e[t+2]^n[2],p=e[t+3]^n[3],f=4,d=1;d<c;d++){var g=i[u>>>24]^r[l>>>16&255]^o[h>>>8&255]^s[255&p]^n[f++],m=i[l>>>24]^r[h>>>16&255]^o[p>>>8&255]^s[255&u]^n[f++],y=i[h>>>24]^r[p>>>16&255]^o[u>>>8&255]^s[255&l]^n[f++],v=i[p>>>24]^r[u>>>16&255]^o[l>>>8&255]^s[255&h]^n[f++];u=g,l=m,h=y,p=v}g=(a[u>>>24]<<24|a[l>>>16&255]<<16|a[h>>>8&255]<<8|a[255&p])^n[f++],m=(a[l>>>24]<<24|a[h>>>16&255]<<16|a[p>>>8&255]<<8|a[255&u])^n[f++],y=(a[h>>>24]<<24|a[p>>>16&255]<<16|a[u>>>8&255]<<8|a[255&l])^n[f++],v=(a[p>>>24]<<24|a[u>>>16&255]<<16|a[l>>>8&255]<<8|a[255&h])^n[f++],e[t]=g,e[t+1]=m,e[t+2]=y,e[t+3]=v},keySize:8});e.AES=t._createHelper(g)}(),i.AES)},function(e,t,n){var i;e.exports=(i=n(12),function(e){var t=i,n=t.lib,r=n.WordArray,o=n.Hasher,s=t.algo,a=[];!function(){for(var t=0;t<64;t++)a[t]=4294967296*e.abs(e.sin(t+1))|0}();var c=s.MD5=o.extend({_doReset:function(){this._hash=new r.init([1732584193,4023233417,2562383102,271733878])},_doProcessBlock:function(e,t){for(var n=0;n<16;n++){var i=t+n,r=e[i];e[i]=16711935&(r<<8|r>>>24)|4278255360&(r<<24|r>>>8)}var o=this._hash.words,s=e[t+0],c=e[t+1],f=e[t+2],d=e[t+3],g=e[t+4],m=e[t+5],y=e[t+6],v=e[t+7],O=e[t+8],R=e[t+9],A=e[t+10],b=e[t+11],C=e[t+12],w=e[t+13],S=e[t+14],T=e[t+15],_=o[0],I=o[1],M=o[2],k=o[3];_=u(_,I,M,k,s,7,a[0]),k=u(k,_,I,M,c,12,a[1]),M=u(M,k,_,I,f,17,a[2]),I=u(I,M,k,_,d,22,a[3]),_=u(_,I,M,k,g,7,a[4]),k=u(k,_,I,M,m,12,a[5]),M=u(M,k,_,I,y,17,a[6]),I=u(I,M,k,_,v,22,a[7]),_=u(_,I,M,k,O,7,a[8]),k=u(k,_,I,M,R,12,a[9]),M=u(M,k,_,I,A,17,a[10]),I=u(I,M,k,_,b,22,a[11]),_=u(_,I,M,k,C,7,a[12]),k=u(k,_,I,M,w,12,a[13]),M=u(M,k,_,I,S,17,a[14]),_=l(_,I=u(I,M,k,_,T,22,a[15]),M,k,c,5,a[16]),k=l(k,_,I,M,y,9,a[17]),M=l(M,k,_,I,b,14,a[18]),I=l(I,M,k,_,s,20,a[19]),_=l(_,I,M,k,m,5,a[20]),k=l(k,_,I,M,A,9,a[21]),M=l(M,k,_,I,T,14,a[22]),I=l(I,M,k,_,g,20,a[23]),_=l(_,I,M,k,R,5,a[24]),k=l(k,_,I,M,S,9,a[25]),M=l(M,k,_,I,d,14,a[26]),I=l(I,M,k,_,O,20,a[27]),_=l(_,I,M,k,w,5,a[28]),k=l(k,_,I,M,f,9,a[29]),M=l(M,k,_,I,v,14,a[30]),_=h(_,I=l(I,M,k,_,C,20,a[31]),M,k,m,4,a[32]),k=h(k,_,I,M,O,11,a[33]),M=h(M,k,_,I,b,16,a[34]),I=h(I,M,k,_,S,23,a[35]),_=h(_,I,M,k,c,4,a[36]),k=h(k,_,I,M,g,11,a[37]),M=h(M,k,_,I,v,16,a[38]),I=h(I,M,k,_,A,23,a[39]),_=h(_,I,M,k,w,4,a[40]),k=h(k,_,I,M,s,11,a[41]),M=h(M,k,_,I,d,16,a[42]),I=h(I,M,k,_,y,23,a[43]),_=h(_,I,M,k,R,4,a[44]),k=h(k,_,I,M,C,11,a[45]),M=h(M,k,_,I,T,16,a[46]),_=p(_,I=h(I,M,k,_,f,23,a[47]),M,k,s,6,a[48]),k=p(k,_,I,M,v,10,a[49]),M=p(M,k,_,I,S,15,a[50]),I=p(I,M,k,_,m,21,a[51]),_=p(_,I,M,k,C,6,a[52]),k=p(k,_,I,M,d,10,a[53]),M=p(M,k,_,I,A,15,a[54]),I=p(I,M,k,_,c,21,a[55]),_=p(_,I,M,k,O,6,a[56]),k=p(k,_,I,M,T,10,a[57]),M=p(M,k,_,I,y,15,a[58]),I=p(I,M,k,_,w,21,a[59]),_=p(_,I,M,k,g,6,a[60]),k=p(k,_,I,M,b,10,a[61]),M=p(M,k,_,I,f,15,a[62]),I=p(I,M,k,_,R,21,a[63]),o[0]=o[0]+_|0,o[1]=o[1]+I|0,o[2]=o[2]+M|0,o[3]=o[3]+k|0},_doFinalize:function(){var t=this._data,n=t.words,i=8*this._nDataBytes,r=8*t.sigBytes;n[r>>>5]|=128<<24-r%32;var o=e.floor(i/4294967296),s=i;n[15+(r+64>>>9<<4)]=16711935&(o<<8|o>>>24)|4278255360&(o<<24|o>>>8),n[14+(r+64>>>9<<4)]=16711935&(s<<8|s>>>24)|4278255360&(s<<24|s>>>8),t.sigBytes=4*(n.length+1),this._process();for(var a=this._hash,c=a.words,u=0;u<4;u++){var l=c[u];c[u]=16711935&(l<<8|l>>>24)|4278255360&(l<<24|l>>>8)}return a},clone:function(){var e=o.clone.call(this);return e._hash=this._hash.clone(),e}});function u(e,t,n,i,r,o,s){var a=e+(t&n|~t&i)+r+s;return(a<<o|a>>>32-o)+t}function l(e,t,n,i,r,o,s){var a=e+(t&i|n&~i)+r+s;return(a<<o|a>>>32-o)+t}function h(e,t,n,i,r,o,s){var a=e+(t^n^i)+r+s;return(a<<o|a>>>32-o)+t}function p(e,t,n,i,r,o,s){var a=e+(n^(t|~i))+r+s;return(a<<o|a>>>32-o)+t}t.MD5=o._createHelper(c),t.HmacMD5=o._createHmacHelper(c)}(Math),i.MD5)},function(e,t,n){"use strict";n.r(t);var i=n(3),r=n(1),o=n(0),s=n(4),a=n(14),c=function(){function e(){this.id=void 0,this.deviceSecret=void 0,this.platform=void 0,this.formFactor=void 0,this.clientId=void 0,this.metadata=void 0,this.deviceIdentityToken=void 0,this.push={recipient:void 0,state:void 0,error:void 0}}return e.prototype.toJSON=function(){return{id:this.id,deviceSecret:this.deviceSecret,platform:this.platform,formFactor:this.formFactor,clientId:this.clientId,metadata:this.metadata,deviceIdentityToken:this.deviceIdentityToken,push:{recipient:this.push.recipient,state:this.push.state,error:this.push.error}}},e.prototype.toString=function(){var e="[DeviceDetails";return this.id&&(e+="; id="+this.id),this.platform&&(e+="; platform="+this.platform),this.formFactor&&(e+="; formFactor="+this.formFactor),this.clientId&&(e+="; clientId="+this.clientId),this.metadata&&(e+="; metadata="+this.metadata),this.deviceIdentityToken&&(e+="; deviceIdentityToken="+JSON.stringify(this.deviceIdentityToken)),this.push.recipient&&(e+="; push.recipient="+JSON.stringify(this.push.recipient)),this.push.state&&(e+="; push.state="+this.push.state),this.push.error&&(e+="; push.error="+JSON.stringify(this.push.error)),this.push.metadata&&(e+="; push.metadata="+this.push.metadata),e+="]"},e.toRequestBody=r.a.encodeBody,e.fromResponseBody=function(t,n){return n&&(t=r.a.decodeBody(t,n)),r.a.isArray(t)?e.fromValuesArray(t):e.fromValues(t)},e.fromValues=function(t){return t.error=t.error&&ErrorInfo.fromValues(t.error),r.a.mixin(new e,t)},e.fromValuesArray=function(t){for(var n=t.length,i=new Array(n),r=0;r<n;r++)i[r]=e.fromValues(t[r]);return i},e}(),u=n(6),l=n(5),h=function(){var e=i.a.msgpack;function t(){}function n(e,t,n,i,o){u.a.supportsAuthHeaders?e.auth.getAuthHeaders((function(e,s){e?i(e):o(r.a.mixin(s,t),n)})):e.auth.getAuthParams((function(e,s){e?i(e):o(t,r.a.mixin(s,n))}))}function s(e){var t=[];if(e)for(var n in e)t.push(n+"="+e[n]);return t.join("&")}function c(e,t){return e+(t?"?":"")+s(t)}return r.a.arrForEach(u.a.methodsWithoutBody,(function(e){t[e]=function(n,i,r,o,s,a){t.do(e,n,i,null,r,o,s,a)}})),r.a.arrForEach(u.a.methodsWithBody,(function(e){t[e]=function(n,i,r,o,s,a,c){t.do(e,n,i,r,o,s,a,c)}})),t.do=function(t,i,h,p,f,d,g,m){o.a.shouldLog(o.a.LOG_MICRO)&&(m=function(e,t,n,i){return function(a,u,h,p,f){a?o.a.logAction(o.a.LOG_MICRO,"Resource."+t+"()","Received Error; "+c(n,i)+"; Error: "+r.a.inspectError(a)):o.a.logAction(o.a.LOG_MICRO,"Resource."+t+"()","Received; "+c(n,i)+"; Headers: "+s(h)+"; StatusCode: "+f+"; Body: "+(l.a.isBuffer(u)?u.toString():u)),e&&e(a,u,h,p,f)}}(m,t,h,d)),g&&(m=m&&function(e,t){return function(n,i,o,s,a){if(!n||i){if(!s)try{i=r.a.decodeBody(i,t)}catch(t){return void e(t)}if(void 0!==i.statusCode){var c=i.statusCode,u=i.response,l=i.headers;if(c<200||c>=300){var h=u&&u.error||n;return h||((h=new Error("Error in unenveloping "+i)).statusCode=c),void e(h,u,l,!0,c)}e(n,u,l,!0,c)}else e(n,i,o,!0,a)}else e(n)}}(m,g),(d=d||{}).envelope=g),n(i,f,d,m,(function s(l,g){o.a.shouldLog(o.a.LOG_MICRO)&&o.a.logAction(o.a.LOG_MICRO,"Resource."+t+"()","Sending; "+c(h,g));var y=[i,h,l,p,g,function(e,t,r,o,c){e&&a.a.isTokenErr(e)?i.auth.authorize(null,null,(function(e){e?m(e):n(i,f,d,m,s)})):m(e,t,r,o,c)}];if(p||y.splice(3,1),o.a.shouldLog(o.a.LOG_MICRO)){var v=p;if((l["content-type"]||"").indexOf("msgpack")>0)try{v=e.decode(p)}catch(e){o.a.logAction(o.a.LOG_MICRO,"Resource."+t+"()","Sending MsgPack Decoding Error: "+r.a.inspectError(e))}o.a.logAction(o.a.LOG_MICRO,"Resource."+t+"()","Sending; "+c(h,g)+"; Body: "+v)}u.a[t].apply(this,y)}))},t}(),p=function(){function e(e,t,n,i,r,o){this.rest=e,this.path=t,this.headers=n,this.envelope=i,this.bodyHandler=r,this.useHttpPaginatedResponse=o||!1}function t(e,t,n){if(this.resource=e,this.items=t,n){var i=this;"first"in n&&(this.first=function(e){if(!e&&i.resource.rest.options.promises)return r.a.promisify(i,"first",[]);i.get(n.first,e)}),"current"in n&&(this.current=function(e){if(!e&&i.resource.rest.options.promises)return r.a.promisify(i,"current",[]);i.get(n.current,e)}),this.next=function(e){if(!e&&i.resource.rest.options.promises)return r.a.promisify(i,"next",[]);"next"in n?i.get(n.next,e):e(null,null)},this.hasNext=function(){return"next"in n},this.isLast=function(){return!this.hasNext()}}}function n(e,n,i,r,o,s){t.call(this,e,n,o),this.statusCode=r,this.success=r<300&&r>=200,this.headers=i,this.errorCode=s&&s.code,this.errorMessage=s&&s.message}return r.a.arrForEach(u.a.methodsWithoutBody,(function(t){e.prototype[t]=function(e,n){var i=this;h[t](i.rest,i.path,i.headers,e,i.envelope,(function(e,t,r,o,s){i.handlePage(e,t,r,o,s,n)}))}})),r.a.arrForEach(u.a.methodsWithBody,(function(t){e.prototype[t]=function(e,n,i){var r=this;h[t](r.rest,r.path,n,r.headers,e,r.envelope,(function(e,t,n,o,s){i&&r.handlePage(e,t,n,o,s,i)}))}})),e.prototype.handlePage=function(e,i,s,a,c,u){if(e&&function(e,t,n){return!(n&&(t||"number"==typeof e.code))}(e,i,this.useHttpPaginatedResponse))return o.a.logAction(o.a.LOG_ERROR,"PaginatedResource.handlePage()","Unexpected error getting resource: err = "+r.a.inspectError(e)),void u(e);var l,h,p;try{l=this.bodyHandler(i,s,a)}catch(t){return void u(e||t)}s&&(h=s.Link||s.link)&&(p=function(e){"string"==typeof e&&(e=e.split(","));for(var t,n,i={},o=0;o<e.length;o++){var s=e[o].match(/^\s*<(.+)>;\s*rel="(\w+)"$/);if(s){var a=(t=s[1],n=void 0,(n=t.match(/^\.\/(\w+)\?(.*)$/))&&r.a.parseQueryString(n[2]));a&&(i[s[2]]=a)}}return i}(h)),this.useHttpPaginatedResponse?u(null,new n(this,l,s,c,p,e)):u(null,new t(this,l,p))},t.prototype.get=function(e,t){var n=this.resource;h.get(n.rest,n.path,n.headers,e,n.envelope,(function(e,i,r,o,s){n.handlePage(e,i,r,o,s,t)}))},r.a.inherits(n,t),e}(),f=n(2),d=function(){function e(){this.channel=void 0,this.deviceId=void 0,this.clientId=void 0}return e.prototype.toJSON=function(){return{channel:this.channel,deviceId:this.deviceId,clientId:this.clientId}},e.prototype.toString=function(){var e="[PushChannelSubscription";return this.channel&&(e+="; channel="+this.channel),this.deviceId&&(e+="; deviceId="+this.deviceId),this.clientId&&(e+="; clientId="+this.clientId),e+="]"},e.toRequestBody=r.a.encodeBody,e.fromResponseBody=function(t,n){return n&&(t=r.a.decodeBody(t,n)),r.a.isArray(t)?e.fromValuesArray(t):e.fromValues(t)},e.fromValues=function(t){return r.a.mixin(new e,t)},e.fromValuesArray=function(t){for(var n=t.length,i=new Array(n),r=0;r<n;r++)i[r]=e.fromValues(t[r]);return i},e}(),g=function(){var e=function(){};function t(e){this.rest=e,this.deviceRegistrations=new n(e),this.channelSubscriptions=new i(e)}function n(e){this.rest=e}function i(e){this.rest=e}return t.prototype.publish=function(t,n,i){var o=this.rest,s=o.options.useBinaryProtocol?"msgpack":"json",a=r.a.mixin({recipient:t},n),c=r.a.defaultPostHeaders(s),u={};if("function"!=typeof i){if(this.rest.options.promises)return r.a.promisify(this,"publish",arguments);i=e}o.options.headers&&r.a.mixin(c,o.options.headers),o.options.pushFullWait&&r.a.mixin(u,{fullWait:"true"}),a=r.a.encodeBody(a,s),h.post(o,"/push/publish",a,c,u,!1,(function(e){i(e)}))},n.prototype.save=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=c.fromValues(t),a=r.a.defaultPostHeaders(o),u={};if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"save",arguments);n=e}i.options.headers&&r.a.mixin(a,i.options.headers),i.options.pushFullWait&&r.a.mixin(u,{fullWait:"true"}),s=r.a.encodeBody(s,o),h.put(i,"/push/deviceRegistrations/"+encodeURIComponent(t.id),s,a,u,!1,(function(e,t,i,r){n(e,!e&&c.fromResponseBody(t,!r&&o))}))},n.prototype.get=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=r.a.defaultGetHeaders(o),a=t.id||t;if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"get",arguments);n=e}"string"==typeof a&&a.length?(i.options.headers&&r.a.mixin(s,i.options.headers),h.get(i,"/push/deviceRegistrations/"+encodeURIComponent(a),s,{},!1,(function(e,t,i,r){n(e,!e&&c.fromResponseBody(t,!r&&o))}))):n(new f.a("First argument to DeviceRegistrations#get must be a deviceId string or DeviceDetails",4e4,400))},n.prototype.list=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=u.a.supportsLinkHeaders?void 0:o,a=r.a.defaultGetHeaders(o);if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"list",arguments);n=e}i.options.headers&&r.a.mixin(a,i.options.headers),new p(i,"/push/deviceRegistrations",a,s,(function(e,t,n){return c.fromResponseBody(e,!n&&o)})).get(t,n)},n.prototype.remove=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=r.a.defaultGetHeaders(o),a={},c=t.id||t;if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"remove",arguments);n=e}"string"==typeof c&&c.length?(i.options.headers&&r.a.mixin(s,i.options.headers),i.options.pushFullWait&&r.a.mixin(a,{fullWait:"true"}),h.delete(i,"/push/deviceRegistrations/"+encodeURIComponent(c),s,a,!1,(function(e){n(e)}))):n(new f.a("First argument to DeviceRegistrations#remove must be a deviceId string or DeviceDetails",4e4,400))},n.prototype.removeWhere=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=r.a.defaultGetHeaders(o);if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"removeWhere",arguments);n=e}i.options.headers&&r.a.mixin(s,i.options.headers),i.options.pushFullWait&&r.a.mixin(t,{fullWait:"true"}),h.delete(i,"/push/deviceRegistrations",s,t,!1,(function(e){n(e)}))},i.prototype.save=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=d.fromValues(t),a=r.a.defaultPostHeaders(o),c={};if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"save",arguments);n=e}i.options.headers&&r.a.mixin(a,i.options.headers),i.options.pushFullWait&&r.a.mixin(c,{fullWait:"true"}),s=r.a.encodeBody(s,o),h.post(i,"/push/channelSubscriptions",s,a,c,!1,(function(e,t,i,r){n(e,!e&&d.fromResponseBody(t,!r&&o))}))},i.prototype.list=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=u.a.supportsLinkHeaders?void 0:o,a=r.a.defaultGetHeaders(o);if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"list",arguments);n=e}i.options.headers&&r.a.mixin(a,i.options.headers),new p(i,"/push/channelSubscriptions",a,s,(function(e,t,n){return d.fromResponseBody(e,!n&&o)})).get(t,n)},i.prototype.removeWhere=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=r.a.defaultGetHeaders(o);if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"removeWhere",arguments);n=e}i.options.headers&&r.a.mixin(s,i.options.headers),i.options.pushFullWait&&r.a.mixin(t,{fullWait:"true"}),h.delete(i,"/push/channelSubscriptions",s,t,!1,(function(e){n(e)}))},i.prototype.remove=i.prototype.removeWhere,i.prototype.listChannels=function(t,n){var i=this.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=u.a.supportsLinkHeaders?void 0:o,a=r.a.defaultGetHeaders(o);if("function"!=typeof n){if(this.rest.options.promises)return r.a.promisify(this,"listChannels",arguments);n=e}i.options.headers&&r.a.mixin(a,i.options.headers),i.options.pushFullWait&&r.a.mixin(t,{fullWait:"true"}),new p(i,"/push/channels",a,s,(function(e,t,n){!n&&o&&(e=r.a.decodeBody(e,o));for(var i=0;i<e.length;i++)e[i]=String(e[i]);return e})).get(t,n)},function(e){this.rest=e,this.admin=new t(e)}}(),m=n(7),y=n(11),v=function(){function e(){}function t(e){this.channel=e,this.basePath=e.basePath+"/presence"}return r.a.inherits(t,m.a),t.prototype.get=function(t,n){if(o.a.logAction(o.a.LOG_MICRO,"Presence.get()","channel = "+this.channel.name),void 0===n)if("function"==typeof t)n=t,t=null;else{if(this.channel.rest.options.promises)return r.a.promisify(this,"get",arguments);n=e}var i=this.channel.rest,s=i.options.useBinaryProtocol?"msgpack":"json",a=u.a.supportsLinkHeaders?void 0:s,c=r.a.defaultGetHeaders(s);i.options.headers&&r.a.mixin(c,i.options.headers);var l=this.channel.channelOptions;new p(i,this.basePath,c,a,(function(e,t,n){return y.a.fromResponseBody(e,l,!n&&s)})).get(t,n)},t.prototype.history=function(e,t){o.a.logAction(o.a.LOG_MICRO,"Presence.history()","channel = "+this.channel.name),this._history(e,t)},t.prototype._history=function(t,n){if(void 0===n)if("function"==typeof t)n=t,t=null;else{if(this.channel.rest.options.promises)return r.a.promisify(this,"_history",arguments);n=e}var i=this.channel.rest,o=i.options.useBinaryProtocol?"msgpack":"json",s=u.a.supportsLinkHeaders?void 0:o,a=r.a.defaultGetHeaders(o);this.channel;i.options.headers&&r.a.mixin(a,i.options.headers);var c=this.channel.channelOptions;new p(i,this.basePath+"/history",a,s,(function(e,t,n){return y.a.fromResponseBody(e,c,!n&&o)})).get(t,n)},t}(),O=n(19),R=n(9),A=function(){function e(){}function t(e,t,n){o.a.logAction(o.a.LOG_MINOR,"Channel()","started; name = "+t),m.a.call(this),this.rest=e,this.name=t,this.basePath="/channels/"+encodeURIComponent(t),this.presence=new v(this),this.setOptions(n)}function n(e){return r.a.arrEvery(e,(function(e){return!e.id}))}return r.a.inherits(t,m.a),t.prototype.setOptions=function(e){if(this.channelOptions=e=e||{},e.cipher){if(!O.a)throw new Error("Encryption not enabled; use ably.encryption.js instead");var t=O.a.getCipher(e.cipher);e.cipher=t.cipherParams,e.channelCipher=t.cipher}else"cipher"in e&&(e.cipher=null,e.channelCipher=null)},t.prototype.history=function(t,n){if(o.a.logAction(o.a.LOG_MICRO,"Channel.history()","channel = "+this.name),void 0===n)if("function"==typeof t)n=t,t=null;else{if(this.rest.options.promises)return r.a.promisify(this,"history",arguments);n=e}this._history(t,n)},t.prototype._history=function(e,t){var n=this.rest,i=n.options.useBinaryProtocol?"msgpack":"json",o=u.a.supportsLinkHeaders?void 0:i,s=r.a.defaultGetHeaders(i);n.options.headers&&r.a.mixin(s,n.options.headers);var a=this.channelOptions;new p(n,this.basePath+"/messages",s,o,(function(e,t,n){return R.a.fromResponseBody(e,a,!n&&i)})).get(e,t)},t.prototype.publish=function(){var t,i,o=arguments.length,s=arguments[0],a=arguments[1],c=arguments[o-1],u=this;if("function"!=typeof c){if(this.rest.options.promises)return r.a.promisify(this,"publish",arguments);c=e}if("string"==typeof s||null===s)t=[R.a.fromValues({name:s,data:a})],i=arguments[2];else if(r.a.isObject(s))t=[R.a.fromValues(s)],i=arguments[1];else{if(!r.a.isArray(s))throw new f.a("The single-argument form of publish() expects a message object or an array of message objects",40013,400);t=R.a.fromValuesArray(s),i=arguments[1]}"object"==typeof i&&i||(i={});var l=this.rest,h=l.options,p=h.useBinaryProtocol?"msgpack":"json",d=l.options.idempotentRestPublishing,g=r.a.defaultPostHeaders(p);if(h.headers&&r.a.mixin(g,h.headers),d&&n(t)){var m=r.a.randomString(9);r.a.arrForEach(t,(function(e,t){e.id=m+":"+t.toString()}))}R.a.encodeArray(t,this.channelOptions,(function(e){if(e)c(e);else{var n=R.a.getMessagesSize(t),r=h.maxMessageSize;n>r?c(new f.a("Maximum size of messages that can be published at once exceeded ( was "+n+" bytes; limit is "+r+" bytes)",40009,400)):u._publish(R.a.serialize(t,p),g,i,c)}}))},t.prototype._publish=function(e,t,n,i){h.post(this.rest,this.basePath+"/messages",e,t,n,!1,i)},t}(),b=function(){function e(e){this.count=e&&e.count||0,this.data=e&&e.data||0,this.uncompressedData=e&&e.uncompressedData||0,this.failed=e&&e.failed||0,this.refused=e&&e.refused||0}function t(t){var n=this;e.call(this,t),this.category=void 0,t&&t.category&&(this.category={},r.a.forInOwnNonNullProps(t.category,(function(i){n.category[i]=new e(t.category[i])})))}function n(e){this.peak=e&&e.peak||0,this.min=e&&e.min||0,this.mean=e&&e.mean||0,this.opened=e&&e.opened||0,this.refused=e&&e.refused||0}function i(e){this.succeeded=e&&e.succeeded||0,this.failed=e&&e.failed||0,this.refused=e&&e.refused||0}function o(e){this.plain=new n(e&&e.plain),this.tls=new n(e&&e.tls),this.all=new n(e&&e.all)}function s(e){this.messages=new t(e&&e.messages),this.presence=new t(e&&e.presence),this.all=new t(e&&e.all)}function a(e){this.realtime=new s(e&&e.realtime),this.rest=new s(e&&e.rest),this.webhook=new s(e&&e.webhook),this.sharedQueue=new s(e&&e.sharedQueue),this.externalQueue=new s(e&&e.externalQueue),this.httpEvent=new s(e&&e.httpEvent),this.push=new s(e&&e.push),this.all=new s(e&&e.all)}function c(e){this.all=new s(e&&e.all),this.inbound=new a(e&&e.inbound),this.outbound=new a(e&&e.outbound)}function u(e){this.all=new s(e&&e.all),this.producerPaid=new c(e&&e.producerPaid),this.consumerPaid=new c(e&&e.consumerPaid)}function l(e){this.messages=e&&e.messages||0;var t=e&&e.notifications;this.notifications={invalid:t&&t.invalid||0,attempted:t&&t.attempted||0,successful:t&&t.successful||0,failed:t&&t.failed||0},this.directPublishes=e&&e.directPublishes||0}function h(e){this.succeeded=e&&e.succeeded||0,this.skipped=e&&e.skipped||0,this.failed=e&&e.failed||0}function p(e){var t=this;this.delta=void 0,e&&e.delta&&(this.delta={},r.a.forInOwnNonNullProps(e.delta,(function(n){t.delta[n]=new h(e.delta[n])})))}function f(e){c.call(this,e),this.persisted=new s(e&&e.persisted),this.connections=new o(e&&e.connections),this.channels=new n(e&&e.channels),this.apiRequests=new i(e&&e.apiRequests),this.tokenRequests=new i(e&&e.tokenRequests),this.xchgProducer=new u(e&&e.xchgProducer),this.xchgConsumer=new u(e&&e.xchgConsumer),this.push=new l(e&&e.pushStats),this.processed=new p(e&&e.processed),this.inProgress=e&&e.inProgress||void 0,this.unit=e&&e.unit||void 0,this.intervalId=e&&e.intervalId||void 0}return f.fromValues=function(e){return new f(e)},f}(),C=function(){var e=function(){},t=i.a.msgpack;function n(e){if(!(this instanceof n))return new n(e);if(!e){var t="no options provided";throw o.a.logAction(o.a.LOG_ERROR,"Rest()",t),new Error(t)}if((e=s.a.objectifyOptions(e)).log&&o.a.setLog(e.log.level,e.log.handler),o.a.logAction(o.a.LOG_MICRO,"Rest()","initialized with clientOptions "+r.a.inspect(e)),this.options=s.a.normaliseOptions(e),e.key){var i=e.key.match(/^([^:\s]+):([^:.\s]+)$/);if(!i){t="invalid key parameter";throw o.a.logAction(o.a.LOG_ERROR,"Rest()",t),new Error(t)}e.keyName=i[1],e.keySecret=i[2]}if("clientId"in e){if("string"!=typeof e.clientId&&null!==e.clientId)throw new f.a("clientId must be either a string or null",40012,400);if("*"===e.clientId)throw new f.a('Can’t use "*" as a clientId as that string is reserved. (To change the default token request behaviour to use a wildcard clientId, use {defaultTokenParams: {clientId: "*"}})',40012,400)}o.a.logAction(o.a.LOG_MINOR,"Rest()","started; version = "+s.a.libstring),this.baseUri=this.authority=function(t){return s.a.getHttpScheme(e)+t+":"+s.a.getPort(e,!1)},this._currentFallback=null,this.serverTimeOffset=null,this.auth=new a.a(this,e),this.channels=new c(this),this.push=new g(this)}function c(e){this.rest=e,this.all=Object.create(null)}return n.prototype.stats=function(t,n){if(void 0===n)if("function"==typeof t)n=t,t=null;else{if(this.options.promises)return r.a.promisify(this,"stats",arguments);n=e}var i=r.a.defaultGetHeaders(),o=this.options.useBinaryProtocol?"msgpack":"json",s=u.a.supportsLinkHeaders?void 0:o;this.options.headers&&r.a.mixin(i,this.options.headers),new p(this,"/stats",i,s,(function(e,t,n){for(var i=n?e:JSON.parse(e),r=0;r<i.length;r++)i[r]=b.fromValues(i[r]);return i})).get(t,n)},n.prototype.time=function(t,n){if(void 0===n)if("function"==typeof t)n=t,t=null;else{if(this.options.promises)return r.a.promisify(this,"time",arguments);n=e}var i=r.a.defaultGetHeaders();this.options.headers&&r.a.mixin(i,this.options.headers);var o=this,s=function(e){return o.authority(e)+"/time"};u.a.get(this,s,i,t,(function(e,t,i,s){if(e)n(e);else{s||(t=JSON.parse(t));var a=t[0];if(!a)return(e=new Error("Internal error (unexpected result type from GET /time)")).statusCode=500,void n(e);o.serverTimeOffset=a-r.a.now(),n(null,a)}}))},n.prototype.request=function(n,i,o,s,a,c){var l=this.options.useBinaryProtocol,h=l?t.encode:JSON.stringify,d=l?t.decode:JSON.parse,g=l?"msgpack":"json",m=u.a.supportsLinkHeaders?void 0:g;o=o||{};var y="get"==(n=n.toLowerCase())?r.a.defaultGetHeaders(g):r.a.defaultPostHeaders(g);if(void 0===c){if(this.options.promises)return r.a.promisify(this,"request",[n,i,o,s,a]);c=e}"string"!=typeof s&&(s=h(s)),this.options.headers&&r.a.mixin(y,this.options.headers),a&&r.a.mixin(y,a);var v=new p(this,i,y,m,(function(e,t,n){return r.a.ensureArray(n?e:d(e))}),!0);if(!r.a.arrIn(u.a.methods,n))throw new f.a("Unsupported method "+n,40500,405);r.a.arrIn(u.a.methodsWithBody,n)?v[n](o,s,c):v[n](o,c)},n.prototype.setLog=function(e){o.a.setLog(e.level,e.handler)},c.prototype.get=function(e,t){e=String(e);var n=this.all[e];return n?t&&n.setOptions(t):this.all[e]=n=new A(this.rest,e,t),n},c.prototype.release=function(e){delete this.all[String(e)]},n}();C.Promise=function(e){return(e=s.a.objectifyOptions(e)).promises=!0,new C(e)},C.Callbacks=C;var w=C,S=n(25),T=n(21),_=function(){function e(){}function t(e,t){m.a.call(this),this.ably=e,this.connectionManager=new S.a(e,t),this.state=this.connectionManager.state.state,this.key=void 0,this.id=void 0,this.serial=void 0,this.timeSerial=void 0,this.recoveryKey=void 0,this.errorReason=null;var n=this;this.connectionManager.on("connectionstate",(function(e){var t=n.state=e.current;r.a.nextTick((function(){n.emit(t,e)}))})),this.connectionManager.on("update",(function(e){r.a.nextTick((function(){n.emit("update",e)}))}))}return r.a.inherits(t,m.a),t.prototype.whenState=function(e,t){return m.a.prototype.whenState.call(this,e,this.state,t,new T.a(void 0,e))},t.prototype.connect=function(){o.a.logAction(o.a.LOG_MINOR,"Connection.connect()",""),this.connectionManager.requestState({state:"connecting"})},t.prototype.ping=function(t){if(o.a.logAction(o.a.LOG_MINOR,"Connection.ping()",""),!t){if(this.ably.options.promises)return r.a.promisify(this,"ping",arguments);t=e}this.connectionManager.ping(null,t)},t.prototype.close=function(){o.a.logAction(o.a.LOG_MINOR,"Connection.close()","connectionKey = "+this.key),this.connectionManager.requestState({state:"closing"})},t}(),I=n(8),M=n(13),k=n(22),E=function(e,t,n,i){this.previous=e,this.current=t,"attached"===t&&(this.resumed=n),i&&(this.reason=i)},x=function(){var e=function(){};function t(e){return e.clientId+":"+e.connectionId}function n(e){var t=e.channel.realtime,n=t.auth.clientId;return(!n||"*"===n)&&"connected"===t.connection.state}function i(e,t,n){switch(e.state){case"attached":case"suspended":n();break;case"initialized":case"detached":case"detaching":case"attaching":e.attach((function(e){e?t(e):n()}));break;default:t(f.a.fromValues(P.invalidStateError(e.state)))}}function s(e,t){v.call(this,e),this.syncComplete=!1,this.members=new a(this),this._myMembers=new a(this),this.subscriptions=new m.a,this.pendingPresence=[]}function a(e){m.a.call(this),this.presence=e,this.map=Object.create(null),this.syncInProgress=!1,this.residualMembers=null}function c(e,t){if(e.isSynthesized()||t.isSynthesized())return e.timestamp>t.timestamp;var n=e.parseId(),i=t.parseId();return n.msgSerial===i.msgSerial?n.index>i.index:n.msgSerial>i.msgSerial}return r.a.inherits(s,v),s.prototype.enter=function(e,t){if(n(this))throw new f.a("clientId must be specified to enter a presence channel",40012,400);return this._enterOrUpdateClient(void 0,e,"enter",t)},s.prototype.update=function(e,t){if(n(this))throw new f.a("clientId must be specified to update presence data",40012,400);return this._enterOrUpdateClient(void 0,e,"update",t)},s.prototype.enterClient=function(e,t,n){return this._enterOrUpdateClient(e,t,"enter",n)},s.prototype.updateClient=function(e,t,n){return this._enterOrUpdateClient(e,t,"update",n)},s.prototype._enterOrUpdateClient=function(t,n,i,s){if(!s)if("function"==typeof n)s=n,n=null;else{if(this.channel.realtime.options.promises)return r.a.promisify(this,"_enterOrUpdateClient",[t,n,i]);s=e}var a=this.channel;if(a.connectionManager.activeState()){o.a.logAction(o.a.LOG_MICRO,"RealtimePresence."+i+"Client()","channel = "+a.name+", client = "+(t||"(implicit) "+this.channel.realtime.auth.clientId));var c=y.a.fromValues({action:i,data:n});t&&(c.clientId=t);var u=this;y.a.encode(c,a.channelOptions,(function(e){if(e)s(e);else switch(a.state){case"attached":a.sendPresence(c,s);break;case"initialized":case"detached":a.attach();case"attaching":u.pendingPresence.push({presence:c,callback:s});break;default:(e=new f.a("Unable to "+i+" presence channel while in "+a.state+" state",90001)).code=90001,s(e)}}))}else s(a.connectionManager.getError())},s.prototype.leave=function(e,t){if(n(this))throw new f.a("clientId must have been specified to enter or leave a presence channel",40012,400);return this.leaveClient(void 0,e,t)},s.prototype.leaveClient=function(t,n,i){if(!i)if("function"==typeof n)i=n,n=null;else{if(this.channel.realtime.options.promises)return r.a.promisify(this,"leaveClient",[t,n]);i=e}var s=this.channel;if(s.connectionManager.activeState()){o.a.logAction(o.a.LOG_MICRO,"RealtimePresence.leaveClient()","leaving; channel = "+this.channel.name+", client = "+t);var a=y.a.fromValues({action:"leave",data:n});switch(t&&(a.clientId=t),s.state){case"attached":s.sendPresence(a,i);break;case"attaching":this.pendingPresence.push({presence:a,callback:i});break;case"initialized":case"failed":i(new f.a("Unable to leave presence channel (incompatible state)",90001));break;default:i(M.a.failed)}}else i(s.connectionManager.getError())},s.prototype.get=function(){var t=Array.prototype.slice.call(arguments);1==t.length&&"function"==typeof t[0]&&t.unshift(null);var n=t[0],o=t[1],s=!n||!("waitForSync"in n)||n.waitForSync;if(!o){if(this.channel.realtime.options.promises)return r.a.promisify(this,"get",t);o=e}function a(e){o(null,n?e.list(n):e.values())}if("suspended"!==this.channel.state){var c=this;i(this.channel,o,(function(){var e=c.members;s?e.waitSync((function(){a(e)})):a(e)}))}else s?o(f.a.fromValues({statusCode:400,code:91005,message:"Presence state is out of sync due to channel being in the SUSPENDED state"})):a(this.members)},s.prototype.history=function(t,n){if(o.a.logAction(o.a.LOG_MICRO,"RealtimePresence.history()","channel = "+this.name),void 0===n)if("function"==typeof t)n=t,t=null;else{if(this.channel.realtime.options.promises)return r.a.promisify(this,"history",arguments);n=e}t&&t.untilAttach&&("attached"===this.channel.state?(delete t.untilAttach,t.from_serial=this.channel.properties.attachSerial):n(new f.a("option untilAttach requires the channel to be attached, was: "+this.channel.state,4e4,400))),v.prototype._history.call(this,t,n)},s.prototype.setPresence=function(e,t,n){o.a.logAction(o.a.LOG_MICRO,"RealtimePresence.setPresence()","received presence for "+e.length+" participants; syncChannelSerial = "+n);var i,r,s=this.members,a=this._myMembers,c=[],u=this.channel.connectionManager.connectionId;t&&(this.members.startSync(),n&&(r=n.match(/^[\w\-]+:(.*)$/))&&(i=r[1]));for(var l=0;l<e.length;l++){switch((h=y.a.fromValues(e[l])).action){case"leave":s.remove(h)&&c.push(h),h.connectionId!==u||h.isSynthesized()||a.remove(h);break;case"enter":case"present":case"update":s.put(h)&&c.push(h),h.connectionId===u&&a.put(h)}}t&&!i&&(s.endSync(),this._ensureMyMembersPresent(),this.channel.setInProgress(P.progressOps.sync,!1),this.channel.syncChannelSerial=null);for(l=0;l<c.length;l++){var h=c[l];this.subscriptions.emit(h.action,h)}},s.prototype.onAttached=function(e){o.a.logAction(o.a.LOG_MINOR,"RealtimePresence.onAttached()","channel = "+this.channel.name+", hasPresence = "+e),e?this.members.startSync():(this._synthesizeLeaves(this.members.values()),this.members.clear(),this._ensureMyMembersPresent());var t=this.pendingPresence,n=t.length;if(n){this.pendingPresence=[];var i=[],r=Object(k.a)();o.a.logAction(o.a.LOG_MICRO,"RealtimePresence.onAttached","sending "+n+" queued presence messages");for(var s=0;s<n;s++){var a=t[s];i.push(a.presence),r.push(a.callback)}this.channel.sendPresence(i,r)}},s.prototype.actOnChannelState=function(e,t,n){switch(e){case"attached":this.onAttached(t);break;case"detached":case"failed":this._clearMyMembers(),this.members.clear();case"suspended":this.failPendingPresence(n)}},s.prototype.failPendingPresence=function(e){if(this.pendingPresence.length){o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel.failPendingPresence","channel; name = "+this.channel.name+", err = "+r.a.inspectError(e));for(var t=0;t<this.pendingPresence.length;t++)try{this.pendingPresence[t].callback(e)}catch(e){}this.pendingPresence=[]}},s.prototype._clearMyMembers=function(){this._myMembers.clear()},s.prototype._ensureMyMembersPresent=function(){var e=this,t=this.members,n=this._myMembers,i=function(t){if(t){var n="Presence auto-re-enter failed: "+t.toString(),i=new f.a(n,91004,400);o.a.logAction(o.a.LOG_ERROR,"RealtimePresence._ensureMyMembersPresent()",n);var r=new E(e.channel.state,e.channel.state,!0,i);e.channel.emit("update",r)}};for(var r in n.map)if(!(r in t.map)){var s=n.map[r];o.a.logAction(o.a.LOG_MICRO,"RealtimePresence._ensureMyMembersPresent()",'Auto-reentering clientId "'+s.clientId+'" into the presence set'),this._enterOrUpdateClient(s.clientId,s.data,"enter",i),delete n.map[r]}},s.prototype._synthesizeLeaves=function(e){var t=this.subscriptions;r.a.arrForEach(e,(function(e){var n=y.a.fromValues({action:"leave",connectionId:e.connectionId,clientId:e.clientId,data:e.data,encoding:e.encoding,timestamp:r.a.now()});t.emit("leave",n)}))},s.prototype.on=function(){o.a.deprecated("presence.on","presence.subscribe"),this.subscribe.apply(this,arguments)},s.prototype.off=function(){o.a.deprecated("presence.off","presence.unsubscribe"),this.unsubscribe.apply(this,arguments)},s.prototype.subscribe=function(){var t=P.processListenerArgs(arguments),n=t[0],i=t[1],o=t[2],s=this.channel;if(!o){if(this.channel.realtime.options.promises)return r.a.promisify(this,"subscribe",[n,i]);o=e}"failed"!==s.state?(this.subscriptions.on(n,i),s.attach(o)):o(f.a.fromValues(P.invalidStateError("failed")))},s.prototype.unsubscribe=function(){var e=P.processListenerArgs(arguments),t=e[0],n=e[1];this.subscriptions.off(t,n)},r.a.inherits(a,m.a),a.prototype.get=function(e){return this.map[e]},a.prototype.getClient=function(e){var t=this.map,n=[];for(var i in t){var r=t[i];r.clientId==e&&"absent"!=r.action&&n.push(r)}return n},a.prototype.list=function(e){var t=this.map,n=e&&e.clientId,i=e&&e.connectionId,r=[];for(var o in t){var s=t[o];"absent"!==s.action&&(n&&n!=s.clientId||i&&i!=s.connectionId||r.push(s))}return r},a.prototype.put=function(e){"enter"!==e.action&&"update"!==e.action||((e=y.a.fromValues(e)).action="present");var n=this.map,i=t(e);this.residualMembers&&delete this.residualMembers[i];var r=n[i];return!(r&&!c(e,r))&&(n[i]=e,!0)},a.prototype.values=function(){var e=this.map,t=[];for(var n in e){var i=e[n];"absent"!=i.action&&t.push(i)}return t},a.prototype.remove=function(e){var n=this.map,i=t(e),r=n[i];return!(r&&!c(e,r))&&(this.syncInProgress?((e=y.a.fromValues(e)).action="absent",n[i]=e):delete n[i],!0)},a.prototype.startSync=function(){var e=this.map,t=this.syncInProgress;o.a.logAction(o.a.LOG_MINOR,"PresenceMap.startSync()","channel = "+this.presence.channel.name+"; syncInProgress = "+t),this.syncInProgress||(this.residualMembers=r.a.copy(e),this.setInProgress(!0))},a.prototype.endSync=function(){var e=this.map,t=this.syncInProgress;if(o.a.logAction(o.a.LOG_MINOR,"PresenceMap.endSync()","channel = "+this.presence.channel.name+"; syncInProgress = "+t),t){for(var n in e){"absent"===e[n].action&&delete e[n]}for(var n in this.presence._synthesizeLeaves(r.a.valuesArray(this.residualMembers)),this.residualMembers)delete e[n];this.residualMembers=null,this.setInProgress(!1)}this.emit("sync")},a.prototype.waitSync=function(e){var t=this.syncInProgress;o.a.logAction(o.a.LOG_MINOR,"PresenceMap.waitSync()","channel = "+this.presence.channel.name+"; syncInProgress = "+t),t?this.once("sync",e):e()},a.prototype.clear=function(e){this.map={},this.setInProgress(!1),this.residualMembers=null},a.prototype.setInProgress=function(e){o.a.logAction(o.a.LOG_MICRO,"PresenceMap.setInProgress()","inProgress = "+e),this.syncInProgress=e,this.presence.syncComplete=!e},s}(),P=function(){var e=I.a.Action,t=function(){};function n(e,t,n){o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel()","started; name = "+t),A.call(this,e,t,n),this.realtime=e,this.presence=new x(this,e.options),this.connectionManager=e.connection.connectionManager,this.state="initialized",this.subscriptions=new m.a,this.syncChannelSerial=void 0,this.properties={attachSerial:void 0},this.setOptions(n),this.errorReason=null,this._requestedFlags=null,this._mode=null,this._attachedMsgIndicator=!1,this._attachResume=!1,this._decodingContext={channelOptions:this.channelOptions,plugins:e.options.plugins||{},baseEncodedPreviousPayload:void 0},this._lastPayload={messageId:null,protocolMessageChannelSerial:null,decodeFailureRecoveryInProgress:null},this._allChannelChanges=new m.a}function i(e){if(e&&"params"in e&&!r.a.isObject(e.params))return new f.a("options.params must be an object",4e4,400);if(e&&"modes"in e){if(!r.a.isArray(e.modes))return new f.a("options.modes must be an array",4e4,400);for(var t=0;t<e.modes.length;t++){var n=e.modes[t];if(!n||"string"!=typeof n||!r.a.arrIn(I.a.channelModes,String.prototype.toUpperCase.call(n)))return new f.a("Invalid channel mode: "+n,4e4,400)}}}return r.a.inherits(n,A),n.invalidStateError=function(e){return{statusCode:400,code:90001,message:"Channel operation failed as channel state is "+e}},n.progressOps={statechange:"statechange",sync:"sync"},n.processListenerArgs=function(e){return"function"==typeof(e=Array.prototype.slice.call(e))[0]&&e.unshift(null),null==e[e.length-1]&&e.pop(),e},n.prototype.setOptions=function(e,t){if(!t){if(this.rest.options.promises)return r.a.promisify(this,"setOptions",arguments);t=function(e){e&&o.a.logAction(o.a.LOG_ERROR,"RealtimeChannel.setOptions()","Set options failed: "+e.toString())}}var n=i(e);n?t(n):(A.prototype.setOptions.call(this,e),this._decodingContext&&(this._decodingContext.channelOptions=this.channelOptions),this._shouldReattachToSetOptions(e)?(this.attachImpl(),this._allChannelChanges.once((function(e){switch(this.event){case"update":case"attached":return void t(null);default:return void t(e.reason)}}))):t())},n.prototype._shouldReattachToSetOptions=function(e){return("attached"===this.state||"attaching"===this.state)&&(e.params||e.modes)},n.prototype.publish=function(){var e=arguments.length,n=arguments[0],i=arguments[e-1];if("function"!=typeof i){if(this.realtime.options.promises)return r.a.promisify(this,"publish",arguments);i=t,++e}if(this.connectionManager.activeState()){if(2==e)if(r.a.isObject(n))n=[R.a.fromValues(n)];else{if(!r.a.isArray(n))throw new f.a("The single-argument form of publish() expects a message object or an array of message objects",40013,400);n=R.a.fromValuesArray(n)}else n=[R.a.fromValues({name:arguments[0],data:arguments[1]})];var o=this,s=this.realtime.options.maxMessageSize;R.a.encodeArray(n,this.channelOptions,(function(e){if(e)i(e);else{var t=R.a.getMessagesSize(n);t>s?i(new f.a("Maximum size of messages that can be published at once exceeded ( was "+t+" bytes; limit is "+s+" bytes)",40009,400)):o._publish(n,i)}}))}else i(this.connectionManager.getError())},n.prototype._publish=function(t,i){o.a.logAction(o.a.LOG_MICRO,"RealtimeChannel.publish()","message count = "+t.length);var r=this.state;switch(r){case"failed":case"suspended":i(f.a.fromValues(n.invalidStateError(r)));break;default:o.a.logAction(o.a.LOG_MICRO,"RealtimeChannel.publish()","sending message; channel state is "+r);var s=new I.a;s.action=e.MESSAGE,s.channel=this.name,s.messages=t,this.sendMessage(s,i)}},n.prototype.onEvent=function(e){o.a.logAction(o.a.LOG_MICRO,"RealtimeChannel.onEvent()","received message");for(var t=this.subscriptions,n=0;n<e.length;n++){var i=e[n];t.emit(i.name,i)}},n.prototype.attach=function(e,t){if("function"==typeof e&&(t=e,e=null),!t){if(this.realtime.options.promises)return r.a.promisify(this,"attach",arguments);t=function(e){e&&o.a.logAction(o.a.LOG_MAJOR,"RealtimeChannel.attach()","Channel attach failed: "+e.toString())}}if(e)o.a.deprecated("channel.attach() with flags","channel.setOptions() with channelOptions.params"),this._requestedFlags=e;else if("attached"===this.state)return void t();this._attach(!1,null,t)},n.prototype._attach=function(e,t,n){n||(n=function(e){e&&o.a.logAction(o.a.LOG_ERROR,"RealtimeChannel._attach()","Channel attach failed: "+e.toString())});var i=this.connectionManager;i.activeState()?(("attaching"!==this.state||e)&&this.requestState("attaching",t),this.once((function(e){switch(this.event){case"attached":n();break;case"detached":case"suspended":case"failed":n(e.reason||i.getError()||new f.a("Unable to attach; reason unknown; state = "+this.event,9e4,500));break;case"detaching":n(new f.a("Attach request superseded by a subsequent detach request",9e4,409))}}))):n(i.getError())},n.prototype.attachImpl=function(){o.a.logAction(o.a.LOG_MICRO,"RealtimeChannel.attachImpl()","sending ATTACH message"),this.setInProgress("statechange",!0);var n=I.a.fromValues({action:e.ATTACH,channel:this.name,params:this.channelOptions.params});this._requestedFlags?n.encodeModesToFlags(this._requestedFlags):this.channelOptions.modes&&n.encodeModesToFlags(r.a.allToUpperCase(this.channelOptions.modes)),this._attachResume&&n.setFlag("ATTACH_RESUME"),this._lastPayload.decodeFailureRecoveryInProgress&&(n.channelSerial=this._lastPayload.protocolMessageChannelSerial),this.sendMessage(n,t)},n.prototype.detach=function(e){if(!e){if(this.realtime.options.promises)return r.a.promisify(this,"detach",arguments);e=t}var n=this.connectionManager;if(n.activeState())switch(this.state){case"suspended":this.notifyState("detached"),e();break;case"detached":e();break;case"failed":e(new f.a("Unable to detach; channel state = failed",90001,400));break;default:this.requestState("detaching");case"detaching":this.once((function(t){switch(this.event){case"detached":e();break;case"attached":case"suspended":case"failed":e(t.reason||n.getError()||new f.a("Unable to detach; reason unknown; state = "+this.event,9e4,500));break;case"attaching":e(new f.a("Detach request superseded by a subsequent attach request",9e4,409))}}))}else e(n.getError())},n.prototype.detachImpl=function(n){o.a.logAction(o.a.LOG_MICRO,"RealtimeChannel.detach()","sending DETACH message"),this.setInProgress("statechange",!0);var i=I.a.fromValues({action:e.DETACH,channel:this.name});this.sendMessage(i,n||t)},n.prototype.subscribe=function(){var e=n.processListenerArgs(arguments),i=e[0],o=e[1],s=e[2];if(!s){if(this.realtime.options.promises)return r.a.promisify(this,"subscribe",[i,o]);s=t}if("failed"!==this.state)return this.subscriptions.on(i,o),this.attach(s);s(f.a.fromValues(n.invalidStateError("failed")))},n.prototype.unsubscribe=function(){var e=n.processListenerArgs(arguments),t=e[0],i=e[1];this.subscriptions.off(t,i)},n.prototype.sync=function(){switch(this.state){case"initialized":case"detaching":case"detached":throw new f.a("Unable to sync to channel; not attached",4e4)}var t=this.connectionManager;if(!t.activeState())throw t.getError();var n=I.a.fromValues({action:e.SYNC,channel:this.name});this.syncChannelSerial&&(n.channelSerial=this.syncChannelSerial),t.send(n)},n.prototype.sendMessage=function(e,t){this.connectionManager.send(e,this.realtime.options.queueMessages,t)},n.prototype.sendPresence=function(t,n){var i=I.a.fromValues({action:e.PRESENCE,channel:this.name,presence:r.a.isArray(t)?y.a.fromValuesArray(t):[y.a.fromValues(t)]});this.sendMessage(i,n)},n.prototype.onMessage=function(t){var n,i=!1;switch(t.action){case e.ATTACHED:this._attachedMsgIndicator=!0,this.properties.attachSerial=t.channelSerial,this._mode=t.getMode(),this.params=t.params||{};var s=t.decodeModesFromFlags();this.modes=s&&r.a.allToLowerCase(s)||void 0;var a=t.hasFlag("RESUMED"),c=t.hasFlag("HAS_PRESENCE");if("attached"===this.state){this.setInProgress("statechange",!1),a||this.presence.onAttached(c);var u=new E(this.state,this.state,a,t.error);this._allChannelChanges.emit("update",u),a&&!this.channelOptions.updateOnAttached||this.emit("update",u)}else"detaching"===this.state?this.checkPendingState():this.notifyState("attached",t.error,a,c);break;case e.DETACHED:var l=t.error?f.a.fromValues(t.error):new f.a("Channel detached",90001,404);"detaching"===this.state?this.notifyState("detached",l):"attaching"===this.state?this.notifyState("suspended",l):this.requestState("attaching",l);break;case e.SYNC:if(i=!0,n=this.syncChannelSerial=t.channelSerial,!t.presence)break;case e.PRESENCE:for(var h=t.presence,p=t.id,d=t.connectionId,g=t.timestamp,m=this.channelOptions,v=0;v<h.length;v++){try{var O=h[v];y.a.decode(O,m)}catch(e){o.a.logAction(o.a.LOG_ERROR,"RealtimeChannel.onMessage()",e.toString())}O.connectionId||(O.connectionId=d),O.timestamp||(O.timestamp=g),O.id||(O.id=p+":"+v)}this.presence.setPresence(h,i,n);break;case e.MESSAGE:if("attached"!==this.state)return void o.a.logAction(o.a.LOG_MAJOR,"RealtimeChannel.onMessage()",'Message "'+t.id+'" skipped as this channel "'+this.name+'" state is not "attached" (state is "'+this.state+'").');var A=t.messages,b=A[0],C=A[A.length-1];p=t.id,d=t.connectionId,g=t.timestamp;if(b.extras&&b.extras.delta&&b.extras.delta.from!==this._lastPayload.messageId){var w='Delta message decode failure - previous message not available for message "'+t.id+'" on this channel "'+this.name+'".';o.a.logAction(o.a.LOG_ERROR,"RealtimeChannel.onMessage()",w),this._startDecodeFailureRecovery(new f.a(w,40018,400));break}for(v=0;v<A.length;v++){w=A[v];try{R.a.decode(w,this._decodingContext)}catch(e){switch(o.a.logAction(o.a.LOG_ERROR,"RealtimeChannel.onMessage()",e.toString()),e.code){case 40018:return void this._startDecodeFailureRecovery(e);case 40019:case 40021:return void this.notifyState("failed",e)}}w.connectionId||(w.connectionId=d),w.timestamp||(w.timestamp=g),w.id||(w.id=p+":"+v)}this._lastPayload.messageId=C.id,this._lastPayload.protocolMessageChannelSerial=t.channelSerial,this.onEvent(A);break;case e.ERROR:(l=t.error)&&80016==l.code?this.checkPendingState():this.notifyState("failed",f.a.fromValues(l));break;default:o.a.logAction(o.a.LOG_ERROR,"RealtimeChannel.onMessage()","Fatal protocol error: unrecognised action ("+t.action+")"),this.connectionManager.abort(M.a.unknownChannelErr)}},n.prototype._startDecodeFailureRecovery=function(e){var t=this;this._lastPayload.decodeFailureRecoveryInProgress||(o.a.logAction(o.a.LOG_MAJOR,"RealtimeChannel.onMessage()","Starting decode failure recovery process."),this._lastPayload.decodeFailureRecoveryInProgress=!0,this._attach(!0,e,(function(){t._lastPayload.decodeFailureRecoveryInProgress=!1})))},n.prototype.onAttached=function(){o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel.onAttached","activating channel; name = "+this.name)},n.prototype.notifyState=function(e,t,n,i){if(o.a.logAction(o.a.LOG_MICRO,"RealtimeChannel.notifyState","name = "+this.name+", current state = "+this.state+", notifying state "+e),this.clearStateTimer(),e!==this.state){this.presence.actOnChannelState(e,i,t),"suspended"===e&&this.connectionManager.state.sendEvents?this.startRetryTimer():this.cancelRetryTimer(),t&&(this.errorReason=t);var r=new E(this.state,e,n,t),s="failed"===e?o.a.LOG_ERROR:o.a.LOG_MAJOR;o.a.logAction(s,'Channel state for channel "'+this.name+'"',e+(t?"; reason: "+t:"")),"attached"===e?(this.onAttached(),this.setInProgress("sync",i),this.setInProgress("statechange",!1)):"detached"!==e&&"failed"!==e&&"suspended"!==e||(this.setInProgress("statechange",!1),this.setInProgress("sync",!1)),"attached"===e?this._attachResume=!0:"detaching"!==e&&"failed"!==e||(this._attachResume=!1),this.state=e,this._allChannelChanges.emit(e,r),this.emit(e,r)}},n.prototype.requestState=function(e,t){o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel.requestState","name = "+this.name+", state = "+e),this.notifyState(e,t),this.checkPendingState()},n.prototype.checkPendingState=function(){var e=this.connectionManager.state;if(e.sendEvents||e.forceQueueEvents)switch(o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel.checkPendingState","name = "+this.name+", state = "+this.state),this.state){case"attaching":this.startStateTimerIfNotRunning(),this.attachImpl();break;case"detaching":this.startStateTimerIfNotRunning(),this.detachImpl();break;case"attached":this.sync()}else o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel.checkPendingState","sendEvents is false; state is "+this.connectionManager.state.state)},n.prototype.timeoutPendingState=function(){switch(this.state){case"attaching":var e=new f.a("Channel attach timed out",90007,408);this.notifyState("suspended",e);break;case"detaching":e=new f.a("Channel detach timed out",90007,408);this.notifyState("attached",e);break;default:this.checkPendingState()}},n.prototype.startStateTimerIfNotRunning=function(){var e=this;this.stateTimer||(this.stateTimer=setTimeout((function(){o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel.startStateTimerIfNotRunning","timer expired"),e.stateTimer=null,e.timeoutPendingState()}),this.realtime.options.timeouts.realtimeRequestTimeout))},n.prototype.clearStateTimer=function(){var e=this.stateTimer;e&&(clearTimeout(e),this.stateTimer=null)},n.prototype.startRetryTimer=function(){var e=this;this.retryTimer||(this.retryTimer=setTimeout((function(){"suspended"===e.state&&e.connectionManager.state.sendEvents&&(e.retryTimer=null,o.a.logAction(o.a.LOG_MINOR,"RealtimeChannel retry timer expired","attempting a new attach"),e.requestState("attaching"))}),this.realtime.options.timeouts.channelRetryTimeout))},n.prototype.cancelRetryTimer=function(){this.retryTimer&&(clearTimeout(this.retryTimer),this.suspendTimer=null)},n.prototype.setInProgress=function(e,t){this.rest.channels.setInProgress(this,e,t)},n.prototype.history=function(e,n){if(o.a.logAction(o.a.LOG_MICRO,"RealtimeChannel.history()","channel = "+this.name),void 0===n)if("function"==typeof e)n=e,e=null;else{if(this.rest.options.promises)return r.a.promisify(this,"history",arguments);n=t}if(e&&e.untilAttach){if("attached"!==this.state)return void n(new f.a("option untilAttach requires the channel to be attached",4e4,400));if(!this.properties.attachSerial)return void n(new f.a("untilAttach was specified and channel is attached, but attachSerial is not defined",4e4,400));delete e.untilAttach,e.from_serial=this.properties.attachSerial}A.prototype._history.call(this,e,n)},n.prototype.whenState=function(e,t){return m.a.prototype.whenState.call(this,e,this.state,t)},n.prototype.getReleaseErr=function(){var e=this.state;return"initialized"===e||"detached"===e||"failed"===e?null:new f.a("Can only release a channel in a state where there is no possibility of further updates from the server being received (initialized, detached, or failed); was "+e,90001,400)},n}(),L=n(23),N=function(){function e(n){if(!(this instanceof e))return new e(n);o.a.logAction(o.a.LOG_MINOR,"Realtime()",""),w.call(this,n),this.connection=new _(this,this.options),this.channels=new t(this),!1!==n.autoConnect&&this.connect()}function t(e){m.a.call(this),this.realtime=e,this.all=Object.create(null),this.inProgress=Object.create(null);var t=this;e.connection.connectionManager.on("transport.active",(function(){t.onTransportActive()}))}return r.a.inherits(e,w),e.prototype.connect=function(){o.a.logAction(o.a.LOG_MINOR,"Realtime.connect()",""),this.connection.connect()},e.prototype.close=function(){o.a.logAction(o.a.LOG_MINOR,"Realtime.close()",""),this.connection.close()},r.a.inherits(t,m.a),t.prototype.onChannelMessage=function(e){var t=e.channel;if(void 0!==t){var n=this.all[t];n?n.onMessage(e):o.a.logAction(o.a.LOG_ERROR,"Channels.onChannelMessage()","received event for non-existent channel: "+t)}else o.a.logAction(o.a.LOG_ERROR,"Channels.onChannelMessage()","received event unspecified channel, action = "+e.action)},t.prototype.onTransportActive=function(){for(var e in this.all){var t=this.all[e];"attaching"===t.state||"detaching"===t.state?t.checkPendingState():"suspended"===t.state&&t.attach()}},t.prototype.reattach=function(e){for(var t in this.all){var n=this.all[t];"attached"===n.state&&n.requestState("attaching",e)}},t.prototype.resetAttachedMsgIndicators=function(){for(var e in this.all){var t=this.all[e];"attached"===t.state&&(t._attachedMsgIndicator=!1)}},t.prototype.checkAttachedMsgIndicators=function(e){for(var t in this.all){var n=this.all[t];if("attached"===n.state&&!1===n._attachedMsgIndicator){var i="30s after a resume, found channel which has not received an attached; channelId = "+t+"; connectionId = "+e;o.a.logAction(o.a.LOG_ERROR,"Channels.checkAttachedMsgIndicators()",i),L.a.report("error",i,"channel-no-attached-after-resume"),n.requestState("attaching")}}},t.prototype.propogateConnectionInterruption=function(e,t){var n=["attaching","attached","detaching","suspended"],i={closing:"detached",closed:"detached",failed:"failed",suspended:"suspended"}[e];for(var o in this.all){var s=this.all[o];r.a.arrIn(n,s.state)&&s.notifyState(i,t)}},t.prototype.get=function(e,t){e=String(e);var n=this.all[e];if(n){if(t){if(n._shouldReattachToSetOptions(t))throw new f.a("Channels.get() cannot be used to set channel options that would cause the channel to reattach. Please, use RealtimeChannel.setOptions() instead.",4e4,400);n.setOptions(t)}}else n=this.all[e]=new P(this.realtime,e,t);return n},t.prototype.release=function(e){e=String(e);var t=this.all[e];if(t){var n=t.getReleaseErr();if(n)throw n;delete this.all[e],delete this.inProgress[e]}},t.prototype.setInProgress=function(e,t,n){this.inProgress[e.name]=this.inProgress[e.name]||{},this.inProgress[e.name][t]=n,!n&&this.hasNopending()&&this.emit("nopending")},t.prototype.onceNopending=function(e){this.hasNopending()?e():this.once("nopending",e)},t.prototype.hasNopending=function(){return r.a.arrEvery(r.a.valuesArray(this.inProgress,!0),(function(e){return!r.a.containsValue(e,!0)}))},e}();N.Promise=function(e){return(e=s.a.objectifyOptions(e)).promises=!0,new N(e)},N.Callbacks=N;var U=N,G=n(24);w.Utils=r.a,w.BufferUtils=l.a,w.Crypto=O.a,w.Defaults=s.a,w.Http=u.a,w.Resource=h,w.Message=R.a,w.PresenceMessage=y.a,U.Utils=r.a,U.BufferUtils=l.a,U.Crypto=O.a,U.Defaults=s.a,U.Http=u.a,U.Message=R.a,U.PresenceMessage=y.a,U.ProtocolMessage=I.a,U.ConnectionManager=S.a;t.default={Rest:w,Realtime:U,msgpack:G.a}}]).default}));
//# sourceMappingURL=ably.min.js.map