xrpl-client - npm Package Compare versions

Comparing version 1.1.2 to 1.1.3

dist/browser.min.js

		@@ -13,2 +13,2 @@ require=function e(t,n,r){function i(s,l){if(!n[s]){if(!t[s]){var u="function"==typeof require&&require;if(!l&&u)return u(s,!0);if(o)return o(s,!0);var a=new Error("Cannot find module '"+s+"'");throw a.code="MODULE_NOT_FOUND",a}var c=n[s]={exports:{}};t[s][0].call(c.exports,(function(e){return i(t[s][1][e]\|\|e)}),c,c.exports,e,t,n,r)}return n[s].exports}for(var o="function"==typeof require&&require,s=0;s<r.length;s++)i(r[s]);return i}({1:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0})},{}],2:[function(e,t,n){(function(n){(function(){"use strict";var r=e("object-assign");
		*/
		"use strict";var r=Object.getOwnPropertySymbols,i=Object.prototype.hasOwnProperty,o=Object.prototype.propertyIsEnumerable;function s(e){if(null==e)throw new TypeError("Object.assign cannot be called with null or undefined");return Object(e)}t.exports=function(){try{if(!Object.assign)return!1;var e=new String("abc");if(e[5]="de","5"===Object.getOwnPropertyNames(e)[0])return!1;for(var t={},n=0;n<10;n++)t["_"+String.fromCharCode(n)]=n;if("0123456789"!==Object.getOwnPropertyNames(t).map((function(e){return t[e]})).join(""))return!1;var r={};return"abcdefghijklmnopqrst".split("").forEach((function(e){r[e]=e})),"abcdefghijklmnopqrst"===Object.keys(Object.assign({},r)).join("")}catch(e){return!1}}()?Object.assign:function(e,t){for(var n,l,u=s(e),a=1;a<arguments.length;a++){for(var c in n=Object(arguments[a]))i.call(n,c)&&(u[c]=n[c]);if(r){l=r(n);for(var f=0;f<l.length;f++)o.call(n,l[f])&&(u[l[f]]=n[l[f]])}}return u}},{}],12:[function(e,t,n){var r,i,o=t.exports={};function s(){throw new Error("setTimeout has not been defined")}function l(){throw new Error("clearTimeout has not been defined")}function u(e){if(r===setTimeout)return setTimeout(e,0);if((r===s\|\|!r)&&setTimeout)return r=setTimeout,setTimeout(e,0);try{return r(e,0)}catch(t){try{return r.call(null,e,0)}catch(t){return r.call(this,e,0)}}}!function(){try{r="function"==typeof setTimeout?setTimeout:s}catch(e){r=s}try{i="function"==typeof clearTimeout?clearTimeout:l}catch(e){i=l}}();var a,c=[],f=!1,d=-1;function p(){f&&a&&(f=!1,a.length?c=a.concat(c):d=-1,c.length&&h())}function h(){if(!f){var e=u(p);f=!0;for(var t=c.length;t;){for(a=c,c=[];++d<t;)a&&a[d].run();d=-1,t=c.length}a=null,f=!1,function(e){if(i===clearTimeout)return clearTimeout(e);if((i===l\|\|!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 v(e,t){this.fun=e,this.array=t}function m(){}o.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];c.push(new v(e,t)),1!==c.length\|\|f\|\|u(h)},v.prototype.run=function(){this.fun.apply(null,this.array)},o.title="browser",o.browser=!0,o.env={},o.argv=[],o.version="",o.versions={},o.on=m,o.addListener=m,o.once=m,o.off=m,o.removeListener=m,o.removeAllListeners=m,o.emit=m,o.prependListener=m,o.prependOnceListener=m,o.listeners=function(e){return[]},o.binding=function(e){throw new Error("process.binding is not supported")},o.cwd=function(){return"/"},o.chdir=function(e){throw new Error("process.chdir is not supported")},o.umask=function(){return 0}},{}],13:[function(e,t,n){var r;if("object"==typeof globalThis)r=globalThis;else try{r=e("es5-ext/global")}catch(e){}finally{if(r\|\|"undefined"==typeof window\|\|(r=window),!r)throw new Error("Could not determine global this")}var i=r.WebSocket\|\|r.MozWebSocket,o=e("./version");function s(e,t){return t?new i(e,t):new i(e)}i&&["CONNECTING","OPEN","CLOSING","CLOSED"].forEach((function(e){Object.defineProperty(s,e,{get:function(){return i[e]}})})),t.exports={w3cwebsocket:i?s:null,version:o}},{"./version":14,"es5-ext/global":8}],14:[function(e,t,n){t.exports=e("../package.json").version},{"../package.json":15}],15:[function(e,t,n){t.exports={name:"websocket",description:"Websocket Client & Server Library implementing the WebSocket protocol as specified in RFC 6455.",keywords:["websocket","websockets","socket","networking","comet","push","RFC-6455","realtime","server","client"],author:"Brian McKelvey <theturtle32@gmail.com> (https://github.com/theturtle32)",contributors:["Iñaki Baz Castillo <ibc@aliax.net> (http://dev.sipdoc.net)"],version:"1.0.34",repository:{type:"git",url:"https://github.com/theturtle32/WebSocket-Node.git"},homepage:"https://github.com/theturtle32/WebSocket-Node",engines:{node:">=4.0.0"},dependencies:{bufferutil:"^4.0.1",debug:"^2.2.0","es5-ext":"^0.10.50","typedarray-to-buffer":"^3.1.5","utf-8-validate":"^5.0.2",yaeti:"^0.0.6"},devDependencies:{"buffer-equal":"^1.0.0",gulp:"^4.0.2","gulp-jshint":"^2.0.4","jshint-stylish":"^2.2.1",jshint:"^2.0.0",tape:"^4.9.1"},config:{verbose:!1},scripts:{test:"tape test/unit/.js",gulp:"gulp"},main:"index",directories:{lib:"./lib"},browser:"lib/browser.js",license:"Apache-2.0"}},{}],"xrpl-client":[function(e,t,n){"use strict";var r=this&&this.__createBinding\|\|(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),i=this&&this.__exportStar\|\|function(e,t){for(var n in e)"default"===n\|\|Object.prototype.hasOwnProperty.call(t,n)\|\|r(t,e,n)},o=this&&this.__awaiter\|\|function(e,t,n,r){return new(n\|\|(n=Promise))((function(i,o){function s(e){try{u(r.next(e))}catch(e){o(e)}}function l(e){try{u(r.throw(e))}catch(e){o(e)}}function u(e){var t;e.done?i(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(s,l)}u((r=r.apply(e,t\|\|[])).next())}))},s=this&&this.__importDefault\|\|function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(n,"__esModule",{value:!0}),n.XrplClient=void 0;const l=s(e("assert")),u=e("events"),a=e("debug"),c=e("websocket");i(e("./types"),n);const f=a.debug("xrplclient"),d=f.extend("warning"),p=f.extend("message"),h=f.extend("node");class v extends u.EventEmitter{constructor(e="wss://xrplcluster.com",t){let n;super(),this.connectBackoff=1e3/1.2,this.closed=!1,this.uplinkReady=!1,this.options={connectAttemptTimeoutSeconds:4,assumeOfflineAfterSeconds:20,maxConnectionAttempts:null},this.callId=0,this.pendingCalls=[],this.subscriptions=[],this.serverState={validatedLedgers:"",reserveBase:null,reserveInc:null,latency:[],fee:[],connectAttempts:0},t&&Object.assign(this.options,t);const r=()=>{var e;clearTimeout(n);const t=1e3Number((null===(e=null==this?void 0:this.options)\|\|void 0===e?void 0:e.assumeOfflineAfterSeconds)\|\|20);n=setTimeout((()=>{var e;d("----- CONNECTION TIMEOUT, NO LEDER INFO RECEIVED FOR ",t,"SECONDS -----");try{null===(e=this.connection)\|\|void 0===e\|\|e.close()}catch(e){}}),t)};r(),this.endpoint=e.trim(),f("Initialized xrpld WebSocket Client"),this.on("ledger",(()=>{i(),r()}));const i=()=>{this.uplinkReady\|\|(this.serverState.connectAttempts=0,h("Connection ready, fire events"),this.connectBackoff=1e3/1.2,this.uplinkReady=!0,this.emit("flush"),this.emit("state",this.getState()))},s=()=>{f("Connection opened :)"),this.send({id:"_WsClient_Internal_Subscription",command:"subscribe",streams:["ledger"]},{sendIfNotReady:!0,noReplayAfterReconnect:!0}),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"},{sendIfNotReady:!0,noReplayAfterReconnect:!0}).then((()=>{i()}))},u=e=>{var t;this.emit("close"),this.emit("state",this.getState()),this.connectBackoff=Math.min(Math.round(1.2this.connectBackoff),1e3Number((null===(t=this.options)\|\|void 0===t?void 0:t.connectAttemptTimeoutSeconds)\|\|4)),this.uplinkReady=!1,this.serverInfo=void 0,d("Upstream/Websocket closed",null==e?void 0:e.code,null==e?void 0:e.reason),O(),this.closed?f("Closed on purpose, not reconnecting"):(this.emit("retry"),d(`Not closed on purpose, reconnecting after ${this.connectBackoff}...`),setTimeout((()=>{this.emit("reconnect")}),this.connectBackoff))},a=e=>{var t,n;if(null===(t=null==e?void 0:e.result)\|\|void 0===t?void 0:t.info){const t=e;this.serverInfo\|\|h("Connected, server_info:",{pubkey_node:t.result.info.pubkey_node,build_version:t.result.info.build_version,complete_ledgers:t.result.info.complete_ledgers});const r=Number(new Date)-Number(String((null==e?void 0:e.id)\|\|"").split("@").reverse()[0]);r&&(this.serverState.latency.push({moment:new Date,value:r}),this.serverState.latency.splice(0,this.serverState.latency.length-10));const i=1.2,o=t.result.info.load_factorNumber(null===(n=t.result.info.validated_ledger)\|\|void 0===n?void 0:n.base_fee_xrp)1e6i;o&&(this.serverState.fee.push({moment:new Date,value:o}),this.serverState.fee.splice(0,this.serverState.fee.length-5)),this.serverInfo=t}},v=e=>{var t,n,r,i,o,s,l,u,a,c;if("_WsClient_Internal_Subscription"!==(null===(t=null==e?void 0:e.id)\|\|void 0===t?void 0:t._Request))if(this.emit("message",e),"ledgerClosed"===(null==e?void 0:e.type))p("Async",e.type),Object.assign(this.serverState,{validatedLedgers:null==e?void 0:e.validated_ledgers,reserveBase:Number(null==e?void 0:e.reserve_base)/1e6\|\|null,reserveInc:Number(null==e?void 0:e.reserve_inc)/1e6\|\|null}),this.emit("ledger",e),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"});else if("path_find"===(null==e?void 0:e.type))p("Async",e.type),this.emit("path",e);else if("transaction"===(null==e?void 0:e.type))p("Async",e.type),this.emit("transaction",e);else if(null==e?void 0:e.validation_public_key)p("Async","validation"),this.emit("validation",e);else{let t;if(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient){const n=this.subscriptions.filter((t=>{var n;return t.id===(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient)}));n.length>0&&(t=n[0])}if("path_find"===(null===(r=null==t?void 0:t.request)\|\|void 0===r?void 0:r.command))p("Async",null===(i=null==t?void 0:t.request)\|\|void 0===i?void 0:i.command),this.emit("path",e);else if("subscribe"===(null===(o=null==t?void 0:t.request)\|\|void 0===o?void 0:o.command)&&Array.isArray(null===(s=null==t?void 0:t.request)\|\|void 0===s?void 0:s.streams)&&(null===(l=null==t?void 0:t.request)\|\|void 0===l?void 0:l.streams.indexOf("ledger"))>-1)p("Async","subscription:ledger"),this.emit("ledger",e);else if(t)t.promiseCallables.resolve(Object.assign(e,{id:null===(u=null==e?void 0:e.id)\|\|void 0===u?void 0:u._Request}));else{(null===(a=null==e?void 0:e.id)\|\|void 0===a?void 0:a._Request)&&String(e.id._Request).match(/^_WsClient_Internal/)\|\|p("Handle <UNKNOWN> Async Message",{internalId:null===(c=null==e?void 0:e.id)\|\|void 0===c?void 0:c._WsClient,matchingSubscription:t,type:null==e?void 0:e.type,message:e})}}},m=e=>{var t,n,r,i,o,s;try{l.default("string"==typeof e.data,"Unexpected incoming WebSocket message data type");const u=JSON.parse(e.data);if(this.lastContact=new Date,null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient){const e=this.subscriptions.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)})),t=this.pendingCalls.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)}));if(1===e.length)v(u);else if(1===t.length){const e="_WsClient_Internal_ServerInfo"===String((null===(i=null===(r=null===(n=t[0])\|\|void 0===n?void 0:n.request)\|\|void 0===r?void 0:r.id)\|\|void 0===i?void 0:i._Request)\|\|"").split("@")[0];Object.assign(u,{id:null===(o=null==u?void 0:u.id)\|\|void 0===o?void 0:o._Request}),(null===(s=t[0].sendOptions)\|\|void 0===s?void 0:s.timeoutSeconds)&&t[0].timeout&&clearTimeout(t[0].timeout),t[0].promiseCallables.resolve((null==u?void 0:u.result)\|\|u),this.pendingCalls.splice(this.pendingCalls.indexOf(t[0]),1),e?a(u):f("» Pending Call Length",this.pendingCalls.length)}else v(u)}else v(u)}catch(e){d("Uplink response: parse error",e.message)}},g=e=>{d("Upstream/Websocket error")},y=e=>{var t;(null===(t=null==e?void 0:e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds)&&!(null==e?void 0:e.timeout)&&Object.assign(e,{timeout:setTimeout((()=>o(this,void 0,void 0,(function(){var t;"_WsClient_Internal_CallResolved"===(yield Promise.race([e.promise,Promise.resolve("_WsClient_Internal_CallResolved")]))&&e.promiseCallables.reject(new Error(`Call timeout after ${null===(t=e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds} seconds`))}))),1e3*Number(e.sendOptions.timeoutSeconds))})},b=e=>{var t,n,r;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(" > Process call",e.id,e.request.command);try{this.connection.send(JSON.stringify(e.request)),(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.timeoutStartsWhenOnline)&&(d("APPLY TIMEOUT ONLY AFTER GOING ONLINE"),y(e))}catch(e){d("Process (send to uplink) error",e.message)}},C=e=>{var t,n,r,i,o;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(`Call ${e.id}: ${e.request.command}\n > `,this.uplinkReady?"Uplink ready, pass immediately":(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.sendIfNotReady)?"Uplink not flagged as ready yet, but `sendIfNotReady` = true, so go ahead":"Uplink not ready, wait for flush"),(null===(i=null==e?void 0:e.sendOptions)\|\|void 0===i?void 0:i.timeoutStartsWhenOnline)\|\|(d("APPLY TIMEOUT NO MATTER ONLINE/OFFLINE STATE"),y(e)),(this.uplinkReady\|\|(null===(o=null==e?void 0:e.sendOptions)\|\|void 0===o?void 0:o.sendIfNotReady))&&b(e)},w=()=>{f("Connected, flushing pending calls & subscriptions"),this.pendingCalls.forEach((e=>{b(e)})),this.subscriptions.forEach((e=>{b(e)}))},_=e=>{this.closed=!0,f("Closing connection"),O();try{this.connection.close()}catch(e){}if(clearTimeout(n),this.subscriptions.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.pendingCalls.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.off("__WsClient_call",C),this.off("__WsClient_close",_),this.off("flush",w),this.off("reconnect",E),e)throw e},O=()=>{f("Cleanup"),this.connection.removeEventListener("open",s),this.connection.removeEventListener("message",m),this.connection.removeEventListener("error",g),this.connection.removeEventListener("close",u)},E=()=>{var e,t,n;try{this.connection.close()}catch(e){}f("Connecting",this.endpoint),this.serverState.connectAttempts++,this.options.maxConnectionAttempts&&Number((null===(e=this.options)\|\|void 0===e?void 0:e.maxConnectionAttempts)\|\|1)>1&&this.serverState.connectAttempts>Number((null===(t=this.options)\|\|void 0===t?void 0:t.maxConnectionAttempts)\|\|1)&&(h("Too many connection attempts",this.serverState.connectAttempts,null===(n=this.options)\|\|void 0===n?void 0:n.maxConnectionAttempts),_(new Error("Max. connection attempts exceeded")));const r=new c.w3cwebsocket(this.endpoint);return r.addEventListener("open",s),r.addEventListener("message",m),r.addEventListener("error",g),r.addEventListener("close",u),this.connection=r,r};this.on("__WsClient_call",C),this.on("__WsClient_close",_),this.on("flush",w),this.on("reconnect",E),this.connection=E(),setInterval((()=>{h("Connection Attempts",this.serverState.connectAttempts)}),4e3)}ready(){return new Promise(((e,t)=>{const n=this.getState();n.online&&n.secLastContact&&n.secLastContact<10&&n.ledger.last?e(this):this.on("ledger",(()=>{e(this)}))}))}send(e,t={}){var n,r,i;l.default("object"==typeof e&&e,"`send()`: expecting object containing `command`"),l.default("string"==typeof e.command,"`command` must be typeof string"),this.callId++;const o={resolve:e=>{},reject:e=>{}},s=new Promise(((e,t)=>{Object.assign(o,{resolve:e,reject:t})})),u={id:this.callId,request:Object.assign(e,{id:{_WsClient:this.callId,_Request:null==e?void 0:e.id},command:e.command.toLowerCase().trim()}),promise:s,promiseCallables:o,sendOptions:t};if(this.closed)return o.reject(new Error("Client in closed state")),s;const a=("subscribe"===u.request.command\|\|"unsubscribe"===u.request.command\|\|"path_find"===u.request.command)&&!(null==t?void 0:t.noReplayAfterReconnect);return"unsubscribe"===(null===(n=u.request)\|\|void 0===n?void 0:n.command)&&Array.isArray(null===(r=u.request)\|\|void 0===r?void 0:r.streams)&&(null===(i=u.request)\|\|void 0===i?void 0:i.streams.indexOf("ledger"))>-1&&(u.request.streams.splice(u.request.streams.indexOf("ledger"),1),0===u.request.streams.length&&0===Object.keys(u.request).filter((e=>"id"!==e&&"streams"!==e&&"command"!==e)).length)?Promise.reject(new Error("Unsubscribing from (just) the ledger stream is not allowed")):("_WsClient_Internal_ServerInfo"!==String((null==e?void 0:e.id)\|\|"").split("@")[0]&&this[a?"subscriptions":"pendingCalls"].push(u),this.emit("__WsClient_call",u),s)}getState(){var e,t,n,r,i,o,s,l,u;const a=this.serverState.validatedLedgers.split(",").map((e=>{const t=e.split("-");return t.length>1?parseInt(t[1])-parseInt(t[0]):1})).reduce(((e,t)=>e+t),0);return{online:this.uplinkReady&&!this.closed&&this.connection.readyState===c.w3cwebsocket.OPEN,latencyMs:{last:this.serverState.latency.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.latency.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.latency.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.latency.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},server:{version:(null===(n=null===(t=null===(e=this.serverInfo)\|\|void 0===e?void 0:e.result)\|\|void 0===t?void 0:t.info)\|\|void 0===n?void 0:n.build_version)\|\|"",uptime:(null===(o=null===(i=null===(r=this.serverInfo)\|\|void 0===r?void 0:r.result)\|\|void 0===i?void 0:i.info)\|\|void 0===o?void 0:o.uptime)\|\|0,publicKey:(null===(u=null===(l=null===(s=this.serverInfo)\|\|void 0===s?void 0:s.result)\|\|void 0===l?void 0:l.info)\|\|void 0===u?void 0:u.pubkey_node)\|\|"",uri:this.endpoint},ledger:{last:Number(this.serverState.validatedLedgers.split(",").reverse()[0].split("-").reverse()[0]),validated:this.serverState.validatedLedgers,count:""===this.serverState.validatedLedgers?0:a},fee:{last:this.serverState.fee.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.fee.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.fee.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.fee.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},reserve:{base:this.serverState.reserveBase,owner:this.serverState.reserveInc},secLastContact:this.lastContact?Number(new Date)/1e3-Number(this.lastContact)/1e3:null}}close(){l.default(!this.closed,"Object already in closed state"),this.emit("__WsClient_close")}}n.XrplClient=v},{"./types":1,assert:2,debug:6,events:9,websocket:13}]},{},[]);
		"use strict";var r=Object.getOwnPropertySymbols,i=Object.prototype.hasOwnProperty,o=Object.prototype.propertyIsEnumerable;function s(e){if(null==e)throw new TypeError("Object.assign cannot be called with null or undefined");return Object(e)}t.exports=function(){try{if(!Object.assign)return!1;var e=new String("abc");if(e[5]="de","5"===Object.getOwnPropertyNames(e)[0])return!1;for(var t={},n=0;n<10;n++)t["_"+String.fromCharCode(n)]=n;if("0123456789"!==Object.getOwnPropertyNames(t).map((function(e){return t[e]})).join(""))return!1;var r={};return"abcdefghijklmnopqrst".split("").forEach((function(e){r[e]=e})),"abcdefghijklmnopqrst"===Object.keys(Object.assign({},r)).join("")}catch(e){return!1}}()?Object.assign:function(e,t){for(var n,l,u=s(e),a=1;a<arguments.length;a++){for(var c in n=Object(arguments[a]))i.call(n,c)&&(u[c]=n[c]);if(r){l=r(n);for(var f=0;f<l.length;f++)o.call(n,l[f])&&(u[l[f]]=n[l[f]])}}return u}},{}],12:[function(e,t,n){var r,i,o=t.exports={};function s(){throw new Error("setTimeout has not been defined")}function l(){throw new Error("clearTimeout has not been defined")}function u(e){if(r===setTimeout)return setTimeout(e,0);if((r===s\|\|!r)&&setTimeout)return r=setTimeout,setTimeout(e,0);try{return r(e,0)}catch(t){try{return r.call(null,e,0)}catch(t){return r.call(this,e,0)}}}!function(){try{r="function"==typeof setTimeout?setTimeout:s}catch(e){r=s}try{i="function"==typeof clearTimeout?clearTimeout:l}catch(e){i=l}}();var a,c=[],f=!1,d=-1;function p(){f&&a&&(f=!1,a.length?c=a.concat(c):d=-1,c.length&&h())}function h(){if(!f){var e=u(p);f=!0;for(var t=c.length;t;){for(a=c,c=[];++d<t;)a&&a[d].run();d=-1,t=c.length}a=null,f=!1,function(e){if(i===clearTimeout)return clearTimeout(e);if((i===l\|\|!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 v(e,t){this.fun=e,this.array=t}function m(){}o.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];c.push(new v(e,t)),1!==c.length\|\|f\|\|u(h)},v.prototype.run=function(){this.fun.apply(null,this.array)},o.title="browser",o.browser=!0,o.env={},o.argv=[],o.version="",o.versions={},o.on=m,o.addListener=m,o.once=m,o.off=m,o.removeListener=m,o.removeAllListeners=m,o.emit=m,o.prependListener=m,o.prependOnceListener=m,o.listeners=function(e){return[]},o.binding=function(e){throw new Error("process.binding is not supported")},o.cwd=function(){return"/"},o.chdir=function(e){throw new Error("process.chdir is not supported")},o.umask=function(){return 0}},{}],13:[function(e,t,n){var r;if("object"==typeof globalThis)r=globalThis;else try{r=e("es5-ext/global")}catch(e){}finally{if(r\|\|"undefined"==typeof window\|\|(r=window),!r)throw new Error("Could not determine global this")}var i=r.WebSocket\|\|r.MozWebSocket,o=e("./version");function s(e,t){return t?new i(e,t):new i(e)}i&&["CONNECTING","OPEN","CLOSING","CLOSED"].forEach((function(e){Object.defineProperty(s,e,{get:function(){return i[e]}})})),t.exports={w3cwebsocket:i?s:null,version:o}},{"./version":14,"es5-ext/global":8}],14:[function(e,t,n){t.exports=e("../package.json").version},{"../package.json":15}],15:[function(e,t,n){t.exports={name:"websocket",description:"Websocket Client & Server Library implementing the WebSocket protocol as specified in RFC 6455.",keywords:["websocket","websockets","socket","networking","comet","push","RFC-6455","realtime","server","client"],author:"Brian McKelvey <theturtle32@gmail.com> (https://github.com/theturtle32)",contributors:["Iñaki Baz Castillo <ibc@aliax.net> (http://dev.sipdoc.net)"],version:"1.0.34",repository:{type:"git",url:"https://github.com/theturtle32/WebSocket-Node.git"},homepage:"https://github.com/theturtle32/WebSocket-Node",engines:{node:">=4.0.0"},dependencies:{bufferutil:"^4.0.1",debug:"^2.2.0","es5-ext":"^0.10.50","typedarray-to-buffer":"^3.1.5","utf-8-validate":"^5.0.2",yaeti:"^0.0.6"},devDependencies:{"buffer-equal":"^1.0.0",gulp:"^4.0.2","gulp-jshint":"^2.0.4","jshint-stylish":"^2.2.1",jshint:"^2.0.0",tape:"^4.9.1"},config:{verbose:!1},scripts:{test:"tape test/unit/.js",gulp:"gulp"},main:"index",directories:{lib:"./lib"},browser:"lib/browser.js",license:"Apache-2.0"}},{}],"xrpl-client":[function(e,t,n){"use strict";var r=this&&this.__createBinding\|\|(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),i=this&&this.__exportStar\|\|function(e,t){for(var n in e)"default"===n\|\|Object.prototype.hasOwnProperty.call(t,n)\|\|r(t,e,n)},o=this&&this.__awaiter\|\|function(e,t,n,r){return new(n\|\|(n=Promise))((function(i,o){function s(e){try{u(r.next(e))}catch(e){o(e)}}function l(e){try{u(r.throw(e))}catch(e){o(e)}}function u(e){var t;e.done?i(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(s,l)}u((r=r.apply(e,t\|\|[])).next())}))},s=this&&this.__importDefault\|\|function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(n,"__esModule",{value:!0}),n.XrplClient=void 0;const l=s(e("assert")),u=e("events"),a=e("debug"),c=e("websocket");i(e("./types"),n);const f=a.debug("xrplclient"),d=f.extend("warning"),p=f.extend("message"),h=f.extend("node");class v extends u.EventEmitter{constructor(e="wss://xrplcluster.com",t){let n;super(),this.connectBackoff=1e3/1.2,this.closed=!1,this.uplinkReady=!1,this.options={connectAttemptTimeoutSeconds:4,assumeOfflineAfterSeconds:20,maxConnectionAttempts:null},this.callId=0,this.pendingCalls=[],this.subscriptions=[],this.serverState={validatedLedgers:"",reserveBase:null,reserveInc:null,latency:[],fee:[],connectAttempts:0},t&&Object.assign(this.options,t);const r=()=>{var e;clearTimeout(n);const t=1e3Number((null===(e=null==this?void 0:this.options)\|\|void 0===e?void 0:e.assumeOfflineAfterSeconds)\|\|20);n=setTimeout((()=>{var e;d("----- CONNECTION TIMEOUT, NO LEDER INFO RECEIVED FOR ",t,"SECONDS -----");try{null===(e=this.connection)\|\|void 0===e\|\|e.close()}catch(e){}}),t)};r(),this.endpoint=e.trim(),f("Initialized xrpld WebSocket Client"),this.on("ledger",(()=>{i(),r()}));const i=()=>{this.uplinkReady\|\|(this.serverState.connectAttempts=0,h("Connection ready, fire events"),this.connectBackoff=1e3/1.2,this.uplinkReady=!0,this.emit("flush"),this.emit("state",this.getState()))},s=()=>{f("Connection opened :)"),this.send({id:"_WsClient_Internal_Subscription",command:"subscribe",streams:["ledger"]},{sendIfNotReady:!0,noReplayAfterReconnect:!0}),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"},{sendIfNotReady:!0,noReplayAfterReconnect:!0}).then((()=>{i()}))},u=e=>{var t;this.emit("close"),this.emit("state",this.getState()),this.connectBackoff=Math.min(Math.round(1.2this.connectBackoff),1e3Number((null===(t=this.options)\|\|void 0===t?void 0:t.connectAttemptTimeoutSeconds)\|\|4)),this.uplinkReady=!1,this.serverInfo=void 0,d("Upstream/Websocket closed",null==e?void 0:e.code,null==e?void 0:e.reason),O(),this.closed?f("Closed on purpose, not reconnecting"):(this.emit("retry"),d(`Not closed on purpose, reconnecting after ${this.connectBackoff}...`),setTimeout((()=>{this.emit("reconnect")}),this.connectBackoff))},a=e=>{var t,n;if(null===(t=null==e?void 0:e.result)\|\|void 0===t?void 0:t.info){const t=e;this.serverInfo\|\|h("Connected, server_info:",{pubkey_node:t.result.info.pubkey_node,build_version:t.result.info.build_version,complete_ledgers:t.result.info.complete_ledgers});const r=Number(new Date)-Number(String((null==e?void 0:e.id)\|\|"").split("@").reverse()[0]);r&&(this.serverState.latency.push({moment:new Date,value:r}),this.serverState.latency.splice(0,this.serverState.latency.length-10));const i=1.2,o=t.result.info.load_factorNumber(null===(n=t.result.info.validated_ledger)\|\|void 0===n?void 0:n.base_fee_xrp)1e6i;o&&(this.serverState.fee.push({moment:new Date,value:o}),this.serverState.fee.splice(0,this.serverState.fee.length-5)),this.serverInfo=t}},v=e=>{var t,n,r,i,o,s,l,u,a,c;if("_WsClient_Internal_Subscription"!==(null===(t=null==e?void 0:e.id)\|\|void 0===t?void 0:t._Request))if(this.emit("message",e),"ledgerClosed"===(null==e?void 0:e.type))p("Async",e.type),Object.assign(this.serverState,{validatedLedgers:null==e?void 0:e.validated_ledgers,reserveBase:Number(null==e?void 0:e.reserve_base)/1e6\|\|null,reserveInc:Number(null==e?void 0:e.reserve_inc)/1e6\|\|null}),this.emit("ledger",e),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"});else if("path_find"===(null==e?void 0:e.type))p("Async",e.type),this.emit("path",e);else if("transaction"===(null==e?void 0:e.type))p("Async",e.type),this.emit("transaction",e);else if(null==e?void 0:e.validation_public_key)p("Async","validation"),this.emit("validation",e);else{let t;if(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient){const n=this.subscriptions.filter((t=>{var n;return t.id===(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient)}));n.length>0&&(t=n[0])}if("path_find"===(null===(r=null==t?void 0:t.request)\|\|void 0===r?void 0:r.command))p("Async",null===(i=null==t?void 0:t.request)\|\|void 0===i?void 0:i.command),this.emit("path",e);else if("subscribe"===(null===(o=null==t?void 0:t.request)\|\|void 0===o?void 0:o.command)&&Array.isArray(null===(s=null==t?void 0:t.request)\|\|void 0===s?void 0:s.streams)&&(null===(l=null==t?void 0:t.request)\|\|void 0===l?void 0:l.streams.indexOf("ledger"))>-1)p("Async","subscription:ledger"),this.emit("ledger",e);else if(t)t.promiseCallables.resolve(Object.assign(e,{id:null===(u=null==e?void 0:e.id)\|\|void 0===u?void 0:u._Request}));else{(null===(a=null==e?void 0:e.id)\|\|void 0===a?void 0:a._Request)&&String(e.id._Request).match(/^_WsClient_Internal/)\|\|p("Handle <UNKNOWN> Async Message",{internalId:null===(c=null==e?void 0:e.id)\|\|void 0===c?void 0:c._WsClient,matchingSubscription:t,type:null==e?void 0:e.type,message:e})}}},m=e=>{var t,n,r,i,o,s;try{l.default("string"==typeof e.data,"Unexpected incoming WebSocket message data type");const u=JSON.parse(e.data);if(this.lastContact=new Date,null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient){const e=this.subscriptions.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)})),t=this.pendingCalls.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)}));if(1===e.length)v(u);else if(1===t.length){const e="_WsClient_Internal_ServerInfo"===String((null===(i=null===(r=null===(n=t[0])\|\|void 0===n?void 0:n.request)\|\|void 0===r?void 0:r.id)\|\|void 0===i?void 0:i._Request)\|\|"").split("@")[0];Object.assign(u,{id:null===(o=null==u?void 0:u.id)\|\|void 0===o?void 0:o._Request}),(null===(s=t[0].sendOptions)\|\|void 0===s?void 0:s.timeoutSeconds)&&t[0].timeout&&clearTimeout(t[0].timeout),t[0].promiseCallables.resolve((null==u?void 0:u.result)\|\|u),this.pendingCalls.splice(this.pendingCalls.indexOf(t[0]),1),e?a(u):f("» Pending Call Length",this.pendingCalls.length)}else v(u)}else v(u)}catch(e){d("Uplink response: parse error",e.message)}},g=e=>{d("Upstream/Websocket error")},y=e=>{var t;(null===(t=null==e?void 0:e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds)&&!(null==e?void 0:e.timeout)&&Object.assign(e,{timeout:setTimeout((()=>o(this,void 0,void 0,(function(){var t;"_WsClient_Internal_CallResolved"===(yield Promise.race([e.promise,Promise.resolve("_WsClient_Internal_CallResolved")]))&&e.promiseCallables.reject(new Error(`Call timeout after ${null===(t=e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds} seconds`))}))),1e3Number(e.sendOptions.timeoutSeconds))})},b=e=>{var t,n,r;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(" > Process call",e.id,e.request.command);try{this.connection.send(JSON.stringify(e.request)),(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.timeoutStartsWhenOnline)&&(d("APPLY TIMEOUT ONLY AFTER GOING ONLINE"),y(e))}catch(e){d("Process (send to uplink) error",e.message)}},C=e=>{var t,n,r,i,o;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(`Call ${e.id}: ${e.request.command}\n > `,this.uplinkReady?"Uplink ready, pass immediately":(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.sendIfNotReady)?"Uplink not flagged as ready yet, but `sendIfNotReady` = true, so go ahead":"Uplink not ready, wait for flush"),(null===(i=null==e?void 0:e.sendOptions)\|\|void 0===i?void 0:i.timeoutStartsWhenOnline)\|\|(d("APPLY TIMEOUT NO MATTER ONLINE/OFFLINE STATE"),y(e)),(this.uplinkReady\|\|(null===(o=null==e?void 0:e.sendOptions)\|\|void 0===o?void 0:o.sendIfNotReady))&&b(e)},w=()=>{f("Connected, flushing pending calls & subscriptions"),this.pendingCalls.forEach((e=>{b(e)})),this.subscriptions.forEach((e=>{b(e)}))},_=e=>{this.closed=!0,f("Closing connection"),O();try{this.connection.close()}catch(e){}if(clearTimeout(n),this.subscriptions.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.pendingCalls.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.off("__WsClient_call",C),this.off("__WsClient_close",_),this.off("flush",w),this.off("reconnect",E),e)throw e},O=()=>{f("Cleanup"),this.connection.removeEventListener("open",s),this.connection.removeEventListener("message",m),this.connection.removeEventListener("error",g),this.connection.removeEventListener("close",u)},E=()=>{var e,t,n;try{this.connection.close()}catch(e){}f("Connecting",this.endpoint),this.serverState.connectAttempts++,this.options.maxConnectionAttempts&&Number((null===(e=this.options)\|\|void 0===e?void 0:e.maxConnectionAttempts)\|\|1)>1&&this.serverState.connectAttempts>Number((null===(t=this.options)\|\|void 0===t?void 0:t.maxConnectionAttempts)\|\|1)&&(h("Too many connection attempts",this.serverState.connectAttempts,null===(n=this.options)\|\|void 0===n?void 0:n.maxConnectionAttempts),_(new Error("Max. connection attempts exceeded")));const r=new c.w3cwebsocket(this.endpoint);return setTimeout((()=>{r.readyState!==c.w3cwebsocket.OPEN&&r.close()}),1.2this.connectBackoff-1),r.addEventListener("open",s),r.addEventListener("message",m),r.addEventListener("error",g),r.addEventListener("close",u),this.connection=r,r};this.on("__WsClient_call",C),this.on("__WsClient_close",_),this.on("flush",w),this.on("reconnect",E),this.connection=E()}ready(){return new Promise(((e,t)=>{const n=this.getState();n.online&&n.secLastContact&&n.secLastContact<10&&n.ledger.last?e(this):this.on("ledger",(()=>{e(this)}))}))}send(e,t={}){var n,r,i;l.default("object"==typeof e&&e,"`send()`: expecting object containing `command`"),l.default("string"==typeof e.command,"`command` must be typeof string"),this.callId++;const o={resolve:e=>{},reject:e=>{}},s=new Promise(((e,t)=>{Object.assign(o,{resolve:e,reject:t})})),u={id:this.callId,request:Object.assign(e,{id:{_WsClient:this.callId,_Request:null==e?void 0:e.id},command:e.command.toLowerCase().trim()}),promise:s,promiseCallables:o,sendOptions:t};if(this.closed)return o.reject(new Error("Client in closed state")),s;const a=("subscribe"===u.request.command\|\|"unsubscribe"===u.request.command\|\|"path_find"===u.request.command)&&!(null==t?void 0:t.noReplayAfterReconnect);return"unsubscribe"===(null===(n=u.request)\|\|void 0===n?void 0:n.command)&&Array.isArray(null===(r=u.request)\|\|void 0===r?void 0:r.streams)&&(null===(i=u.request)\|\|void 0===i?void 0:i.streams.indexOf("ledger"))>-1&&(u.request.streams.splice(u.request.streams.indexOf("ledger"),1),0===u.request.streams.length&&0===Object.keys(u.request).filter((e=>"id"!==e&&"streams"!==e&&"command"!==e)).length)?Promise.reject(new Error("Unsubscribing from (just) the ledger stream is not allowed")):("_WsClient_Internal_ServerInfo"!==String((null==e?void 0:e.id)\|\|"").split("@")[0]&&this[a?"subscriptions":"pendingCalls"].push(u),this.emit("__WsClient_call",u),s)}getState(){var e,t,n,r,i,o,s,l,u;const a=this.serverState.validatedLedgers.split(",").map((e=>{const t=e.split("-");return t.length>1?parseInt(t[1])-parseInt(t[0]):1})).reduce(((e,t)=>e+t),0);return{online:this.uplinkReady&&!this.closed&&this.connection.readyState===c.w3cwebsocket.OPEN,latencyMs:{last:this.serverState.latency.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.latency.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.latency.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.latency.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},server:{version:(null===(n=null===(t=null===(e=this.serverInfo)\|\|void 0===e?void 0:e.result)\|\|void 0===t?void 0:t.info)\|\|void 0===n?void 0:n.build_version)\|\|"",uptime:(null===(o=null===(i=null===(r=this.serverInfo)\|\|void 0===r?void 0:r.result)\|\|void 0===i?void 0:i.info)\|\|void 0===o?void 0:o.uptime)\|\|0,publicKey:(null===(u=null===(l=null===(s=this.serverInfo)\|\|void 0===s?void 0:s.result)\|\|void 0===l?void 0:l.info)\|\|void 0===u?void 0:u.pubkey_node)\|\|"",uri:this.endpoint},ledger:{last:Number(this.serverState.validatedLedgers.split(",").reverse()[0].split("-").reverse()[0]),validated:this.serverState.validatedLedgers,count:""===this.serverState.validatedLedgers?0:a},fee:{last:this.serverState.fee.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.fee.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.fee.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.fee.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},reserve:{base:this.serverState.reserveBase,owner:this.serverState.reserveInc},secLastContact:this.lastContact?Number(new Date)/1e3-Number(this.lastContact)/1e3:null}}close(){l.default(!this.closed,"Object already in closed state"),this.emit("__WsClient_close")}}n.XrplClient=v},{"./types":1,assert:2,debug:6,events:9,websocket:13}]},{},[]);

dist/src/index.js

		@@ -428,2 +428,9 @@ "use strict";
		const connection = new websocket_1.w3cwebsocket(this.endpoint);
		// Prevent possible DNS resolve hang, and a custom
		// resolver sucks
		setTimeout(() => {
		if (connection.readyState !== websocket_1.w3cwebsocket.OPEN) {
		connection.close();
		}
		}, this.connectBackoff * 1.2 - 1);
		connection.addEventListener("open", WsOpen);
		@@ -443,5 +450,5 @@ connection.addEventListener("message", WsMessage);
		// }, 2000);
		setInterval(() => {
		logNodeInfo("Connection Attempts", this.serverState.connectAttempts);
		}, 4000);
		// setInterval(() => {
		// logNodeInfo("Connection Attempts", this.serverState.connectAttempts);
		// }, 4000);
		}
		@@ -448,0 +455,0 @@ ready() {

package.json

		{
		"name": "xrpl-client",
		"version": "1.1.2",
		"version": "1.1.3",
		"description": "Connect to the XRP Ledger using websockets",
		@@ -5,0 +5,0 @@ "main": "dist/src/index.js",

dist/browser.js

Sorry, the diff of this file is too big to display

		@@ -13,2 +13,2 @@ require=function e(t,n,r){function i(s,l){if(!n[s]){if(!t[s]){var u="function"==typeof require&&require;if(!l&&u)return u(s,!0);if(o)return o(s,!0);var a=new Error("Cannot find module '"+s+"'");throw a.code="MODULE_NOT_FOUND",a}var c=n[s]={exports:{}};t[s][0].call(c.exports,(function(e){return i(t[s][1][e]\|\|e)}),c,c.exports,e,t,n,r)}return n[s].exports}for(var o="function"==typeof require&&require,s=0;s<r.length;s++)i(r[s]);return i}({1:[function(e,t,n){"use strict";Object.defineProperty(n,"__esModule",{value:!0})},{}],2:[function(e,t,n){(function(n){(function(){"use strict";var r=e("object-assign");
		*/
		"use strict";var r=Object.getOwnPropertySymbols,i=Object.prototype.hasOwnProperty,o=Object.prototype.propertyIsEnumerable;function s(e){if(null==e)throw new TypeError("Object.assign cannot be called with null or undefined");return Object(e)}t.exports=function(){try{if(!Object.assign)return!1;var e=new String("abc");if(e[5]="de","5"===Object.getOwnPropertyNames(e)[0])return!1;for(var t={},n=0;n<10;n++)t["_"+String.fromCharCode(n)]=n;if("0123456789"!==Object.getOwnPropertyNames(t).map((function(e){return t[e]})).join(""))return!1;var r={};return"abcdefghijklmnopqrst".split("").forEach((function(e){r[e]=e})),"abcdefghijklmnopqrst"===Object.keys(Object.assign({},r)).join("")}catch(e){return!1}}()?Object.assign:function(e,t){for(var n,l,u=s(e),a=1;a<arguments.length;a++){for(var c in n=Object(arguments[a]))i.call(n,c)&&(u[c]=n[c]);if(r){l=r(n);for(var f=0;f<l.length;f++)o.call(n,l[f])&&(u[l[f]]=n[l[f]])}}return u}},{}],12:[function(e,t,n){var r,i,o=t.exports={};function s(){throw new Error("setTimeout has not been defined")}function l(){throw new Error("clearTimeout has not been defined")}function u(e){if(r===setTimeout)return setTimeout(e,0);if((r===s\|\|!r)&&setTimeout)return r=setTimeout,setTimeout(e,0);try{return r(e,0)}catch(t){try{return r.call(null,e,0)}catch(t){return r.call(this,e,0)}}}!function(){try{r="function"==typeof setTimeout?setTimeout:s}catch(e){r=s}try{i="function"==typeof clearTimeout?clearTimeout:l}catch(e){i=l}}();var a,c=[],f=!1,d=-1;function p(){f&&a&&(f=!1,a.length?c=a.concat(c):d=-1,c.length&&h())}function h(){if(!f){var e=u(p);f=!0;for(var t=c.length;t;){for(a=c,c=[];++d<t;)a&&a[d].run();d=-1,t=c.length}a=null,f=!1,function(e){if(i===clearTimeout)return clearTimeout(e);if((i===l\|\|!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 v(e,t){this.fun=e,this.array=t}function m(){}o.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];c.push(new v(e,t)),1!==c.length\|\|f\|\|u(h)},v.prototype.run=function(){this.fun.apply(null,this.array)},o.title="browser",o.browser=!0,o.env={},o.argv=[],o.version="",o.versions={},o.on=m,o.addListener=m,o.once=m,o.off=m,o.removeListener=m,o.removeAllListeners=m,o.emit=m,o.prependListener=m,o.prependOnceListener=m,o.listeners=function(e){return[]},o.binding=function(e){throw new Error("process.binding is not supported")},o.cwd=function(){return"/"},o.chdir=function(e){throw new Error("process.chdir is not supported")},o.umask=function(){return 0}},{}],13:[function(e,t,n){var r;if("object"==typeof globalThis)r=globalThis;else try{r=e("es5-ext/global")}catch(e){}finally{if(r\|\|"undefined"==typeof window\|\|(r=window),!r)throw new Error("Could not determine global this")}var i=r.WebSocket\|\|r.MozWebSocket,o=e("./version");function s(e,t){return t?new i(e,t):new i(e)}i&&["CONNECTING","OPEN","CLOSING","CLOSED"].forEach((function(e){Object.defineProperty(s,e,{get:function(){return i[e]}})})),t.exports={w3cwebsocket:i?s:null,version:o}},{"./version":14,"es5-ext/global":8}],14:[function(e,t,n){t.exports=e("../package.json").version},{"../package.json":15}],15:[function(e,t,n){t.exports={name:"websocket",description:"Websocket Client & Server Library implementing the WebSocket protocol as specified in RFC 6455.",keywords:["websocket","websockets","socket","networking","comet","push","RFC-6455","realtime","server","client"],author:"Brian McKelvey <theturtle32@gmail.com> (https://github.com/theturtle32)",contributors:["Iñaki Baz Castillo <ibc@aliax.net> (http://dev.sipdoc.net)"],version:"1.0.34",repository:{type:"git",url:"https://github.com/theturtle32/WebSocket-Node.git"},homepage:"https://github.com/theturtle32/WebSocket-Node",engines:{node:">=4.0.0"},dependencies:{bufferutil:"^4.0.1",debug:"^2.2.0","es5-ext":"^0.10.50","typedarray-to-buffer":"^3.1.5","utf-8-validate":"^5.0.2",yaeti:"^0.0.6"},devDependencies:{"buffer-equal":"^1.0.0",gulp:"^4.0.2","gulp-jshint":"^2.0.4","jshint-stylish":"^2.2.1",jshint:"^2.0.0",tape:"^4.9.1"},config:{verbose:!1},scripts:{test:"tape test/unit/.js",gulp:"gulp"},main:"index",directories:{lib:"./lib"},browser:"lib/browser.js",license:"Apache-2.0"}},{}],"xrpl-client":[function(e,t,n){"use strict";var r=this&&this.__createBinding\|\|(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),i=this&&this.__exportStar\|\|function(e,t){for(var n in e)"default"===n\|\|Object.prototype.hasOwnProperty.call(t,n)\|\|r(t,e,n)},o=this&&this.__awaiter\|\|function(e,t,n,r){return new(n\|\|(n=Promise))((function(i,o){function s(e){try{u(r.next(e))}catch(e){o(e)}}function l(e){try{u(r.throw(e))}catch(e){o(e)}}function u(e){var t;e.done?i(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(s,l)}u((r=r.apply(e,t\|\|[])).next())}))},s=this&&this.__importDefault\|\|function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(n,"__esModule",{value:!0}),n.XrplClient=void 0;const l=s(e("assert")),u=e("events"),a=e("debug"),c=e("websocket");i(e("./types"),n);const f=a.debug("xrplclient"),d=f.extend("warning"),p=f.extend("message"),h=f.extend("node");class v extends u.EventEmitter{constructor(e="wss://xrplcluster.com",t){let n;super(),this.connectBackoff=1e3/1.2,this.closed=!1,this.uplinkReady=!1,this.options={connectAttemptTimeoutSeconds:4,assumeOfflineAfterSeconds:20,maxConnectionAttempts:null},this.callId=0,this.pendingCalls=[],this.subscriptions=[],this.serverState={validatedLedgers:"",reserveBase:null,reserveInc:null,latency:[],fee:[],connectAttempts:0},t&&Object.assign(this.options,t);const r=()=>{var e;clearTimeout(n);const t=1e3Number((null===(e=null==this?void 0:this.options)\|\|void 0===e?void 0:e.assumeOfflineAfterSeconds)\|\|20);n=setTimeout((()=>{var e;d("----- CONNECTION TIMEOUT, NO LEDER INFO RECEIVED FOR ",t,"SECONDS -----");try{null===(e=this.connection)\|\|void 0===e\|\|e.close()}catch(e){}}),t)};r(),this.endpoint=e.trim(),f("Initialized xrpld WebSocket Client"),this.on("ledger",(()=>{i(),r()}));const i=()=>{this.uplinkReady\|\|(this.serverState.connectAttempts=0,h("Connection ready, fire events"),this.connectBackoff=1e3/1.2,this.uplinkReady=!0,this.emit("flush"),this.emit("state",this.getState()))},s=()=>{f("Connection opened :)"),this.send({id:"_WsClient_Internal_Subscription",command:"subscribe",streams:["ledger"]},{sendIfNotReady:!0,noReplayAfterReconnect:!0}),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"},{sendIfNotReady:!0,noReplayAfterReconnect:!0}).then((()=>{i()}))},u=e=>{var t;this.emit("close"),this.emit("state",this.getState()),this.connectBackoff=Math.min(Math.round(1.2this.connectBackoff),1e3Number((null===(t=this.options)\|\|void 0===t?void 0:t.connectAttemptTimeoutSeconds)\|\|4)),this.uplinkReady=!1,this.serverInfo=void 0,d("Upstream/Websocket closed",null==e?void 0:e.code,null==e?void 0:e.reason),O(),this.closed?f("Closed on purpose, not reconnecting"):(this.emit("retry"),d(`Not closed on purpose, reconnecting after ${this.connectBackoff}...`),setTimeout((()=>{this.emit("reconnect")}),this.connectBackoff))},a=e=>{var t,n;if(null===(t=null==e?void 0:e.result)\|\|void 0===t?void 0:t.info){const t=e;this.serverInfo\|\|h("Connected, server_info:",{pubkey_node:t.result.info.pubkey_node,build_version:t.result.info.build_version,complete_ledgers:t.result.info.complete_ledgers});const r=Number(new Date)-Number(String((null==e?void 0:e.id)\|\|"").split("@").reverse()[0]);r&&(this.serverState.latency.push({moment:new Date,value:r}),this.serverState.latency.splice(0,this.serverState.latency.length-10));const i=1.2,o=t.result.info.load_factorNumber(null===(n=t.result.info.validated_ledger)\|\|void 0===n?void 0:n.base_fee_xrp)1e6i;o&&(this.serverState.fee.push({moment:new Date,value:o}),this.serverState.fee.splice(0,this.serverState.fee.length-5)),this.serverInfo=t}},v=e=>{var t,n,r,i,o,s,l,u,a,c;if("_WsClient_Internal_Subscription"!==(null===(t=null==e?void 0:e.id)\|\|void 0===t?void 0:t._Request))if(this.emit("message",e),"ledgerClosed"===(null==e?void 0:e.type))p("Async",e.type),Object.assign(this.serverState,{validatedLedgers:null==e?void 0:e.validated_ledgers,reserveBase:Number(null==e?void 0:e.reserve_base)/1e6\|\|null,reserveInc:Number(null==e?void 0:e.reserve_inc)/1e6\|\|null}),this.emit("ledger",e),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"});else if("path_find"===(null==e?void 0:e.type))p("Async",e.type),this.emit("path",e);else if("transaction"===(null==e?void 0:e.type))p("Async",e.type),this.emit("transaction",e);else if(null==e?void 0:e.validation_public_key)p("Async","validation"),this.emit("validation",e);else{let t;if(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient){const n=this.subscriptions.filter((t=>{var n;return t.id===(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient)}));n.length>0&&(t=n[0])}if("path_find"===(null===(r=null==t?void 0:t.request)\|\|void 0===r?void 0:r.command))p("Async",null===(i=null==t?void 0:t.request)\|\|void 0===i?void 0:i.command),this.emit("path",e);else if("subscribe"===(null===(o=null==t?void 0:t.request)\|\|void 0===o?void 0:o.command)&&Array.isArray(null===(s=null==t?void 0:t.request)\|\|void 0===s?void 0:s.streams)&&(null===(l=null==t?void 0:t.request)\|\|void 0===l?void 0:l.streams.indexOf("ledger"))>-1)p("Async","subscription:ledger"),this.emit("ledger",e);else if(t)t.promiseCallables.resolve(Object.assign(e,{id:null===(u=null==e?void 0:e.id)\|\|void 0===u?void 0:u._Request}));else{(null===(a=null==e?void 0:e.id)\|\|void 0===a?void 0:a._Request)&&String(e.id._Request).match(/^_WsClient_Internal/)\|\|p("Handle <UNKNOWN> Async Message",{internalId:null===(c=null==e?void 0:e.id)\|\|void 0===c?void 0:c._WsClient,matchingSubscription:t,type:null==e?void 0:e.type,message:e})}}},m=e=>{var t,n,r,i,o,s;try{l.default("string"==typeof e.data,"Unexpected incoming WebSocket message data type");const u=JSON.parse(e.data);if(this.lastContact=new Date,null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient){const e=this.subscriptions.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)})),t=this.pendingCalls.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)}));if(1===e.length)v(u);else if(1===t.length){const e="_WsClient_Internal_ServerInfo"===String((null===(i=null===(r=null===(n=t[0])\|\|void 0===n?void 0:n.request)\|\|void 0===r?void 0:r.id)\|\|void 0===i?void 0:i._Request)\|\|"").split("@")[0];Object.assign(u,{id:null===(o=null==u?void 0:u.id)\|\|void 0===o?void 0:o._Request}),(null===(s=t[0].sendOptions)\|\|void 0===s?void 0:s.timeoutSeconds)&&t[0].timeout&&clearTimeout(t[0].timeout),t[0].promiseCallables.resolve((null==u?void 0:u.result)\|\|u),this.pendingCalls.splice(this.pendingCalls.indexOf(t[0]),1),e?a(u):f("» Pending Call Length",this.pendingCalls.length)}else v(u)}else v(u)}catch(e){d("Uplink response: parse error",e.message)}},g=e=>{d("Upstream/Websocket error")},y=e=>{var t;(null===(t=null==e?void 0:e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds)&&!(null==e?void 0:e.timeout)&&Object.assign(e,{timeout:setTimeout((()=>o(this,void 0,void 0,(function(){var t;"_WsClient_Internal_CallResolved"===(yield Promise.race([e.promise,Promise.resolve("_WsClient_Internal_CallResolved")]))&&e.promiseCallables.reject(new Error(`Call timeout after ${null===(t=e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds} seconds`))}))),1e3*Number(e.sendOptions.timeoutSeconds))})},b=e=>{var t,n,r;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(" > Process call",e.id,e.request.command);try{this.connection.send(JSON.stringify(e.request)),(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.timeoutStartsWhenOnline)&&(d("APPLY TIMEOUT ONLY AFTER GOING ONLINE"),y(e))}catch(e){d("Process (send to uplink) error",e.message)}},C=e=>{var t,n,r,i,o;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(`Call ${e.id}: ${e.request.command}\n > `,this.uplinkReady?"Uplink ready, pass immediately":(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.sendIfNotReady)?"Uplink not flagged as ready yet, but `sendIfNotReady` = true, so go ahead":"Uplink not ready, wait for flush"),(null===(i=null==e?void 0:e.sendOptions)\|\|void 0===i?void 0:i.timeoutStartsWhenOnline)\|\|(d("APPLY TIMEOUT NO MATTER ONLINE/OFFLINE STATE"),y(e)),(this.uplinkReady\|\|(null===(o=null==e?void 0:e.sendOptions)\|\|void 0===o?void 0:o.sendIfNotReady))&&b(e)},w=()=>{f("Connected, flushing pending calls & subscriptions"),this.pendingCalls.forEach((e=>{b(e)})),this.subscriptions.forEach((e=>{b(e)}))},_=e=>{this.closed=!0,f("Closing connection"),O();try{this.connection.close()}catch(e){}if(clearTimeout(n),this.subscriptions.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.pendingCalls.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.off("__WsClient_call",C),this.off("__WsClient_close",_),this.off("flush",w),this.off("reconnect",E),e)throw e},O=()=>{f("Cleanup"),this.connection.removeEventListener("open",s),this.connection.removeEventListener("message",m),this.connection.removeEventListener("error",g),this.connection.removeEventListener("close",u)},E=()=>{var e,t,n;try{this.connection.close()}catch(e){}f("Connecting",this.endpoint),this.serverState.connectAttempts++,this.options.maxConnectionAttempts&&Number((null===(e=this.options)\|\|void 0===e?void 0:e.maxConnectionAttempts)\|\|1)>1&&this.serverState.connectAttempts>Number((null===(t=this.options)\|\|void 0===t?void 0:t.maxConnectionAttempts)\|\|1)&&(h("Too many connection attempts",this.serverState.connectAttempts,null===(n=this.options)\|\|void 0===n?void 0:n.maxConnectionAttempts),_(new Error("Max. connection attempts exceeded")));const r=new c.w3cwebsocket(this.endpoint);return r.addEventListener("open",s),r.addEventListener("message",m),r.addEventListener("error",g),r.addEventListener("close",u),this.connection=r,r};this.on("__WsClient_call",C),this.on("__WsClient_close",_),this.on("flush",w),this.on("reconnect",E),this.connection=E(),setInterval((()=>{h("Connection Attempts",this.serverState.connectAttempts)}),4e3)}ready(){return new Promise(((e,t)=>{const n=this.getState();n.online&&n.secLastContact&&n.secLastContact<10&&n.ledger.last?e(this):this.on("ledger",(()=>{e(this)}))}))}send(e,t={}){var n,r,i;l.default("object"==typeof e&&e,"`send()`: expecting object containing `command`"),l.default("string"==typeof e.command,"`command` must be typeof string"),this.callId++;const o={resolve:e=>{},reject:e=>{}},s=new Promise(((e,t)=>{Object.assign(o,{resolve:e,reject:t})})),u={id:this.callId,request:Object.assign(e,{id:{_WsClient:this.callId,_Request:null==e?void 0:e.id},command:e.command.toLowerCase().trim()}),promise:s,promiseCallables:o,sendOptions:t};if(this.closed)return o.reject(new Error("Client in closed state")),s;const a=("subscribe"===u.request.command\|\|"unsubscribe"===u.request.command\|\|"path_find"===u.request.command)&&!(null==t?void 0:t.noReplayAfterReconnect);return"unsubscribe"===(null===(n=u.request)\|\|void 0===n?void 0:n.command)&&Array.isArray(null===(r=u.request)\|\|void 0===r?void 0:r.streams)&&(null===(i=u.request)\|\|void 0===i?void 0:i.streams.indexOf("ledger"))>-1&&(u.request.streams.splice(u.request.streams.indexOf("ledger"),1),0===u.request.streams.length&&0===Object.keys(u.request).filter((e=>"id"!==e&&"streams"!==e&&"command"!==e)).length)?Promise.reject(new Error("Unsubscribing from (just) the ledger stream is not allowed")):("_WsClient_Internal_ServerInfo"!==String((null==e?void 0:e.id)\|\|"").split("@")[0]&&this[a?"subscriptions":"pendingCalls"].push(u),this.emit("__WsClient_call",u),s)}getState(){var e,t,n,r,i,o,s,l,u;const a=this.serverState.validatedLedgers.split(",").map((e=>{const t=e.split("-");return t.length>1?parseInt(t[1])-parseInt(t[0]):1})).reduce(((e,t)=>e+t),0);return{online:this.uplinkReady&&!this.closed&&this.connection.readyState===c.w3cwebsocket.OPEN,latencyMs:{last:this.serverState.latency.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.latency.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.latency.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.latency.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},server:{version:(null===(n=null===(t=null===(e=this.serverInfo)\|\|void 0===e?void 0:e.result)\|\|void 0===t?void 0:t.info)\|\|void 0===n?void 0:n.build_version)\|\|"",uptime:(null===(o=null===(i=null===(r=this.serverInfo)\|\|void 0===r?void 0:r.result)\|\|void 0===i?void 0:i.info)\|\|void 0===o?void 0:o.uptime)\|\|0,publicKey:(null===(u=null===(l=null===(s=this.serverInfo)\|\|void 0===s?void 0:s.result)\|\|void 0===l?void 0:l.info)\|\|void 0===u?void 0:u.pubkey_node)\|\|"",uri:this.endpoint},ledger:{last:Number(this.serverState.validatedLedgers.split(",").reverse()[0].split("-").reverse()[0]),validated:this.serverState.validatedLedgers,count:""===this.serverState.validatedLedgers?0:a},fee:{last:this.serverState.fee.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.fee.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.fee.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.fee.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},reserve:{base:this.serverState.reserveBase,owner:this.serverState.reserveInc},secLastContact:this.lastContact?Number(new Date)/1e3-Number(this.lastContact)/1e3:null}}close(){l.default(!this.closed,"Object already in closed state"),this.emit("__WsClient_close")}}n.XrplClient=v},{"./types":1,assert:2,debug:6,events:9,websocket:13}]},{},[]);
		"use strict";var r=Object.getOwnPropertySymbols,i=Object.prototype.hasOwnProperty,o=Object.prototype.propertyIsEnumerable;function s(e){if(null==e)throw new TypeError("Object.assign cannot be called with null or undefined");return Object(e)}t.exports=function(){try{if(!Object.assign)return!1;var e=new String("abc");if(e[5]="de","5"===Object.getOwnPropertyNames(e)[0])return!1;for(var t={},n=0;n<10;n++)t["_"+String.fromCharCode(n)]=n;if("0123456789"!==Object.getOwnPropertyNames(t).map((function(e){return t[e]})).join(""))return!1;var r={};return"abcdefghijklmnopqrst".split("").forEach((function(e){r[e]=e})),"abcdefghijklmnopqrst"===Object.keys(Object.assign({},r)).join("")}catch(e){return!1}}()?Object.assign:function(e,t){for(var n,l,u=s(e),a=1;a<arguments.length;a++){for(var c in n=Object(arguments[a]))i.call(n,c)&&(u[c]=n[c]);if(r){l=r(n);for(var f=0;f<l.length;f++)o.call(n,l[f])&&(u[l[f]]=n[l[f]])}}return u}},{}],12:[function(e,t,n){var r,i,o=t.exports={};function s(){throw new Error("setTimeout has not been defined")}function l(){throw new Error("clearTimeout has not been defined")}function u(e){if(r===setTimeout)return setTimeout(e,0);if((r===s\|\|!r)&&setTimeout)return r=setTimeout,setTimeout(e,0);try{return r(e,0)}catch(t){try{return r.call(null,e,0)}catch(t){return r.call(this,e,0)}}}!function(){try{r="function"==typeof setTimeout?setTimeout:s}catch(e){r=s}try{i="function"==typeof clearTimeout?clearTimeout:l}catch(e){i=l}}();var a,c=[],f=!1,d=-1;function p(){f&&a&&(f=!1,a.length?c=a.concat(c):d=-1,c.length&&h())}function h(){if(!f){var e=u(p);f=!0;for(var t=c.length;t;){for(a=c,c=[];++d<t;)a&&a[d].run();d=-1,t=c.length}a=null,f=!1,function(e){if(i===clearTimeout)return clearTimeout(e);if((i===l\|\|!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 v(e,t){this.fun=e,this.array=t}function m(){}o.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];c.push(new v(e,t)),1!==c.length\|\|f\|\|u(h)},v.prototype.run=function(){this.fun.apply(null,this.array)},o.title="browser",o.browser=!0,o.env={},o.argv=[],o.version="",o.versions={},o.on=m,o.addListener=m,o.once=m,o.off=m,o.removeListener=m,o.removeAllListeners=m,o.emit=m,o.prependListener=m,o.prependOnceListener=m,o.listeners=function(e){return[]},o.binding=function(e){throw new Error("process.binding is not supported")},o.cwd=function(){return"/"},o.chdir=function(e){throw new Error("process.chdir is not supported")},o.umask=function(){return 0}},{}],13:[function(e,t,n){var r;if("object"==typeof globalThis)r=globalThis;else try{r=e("es5-ext/global")}catch(e){}finally{if(r\|\|"undefined"==typeof window\|\|(r=window),!r)throw new Error("Could not determine global this")}var i=r.WebSocket\|\|r.MozWebSocket,o=e("./version");function s(e,t){return t?new i(e,t):new i(e)}i&&["CONNECTING","OPEN","CLOSING","CLOSED"].forEach((function(e){Object.defineProperty(s,e,{get:function(){return i[e]}})})),t.exports={w3cwebsocket:i?s:null,version:o}},{"./version":14,"es5-ext/global":8}],14:[function(e,t,n){t.exports=e("../package.json").version},{"../package.json":15}],15:[function(e,t,n){t.exports={name:"websocket",description:"Websocket Client & Server Library implementing the WebSocket protocol as specified in RFC 6455.",keywords:["websocket","websockets","socket","networking","comet","push","RFC-6455","realtime","server","client"],author:"Brian McKelvey <theturtle32@gmail.com> (https://github.com/theturtle32)",contributors:["Iñaki Baz Castillo <ibc@aliax.net> (http://dev.sipdoc.net)"],version:"1.0.34",repository:{type:"git",url:"https://github.com/theturtle32/WebSocket-Node.git"},homepage:"https://github.com/theturtle32/WebSocket-Node",engines:{node:">=4.0.0"},dependencies:{bufferutil:"^4.0.1",debug:"^2.2.0","es5-ext":"^0.10.50","typedarray-to-buffer":"^3.1.5","utf-8-validate":"^5.0.2",yaeti:"^0.0.6"},devDependencies:{"buffer-equal":"^1.0.0",gulp:"^4.0.2","gulp-jshint":"^2.0.4","jshint-stylish":"^2.2.1",jshint:"^2.0.0",tape:"^4.9.1"},config:{verbose:!1},scripts:{test:"tape test/unit/.js",gulp:"gulp"},main:"index",directories:{lib:"./lib"},browser:"lib/browser.js",license:"Apache-2.0"}},{}],"xrpl-client":[function(e,t,n){"use strict";var r=this&&this.__createBinding\|\|(Object.create?function(e,t,n,r){void 0===r&&(r=n),Object.defineProperty(e,r,{enumerable:!0,get:function(){return t[n]}})}:function(e,t,n,r){void 0===r&&(r=n),e[r]=t[n]}),i=this&&this.__exportStar\|\|function(e,t){for(var n in e)"default"===n\|\|Object.prototype.hasOwnProperty.call(t,n)\|\|r(t,e,n)},o=this&&this.__awaiter\|\|function(e,t,n,r){return new(n\|\|(n=Promise))((function(i,o){function s(e){try{u(r.next(e))}catch(e){o(e)}}function l(e){try{u(r.throw(e))}catch(e){o(e)}}function u(e){var t;e.done?i(e.value):(t=e.value,t instanceof n?t:new n((function(e){e(t)}))).then(s,l)}u((r=r.apply(e,t\|\|[])).next())}))},s=this&&this.__importDefault\|\|function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(n,"__esModule",{value:!0}),n.XrplClient=void 0;const l=s(e("assert")),u=e("events"),a=e("debug"),c=e("websocket");i(e("./types"),n);const f=a.debug("xrplclient"),d=f.extend("warning"),p=f.extend("message"),h=f.extend("node");class v extends u.EventEmitter{constructor(e="wss://xrplcluster.com",t){let n;super(),this.connectBackoff=1e3/1.2,this.closed=!1,this.uplinkReady=!1,this.options={connectAttemptTimeoutSeconds:4,assumeOfflineAfterSeconds:20,maxConnectionAttempts:null},this.callId=0,this.pendingCalls=[],this.subscriptions=[],this.serverState={validatedLedgers:"",reserveBase:null,reserveInc:null,latency:[],fee:[],connectAttempts:0},t&&Object.assign(this.options,t);const r=()=>{var e;clearTimeout(n);const t=1e3Number((null===(e=null==this?void 0:this.options)\|\|void 0===e?void 0:e.assumeOfflineAfterSeconds)\|\|20);n=setTimeout((()=>{var e;d("----- CONNECTION TIMEOUT, NO LEDER INFO RECEIVED FOR ",t,"SECONDS -----");try{null===(e=this.connection)\|\|void 0===e\|\|e.close()}catch(e){}}),t)};r(),this.endpoint=e.trim(),f("Initialized xrpld WebSocket Client"),this.on("ledger",(()=>{i(),r()}));const i=()=>{this.uplinkReady\|\|(this.serverState.connectAttempts=0,h("Connection ready, fire events"),this.connectBackoff=1e3/1.2,this.uplinkReady=!0,this.emit("flush"),this.emit("state",this.getState()))},s=()=>{f("Connection opened :)"),this.send({id:"_WsClient_Internal_Subscription",command:"subscribe",streams:["ledger"]},{sendIfNotReady:!0,noReplayAfterReconnect:!0}),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"},{sendIfNotReady:!0,noReplayAfterReconnect:!0}).then((()=>{i()}))},u=e=>{var t;this.emit("close"),this.emit("state",this.getState()),this.connectBackoff=Math.min(Math.round(1.2this.connectBackoff),1e3Number((null===(t=this.options)\|\|void 0===t?void 0:t.connectAttemptTimeoutSeconds)\|\|4)),this.uplinkReady=!1,this.serverInfo=void 0,d("Upstream/Websocket closed",null==e?void 0:e.code,null==e?void 0:e.reason),O(),this.closed?f("Closed on purpose, not reconnecting"):(this.emit("retry"),d(`Not closed on purpose, reconnecting after ${this.connectBackoff}...`),setTimeout((()=>{this.emit("reconnect")}),this.connectBackoff))},a=e=>{var t,n;if(null===(t=null==e?void 0:e.result)\|\|void 0===t?void 0:t.info){const t=e;this.serverInfo\|\|h("Connected, server_info:",{pubkey_node:t.result.info.pubkey_node,build_version:t.result.info.build_version,complete_ledgers:t.result.info.complete_ledgers});const r=Number(new Date)-Number(String((null==e?void 0:e.id)\|\|"").split("@").reverse()[0]);r&&(this.serverState.latency.push({moment:new Date,value:r}),this.serverState.latency.splice(0,this.serverState.latency.length-10));const i=1.2,o=t.result.info.load_factorNumber(null===(n=t.result.info.validated_ledger)\|\|void 0===n?void 0:n.base_fee_xrp)1e6i;o&&(this.serverState.fee.push({moment:new Date,value:o}),this.serverState.fee.splice(0,this.serverState.fee.length-5)),this.serverInfo=t}},v=e=>{var t,n,r,i,o,s,l,u,a,c;if("_WsClient_Internal_Subscription"!==(null===(t=null==e?void 0:e.id)\|\|void 0===t?void 0:t._Request))if(this.emit("message",e),"ledgerClosed"===(null==e?void 0:e.type))p("Async",e.type),Object.assign(this.serverState,{validatedLedgers:null==e?void 0:e.validated_ledgers,reserveBase:Number(null==e?void 0:e.reserve_base)/1e6\|\|null,reserveInc:Number(null==e?void 0:e.reserve_inc)/1e6\|\|null}),this.emit("ledger",e),this.send({id:"_WsClient_Internal_ServerInfo@"+Number(new Date),command:"server_info"});else if("path_find"===(null==e?void 0:e.type))p("Async",e.type),this.emit("path",e);else if("transaction"===(null==e?void 0:e.type))p("Async",e.type),this.emit("transaction",e);else if(null==e?void 0:e.validation_public_key)p("Async","validation"),this.emit("validation",e);else{let t;if(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient){const n=this.subscriptions.filter((t=>{var n;return t.id===(null===(n=null==e?void 0:e.id)\|\|void 0===n?void 0:n._WsClient)}));n.length>0&&(t=n[0])}if("path_find"===(null===(r=null==t?void 0:t.request)\|\|void 0===r?void 0:r.command))p("Async",null===(i=null==t?void 0:t.request)\|\|void 0===i?void 0:i.command),this.emit("path",e);else if("subscribe"===(null===(o=null==t?void 0:t.request)\|\|void 0===o?void 0:o.command)&&Array.isArray(null===(s=null==t?void 0:t.request)\|\|void 0===s?void 0:s.streams)&&(null===(l=null==t?void 0:t.request)\|\|void 0===l?void 0:l.streams.indexOf("ledger"))>-1)p("Async","subscription:ledger"),this.emit("ledger",e);else if(t)t.promiseCallables.resolve(Object.assign(e,{id:null===(u=null==e?void 0:e.id)\|\|void 0===u?void 0:u._Request}));else{(null===(a=null==e?void 0:e.id)\|\|void 0===a?void 0:a._Request)&&String(e.id._Request).match(/^_WsClient_Internal/)\|\|p("Handle <UNKNOWN> Async Message",{internalId:null===(c=null==e?void 0:e.id)\|\|void 0===c?void 0:c._WsClient,matchingSubscription:t,type:null==e?void 0:e.type,message:e})}}},m=e=>{var t,n,r,i,o,s;try{l.default("string"==typeof e.data,"Unexpected incoming WebSocket message data type");const u=JSON.parse(e.data);if(this.lastContact=new Date,null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient){const e=this.subscriptions.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)})),t=this.pendingCalls.filter((e=>{var t;return e.id===(null===(t=null==u?void 0:u.id)\|\|void 0===t?void 0:t._WsClient)}));if(1===e.length)v(u);else if(1===t.length){const e="_WsClient_Internal_ServerInfo"===String((null===(i=null===(r=null===(n=t[0])\|\|void 0===n?void 0:n.request)\|\|void 0===r?void 0:r.id)\|\|void 0===i?void 0:i._Request)\|\|"").split("@")[0];Object.assign(u,{id:null===(o=null==u?void 0:u.id)\|\|void 0===o?void 0:o._Request}),(null===(s=t[0].sendOptions)\|\|void 0===s?void 0:s.timeoutSeconds)&&t[0].timeout&&clearTimeout(t[0].timeout),t[0].promiseCallables.resolve((null==u?void 0:u.result)\|\|u),this.pendingCalls.splice(this.pendingCalls.indexOf(t[0]),1),e?a(u):f("» Pending Call Length",this.pendingCalls.length)}else v(u)}else v(u)}catch(e){d("Uplink response: parse error",e.message)}},g=e=>{d("Upstream/Websocket error")},y=e=>{var t;(null===(t=null==e?void 0:e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds)&&!(null==e?void 0:e.timeout)&&Object.assign(e,{timeout:setTimeout((()=>o(this,void 0,void 0,(function(){var t;"_WsClient_Internal_CallResolved"===(yield Promise.race([e.promise,Promise.resolve("_WsClient_Internal_CallResolved")]))&&e.promiseCallables.reject(new Error(`Call timeout after ${null===(t=e.sendOptions)\|\|void 0===t?void 0:t.timeoutSeconds} seconds`))}))),1e3Number(e.sendOptions.timeoutSeconds))})},b=e=>{var t,n,r;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(" > Process call",e.id,e.request.command);try{this.connection.send(JSON.stringify(e.request)),(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.timeoutStartsWhenOnline)&&(d("APPLY TIMEOUT ONLY AFTER GOING ONLINE"),y(e))}catch(e){d("Process (send to uplink) error",e.message)}},C=e=>{var t,n,r,i,o;"_WsClient_Internal_ServerInfo"!==String((null===(n=null===(t=null==e?void 0:e.request)\|\|void 0===t?void 0:t.id)\|\|void 0===n?void 0:n._Request)\|\|"").split("@")[0]&&f(`Call ${e.id}: ${e.request.command}\n > `,this.uplinkReady?"Uplink ready, pass immediately":(null===(r=null==e?void 0:e.sendOptions)\|\|void 0===r?void 0:r.sendIfNotReady)?"Uplink not flagged as ready yet, but `sendIfNotReady` = true, so go ahead":"Uplink not ready, wait for flush"),(null===(i=null==e?void 0:e.sendOptions)\|\|void 0===i?void 0:i.timeoutStartsWhenOnline)\|\|(d("APPLY TIMEOUT NO MATTER ONLINE/OFFLINE STATE"),y(e)),(this.uplinkReady\|\|(null===(o=null==e?void 0:e.sendOptions)\|\|void 0===o?void 0:o.sendIfNotReady))&&b(e)},w=()=>{f("Connected, flushing pending calls & subscriptions"),this.pendingCalls.forEach((e=>{b(e)})),this.subscriptions.forEach((e=>{b(e)}))},_=e=>{this.closed=!0,f("Closing connection"),O();try{this.connection.close()}catch(e){}if(clearTimeout(n),this.subscriptions.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.pendingCalls.forEach((e=>{e.promiseCallables.reject(new Error("Class (connection) hard close requested"))})),this.off("__WsClient_call",C),this.off("__WsClient_close",_),this.off("flush",w),this.off("reconnect",E),e)throw e},O=()=>{f("Cleanup"),this.connection.removeEventListener("open",s),this.connection.removeEventListener("message",m),this.connection.removeEventListener("error",g),this.connection.removeEventListener("close",u)},E=()=>{var e,t,n;try{this.connection.close()}catch(e){}f("Connecting",this.endpoint),this.serverState.connectAttempts++,this.options.maxConnectionAttempts&&Number((null===(e=this.options)\|\|void 0===e?void 0:e.maxConnectionAttempts)\|\|1)>1&&this.serverState.connectAttempts>Number((null===(t=this.options)\|\|void 0===t?void 0:t.maxConnectionAttempts)\|\|1)&&(h("Too many connection attempts",this.serverState.connectAttempts,null===(n=this.options)\|\|void 0===n?void 0:n.maxConnectionAttempts),_(new Error("Max. connection attempts exceeded")));const r=new c.w3cwebsocket(this.endpoint);return setTimeout((()=>{r.readyState!==c.w3cwebsocket.OPEN&&r.close()}),1.2this.connectBackoff-1),r.addEventListener("open",s),r.addEventListener("message",m),r.addEventListener("error",g),r.addEventListener("close",u),this.connection=r,r};this.on("__WsClient_call",C),this.on("__WsClient_close",_),this.on("flush",w),this.on("reconnect",E),this.connection=E()}ready(){return new Promise(((e,t)=>{const n=this.getState();n.online&&n.secLastContact&&n.secLastContact<10&&n.ledger.last?e(this):this.on("ledger",(()=>{e(this)}))}))}send(e,t={}){var n,r,i;l.default("object"==typeof e&&e,"`send()`: expecting object containing `command`"),l.default("string"==typeof e.command,"`command` must be typeof string"),this.callId++;const o={resolve:e=>{},reject:e=>{}},s=new Promise(((e,t)=>{Object.assign(o,{resolve:e,reject:t})})),u={id:this.callId,request:Object.assign(e,{id:{_WsClient:this.callId,_Request:null==e?void 0:e.id},command:e.command.toLowerCase().trim()}),promise:s,promiseCallables:o,sendOptions:t};if(this.closed)return o.reject(new Error("Client in closed state")),s;const a=("subscribe"===u.request.command\|\|"unsubscribe"===u.request.command\|\|"path_find"===u.request.command)&&!(null==t?void 0:t.noReplayAfterReconnect);return"unsubscribe"===(null===(n=u.request)\|\|void 0===n?void 0:n.command)&&Array.isArray(null===(r=u.request)\|\|void 0===r?void 0:r.streams)&&(null===(i=u.request)\|\|void 0===i?void 0:i.streams.indexOf("ledger"))>-1&&(u.request.streams.splice(u.request.streams.indexOf("ledger"),1),0===u.request.streams.length&&0===Object.keys(u.request).filter((e=>"id"!==e&&"streams"!==e&&"command"!==e)).length)?Promise.reject(new Error("Unsubscribing from (just) the ledger stream is not allowed")):("_WsClient_Internal_ServerInfo"!==String((null==e?void 0:e.id)\|\|"").split("@")[0]&&this[a?"subscriptions":"pendingCalls"].push(u),this.emit("__WsClient_call",u),s)}getState(){var e,t,n,r,i,o,s,l,u;const a=this.serverState.validatedLedgers.split(",").map((e=>{const t=e.split("-");return t.length>1?parseInt(t[1])-parseInt(t[0]):1})).reduce(((e,t)=>e+t),0);return{online:this.uplinkReady&&!this.closed&&this.connection.readyState===c.w3cwebsocket.OPEN,latencyMs:{last:this.serverState.latency.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.latency.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.latency.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.latency.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},server:{version:(null===(n=null===(t=null===(e=this.serverInfo)\|\|void 0===e?void 0:e.result)\|\|void 0===t?void 0:t.info)\|\|void 0===n?void 0:n.build_version)\|\|"",uptime:(null===(o=null===(i=null===(r=this.serverInfo)\|\|void 0===r?void 0:r.result)\|\|void 0===i?void 0:i.info)\|\|void 0===o?void 0:o.uptime)\|\|0,publicKey:(null===(u=null===(l=null===(s=this.serverInfo)\|\|void 0===s?void 0:s.result)\|\|void 0===l?void 0:l.info)\|\|void 0===u?void 0:u.pubkey_node)\|\|"",uri:this.endpoint},ledger:{last:Number(this.serverState.validatedLedgers.split(",").reverse()[0].split("-").reverse()[0]),validated:this.serverState.validatedLedgers,count:""===this.serverState.validatedLedgers?0:a},fee:{last:this.serverState.fee.slice(-1).map((e=>e.value))[0]\|\|null,avg:this.serverState.fee.map((e=>e.value)).reduce(((e,t)=>e+t),0)/this.serverState.fee.length\|\|null,secAgo:Number(new Date)/1e3-this.serverState.fee.slice(-1).map((e=>Number(e.moment)/1e3))[0]\|\|null},reserve:{base:this.serverState.reserveBase,owner:this.serverState.reserveInc},secLastContact:this.lastContact?Number(new Date)/1e3-Number(this.lastContact)/1e3:null}}close(){l.default(!this.closed,"Object already in closed state"),this.emit("__WsClient_close")}}n.XrplClient=v},{"./types":1,assert:2,debug:6,events:9,websocket:13}]},{},[]);

xrpl-client - npm Package Compare versions

New alerts

Fixed alerts

Improved metrics