Pull out queryUnverified

This commit is contained in:
Simon Warta 2020-08-06 16:15:15 +02:00
parent 05a8ac9b71
commit e587fd639f
2 changed files with 18 additions and 12 deletions

View File

@ -87,18 +87,9 @@ export class StargateClient {
public async getUnverifiedAllBalances(address: string): Promise<readonly Coin[]> {
const path = "/cosmos.bank.Query/AllBalances";
const request = QueryAllBalancesRequest.encode({ address: Bech32.decode(address).data }).finish();
const response = await this.tmClient.abciQuery({
path: path,
data: request,
prove: false,
});
if (response.code) {
throw new Error(`Query failed with (${response.code}): ${response.log}`);
}
const result = QueryAllBalancesResponse.decode(response.value);
return (result.balances || []).map(
const responseData = await this.queryUnverified(path, request);
const response = QueryAllBalancesResponse.decode(responseData);
return (response.balances || []).map(
(balance): Coin => {
assertDefined(balance.amount);
assertDefined(balance.denom);
@ -137,4 +128,18 @@ export class StargateClient {
return response.value;
}
private async queryUnverified(path: string, request: Uint8Array): Promise<Uint8Array> {
const response = await this.tmClient.abciQuery({
path: path,
data: request,
prove: false,
});
if (response.code) {
throw new Error(`Query failed with (${response.code}): ${response.log}`);
}
return response.value;
}
}

View File

@ -18,4 +18,5 @@ export declare class StargateClient {
getUnverifiedAllBalances(address: string): Promise<readonly Coin[]>;
disconnect(): void;
private queryVerified;
private queryUnverified;
}