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

Configure block times

Browse Source
This commit is contained in:
Simon Warta 2020-09-23 09:35:49 +02:00
parent 1cb983e3fe
commit 57c47280c0
2 changed files with 20 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
packages/tendermint-rpc/src/config.spec.ts
View File

@ -8,6 +8,8 @@ export interface ExpectedValues {
export interface TendermintInstance {
readonly url: string;
readonly version: string;
/** rough block time in ms */
readonly blockTime: number;
/** Values we expect in the backend */
readonly expected: ExpectedValues;
}
@ -28,6 +30,7 @@ export const tendermintInstances: readonly TendermintInstance[] = [
{
url: "localhost:11133",
version: "0.33.x",
blockTime: 1000,
expected: {
appCreator: "Cosmoshi Netowoko",
p2pVersion: 7,
@ -38,6 +41,7 @@ export const tendermintInstances: readonly TendermintInstance[] = [
{
url: "localhost:11134",
version: "0.34.x",
blockTime: 500,
expected: {
appCreator: "Cosmoshi Netowoko",
p2pVersion: 8,

32
packages/tendermint-rpc/src/rpcclients/websocketclient.spec.ts
View File

@ -15,7 +15,7 @@ function pendingWithoutTendermint(): void {
}
describe("WebsocketClient", () => {
const tendermintUrl = defaultInstance.url;
const { blockTime, url: tendermintUrl } = defaultInstance;
it("can make a simple call", async () => {
pendingWithoutTendermint();
@ -48,27 +48,27 @@ describe("WebsocketClient", () => {
const events: SubscriptionEvent[] = [];
const sub = headers.subscribe({
const subscription = headers.subscribe({
error: done.fail,
complete: () => done.fail("subscription should not complete"),
next: (evt: SubscriptionEvent) => {
events.push(evt);
expect(evt.query).toEqual(query);
next: (event: SubscriptionEvent) => {
events.push(event);
expect(event.query).toEqual(query);
if (events.length === 2) {
// make sure they are consequtive heights
const height = (i: number): number => Integer.parse(events[i].data.value.header.height);
expect(height(1)).toEqual(height(0) + 1);
sub.unsubscribe();
subscription.unsubscribe();
// wait 1.5s and check we did not get more events
// wait 1.5 * blockTime and check we did not get more events
setTimeout(() => {
expect(events.length).toEqual(2);
client.disconnect();
done();
}, 1500);
}, 1.5 * blockTime);
}
},
});
@ -110,23 +110,23 @@ describe("WebsocketClient", () => {
const events: SubscriptionEvent[] = [];
const sub = headers.subscribe({
const subscription = headers.subscribe({
error: done.fail,
complete: () => done.fail("subscription should not complete"),
next: (evt: SubscriptionEvent) => {
events.push(evt);
expect(evt.query).toEqual(query);
next: (event: SubscriptionEvent) => {
events.push(event);
expect(event.query).toEqual(query);
if (events.length === 2) {
sub.unsubscribe();
subscription.unsubscribe();
// wait 1.5s and check we did not get more events
// wait 1.5 * blockTime and check we did not get more events
setTimeout(() => {
expect(events.length).toEqual(2);
client.disconnect();
done();
}, 1500);
}, 1.5 * blockTime);
}
},
});
@ -148,7 +148,7 @@ describe("WebsocketClient", () => {
const receivedEvents: SubscriptionEvent[] = [];
setTimeout(() => client.disconnect(), 1500);
setTimeout(() => client.disconnect(), blockTime);
headers.subscribe({
error: done.fail,