Compare commits

...

4 Commits

5 changed files with 9 additions and 3 deletions

2
dist/query/base.js vendored
View File

@ -50,7 +50,7 @@ export default class RpcQueryBase {
await this._run();
}
catch (e) {
this._promiseResolve?.({ error: e.message });
this._promiseResolve?.({ error: e?.message || e?.error });
}
}
setupRelayTimeout(reject) {

View File

@ -1 +1 @@
{"version":3,"file":"wisdom.d.ts","sourceRoot":"","sources":["../../src/query/wisdom.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,gBAAgB,EAEhB,oBAAoB,EAEpB,WAAW,EACZ,MAAM,sBAAsB,CAAC;AAW9B,OAAO,YAAY,MAAM,WAAW,CAAC;AAUrC,MAAM,CAAC,OAAO,OAAO,cAAe,SAAQ,YAAY;IACtD,UAAkB,SAAS,CAAC,EAAE,oBAAoB,CAAC;IACnD,UAAkB,MAAM,EAAE,gBAAgB,CAAC;IAC3C,IAAI,MAAM,IAAI,OAAO,CAAC,WAAW,CAAC,CAEjC;cAEe,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC;IAMrC,SAAS,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,WAAW,EAAE,OAAO,GAAE,OAAe,GAAG,IAAI;cAcrD,UAAU,IAAI,OAAO,CAAC,GAAG,CAAC;cA8B1B,aAAa;IAyE7B,SAAS,CAAC,SAAS,IAAI,MAAM,EAAE;CAmBhC"}
{"version":3,"file":"wisdom.d.ts","sourceRoot":"","sources":["../../src/query/wisdom.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,gBAAgB,EAEhB,oBAAoB,EAEpB,WAAW,EACZ,MAAM,sBAAsB,CAAC;AAW9B,OAAO,YAAY,MAAM,WAAW,CAAC;AAUrC,MAAM,CAAC,OAAO,OAAO,cAAe,SAAQ,YAAY;IACtD,UAAkB,SAAS,CAAC,EAAE,oBAAoB,CAAC;IACnD,UAAkB,MAAM,EAAE,gBAAgB,CAAC;IAC3C,IAAI,MAAM,IAAI,OAAO,CAAC,WAAW,CAAC,CAEjC;cAEe,IAAI,IAAI,OAAO,CAAC,IAAI,CAAC;IAMrC,SAAS,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,WAAW,EAAE,OAAO,GAAE,OAAe,GAAG,IAAI;cAcrD,UAAU,IAAI,OAAO,CAAC,GAAG,CAAC;cA8B1B,aAAa;IA4E7B,SAAS,CAAC,SAAS,IAAI,MAAM,EAAE;CAmBhC"}

View File

@ -69,6 +69,9 @@ export default class WisdomRpcQuery extends RpcQueryBase {
let relays = [];
for (const relay in this._response?.relays) {
const resp = this._response?.relays[relay];
if (resp?.error) {
continue;
}
if (validateTimestampedResponse(b4a.from(relay, "hex"), resp)) {
relays.push(resp);
}

View File

@ -81,7 +81,7 @@ export default abstract class RpcQueryBase {
await this._network.ready;
await this._run();
} catch (e: any) {
this._promiseResolve?.({ error: e.message });
this._promiseResolve?.({ error: e?.message || e?.error });
}
}

View File

@ -103,6 +103,9 @@ export default class WisdomRpcQuery extends RpcQueryBase {
for (const relay in this._response?.relays) {
const resp = this._response?.relays[relay];
if (resp?.error) {
continue;
}
if (
validateTimestampedResponse(
b4a.from(relay, "hex") as Buffer,