LaconicNetwork/cosmjs-util
10
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Merge pull request #510 from cosmos/494-ibc-query-tests

Browse Source 
Improve IBC query tests
This commit is contained in:
Will Clark 2020-11-04 13:27:15 +01:00 committed by GitHub
commit 21a465b0d9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 150 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

107
packages/stargate/src/queries/ibc.spec.ts
View File

@ -1,7 +1,10 @@
import { Client as TendermintClient } from "@cosmjs/tendermint-rpc";
import Long from "long";
import { cosmos, ibc } from "../codec";
import { pendingWithoutSimapp, simapp } from "../testutils.spec";
import { IbcExtension, setupIbcExtension } from "./ibc";
import * as ibcTest from "./ibctestdata.spec";
import { QueryClient } from "./queryclient";
async function makeClientWithIbc(rpcUrl: string): Promise<[QueryClient & IbcExtension, TendermintClient]> {
@ -12,116 +15,130 @@ async function makeClientWithIbc(rpcUrl: string): Promise<[QueryClient & IbcExte
describe("IbcExtension", () => {
describe("unverified", () => {
describe("channel", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.channel("foo", "bar");
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.channel(ibcTest.portId, ibcTest.channelId);
expect(response.channel).toEqual(ibcTest.channel);
expect(response.proofHeight).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("channels", () => {
it("can be called", async () => {
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.channels();
expect(response).toBeTruthy(); // TODO: implement checks
expect(response.channels).toEqual([ibcTest.identifiedChannel]);
expect(response.pagination).toBeInstanceOf(cosmos.base.query.v1beta1.PageResponse);
expect(response.height).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("connectionChannels", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.connectionChannels("foo");
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.connectionChannels(ibcTest.connectionId);
expect(response.channels).toEqual([ibcTest.identifiedChannel]);
expect(response.pagination).toBeInstanceOf(cosmos.base.query.v1beta1.PageResponse);
expect(response.height).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("packetCommitment", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.packetCommitment("foo", "bar", 0);
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.packetCommitment(ibcTest.portId, ibcTest.channelId, 4);
expect(response.commitment).toEqual(ibcTest.commitmentData);
expect(response.proofHeight).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("packetCommitments", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.packetCommitments("foo", "bar");
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.packetCommitments(ibcTest.portId, ibcTest.channelId);
expect(response.commitments).toEqual([ibcTest.packetState]);
expect(response.pagination).toBeInstanceOf(cosmos.base.query.v1beta1.PageResponse);
expect(response.height).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("packetAcknowledgement", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.packetAcknowledgement("foo", "bar", 1);
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.packetAcknowledgement(
ibcTest.portId,
ibcTest.channelId,
1,
);
expect(response.acknowledgement).toEqual(ibcTest.acknowledgement);
expect(response.proofHeight).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("unreceivedPackets", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.unreceivedPackets("foo", "bar", [0, 1]);
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.unreceivedPackets(ibcTest.portId, ibcTest.channelId, [
4,
5,
]);
expect(response.sequences).toEqual([Long.fromInt(4, true), Long.fromInt(5, true)]);
expect(response.height).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("unreceivedAcks", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.unreceivedAcks("foo", "bar", [0, 1]);
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.unreceivedAcks(ibcTest.portId, ibcTest.channelId, [
4,
5,
]);
expect(response.sequences).toEqual([Long.fromInt(4, true)]);
expect(response.height).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("nextSequenceReceive", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.nextSequenceReceive("foo", "bar");
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.nextSequenceReceive(ibcTest.portId, ibcTest.channelId);
expect(response.nextSequenceReceive).toEqual(Long.fromInt(1, true));
expect(response.proofHeight).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
@ -130,38 +147,40 @@ describe("IbcExtension", () => {
// Queries for ibc.connection
describe("connection", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.connection("foo");
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.connection(ibcTest.connectionId);
expect(response.connection).toEqual(ibcTest.connection);
expect(response.proofHeight).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("connections", () => {
it("can be called", async () => {
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.connections();
expect(response).toBeTruthy(); // TODO: implement checks
expect(response.connections).toEqual([ibcTest.identifiedConnection]);
expect(response.pagination).toBeInstanceOf(cosmos.base.query.v1beta1.PageResponse);
expect(response.height).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});
});
describe("clientConnections", () => {
it("can be called", async () => {
pending("Fails with 'Query failed with (1): internal'. Make it work.");
it("works", async () => {
pendingWithoutSimapp();
const [client, tmClient] = await makeClientWithIbc(simapp.tendermintUrl);
const response = await client.ibc.unverified.clientConnections("foo");
expect(response).toBeTruthy(); // TODO: implement checks
const response = await client.ibc.unverified.clientConnections(ibcTest.clientId);
expect(response.connectionPaths).toEqual([ibcTest.connectionId]);
expect(response.proofHeight).toBeInstanceOf(ibc.core.client.v1.Height);
tmClient.disconnect();
});

82
packages/stargate/src/queries/ibctestdata.spec.ts Normal file
View File

@ -0,0 +1,82 @@
import { fromBase64 } from "@cosmjs/encoding";
import Long from "long";
import { ibc } from "../codec";
// From scripts/simapp/genesis-ibc.json
export const portId = "wasm.cosmos18vd8fpwxzck93qlwghaj6arh4p7c5n89uzcee5";
export const channelId = "testchain0-conn00";
export const connectionId = "testchain0-conn0";
export const clientId = "client0Fortestchain1";
export const channel = ibc.core.channel.v1.Channel.create({
state: ibc.core.channel.v1.State.STATE_OPEN,
ordering: ibc.core.channel.v1.Order.ORDER_UNORDERED,
counterparty: ibc.core.channel.v1.Counterparty.create({
portId: "wasm.cosmos10pyejy66429refv3g35g2t7am0was7yacjc2l4",
channelId: "testchain1-conn00",
}),
connectionHops: [connectionId],
version: "pong",
});
export const identifiedChannel = ibc.core.channel.v1.IdentifiedChannel.create({
state: ibc.core.channel.v1.State.STATE_OPEN,
ordering: ibc.core.channel.v1.Order.ORDER_UNORDERED,
counterparty: ibc.core.channel.v1.Counterparty.create({
portId: "wasm.cosmos10pyejy66429refv3g35g2t7am0was7yacjc2l4",
channelId: "testchain1-conn00",
}),
connectionHops: [connectionId],
version: "pong",
portId: portId,
channelId: channelId,
});
export const commitmentData = fromBase64("DIuspQzH8GooFceqNxkTsiZXBn9qoWWJMUqsAIB1G5c=");
export const packetState = ibc.core.channel.v1.PacketState.create({
portId: portId,
channelId: channelId,
sequence: Long.fromInt(4, true),
data: commitmentData,
});
export const acknowledgement = fromBase64("9RKC5OuTvBsFMtD79dHHvb9qCxw08IKsSJlAwmiw8tI=");
export const connection = ibc.core.connection.v1.ConnectionEnd.create({
clientId: clientId,
versions: [
ibc.core.connection.v1.Version.create({
identifier: "1",
features: ["ORDER_ORDERED", "ORDER_UNORDERED"],
}),
],
state: ibc.core.connection.v1.State.STATE_OPEN,
counterparty: ibc.core.connection.v1.Counterparty.create({
clientId: "client0Fortestchain0",
connectionId: "testchain1-conn0",
prefix: ibc.core.commitment.v1.MerklePrefix.create({
keyPrefix: fromBase64("aWJj"),
}),
}),
});
export const identifiedConnection = ibc.core.connection.v1.IdentifiedConnection.create({
id: connectionId,
clientId: clientId,
versions: [
ibc.core.connection.v1.Version.create({
identifier: "1",
features: ["ORDER_ORDERED", "ORDER_UNORDERED"],
}),
],
state: ibc.core.connection.v1.State.STATE_OPEN,
counterparty: ibc.core.connection.v1.Counterparty.create({
clientId: "client0Fortestchain0",
connectionId: "testchain1-conn0",
prefix: ibc.core.commitment.v1.MerklePrefix.create({
keyPrefix: fromBase64("aWJj"),
}),
}),
});

5
packages/stargate/src/signingstargateclient.spec.ts
View File

@ -12,6 +12,7 @@ import { faucet, makeRandomAddress, pendingWithoutSimapp, simapp, validator } fr
describe("SigningStargateClient", () => {
describe("constructor", () => {
it("can be constructed with default fees", async () => {
pendingWithoutSimapp();
const wallet = await DirectSecp256k1Wallet.fromMnemonic(faucet.mnemonic);
const client = await SigningStargateClient.connectWithWallet(simapp.tendermintUrl, wallet);
const openedClient = (client as unknown) as PrivateSigningStargateClient;
@ -29,6 +30,7 @@ describe("SigningStargateClient", () => {
});
it("can be constructed with custom registry", async () => {
pendingWithoutSimapp();
const wallet = await DirectSecp256k1Wallet.fromMnemonic(faucet.mnemonic);
const registry = new Registry();
registry.register("/custom.MsgCustom", cosmos.bank.v1beta1.MsgSend);
@ -39,6 +41,7 @@ describe("SigningStargateClient", () => {
});
it("can be constructed with custom gas price", async () => {
pendingWithoutSimapp();
const wallet = await DirectSecp256k1Wallet.fromMnemonic(faucet.mnemonic);
const gasPrice = GasPrice.fromString("3.14utest");
const options = { gasPrice: gasPrice };
@ -58,6 +61,7 @@ describe("SigningStargateClient", () => {
});
it("can be constructed with custom gas limits", async () => {
pendingWithoutSimapp();
const wallet = await DirectSecp256k1Wallet.fromMnemonic(faucet.mnemonic);
const gasLimits = {
send: 160000,
@ -79,6 +83,7 @@ describe("SigningStargateClient", () => {
});
it("can be constructed with custom gas price and gas limits", async () => {
pendingWithoutSimapp();
const wallet = await DirectSecp256k1Wallet.fromMnemonic(faucet.mnemonic);
const gasPrice = GasPrice.fromString("3.14utest");
const gasLimits = {