(self.__LOADABLE_LOADED_CHUNKS__=self.__LOADABLE_LOADED_CHUNKS__||[]).push([[9053],{6481:function(t,e,n){"use strict";n.r(e),n.d(e,{AbortError:function(){return a},DefaultHttpClient:function(){return R},HttpClient:function(){return h},HttpError:function(){return s},HttpResponse:function(){return l},HttpTransportType:function(){return _},HubConnection:function(){return W},HubConnectionBuilder:function(){return st},HubConnectionState:function(){return O},JsonHubProtocol:function(){return ot},LogLevel:function(){return r},MessageType:function(){return E},NullLogger:function(){return p},Subject:function(){return j},TimeoutError:function(){return c},TransferFormat:function(){return L},VERSION:function(){return ct}});var o,r,i=(o=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var n in e)e.hasOwnProperty(n)&&(t[n]=e[n])},function(t,e){function n(){this.constructor=t}o(t,e),t.prototype=null===e?Object.create(e):(n.prototype=e.prototype,new n)}),s=function(t){function e(e,n){var o=this,r=this.constructor.prototype;return(o=t.call(this,e)||this).statusCode=n,o.__proto__=r,o}return i(e,t),e}(Error),c=function(t){function e(e){void 0===e&&(e="A timeout occurred.");var n=this,o=this.constructor.prototype;return(n=t.call(this,e)||this).__proto__=o,n}return i(e,t),e}(Error),a=function(t){function e(e){void 0===e&&(e="An abort occurred.");var n=this,o=this.constructor.prototype;return(n=t.call(this,e)||this).__proto__=o,n}return i(e,t),e}(Error),u=Object.assign||function(t){for(var e,n=1,o=arguments.length;n<o;n++)for(var r in e=arguments[n])Object.prototype.hasOwnProperty.call(e,r)&&(t[r]=e[r]);return t},l=function(t,e,n){this.statusCode=t,this.statusText=e,this.content=n},h=function(){function t(){}return t.prototype.get=function(t,e){return this.send(u({},e,{method:"GET",url:t}))},t.prototype.post=function(t,e){return this.send(u({},e,{method:"POST",url:t}))},t.prototype.delete=function(t,e){return this.send(u({},e,{method:"DELETE",url:t}))},t.prototype.getCookieString=function(t){return""},t}();!function(t){t[t.Trace=0]="Trace",t[t.Debug=1]="Debug",t[t.Information=2]="Information",t[t.Warning=3]="Warning",t[t.Error=4]="Error",t[t.Critical=5]="Critical",t[t.None=6]="None"}(r||(r={}));var p=function(){function t(){}return t.prototype.log=function(t,e){},t.instance=new t,t}(),f=function(){function t(){}return t.isRequired=function(t,e){if(null==t)throw new Error("The '"+e+"' argument is required.")},t.isIn=function(t,e,n){if(!(t in e))throw new Error("Unknown "+n+" value: "+t+".")},t}(),g=function(){function t(){}return Object.defineProperty(t,"isBrowser",{get:function(){return"object"==typeof window},enumerable:!0,configurable:!0}),Object.defineProperty(t,"isWebWorker",{get:function(){return"object"==typeof self&&"importScripts"in self},enumerable:!0,configurable:!0}),Object.defineProperty(t,"isNode",{get:function(){return!this.isBrowser&&!this.isWebWorker},enumerable:!0,configurable:!0}),t}();function d(t,e){var n="";return v(t)?(n="Binary data of length "+t.byteLength,e&&(n+=". Content: '"+function(t){var e=new Uint8Array(t),n="";return e.forEach((function(t){n+="0x"+(t<16?"0":"")+t.toString(16)+" "})),n.substr(0,n.length-1)}(t)+"'")):"string"==typeof t&&(n="String data of length "+t.length,e&&(n+=". Content: '"+t+"'")),n}function v(t){return t&&"undefined"!=typeof ArrayBuffer&&(t instanceof ArrayBuffer||t.constructor&&"ArrayBuffer"===t.constructor.name)}function b(t,e,n,o,i,s,c){return a=this,u=void 0,h=function(){var a,u,l,h,p;return function(t,e){var n,o,r,i,s={label:0,sent:function(){if(1&r[0])throw r[1];return r[1]},trys:[],ops:[]};return i={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function c(i){return function(c){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,o&&(r=2&i[0]?o.return:i[0]?o.throw||((r=o.return)&&r.call(o),0):o.next)&&!(r=r.call(o,i[1])).done)return r;switch(o=0,r&&(i=[2&i[0],r.value]),i[0]){case 0:case 1:r=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,o=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!((r=(r=s.trys).length>0&&r[r.length-1])||6!==i[0]&&2!==i[0])){s=0;continue}if(3===i[0]&&(!r||i[1]>r[0]&&i[1]<r[3])){s.label=i[1];break}if(6===i[0]&&s.label<r[1]){s.label=r[1],r=i;break}if(r&&s.label<r[2]){s.label=r[2],s.ops.push(i);break}r[2]&&s.ops.pop(),s.trys.pop();continue}i=e.call(t,s)}catch(t){i=[6,t],o=0}finally{n=r=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,c])}}}(this,(function(f){switch(f.label){case 0:return i?[4,i()]:[3,2];case 1:(l=f.sent())&&((a={}).Authorization="Bearer "+l,u=a),f.label=2;case 2:return t.log(r.Trace,"("+e+" transport) sending data. "+d(s,c)+"."),h=v(s)?"arraybuffer":"text",[4,n.post(o,{content:s,headers:u,responseType:h})];case 3:return p=f.sent(),t.log(r.Trace,"("+e+" transport) request complete. Response status: "+p.statusCode+"."),[2]}}))},new((l=void 0)||(l=Promise))((function(t,e){function n(t){try{r(h.next(t))}catch(t){e(t)}}function o(t){try{r(h.throw(t))}catch(t){e(t)}}function r(e){e.done?t(e.value):new l((function(t){t(e.value)})).then(n,o)}r((h=h.apply(a,u||[])).next())}));var a,u,l,h}var y,m=function(){function t(t,e){this.subject=t,this.observer=e}return t.prototype.dispose=function(){var t=this.subject.observers.indexOf(this.observer);t>-1&&this.subject.observers.splice(t,1),0===this.subject.observers.length&&this.subject.cancelCallback&&this.subject.cancelCallback().catch((function(t){}))},t}(),w=function(){function t(t){this.minimumLogLevel=t,this.outputConsole=console}return t.prototype.log=function(t,e){if(t>=this.minimumLogLevel)switch(t){case r.Critical:case r.Error:this.outputConsole.error("["+(new Date).toISOString()+"] "+r[t]+": "+e);break;case r.Warning:this.outputConsole.warn("["+(new Date).toISOString()+"] "+r[t]+": "+e);break;case r.Information:this.outputConsole.info("["+(new Date).toISOString()+"] "+r[t]+": "+e);break;default:this.outputConsole.log("["+(new Date).toISOString()+"] "+r[t]+": "+e)}},t}(),S=function(){var t=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var n in e)e.hasOwnProperty(n)&&(t[n]=e[n])};return function(e,n){function o(){this.constructor=e}t(e,n),e.prototype=null===n?Object.create(n):(o.prototype=n.prototype,new o)}}(),C=Object.assign||function(t){for(var e,n=1,o=arguments.length;n<o;n++)for(var r in e=arguments[n])Object.prototype.hasOwnProperty.call(e,r)&&(t[r]=e[r]);return t};if("undefined"==typeof XMLHttpRequest){var k=require;y=k("request")}var E,T=function(t){function e(e){var n=t.call(this)||this;if(void 0===y)throw new Error("The 'request' module could not be loaded.");return n.logger=e,n.cookieJar=y.jar(),n.request=y.defaults({jar:n.cookieJar}),n}return S(e,t),e.prototype.send=function(t){var e=this;return t.abortSignal&&t.abortSignal.aborted?Promise.reject(new a):new Promise((function(n,o){var i;i=v(t.content)?Buffer.from(t.content):t.content||"";var u=e.request(t.url,{body:i,encoding:"arraybuffer"===t.responseType?null:"utf8",headers:C({"X-Requested-With":"XMLHttpRequest"},t.headers),method:t.method,timeout:t.timeout},(function(i,a,u){if(t.abortSignal&&(t.abortSignal.onabort=null),i)return"ETIMEDOUT"===i.code&&(e.logger.log(r.Warning,"Timeout from HTTP request."),o(new c)),e.logger.log(r.Warning,"Error from HTTP request. "+i),void o(i);a.statusCode>=200&&a.statusCode<300?n(new l(a.statusCode,a.statusMessage||"",u)):o(new s(a.statusMessage||"",a.statusCode||0))}));t.abortSignal&&(t.abortSignal.onabort=function(){u.abort(),o(new a)})}))},e.prototype.getCookieString=function(t){return this.cookieJar.getCookieString(t)},e}(h),P=function(){var t=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var n in e)e.hasOwnProperty(n)&&(t[n]=e[n])};return function(e,n){function o(){this.constructor=e}t(e,n),e.prototype=null===n?Object.create(n):(o.prototype=n.prototype,new o)}}(),I=function(t){function e(e){var n=t.call(this)||this;return n.logger=e,n}return P(e,t),e.prototype.send=function(t){var e=this;return t.abortSignal&&t.abortSignal.aborted?Promise.reject(new a):t.method?t.url?new Promise((function(n,o){var i=new XMLHttpRequest;i.open(t.method,t.url,!0),i.withCredentials=!0,i.setRequestHeader("X-Requested-With","XMLHttpRequest"),i.setRequestHeader("Content-Type","text/plain;charset=UTF-8");var u=t.headers;u&&Object.keys(u).forEach((function(t){i.setRequestHeader(t,u[t])})),t.responseType&&(i.responseType=t.responseType),t.abortSignal&&(t.abortSignal.onabort=function(){i.abort(),o(new a)}),t.timeout&&(i.timeout=t.timeout),i.onload=function(){t.abortSignal&&(t.abortSignal.onabort=null),i.status>=200&&i.status<300?n(new l(i.status,i.statusText,i.response||i.responseText)):o(new s(i.statusText,i.status))},i.onerror=function(){e.logger.log(r.Warning,"Error from HTTP request. "+i.status+": "+i.statusText+"."),o(new s(i.statusText,i.status))},i.ontimeout=function(){e.logger.log(r.Warning,"Timeout from HTTP request."),o(new c)},i.send(t.content||"")})):Promise.reject(new Error("No url defined.")):Promise.reject(new Error("No method defined."))},e}(h),D=function(){var t=Object.setPrototypeOf||{__proto__:[]}instanceof Array&&function(t,e){t.__proto__=e}||function(t,e){for(var n in e)e.hasOwnProperty(n)&&(t[n]=e[n])};return function(e,n){function o(){this.constructor=e}t(e,n),e.prototype=null===n?Object.create(n):(o.prototype=n.prototype,new o)}}(),R=function(t){function e(e){var n=t.call(this)||this;return"undefined"!=typeof XMLHttpRequest?n.httpClient=new I(e):n.httpClient=new T(e),n}return D(e,t),e.prototype.send=function(t){return t.abortSignal&&t.abortSignal.aborted?Promise.reject(new a):t.method?t.url?this.httpClient.send(t):Promise.reject(new Error("No url defined.")):Promise.reject(new Error("No method defined."))},e.prototype.getCookieString=function(t){return this.httpClient.getCookieString(t)},e}(h),x=function(){function t(){}return t.write=function(e){return""+e+t.RecordSeparator},t.parse=function(e){if(e[e.length-1]!==t.RecordSeparator)throw new Error("Message is incomplete.");var n=e.split(t.RecordSeparator);return n.pop(),n},t.RecordSeparatorCode=30,t.RecordSeparator=String.fromCharCode(t.RecordSeparatorCode),t}(),H=function(){function t(){}return t.prototype.writeHandshakeRequest=function(t){return x.write(JSON.stringify(t))},t.prototype.parseHandshakeResponse=function(t){var e,n;if(v(t)||"undefined"!=typeof Buffer&&t instanceof Buffer){var o=new Uint8Array(t);if(-1===(i=o.indexOf(x.RecordSeparatorCode)))throw new Error("Message is incomplete.");var r=i+1;e=String.fromCharCode.apply(null,o.slice(0,r)),n=o.byteLength>r?o.slice(r).buffer:null}else{var i,s=t;if(-1===(i=s.indexOf(x.RecordSeparator)))throw new Error("Message is incomplete.");r=i+1,e=s.substring(0,r),n=s.length>r?s.substring(r):null}var c=x.parse(e),a=JSON.parse(c[0]);if(a.type)throw new Error("Expected a handshake response from the server.");return[n,a]},t}();!function(t){t[t.Invocation=1]="Invocation",t[t.StreamItem=2]="StreamItem",t[t.Completion=3]="Completion",t[t.StreamInvocation=4]="StreamInvocation",t[t.CancelInvocation=5]="CancelInvocation",t[t.Ping=6]="Ping",t[t.Close=7]="Close"}(E||(E={}));var O,j=function(){function t(){this.observers=[]}return t.prototype.next=function(t){for(var e=0,n=this.observers;e<n.length;e++)n[e].next(t)},t.prototype.error=function(t){for(var e=0,n=this.observers;e<n.length;e++){var o=n[e];o.error&&o.error(t)}},t.prototype.complete=function(){for(var t=0,e=this.observers;t<e.length;t++){var n=e[t];n.complete&&n.complete()}},t.prototype.subscribe=function(t){return this.observers.push(t),new m(this,t)},t}(),M=function(t,e,n,o){return new(n||(n=Promise))((function(r,i){function s(t){try{a(o.next(t))}catch(t){i(t)}}function c(t){try{a(o.throw(t))}catch(t){i(t)}}function a(t){t.done?r(t.value):new n((function(e){e(t.value)})).then(s,c)}a((o=o.apply(t,e||[])).next())}))},A=function(t,e){var n,o,r,i,s={label:0,sent:function(){if(1&r[0])throw r[1];return r[1]},trys:[],ops:[]};return i={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function c(i){return function(c){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,o&&(r=2&i[0]?o.return:i[0]?o.throw||((r=o.return)&&r.call(o),0):o.next)&&!(r=r.call(o,i[1])).done)return r;switch(o=0,r&&(i=[2&i[0],r.value]),i[0]){case 0:case 1:r=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,o=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!((r=(r=s.trys).length>0&&r[r.length-1])||6!==i[0]&&2!==i[0])){s=0;continue}if(3===i[0]&&(!r||i[1]>r[0]&&i[1]<r[3])){s.label=i[1];break}if(6===i[0]&&s.label<r[1]){s.label=r[1],r=i;break}if(r&&s.label<r[2]){s.label=r[2],s.ops.push(i);break}r[2]&&s.ops.pop(),s.trys.pop();continue}i=e.call(t,s)}catch(t){i=[6,t],o=0}finally{n=r=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,c])}}};!function(t){t.Disconnected="Disconnected",t.Connecting="Connecting",t.Connected="Connected",t.Disconnecting="Disconnecting",t.Reconnecting="Reconnecting"}(O||(O={}));var _,L,W=function(){function t(t,e,n,o){var r=this;this.nextKeepAlive=0,f.isRequired(t,"connection"),f.isRequired(e,"logger"),f.isRequired(n,"protocol"),this.serverTimeoutInMilliseconds=3e4,this.keepAliveIntervalInMilliseconds=15e3,this.logger=e,this.protocol=n,this.connection=t,this.reconnectPolicy=o,this.handshakeProtocol=new H,this.connection.onreceive=function(t){return r.processIncomingData(t)},this.connection.onclose=function(t){return r.connectionClosed(t)},this.callbacks={},this.methods={},this.closedCallbacks=[],this.reconnectingCallbacks=[],this.reconnectedCallbacks=[],this.invocationId=0,this.receivedHandshakeResponse=!1,this.connectionState=O.Disconnected,this.connectionStarted=!1,this.cachedPingMessage=this.protocol.writeMessage({type:E.Ping})}return t.create=function(e,n,o,r){return new t(e,n,o,r)},Object.defineProperty(t.prototype,"state",{get:function(){return this.connectionState},enumerable:!0,configurable:!0}),Object.defineProperty(t.prototype,"connectionId",{get:function(){return this.connection&&this.connection.connectionId||null},enumerable:!0,configurable:!0}),Object.defineProperty(t.prototype,"baseUrl",{get:function(){return this.connection.baseUrl||""},set:function(t){if(this.connectionState!==O.Disconnected&&this.connectionState!==O.Reconnecting)throw new Error("The HubConnection must be in the Disconnected or Reconnecting state to change the url.");if(!t)throw new Error("The HubConnection url must be a valid url.");this.connection.baseUrl=t},enumerable:!0,configurable:!0}),t.prototype.start=function(){return this.startPromise=this.startWithStateTransitions(),this.startPromise},t.prototype.startWithStateTransitions=function(){return M(this,void 0,void 0,(function(){var t;return A(this,(function(e){switch(e.label){case 0:if(this.connectionState!==O.Disconnected)return[2,Promise.reject(new Error("Cannot start a HubConnection that is not in the 'Disconnected' state."))];this.connectionState=O.Connecting,this.logger.log(r.Debug,"Starting HubConnection."),e.label=1;case 1:return e.trys.push([1,3,,4]),[4,this.startInternal()];case 2:return e.sent(),this.connectionState=O.Connected,this.connectionStarted=!0,this.logger.log(r.Debug,"HubConnection connected successfully."),[3,4];case 3:return t=e.sent(),this.connectionState=O.Disconnected,this.logger.log(r.Debug,"HubConnection failed to start successfully because of error '"+t+"'."),[2,Promise.reject(t)];case 4:return[2]}}))}))},t.prototype.startInternal=function(){return M(this,void 0,void 0,(function(){var t,e,n,o=this;return A(this,(function(i){switch(i.label){case 0:return this.stopDuringStartError=void 0,this.receivedHandshakeResponse=!1,t=new Promise((function(t,e){o.handshakeResolver=t,o.handshakeRejecter=e})),[4,this.connection.start(this.protocol.transferFormat)];case 1:i.sent(),i.label=2;case 2:return i.trys.push([2,5,,7]),e={protocol:this.protocol.name,version:this.protocol.version},this.logger.log(r.Debug,"Sending handshake request."),[4,this.sendMessage(this.handshakeProtocol.writeHandshakeRequest(e))];case 3:return i.sent(),this.logger.log(r.Information,"Using HubProtocol '"+this.protocol.name+"'."),this.cleanupTimeout(),this.resetTimeoutPeriod(),this.resetKeepAliveInterval(),[4,t];case 4:if(i.sent(),this.stopDuringStartError)throw this.stopDuringStartError;return[3,7];case 5:return n=i.sent(),this.logger.log(r.Debug,"Hub handshake failed with error '"+n+"' during start(). Stopping HubConnection."),this.cleanupTimeout(),this.cleanupPingTimer(),[4,this.connection.stop(n)];case 6:throw i.sent(),n;case 7:return[2]}}))}))},t.prototype.stop=function(){return M(this,void 0,void 0,(function(){var t;return A(this,(function(e){switch(e.label){case 0:return t=this.startPromise,this.stopPromise=this.stopInternal(),[4,this.stopPromise];case 1:e.sent(),e.label=2;case 2:return e.trys.push([2,4,,5]),[4,t];case 3:case 4:return e.sent(),[3,5];case 5:return[2]}}))}))},t.prototype.stopInternal=function(t){return this.connectionState===O.Disconnected?(this.logger.log(r.Debug,"Call to HubConnection.stop("+t+") ignored because it is already in the disconnected state."),Promise.resolve()):this.connectionState===O.Disconnecting?(this.logger.log(r.Debug,"Call to HttpConnection.stop("+t+") ignored because the connection is already in the disconnecting state."),this.stopPromise):(this.connectionState=O.Disconnecting,this.logger.log(r.Debug,"Stopping HubConnection."),this.reconnectDelayHandle?(this.logger.log(r.Debug,"Connection stopped during reconnect delay. Done reconnecting."),clearTimeout(this.reconnectDelayHandle),this.reconnectDelayHandle=void 0,this.completeClose(),Promise.resolve()):(this.cleanupTimeout(),this.cleanupPingTimer(),this.stopDuringStartError=t||new Error("The connection was stopped before the hub handshake could complete."),this.connection.stop(t)))},t.prototype.stream=function(t){for(var e=this,n=[],o=1;o<arguments.length;o++)n[o-1]=arguments[o];var r,i=this.replaceStreamingParams(n),s=i[0],c=i[1],a=this.createStreamInvocation(t,n,c),u=new j;return u.cancelCallback=function(){var t=e.createCancelInvocation(a.invocationId);return delete e.callbacks[a.invocationId],r.then((function(){return e.sendWithProtocol(t)}))},this.callbacks[a.invocationId]=function(t,e){e?u.error(e):t&&(t.type===E.Completion?t.error?u.error(new Error(t.error)):u.complete():u.next(t.item))},r=this.sendWithProtocol(a).catch((function(t){u.error(t),delete e.callbacks[a.invocationId]})),this.launchStreams(s,r),u},t.prototype.sendMessage=function(t){return this.resetKeepAliveInterval(),this.connection.send(t)},t.prototype.sendWithProtocol=function(t){return this.sendMessage(this.protocol.writeMessage(t))},t.prototype.send=function(t){for(var e=[],n=1;n<arguments.length;n++)e[n-1]=arguments[n];var o=this.replaceStreamingParams(e),r=o[0],i=o[1],s=this.sendWithProtocol(this.createInvocation(t,e,!0,i));return this.launchStreams(r,s),s},t.prototype.invoke=function(t){for(var e=this,n=[],o=1;o<arguments.length;o++)n[o-1]=arguments[o];var r=this.replaceStreamingParams(n),i=r[0],s=r[1],c=this.createInvocation(t,n,!1,s),a=new Promise((function(t,n){e.callbacks[c.invocationId]=function(e,o){o?n(o):e&&(e.type===E.Completion?e.error?n(new Error(e.error)):t(e.result):n(new Error("Unexpected message type: "+e.type)))};var o=e.sendWithProtocol(c).catch((function(t){n(t),delete e.callbacks[c.invocationId]}));e.launchStreams(i,o)}));return a},t.prototype.on=function(t,e){t&&e&&(t=t.toLowerCase(),this.methods[t]||(this.methods[t]=[]),-1===this.methods[t].indexOf(e)&&this.methods[t].push(e))},t.prototype.off=function(t,e){if(t){t=t.toLowerCase();var n=this.methods[t];if(n)if(e){var o=n.indexOf(e);-1!==o&&(n.splice(o,1),0===n.length&&delete this.methods[t])}else delete this.methods[t]}},t.prototype.onclose=function(t){t&&this.closedCallbacks.push(t)},t.prototype.onreconnecting=function(t){t&&this.reconnectingCallbacks.push(t)},t.prototype.onreconnected=function(t){t&&this.reconnectedCallbacks.push(t)},t.prototype.processIncomingData=function(t){if(this.cleanupTimeout(),this.receivedHandshakeResponse||(t=this.processHandshakeResponse(t),this.receivedHandshakeResponse=!0),t)for(var e=0,n=this.protocol.parseMessages(t,this.logger);e<n.length;e++){var o=n[e];switch(o.type){case E.Invocation:this.invokeClientMethod(o);break;case E.StreamItem:case E.Completion:var i=this.callbacks[o.invocationId];i&&(o.type===E.Completion&&delete this.callbacks[o.invocationId],i(o));break;case E.Ping:break;case E.Close:this.logger.log(r.Information,"Close message received from server.");var s=o.error?new Error("Server returned an error on close: "+o.error):void 0;!0===o.allowReconnect?this.connection.stop(s):this.stopPromise=this.stopInternal(s);break;default:this.logger.log(r.Warning,"Invalid message type: "+o.type+".")}}this.resetTimeoutPeriod()},t.prototype.processHandshakeResponse=function(t){var e,n,o;try{o=(e=this.handshakeProtocol.parseHandshakeResponse(t))[0],n=e[1]}catch(t){var i="Error parsing handshake response: "+t;this.logger.log(r.Error,i);var s=new Error(i);throw this.handshakeRejecter(s),s}if(n.error)throw i="Server returned handshake error: "+n.error,this.logger.log(r.Error,i),s=new Error(i),this.handshakeRejecter(s),s;return this.logger.log(r.Debug,"Server handshake complete."),this.handshakeResolver(),o},t.prototype.resetKeepAliveInterval=function(){this.connection.features.inherentKeepAlive||(this.nextKeepAlive=(new Date).getTime()+this.keepAliveIntervalInMilliseconds,this.cleanupPingTimer())},t.prototype.resetTimeoutPeriod=function(){var t=this;if(!(this.connection.features&&this.connection.features.inherentKeepAlive||(this.timeoutHandle=setTimeout((function(){return t.serverTimeout()}),this.serverTimeoutInMilliseconds),void 0!==this.pingServerHandle))){var e=this.nextKeepAlive-(new Date).getTime();e<0&&(e=0),this.pingServerHandle=setTimeout((function(){return M(t,void 0,void 0,(function(){return A(this,(function(t){switch(t.label){case 0:if(this.connectionState!==O.Connected)return[3,4];t.label=1;case 1:return t.trys.push([1,3,,4]),[4,this.sendMessage(this.cachedPingMessage)];case 2:return t.sent(),[3,4];case 3:return t.sent(),this.cleanupPingTimer(),[3,4];case 4:return[2]}}))}))}),e)}},t.prototype.serverTimeout=function(){this.connection.stop(new Error("Server timeout elapsed without receiving a message from the server."))},t.prototype.invokeClientMethod=function(t){var e=this,n=this.methods[t.target.toLowerCase()];if(n){try{n.forEach((function(n){return n.apply(e,t.arguments)}))}catch(e){this.logger.log(r.Error,"A callback for the method "+t.target.toLowerCase()+" threw error '"+e+"'.")}if(t.invocationId){var o="Server requested a response, which is not supported in this version of the client.";this.logger.log(r.Error,o),this.stopPromise=this.stopInternal(new Error(o))}}else this.logger.log(r.Warning,"No client method with the name '"+t.target+"' found.")},t.prototype.connectionClosed=function(t){this.logger.log(r.Debug,"HubConnection.connectionClosed("+t+") called while in state "+this.connectionState+"."),this.stopDuringStartError=this.stopDuringStartError||t||new Error("The underlying connection was closed before the hub handshake could complete."),this.handshakeResolver&&this.handshakeResolver(),this.cancelCallbacksWithError(t||new Error("Invocation canceled due to the underlying connection being closed.")),this.cleanupTimeout(),this.cleanupPingTimer(),this.connectionState===O.Disconnecting?this.completeClose(t):this.connectionState===O.Connected&&this.reconnectPolicy?this.reconnect(t):this.connectionState===O.Connected&&this.completeClose(t)},t.prototype.completeClose=function(t){var e=this;if(this.connectionStarted){this.connectionState=O.Disconnected,this.connectionStarted=!1;try{this.closedCallbacks.forEach((function(n){return n.apply(e,[t])}))}catch(e){this.logger.log(r.Error,"An onclose callback called with error '"+t+"' threw error '"+e+"'.")}}},t.prototype.reconnect=function(t){return M(this,void 0,void 0,(function(){var e,n,o,i,s,c=this;return A(this,(function(a){switch(a.label){case 0:if(e=Date.now(),n=0,o=void 0!==t?t:new Error("Attempting to reconnect due to a unknown error."),null===(i=this.getNextRetryDelay(n++,0,o)))return this.logger.log(r.Debug,"Connection not reconnecting because the IRetryPolicy returned null on the first reconnect attempt."),this.completeClose(t),[2];if(this.connectionState=O.Reconnecting,t?this.logger.log(r.Information,"Connection reconnecting because of error '"+t+"'."):this.logger.log(r.Information,"Connection reconnecting."),this.onreconnecting){try{this.reconnectingCallbacks.forEach((function(e){return e.apply(c,[t])}))}catch(e){this.logger.log(r.Error,"An onreconnecting callback called with error '"+t+"' threw error '"+e+"'.")}if(this.connectionState!==O.Reconnecting)return this.logger.log(r.Debug,"Connection left the reconnecting state in onreconnecting callback. Done reconnecting."),[2]}a.label=1;case 1:return null===i?[3,7]:(this.logger.log(r.Information,"Reconnect attempt number "+n+" will start in "+i+" ms."),[4,new Promise((function(t){c.reconnectDelayHandle=setTimeout(t,i)}))]);case 2:if(a.sent(),this.reconnectDelayHandle=void 0,this.connectionState!==O.Reconnecting)return this.logger.log(r.Debug,"Connection left the reconnecting state during reconnect delay. Done reconnecting."),[2];a.label=3;case 3:return a.trys.push([3,5,,6]),[4,this.startInternal()];case 4:if(a.sent(),this.connectionState=O.Connected,this.logger.log(r.Information,"HubConnection reconnected successfully."),this.onreconnected)try{this.reconnectedCallbacks.forEach((function(t){return t.apply(c,[c.connection.connectionId])}))}catch(t){this.logger.log(r.Error,"An onreconnected callback called with connectionId '"+this.connection.connectionId+"; threw error '"+t+"'.")}return[2];case 5:return s=a.sent(),this.logger.log(r.Information,"Reconnect attempt failed because of error '"+s+"'."),this.connectionState!==O.Reconnecting?(this.logger.log(r.Debug,"Connection moved to the '"+this.connectionState+"' from the reconnecting state during reconnect attempt. Done reconnecting."),this.connectionState===O.Disconnecting&&this.completeClose(),[2]):(o=s instanceof Error?s:new Error(s.toString()),i=this.getNextRetryDelay(n++,Date.now()-e,o),[3,6]);case 6:return[3,1];case 7:return this.logger.log(r.Information,"Reconnect retries have been exhausted after "+(Date.now()-e)+" ms and "+n+" failed attempts. Connection disconnecting."),this.completeClose(),[2]}}))}))},t.prototype.getNextRetryDelay=function(t,e,n){try{return this.reconnectPolicy.nextRetryDelayInMilliseconds({elapsedMilliseconds:e,previousRetryCount:t,retryReason:n})}catch(n){return this.logger.log(r.Error,"IRetryPolicy.nextRetryDelayInMilliseconds("+t+", "+e+") threw error '"+n+"'."),null}},t.prototype.cancelCallbacksWithError=function(t){var e=this.callbacks;this.callbacks={},Object.keys(e).forEach((function(n){(0,e[n])(null,t)}))},t.prototype.cleanupPingTimer=function(){this.pingServerHandle&&(clearTimeout(this.pingServerHandle),this.pingServerHandle=void 0)},t.prototype.cleanupTimeout=function(){this.timeoutHandle&&clearTimeout(this.timeoutHandle)},t.prototype.createInvocation=function(t,e,n,o){if(n)return{arguments:e,streamIds:o,target:t,type:E.Invocation};var r=this.invocationId;return this.invocationId++,{arguments:e,invocationId:r.toString(),streamIds:o,target:t,type:E.Invocation}},t.prototype.launchStreams=function(t,e){var n=this;if(0!==t.length){e||(e=Promise.resolve());var o=function(o){t[o].subscribe({complete:function(){e=e.then((function(){return n.sendWithProtocol(n.createCompletionMessage(o))}))},error:function(t){var r;r=t instanceof Error?t.message:t&&t.toString?t.toString():"Unknown error",e=e.then((function(){return n.sendWithProtocol(n.createCompletionMessage(o,r))}))},next:function(t){e=e.then((function(){return n.sendWithProtocol(n.createStreamItemMessage(o,t))}))}})};for(var r in t)o(r)}},t.prototype.replaceStreamingParams=function(t){for(var e=[],n=[],o=0;o<t.length;o++){var r=t[o];if(this.isObservable(r)){var i=this.invocationId;this.invocationId++,e[i]=r,n.push(i.toString()),t.splice(o,1)}}return[e,n]},t.prototype.isObservable=function(t){return t&&t.subscribe&&"function"==typeof t.subscribe},t.prototype.createStreamInvocation=function(t,e,n){var o=this.invocationId;return this.invocationId++,{arguments:e,invocationId:o.toString(),streamIds:n,target:t,type:E.StreamInvocation}},t.prototype.createCancelInvocation=function(t){return{invocationId:t,type:E.CancelInvocation}},t.prototype.createStreamItemMessage=function(t,e){return{invocationId:t,item:e,type:E.StreamItem}},t.prototype.createCompletionMessage=function(t,e,n){return e?{error:e,invocationId:t,type:E.Completion}:{invocationId:t,result:n,type:E.Completion}},t}(),N=[0,2e3,1e4,3e4,null],q=function(){function t(t){this.retryDelays=void 0!==t?t.concat([null]):N}return t.prototype.nextRetryDelayInMilliseconds=function(t){return this.retryDelays[t.previousRetryCount]},t}();!function(t){t[t.None=0]="None",t[t.WebSockets=1]="WebSockets",t[t.ServerSentEvents=2]="ServerSentEvents",t[t.LongPolling=4]="LongPolling"}(_||(_={})),function(t){t[t.Text=1]="Text",t[t.Binary=2]="Binary"}(L||(L={}));var F=function(){function t(){this.isAborted=!1,this.onabort=null}return t.prototype.abort=function(){this.isAborted||(this.isAborted=!0,this.onabort&&this.onabort())},Object.defineProperty(t.prototype,"signal",{get:function(){return this},enumerable:!0,configurable:!0}),Object.defineProperty(t.prototype,"aborted",{get:function(){return this.isAborted},enumerable:!0,configurable:!0}),t}(),U=function(t,e,n,o){return new(n||(n=Promise))((function(r,i){function s(t){try{a(o.next(t))}catch(t){i(t)}}function c(t){try{a(o.throw(t))}catch(t){i(t)}}function a(t){t.done?r(t.value):new n((function(e){e(t.value)})).then(s,c)}a((o=o.apply(t,e||[])).next())}))},B=function(t,e){var n,o,r,i,s={label:0,sent:function(){if(1&r[0])throw r[1];return r[1]},trys:[],ops:[]};return i={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function c(i){return function(c){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,o&&(r=2&i[0]?o.return:i[0]?o.throw||((r=o.return)&&r.call(o),0):o.next)&&!(r=r.call(o,i[1])).done)return r;switch(o=0,r&&(i=[2&i[0],r.value]),i[0]){case 0:case 1:r=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,o=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!((r=(r=s.trys).length>0&&r[r.length-1])||6!==i[0]&&2!==i[0])){s=0;continue}if(3===i[0]&&(!r||i[1]>r[0]&&i[1]<r[3])){s.label=i[1];break}if(6===i[0]&&s.label<r[1]){s.label=r[1],r=i;break}if(r&&s.label<r[2]){s.label=r[2],s.ops.push(i);break}r[2]&&s.ops.pop(),s.trys.pop();continue}i=e.call(t,s)}catch(t){i=[6,t],o=0}finally{n=r=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,c])}}},K=function(){function t(t,e,n,o){this.httpClient=t,this.accessTokenFactory=e,this.logger=n,this.pollAbort=new F,this.logMessageContent=o,this.running=!1,this.onreceive=null,this.onclose=null}return Object.defineProperty(t.prototype,"pollAborted",{get:function(){return this.pollAbort.aborted},enumerable:!0,configurable:!0}),t.prototype.connect=function(t,e){return U(this,void 0,void 0,(function(){var n,o,i,c;return B(this,(function(a){switch(a.label){case 0:if(f.isRequired(t,"url"),f.isRequired(e,"transferFormat"),f.isIn(e,L,"transferFormat"),this.url=t,this.logger.log(r.Trace,"(LongPolling transport) Connecting."),e===L.Binary&&"undefined"!=typeof XMLHttpRequest&&"string"!=typeof(new XMLHttpRequest).responseType)throw new Error("Binary protocols over XmlHttpRequest not implementing advanced features are not supported.");return n={abortSignal:this.pollAbort.signal,headers:{},timeout:1e5},e===L.Binary&&(n.responseType="arraybuffer"),[4,this.getAccessToken()];case 1:return o=a.sent(),this.updateHeaderToken(n,o),i=t+"&_="+Date.now(),this.logger.log(r.Trace,"(LongPolling transport) polling: "+i+"."),[4,this.httpClient.get(i,n)];case 2:return 200!==(c=a.sent()).statusCode?(this.logger.log(r.Error,"(LongPolling transport) Unexpected response code: "+c.statusCode+"."),this.closeError=new s(c.statusText||"",c.statusCode),this.running=!1):this.running=!0,this.receiving=this.poll(this.url,n),[2]}}))}))},t.prototype.getAccessToken=function(){return U(this,void 0,void 0,(function(){return B(this,(function(t){switch(t.label){case 0:return this.accessTokenFactory?[4,this.accessTokenFactory()]:[3,2];case 1:return[2,t.sent()];case 2:return[2,null]}}))}))},t.prototype.updateHeaderToken=function(t,e){t.headers||(t.headers={}),e?t.headers.Authorization="Bearer "+e:t.headers.Authorization&&delete t.headers.Authorization},t.prototype.poll=function(t,e){return U(this,void 0,void 0,(function(){var n,o,i,a;return B(this,(function(u){switch(u.label){case 0:u.trys.push([0,,8,9]),u.label=1;case 1:return this.running?[4,this.getAccessToken()]:[3,7];case 2:n=u.sent(),this.updateHeaderToken(e,n),u.label=3;case 3:return u.trys.push([3,5,,6]),o=t+"&_="+Date.now(),this.logger.log(r.Trace,"(LongPolling transport) polling: "+o+"."),[4,this.httpClient.get(o,e)];case 4:return 204===(i=u.sent()).statusCode?(this.logger.log(r.Information,"(LongPolling transport) Poll terminated by server."),this.running=!1):200!==i.statusCode?(this.logger.log(r.Error,"(LongPolling transport) Unexpected response code: "+i.statusCode+"."),this.closeError=new s(i.statusText||"",i.statusCode),this.running=!1):i.content?(this.logger.log(r.Trace,"(LongPolling transport) data received. "+d(i.content,this.logMessageContent)+"."),this.onreceive&&this.onreceive(i.content)):this.logger.log(r.Trace,"(LongPolling transport) Poll timed out, reissuing."),[3,6];case 5:return a=u.sent(),this.running?a instanceof c?this.logger.log(r.Trace,"(LongPolling transport) Poll timed out, reissuing."):(this.closeError=a,this.running=!1):this.logger.log(r.Trace,"(LongPolling transport) Poll errored after shutdown: "+a.message),[3,6];case 6:return[3,1];case 7:return[3,9];case 8:return this.logger.log(r.Trace,"(LongPolling transport) Polling complete."),this.pollAborted||this.raiseOnClose(),[7];case 9:return[2]}}))}))},t.prototype.send=function(t){return U(this,void 0,void 0,(function(){return B(this,(function(e){return this.running?[2,b(this.logger,"LongPolling",this.httpClient,this.url,this.accessTokenFactory,t,this.logMessageContent)]:[2,Promise.reject(new Error("Cannot send until the transport is connected"))]}))}))},t.prototype.stop=function(){return U(this,void 0,void 0,(function(){var t,e;return B(this,(function(n){switch(n.label){case 0:this.logger.log(r.Trace,"(LongPolling transport) Stopping polling."),this.running=!1,this.pollAbort.abort(),n.label=1;case 1:return n.trys.push([1,,5,6]),[4,this.receiving];case 2:return n.sent(),this.logger.log(r.Trace,"(LongPolling transport) sending DELETE request to "+this.url+"."),t={headers:{}},[4,this.getAccessToken()];case 3:return e=n.sent(),this.updateHeaderToken(t,e),[4,this.httpClient.delete(this.url,t)];case 4:return n.sent(),this.logger.log(r.Trace,"(LongPolling transport) DELETE request sent."),[3,6];case 5:return this.logger.log(r.Trace,"(LongPolling transport) Stop finished."),this.raiseOnClose(),[7];case 6:return[2]}}))}))},t.prototype.raiseOnClose=function(){if(this.onclose){var t="(LongPolling transport) Firing onclose event.";this.closeError&&(t+=" Error: "+this.closeError),this.logger.log(r.Trace,t),this.onclose(this.closeError)}},t}(),J=function(t,e,n,o){return new(n||(n=Promise))((function(r,i){function s(t){try{a(o.next(t))}catch(t){i(t)}}function c(t){try{a(o.throw(t))}catch(t){i(t)}}function a(t){t.done?r(t.value):new n((function(e){e(t.value)})).then(s,c)}a((o=o.apply(t,e||[])).next())}))},X=function(t,e){var n,o,r,i,s={label:0,sent:function(){if(1&r[0])throw r[1];return r[1]},trys:[],ops:[]};return i={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function c(i){return function(c){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,o&&(r=2&i[0]?o.return:i[0]?o.throw||((r=o.return)&&r.call(o),0):o.next)&&!(r=r.call(o,i[1])).done)return r;switch(o=0,r&&(i=[2&i[0],r.value]),i[0]){case 0:case 1:r=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,o=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!((r=(r=s.trys).length>0&&r[r.length-1])||6!==i[0]&&2!==i[0])){s=0;continue}if(3===i[0]&&(!r||i[1]>r[0]&&i[1]<r[3])){s.label=i[1];break}if(6===i[0]&&s.label<r[1]){s.label=r[1],r=i;break}if(r&&s.label<r[2]){s.label=r[2],s.ops.push(i);break}r[2]&&s.ops.pop(),s.trys.pop();continue}i=e.call(t,s)}catch(t){i=[6,t],o=0}finally{n=r=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,c])}}},V=function(){function t(t,e,n,o,r){this.httpClient=t,this.accessTokenFactory=e,this.logger=n,this.logMessageContent=o,this.eventSourceConstructor=r,this.onreceive=null,this.onclose=null}return t.prototype.connect=function(t,e){return J(this,void 0,void 0,(function(){var n,o=this;return X(this,(function(i){switch(i.label){case 0:return f.isRequired(t,"url"),f.isRequired(e,"transferFormat"),f.isIn(e,L,"transferFormat"),this.logger.log(r.Trace,"(SSE transport) Connecting."),this.url=t,this.accessTokenFactory?[4,this.accessTokenFactory()]:[3,2];case 1:(n=i.sent())&&(t+=(t.indexOf("?")<0?"?":"&")+"access_token="+encodeURIComponent(n)),i.label=2;case 2:return[2,new Promise((function(n,i){var s=!1;if(e===L.Text){var c;if(g.isBrowser||g.isWebWorker)c=new o.eventSourceConstructor(t,{withCredentials:!0});else{var a=o.httpClient.getCookieString(t);c=new o.eventSourceConstructor(t,{withCredentials:!0,headers:{Cookie:a}})}try{c.onmessage=function(t){if(o.onreceive)try{o.logger.log(r.Trace,"(SSE transport) data received. "+d(t.data,o.logMessageContent)+"."),o.onreceive(t.data)}catch(t){return void o.close(t)}},c.onerror=function(t){var e=new Error(t.data||"Error occurred");s?o.close(e):i(e)},c.onopen=function(){o.logger.log(r.Information,"SSE connected to "+o.url),o.eventSource=c,s=!0,n()}}catch(t){return void i(t)}}else i(new Error("The Server-Sent Events transport only supports the 'Text' transfer format"))}))]}}))}))},t.prototype.send=function(t){return J(this,void 0,void 0,(function(){return X(this,(function(e){return this.eventSource?[2,b(this.logger,"SSE",this.httpClient,this.url,this.accessTokenFactory,t,this.logMessageContent)]:[2,Promise.reject(new Error("Cannot send until the transport is connected"))]}))}))},t.prototype.stop=function(){return this.close(),Promise.resolve()},t.prototype.close=function(t){this.eventSource&&(this.eventSource.close(),this.eventSource=void 0,this.onclose&&this.onclose(t))},t}(),G=function(){function t(t,e,n,o,r){this.logger=n,this.accessTokenFactory=e,this.logMessageContent=o,this.webSocketConstructor=r,this.httpClient=t,this.onreceive=null,this.onclose=null}return t.prototype.connect=function(t,e){return n=this,o=void 0,s=function(){var n,o=this;return function(t,e){var n,o,r,i,s={label:0,sent:function(){if(1&r[0])throw r[1];return r[1]},trys:[],ops:[]};return i={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function c(i){return function(c){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,o&&(r=2&i[0]?o.return:i[0]?o.throw||((r=o.return)&&r.call(o),0):o.next)&&!(r=r.call(o,i[1])).done)return r;switch(o=0,r&&(i=[2&i[0],r.value]),i[0]){case 0:case 1:r=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,o=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!((r=(r=s.trys).length>0&&r[r.length-1])||6!==i[0]&&2!==i[0])){s=0;continue}if(3===i[0]&&(!r||i[1]>r[0]&&i[1]<r[3])){s.label=i[1];break}if(6===i[0]&&s.label<r[1]){s.label=r[1],r=i;break}if(r&&s.label<r[2]){s.label=r[2],s.ops.push(i);break}r[2]&&s.ops.pop(),s.trys.pop();continue}i=e.call(t,s)}catch(t){i=[6,t],o=0}finally{n=r=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,c])}}}(this,(function(i){switch(i.label){case 0:return f.isRequired(t,"url"),f.isRequired(e,"transferFormat"),f.isIn(e,L,"transferFormat"),this.logger.log(r.Trace,"(WebSockets transport) Connecting."),this.accessTokenFactory?[4,this.accessTokenFactory()]:[3,2];case 1:(n=i.sent())&&(t+=(t.indexOf("?")<0?"?":"&")+"access_token="+encodeURIComponent(n)),i.label=2;case 2:return[2,new Promise((function(n,i){var s;t=t.replace(/^http/,"ws");var c=o.httpClient.getCookieString(t),a=!1;g.isNode&&c&&(s=new o.webSocketConstructor(t,void 0,{headers:{Cookie:""+c}})),s||(s=new o.webSocketConstructor(t)),e===L.Binary&&(s.binaryType="arraybuffer"),s.onopen=function(e){o.logger.log(r.Information,"WebSocket connected to "+t+"."),o.webSocket=s,a=!0,n()},s.onerror=function(t){var e;e="undefined"!=typeof ErrorEvent&&t instanceof ErrorEvent?t.error:new Error("There was an error with the transport."),i(e)},s.onmessage=function(t){o.logger.log(r.Trace,"(WebSockets transport) data received. "+d(t.data,o.logMessageContent)+"."),o.onreceive&&o.onreceive(t.data)},s.onclose=function(t){var e;a?o.close(t):(e="undefined"!=typeof ErrorEvent&&t instanceof ErrorEvent?t.error:new Error("There was an error with the transport."),i(e))}}))]}}))},new((i=void 0)||(i=Promise))((function(t,e){function r(t){try{a(s.next(t))}catch(t){e(t)}}function c(t){try{a(s.throw(t))}catch(t){e(t)}}function a(e){e.done?t(e.value):new i((function(t){t(e.value)})).then(r,c)}a((s=s.apply(n,o||[])).next())}));var n,o,i,s},t.prototype.send=function(t){return this.webSocket&&this.webSocket.readyState===this.webSocketConstructor.OPEN?(this.logger.log(r.Trace,"(WebSockets transport) sending data. "+d(t,this.logMessageContent)+"."),this.webSocket.send(t),Promise.resolve()):Promise.reject("WebSocket is not in the OPEN state")},t.prototype.stop=function(){return this.webSocket&&this.close(void 0),Promise.resolve()},t.prototype.close=function(t){this.webSocket&&(this.webSocket.onclose=function(){},this.webSocket.onmessage=function(){},this.webSocket.onerror=function(){},this.webSocket.close(),this.webSocket=void 0),this.logger.log(r.Trace,"(WebSockets transport) socket closed."),this.onclose&&(!t||!1!==t.wasClean&&1e3===t.code?this.onclose():this.onclose(new Error("WebSocket closed with status code: "+t.code+" ("+t.reason+").")))},t}(),Q=function(t,e,n,o){return new(n||(n=Promise))((function(r,i){function s(t){try{a(o.next(t))}catch(t){i(t)}}function c(t){try{a(o.throw(t))}catch(t){i(t)}}function a(t){t.done?r(t.value):new n((function(e){e(t.value)})).then(s,c)}a((o=o.apply(t,e||[])).next())}))},z=function(t,e){var n,o,r,i,s={label:0,sent:function(){if(1&r[0])throw r[1];return r[1]},trys:[],ops:[]};return i={next:c(0),throw:c(1),return:c(2)},"function"==typeof Symbol&&(i[Symbol.iterator]=function(){return this}),i;function c(i){return function(c){return function(i){if(n)throw new TypeError("Generator is already executing.");for(;s;)try{if(n=1,o&&(r=2&i[0]?o.return:i[0]?o.throw||((r=o.return)&&r.call(o),0):o.next)&&!(r=r.call(o,i[1])).done)return r;switch(o=0,r&&(i=[2&i[0],r.value]),i[0]){case 0:case 1:r=i;break;case 4:return s.label++,{value:i[1],done:!1};case 5:s.label++,o=i[1],i=[0];continue;case 7:i=s.ops.pop(),s.trys.pop();continue;default:if(!((r=(r=s.trys).length>0&&r[r.length-1])||6!==i[0]&&2!==i[0])){s=0;continue}if(3===i[0]&&(!r||i[1]>r[0]&&i[1]<r[3])){s.label=i[1];break}if(6===i[0]&&s.label<r[1]){s.label=r[1],r=i;break}if(r&&s.label<r[2]){s.label=r[2],s.ops.push(i);break}r[2]&&s.ops.pop(),s.trys.pop();continue}i=e.call(t,s)}catch(t){i=[6,t],o=0}finally{n=r=0}if(5&i[0])throw i[1];return{value:i[0]?i[1]:void 0,done:!0}}([i,c])}}},Y=null,Z=null;if(g.isNode){var $=require;Y=$("ws"),Z=$("eventsource")}var tt=function(){function t(t,e){var n;void 0===e&&(e={}),this.stopPromiseResolver=function(){},this.features={},this.negotiateVersion=1,f.isRequired(t,"url"),this.logger=void 0===(n=e.logger)?new w(r.Information):null===n?p.instance:n.log?n:new w(n),this.baseUrl=this.resolveUrl(t),(e=e||{}).logMessageContent=e.logMessageContent||!1,g.isNode||"undefined"==typeof WebSocket||e.WebSocket?g.isNode&&!e.WebSocket&&Y&&(e.WebSocket=Y):e.WebSocket=WebSocket,g.isNode||"undefined"==typeof EventSource||e.EventSource?g.isNode&&!e.EventSource&&void 0!==Z&&(e.EventSource=Z):e.EventSource=EventSource,this.httpClient=e.httpClient||new R(this.logger),this.connectionState="Disconnected",this.connectionStarted=!1,this.options=e,this.onreceive=null,this.onclose=null}return t.prototype.start=function(t){return Q(this,void 0,void 0,(function(){var e;return z(this,(function(n){switch(n.label){case 0:return t=t||L.Binary,f.isIn(t,L,"transferFormat"),this.logger.log(r.Debug,"Starting connection with transfer format '"+L[t]+"'."),"Disconnected"!==this.connectionState?[2,Promise.reject(new Error("Cannot start an HttpConnection that is not in the 'Disconnected' state."))]:(this.connectionState="Connecting ",this.startInternalPromise=this.startInternal(t),[4,this.startInternalPromise]);case 1:return n.sent(),"Disconnecting"!==this.connectionState?[3,3]:(e="Failed to start the HttpConnection before stop() was called.",this.logger.log(r.Error,e),[4,this.stopPromise]);case 2:return n.sent(),[2,Promise.reject(new Error(e))];case 3:if("Connected"!==this.connectionState)return e="HttpConnection.startInternal completed gracefully but didn't enter the connection into the connected state!",this.logger.log(r.Error,e),[2,Promise.reject(new Error(e))];n.label=4;case 4:return this.connectionStarted=!0,[2]}}))}))},t.prototype.send=function(t){return"Connected"!==this.connectionState?Promise.reject(new Error("Cannot send data if the connection is not in the 'Connected' State.")):(this.sendQueue||(this.sendQueue=new et(this.transport)),this.sendQueue.send(t))},t.prototype.stop=function(t){return Q(this,void 0,void 0,(function(){var e=this;return z(this,(function(n){switch(n.label){case 0:return"Disconnected"===this.connectionState?(this.logger.log(r.Debug,"Call to HttpConnection.stop("+t+") ignored because the connection is already in the disconnected state."),[2,Promise.resolve()]):"Disconnecting"===this.connectionState?(this.logger.log(r.Debug,"Call to HttpConnection.stop("+t+") ignored because the connection is already in the disconnecting state."),[2,this.stopPromise]):(this.connectionState="Disconnecting",this.stopPromise=new Promise((function(t){e.stopPromiseResolver=t})),[4,this.stopInternal(t)]);case 1:return n.sent(),[4,this.stopPromise];case 2:return n.sent(),[2]}}))}))},t.prototype.stopInternal=function(t){return Q(this,void 0,void 0,(function(){var e;return z(this,(function(n){switch(n.label){case 0:this.stopError=t,n.label=1;case 1:return n.trys.push([1,3,,4]),[4,this.startInternalPromise];case 2:case 3:return n.sent(),[3,4];case 4:if(!this.transport)return[3,9];n.label=5;case 5:return n.trys.push([5,7,,8]),[4,this.transport.stop()];case 6:return n.sent(),[3,8];case 7:return e=n.sent(),this.logger.log(r.Error,"HttpConnection.transport.stop() threw error '"+e+"'."),this.stopConnection(),[3,8];case 8:return this.transport=void 0,[3,10];case 9:this.logger.log(r.Debug,"HttpConnection.transport is undefined in HttpConnection.stop() because start() failed."),n.label=10;case 10:return[2]}}))}))},t.prototype.startInternal=function(t){return Q(this,void 0,void 0,(function(){var e,n,o,i,s,c;return z(this,(function(a){switch(a.label){case 0:e=this.baseUrl,this.accessTokenFactory=this.options.accessTokenFactory,a.label=1;case 1:return a.trys.push([1,12,,13]),this.options.skipNegotiation?this.options.transport!==_.WebSockets?[3,3]:(this.transport=this.constructTransport(_.WebSockets),[4,this.startTransport(e,t)]):[3,5];case 2:return a.sent(),[3,4];case 3:throw new Error("Negotiation can only be skipped when using the WebSocket transport directly.");case 4:return[3,11];case 5:n=null,o=0,i=function(){var t;return z(this,(function(r){switch(r.label){case 0:return[4,s.getNegotiationResponse(e)];case 1:if(n=r.sent(),"Disconnecting"===s.connectionState||"Disconnected"===s.connectionState)throw new Error("The connection was stopped during negotiation.");if(n.error)throw new Error(n.error);if(n.ProtocolVersion)throw new Error("Detected a connection attempt to an ASP.NET SignalR Server. This client only supports connecting to an ASP.NET Core SignalR Server. See https://aka.ms/signalr-core-differences for details.");return n.url&&(e=n.url),n.accessToken&&(t=n.accessToken,s.accessTokenFactory=function(){return t}),o++,[2]}}))},s=this,a.label=6;case 6:return[5,i()];case 7:a.sent(),a.label=8;case 8:if(n.url&&o<100)return[3,6];a.label=9;case 9:if(100===o&&n.url)throw new Error("Negotiate redirection limit exceeded.");return[4,this.createTransport(e,this.options.transport,n,t)];case 10:a.sent(),a.label=11;case 11:return this.transport instanceof K&&(this.features.inherentKeepAlive=!0),"Connecting "===this.connectionState&&(this.logger.log(r.Debug,"The HttpConnection connected successfully."),this.connectionState="Connected"),[3,13];case 12:return c=a.sent(),this.logger.log(r.Error,"Failed to start the connection: "+c),this.connectionState="Disconnected",this.transport=void 0,this.stopPromiseResolver(),[2,Promise.reject(c)];case 13:return[2]}}))}))},t.prototype.getNegotiationResponse=function(t){return Q(this,void 0,void 0,(function(){var e,n,o,i,s,c,a;return z(this,(function(u){switch(u.label){case 0:return this.accessTokenFactory?[4,this.accessTokenFactory()]:[3,2];case 1:(o=u.sent())&&((e={}).Authorization="Bearer "+o,n=e),u.label=2;case 2:i=this.resolveNegotiateUrl(t),this.logger.log(r.Debug,"Sending negotiation request: "+i+"."),u.label=3;case 3:return u.trys.push([3,5,,6]),[4,this.httpClient.post(i,{content:"",headers:n})];case 4:return 200!==(s=u.sent()).statusCode?[2,Promise.reject(new Error("Unexpected status code returned from negotiate "+s.statusCode))]:((!(c=JSON.parse(s.content)).negotiateVersion||c.negotiateVersion<1)&&(c.connectionToken=c.connectionId),[2,c]);case 5:return a=u.sent(),this.logger.log(r.Error,"Failed to complete negotiation with the server: "+a),[2,Promise.reject(a)];case 6:return[2]}}))}))},t.prototype.createConnectUrl=function(t,e){return e?t+(-1===t.indexOf("?")?"?":"&")+"id="+e:t},t.prototype.createTransport=function(t,e,n,o){return Q(this,void 0,void 0,(function(){var i,s,c,a,u,l,h,p,f,g,d;return z(this,(function(v){switch(v.label){case 0:return i=this.createConnectUrl(t,n.connectionToken),this.isITransport(e)?(this.logger.log(r.Debug,"Connection was provided an instance of ITransport, using that directly."),this.transport=e,[4,this.startTransport(i,o)]):[3,2];case 1:return v.sent(),this.connectionId=n.connectionId,[2];case 2:s=[],c=n.availableTransports||[],a=n,u=0,l=c,v.label=3;case 3:return u<l.length?(h=l[u],(p=this.resolveTransportOrError(h,e,o))instanceof Error?(s.push(h.transport+" failed: "+p),[3,12]):[3,4]):[3,13];case 4:if(!this.isITransport(p))return[3,12];if(this.transport=p,a)return[3,9];v.label=5;case 5:return v.trys.push([5,7,,8]),[4,this.getNegotiationResponse(t)];case 6:return a=v.sent(),[3,8];case 7:return f=v.sent(),[2,Promise.reject(f)];case 8:i=this.createConnectUrl(t,a.connectionToken),v.label=9;case 9:return v.trys.push([9,11,,12]),[4,this.startTransport(i,o)];case 10:return v.sent(),this.connectionId=a.connectionId,[2];case 11:return g=v.sent(),this.logger.log(r.Error,"Failed to start the transport '"+h.transport+"': "+g),a=void 0,s.push(h.transport+" failed: "+g),"Connecting "!==this.connectionState?(d="Failed to select transport before stop() was called.",this.logger.log(r.Debug,d),[2,Promise.reject(new Error(d))]):[3,12];case 12:return u++,[3,3];case 13:return s.length>0?[2,Promise.reject(new Error("Unable to connect to the server with any of the available transports. "+s.join(" ")))]:[2,Promise.reject(new Error("None of the transports supported by the client are supported by the server."))]}}))}))},t.prototype.constructTransport=function(t){switch(t){case _.WebSockets:if(!this.options.WebSocket)throw new Error("'WebSocket' is not supported in your environment.");return new G(this.httpClient,this.accessTokenFactory,this.logger,this.options.logMessageContent||!1,this.options.WebSocket);case _.ServerSentEvents:if(!this.options.EventSource)throw new Error("'EventSource' is not supported in your environment.");return new V(this.httpClient,this.accessTokenFactory,this.logger,this.options.logMessageContent||!1,this.options.EventSource);case _.LongPolling:return new K(this.httpClient,this.accessTokenFactory,this.logger,this.options.logMessageContent||!1);default:throw new Error("Unknown transport: "+t+".")}},t.prototype.startTransport=function(t,e){var n=this;return this.transport.onreceive=this.onreceive,this.transport.onclose=function(t){return n.stopConnection(t)},this.transport.connect(t,e)},t.prototype.resolveTransportOrError=function(t,e,n){var o=_[t.transport];if(null==o)return this.logger.log(r.Debug,"Skipping transport '"+t.transport+"' because it is not supported by this client."),new Error("Skipping transport '"+t.transport+"' because it is not supported by this client.");if(!function(t,e){return!t||0!=(e&t)}(e,o))return this.logger.log(r.Debug,"Skipping transport '"+_[o]+"' because it was disabled by the client."),new Error("'"+_[o]+"' is disabled by the client.");if(!(t.transferFormats.map((function(t){return L[t]})).indexOf(n)>=0))return this.logger.log(r.Debug,"Skipping transport '"+_[o]+"' because it does not support the requested transfer format '"+L[n]+"'."),new Error("'"+_[o]+"' does not support "+L[n]+".");if(o===_.WebSockets&&!this.options.WebSocket||o===_.ServerSentEvents&&!this.options.EventSource)return this.logger.log(r.Debug,"Skipping transport '"+_[o]+"' because it is not supported in your environment.'"),new Error("'"+_[o]+"' is not supported in your environment.");this.logger.log(r.Debug,"Selecting transport '"+_[o]+"'.");try{return this.constructTransport(o)}catch(t){return t}},t.prototype.isITransport=function(t){return t&&"object"==typeof t&&"connect"in t},t.prototype.stopConnection=function(t){var e=this;if(this.logger.log(r.Debug,"HttpConnection.stopConnection("+t+") called while in state "+this.connectionState+"."),this.transport=void 0,t=this.stopError||t,this.stopError=void 0,"Disconnected"!==this.connectionState)if("Connecting "!==this.connectionState){if("Disconnecting"===this.connectionState&&this.stopPromiseResolver(),t?this.logger.log(r.Error,"Connection disconnected with error '"+t+"'."):this.logger.log(r.Information,"Connection disconnected."),this.sendQueue&&(this.sendQueue.stop().catch((function(t){e.logger.log(r.Error,"TransportSendQueue.stop() threw error '"+t+"'.")})),this.sendQueue=void 0),this.connectionId=void 0,this.connectionState="Disconnected",this.connectionStarted){this.connectionStarted=!1;try{this.onclose&&this.onclose(t)}catch(e){this.logger.log(r.Error,"HttpConnection.onclose("+t+") threw error '"+e+"'.")}}}else this.logger.log(r.Warning,"Call to HttpConnection.stopConnection("+t+") was ignored because the connection hasn't yet left the in the connecting state.");else this.logger.log(r.Debug,"Call to HttpConnection.stopConnection("+t+") was ignored because the connection is already in the disconnected state.")},t.prototype.resolveUrl=function(t){if(0===t.lastIndexOf("https://",0)||0===t.lastIndexOf("http://",0))return t;if(!g.isBrowser||!window.document)throw new Error("Cannot resolve '"+t+"'.");var e=window.document.createElement("a");return e.href=t,this.logger.log(r.Information,"Normalizing '"+t+"' to '"+e.href+"'."),e.href},t.prototype.resolveNegotiateUrl=function(t){var e=t.indexOf("?"),n=t.substring(0,-1===e?t.length:e);return"/"!==n[n.length-1]&&(n+="/"),n+="negotiate",-1===(n+=-1===e?"":t.substring(e)).indexOf("negotiateVersion")&&(n+=-1===e?"?":"&",n+="negotiateVersion="+this.negotiateVersion),n},t}(),et=function(){function t(t){this.transport=t,this.buffer=[],this.executing=!0,this.sendBufferedData=new nt,this.transportResult=new nt,this.sendLoopPromise=this.sendLoop()}return t.prototype.send=function(t){return this.bufferData(t),this.transportResult||(this.transportResult=new nt),this.transportResult.promise},t.prototype.stop=function(){return this.executing=!1,this.sendBufferedData.resolve(),this.sendLoopPromise},t.prototype.bufferData=function(t){if(this.buffer.length&&typeof this.buffer[0]!=typeof t)throw new Error("Expected data to be of type "+typeof this.buffer+" but was of type "+typeof t);this.buffer.push(t),this.sendBufferedData.resolve()},t.prototype.sendLoop=function(){return Q(this,void 0,void 0,(function(){var e,n,o;return z(this,(function(r){switch(r.label){case 0:return[4,this.sendBufferedData.promise];case 1:if(r.sent(),!this.executing)return this.transportResult&&this.transportResult.reject("Connection stopped."),[3,6];this.sendBufferedData=new nt,e=this.transportResult,this.transportResult=void 0,n="string"==typeof this.buffer[0]?this.buffer.join(""):t.concatBuffers(this.buffer),this.buffer.length=0,r.label=2;case 2:return r.trys.push([2,4,,5]),[4,this.transport.send(n)];case 3:return r.sent(),e.resolve(),[3,5];case 4:return o=r.sent(),e.reject(o),[3,5];case 5:return[3,0];case 6:return[2]}}))}))},t.concatBuffers=function(t){for(var e=t.map((function(t){return t.byteLength})).reduce((function(t,e){return t+e})),n=new Uint8Array(e),o=0,r=0,i=t;r<i.length;r++){var s=i[r];n.set(new Uint8Array(s),o),o+=s.byteLength}return n},t}(),nt=function(){function t(){var t=this;this.promise=new Promise((function(e,n){var o;return o=[e,n],t.resolver=o[0],t.rejecter=o[1],o}))}return t.prototype.resolve=function(){this.resolver()},t.prototype.reject=function(t){this.rejecter(t)},t}(),ot=function(){function t(){this.name="json",this.version=1,this.transferFormat=L.Text}return t.prototype.parseMessages=function(t,e){if("string"!=typeof t)throw new Error("Invalid input for JSON hub protocol. Expected a string.");if(!t)return[];null===e&&(e=p.instance);for(var n=[],o=0,i=x.parse(t);o<i.length;o++){var s=i[o],c=JSON.parse(s);if("number"!=typeof c.type)throw new Error("Invalid payload.");switch(c.type){case E.Invocation:this.isInvocationMessage(c);break;case E.StreamItem:this.isStreamItemMessage(c);break;case E.Completion:this.isCompletionMessage(c);break;case E.Ping:case E.Close:break;default:e.log(r.Information,"Unknown message type '"+c.type+"' ignored.");continue}n.push(c)}return n},t.prototype.writeMessage=function(t){return x.write(JSON.stringify(t))},t.prototype.isInvocationMessage=function(t){this.assertNotEmptyString(t.target,"Invalid payload for Invocation message."),void 0!==t.invocationId&&this.assertNotEmptyString(t.invocationId,"Invalid payload for Invocation message.")},t.prototype.isStreamItemMessage=function(t){if(this.assertNotEmptyString(t.invocationId,"Invalid payload for StreamItem message."),void 0===t.item)throw new Error("Invalid payload for StreamItem message.")},t.prototype.isCompletionMessage=function(t){if(t.result&&t.error)throw new Error("Invalid payload for Completion message.");!t.result&&t.error&&this.assertNotEmptyString(t.error,"Invalid payload for Completion message."),this.assertNotEmptyString(t.invocationId,"Invalid payload for Completion message.")},t.prototype.assertNotEmptyString=function(t,e){if("string"!=typeof t||""===t)throw new Error(e)},t}(),rt=Object.assign||function(t){for(var e,n=1,o=arguments.length;n<o;n++)for(var r in e=arguments[n])Object.prototype.hasOwnProperty.call(e,r)&&(t[r]=e[r]);return t},it={trace:r.Trace,debug:r.Debug,info:r.Information,information:r.Information,warn:r.Warning,warning:r.Warning,error:r.Error,critical:r.Critical,none:r.None},st=function(){function t(){}return t.prototype.configureLogging=function(t){if(f.isRequired(t,"logging"),void 0!==t.log)this.logger=t;else if("string"==typeof t){var e=function(t){var e=it[t.toLowerCase()];if(void 0!==e)return e;throw new Error("Unknown log level: "+t)}(t);this.logger=new w(e)}else this.logger=new w(t);return this},t.prototype.withUrl=function(t,e){return f.isRequired(t,"url"),this.url=t,this.httpConnectionOptions=rt({},this.httpConnectionOptions,"object"==typeof e?e:{transport:e}),this},t.prototype.withHubProtocol=function(t){return f.isRequired(t,"protocol"),this.protocol=t,this},t.prototype.withAutomaticReconnect=function(t){if(this.reconnectPolicy)throw new Error("A reconnectPolicy has already been set.");return t?Array.isArray(t)?this.reconnectPolicy=new q(t):this.reconnectPolicy=t:this.reconnectPolicy=new q,this},t.prototype.build=function(){var t=this.httpConnectionOptions||{};if(void 0===t.logger&&(t.logger=this.logger),!this.url)throw new Error("The 'HubConnectionBuilder.withUrl' method must be called before building the connection.");var e=new tt(this.url,t);return W.create(e,this.logger||p.instance,this.protocol||new ot,this.reconnectPolicy)},t}(),ct="3.1.25"},83608:function(t,e,n){var o=n(69877),r=n(16612),i=n(18601),s=parseFloat,c=Math.min,a=Math.random;t.exports=function(t,e,n){if(n&&"boolean"!=typeof n&&r(t,e,n)&&(e=n=void 0),void 0===n&&("boolean"==typeof e?(n=e,e=void 0):"boolean"==typeof t&&(n=t,t=void 0)),void 0===t&&void 0===e?(t=0,e=1):(t=i(t),void 0===e?(e=t,t=0):e=i(e)),t>e){var u=t;t=e,e=u}if(n||t%1||e%1){var l=a();return c(t+l*(e-t+s("1e-"+((l+"").length-1))),e)}return o(t,e)}}}]);