From ef62888c31f5bcf63432a3d76ed3fc47b8f3c9e5 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Sun, 14 Aug 2022 09:44:50 -0400 Subject: [PATCH] *Update dist --- dist/rpcQuery.d.ts | 2 ++ dist/rpcQuery.d.ts.map | 2 +- dist/rpcQuery.js | 12 +++++++++--- 3 files changed, 12 insertions(+), 4 deletions(-) diff --git a/dist/rpcQuery.d.ts b/dist/rpcQuery.d.ts index 116ba93..1845c44 100644 --- a/dist/rpcQuery.d.ts +++ b/dist/rpcQuery.d.ts @@ -9,6 +9,8 @@ export default class RpcQuery { private _completed; private _responses; private _promiseResolve?; + private _maxTries; + private _tries; constructor(network: RpcNetwork, query: RPCRequest); get result(): Promise; private handeTimeout; diff --git a/dist/rpcQuery.d.ts.map b/dist/rpcQuery.d.ts.map index 69ce1d2..9020a6d 100644 --- a/dist/rpcQuery.d.ts.map +++ b/dist/rpcQuery.d.ts.map @@ -1 +1 @@ -{"version":3,"file":"rpcQuery.d.ts","sourceRoot":"","sources":["../src/rpcQuery.ts"],"names":[],"mappings":"AACA,OAAO,UAAU,MAAM,iBAAiB,CAAC;AAEzC,OAAO,EAAE,UAAU,EAAe,MAAM,SAAS,CAAC;AAKlD,MAAM,CAAC,OAAO,OAAO,QAAQ;IAC3B,OAAO,CAAC,QAAQ,CAAa;IAC7B,OAAO,CAAC,MAAM,CAAa;IAC3B,OAAO,CAAC,QAAQ,CAAC,CAAe;IAChC,OAAO,CAAC,aAAa,CAAC,CAAM;IAC5B,OAAO,CAAC,QAAQ,CAAkB;IAClC,OAAO,CAAC,UAAU,CAAkB;IACpC,OAAO,CAAC,UAAU,CAAwC;IAC1D,OAAO,CAAC,eAAe,CAAC,CAAsB;gBAElC,OAAO,EAAE,UAAU,EAAE,KAAK,EAAE,UAAU;IAMlD,IAAI,MAAM,IAAI,OAAO,CAAC,GAAG,CAAC,CAEzB;IAED,OAAO,CAAC,YAAY;IAIpB,OAAO,CAAC,OAAO;YAQD,IAAI;YA2BJ,UAAU;IAgCxB,OAAO,CAAC,cAAc;IAgDtB,OAAO,CAAC,KAAK;CASd"} \ No newline at end of file +{"version":3,"file":"rpcQuery.d.ts","sourceRoot":"","sources":["../src/rpcQuery.ts"],"names":[],"mappings":"AACA,OAAO,UAAU,MAAM,iBAAiB,CAAC;AAEzC,OAAO,EAAE,UAAU,EAAe,MAAM,SAAS,CAAC;AAKlD,MAAM,CAAC,OAAO,OAAO,QAAQ;IAC3B,OAAO,CAAC,QAAQ,CAAa;IAC7B,OAAO,CAAC,MAAM,CAAa;IAC3B,OAAO,CAAC,QAAQ,CAAC,CAAe;IAChC,OAAO,CAAC,aAAa,CAAC,CAAM;IAC5B,OAAO,CAAC,QAAQ,CAAkB;IAClC,OAAO,CAAC,UAAU,CAAkB;IACpC,OAAO,CAAC,UAAU,CAAwC;IAC1D,OAAO,CAAC,eAAe,CAAC,CAAsB;IAC9C,OAAO,CAAC,SAAS,CAAK;IACtB,OAAO,CAAC,MAAM,CAAK;gBAEP,OAAO,EAAE,UAAU,EAAE,KAAK,EAAE,UAAU;IAMlD,IAAI,MAAM,IAAI,OAAO,CAAC,GAAG,CAAC,CAEzB;IAED,OAAO,CAAC,YAAY;IAIpB,OAAO,CAAC,OAAO;YAQD,IAAI;YA2BJ,UAAU;IAgCxB,OAAO,CAAC,cAAc;IAqDtB,OAAO,CAAC,KAAK;CASd"} \ No newline at end of file diff --git a/dist/rpcQuery.js b/dist/rpcQuery.js index e209d64..6644a4b 100644 --- a/dist/rpcQuery.js +++ b/dist/rpcQuery.js @@ -12,6 +12,8 @@ export default class RpcQuery { _completed = false; _responses = {}; _promiseResolve; + _maxTries = 3; + _tries = 0; constructor(network, query) { this._network = network; this._query = query; @@ -99,11 +101,15 @@ export default class RpcQuery { if (responses[responseHash] / responseStoreData.length >= this._network.majorityThreshold) { // @ts-ignore - const response = responseObjects[responseHash]; + let response = responseObjects[responseHash]; // @ts-ignore if (null === response) { - this.retry(); - return; + if (this._tries <= this._maxTries) { + this._tries++; + this.retry(); + return; + } + response = false; } this.resolve(response); break;