@cosmjs/tendermint-rpc - npm Package Compare versions

Comparing version 0.31.3 to 0.32.0-rc.1

build/index.d.ts

 export { pubkeyToAddress, pubkeyToRawAddress, rawEd25519PubkeyToRawAddress, rawSecp256k1PubkeyToRawAddress, } from "./addresses";
 export { DateTime, fromRfc3339WithNanoseconds, fromSeconds, ReadonlyDateWithNanoseconds, toRfc3339WithNanoseconds, toSeconds, } from "./dates";
+export * as comet38 from "./comet38";
+export { Comet38Client } from "./comet38";
 export { HttpBatchClient, HttpBatchClientOptions, HttpClient, HttpEndpoint, // This type is part of the Tendermint34Client.connect API
@@ -11,3 +13,3 @@ RpcClient, // Interface type in Tendermint34Client.create
 export { Tendermint37Client } from "./tendermint37";
-export { isTendermint34Client, isTendermint37Client, TendermintClient } from "./tendermintclient";
+export { CometClient, connectComet, isComet38Client, isTendermint34Client, isTendermint37Client, TendermintClient, } from "./tendermintclient";
 export { BlockIdFlag, CommitSignature, ValidatorEd25519Pubkey, ValidatorPubkey, ValidatorSecp256k1Pubkey, } from "./types";

build/index.js

@@ -26,3 +26,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.BlockIdFlag = exports.isTendermint37Client = exports.isTendermint34Client = exports.Tendermint37Client = exports.tendermint37 = exports.Tendermint34Client = exports.tendermint34 = exports.VoteType = exports.SubscriptionEventType = exports.Method = exports.broadcastTxSyncSuccess = exports.broadcastTxCommitSuccess = exports.WebsocketClient = exports.HttpClient = exports.HttpBatchClient = exports.toSeconds = exports.toRfc3339WithNanoseconds = exports.fromSeconds = exports.fromRfc3339WithNanoseconds = exports.DateTime = exports.rawSecp256k1PubkeyToRawAddress = exports.rawEd25519PubkeyToRawAddress = exports.pubkeyToRawAddress = exports.pubkeyToAddress = void 0;
+exports.BlockIdFlag = exports.isTendermint37Client = exports.isTendermint34Client = exports.isComet38Client = exports.connectComet = exports.Tendermint37Client = exports.tendermint37 = exports.Tendermint34Client = exports.tendermint34 = exports.VoteType = exports.SubscriptionEventType = exports.Method = exports.broadcastTxSyncSuccess = exports.broadcastTxCommitSuccess = exports.WebsocketClient = exports.HttpClient = exports.HttpBatchClient = exports.Comet38Client = exports.comet38 = exports.toSeconds = exports.toRfc3339WithNanoseconds = exports.fromSeconds = exports.fromRfc3339WithNanoseconds = exports.DateTime = exports.rawSecp256k1PubkeyToRawAddress = exports.rawEd25519PubkeyToRawAddress = exports.pubkeyToRawAddress = exports.pubkeyToAddress = void 0;
 var addresses_1 = require("./addresses");
@@ -42,2 +42,5 @@ Object.defineProperty(exports, "pubkeyToAddress", { enumerable: true, get: function () { return addresses_1.pubkeyToAddress; } });
 // Due to this API, we make RPC client implementations public.
+exports.comet38 = __importStar(require("./comet38"));
+var comet38_1 = require("./comet38");
+Object.defineProperty(exports, "Comet38Client", { enumerable: true, get: function () { return comet38_1.Comet38Client; } });
 var rpcclients_1 = require("./rpcclients");
@@ -60,2 +63,4 @@ Object.defineProperty(exports, "HttpBatchClient", { enumerable: true, get: function () { return rpcclients_1.HttpBatchClient; } });
 var tendermintclient_1 = require("./tendermintclient");
+Object.defineProperty(exports, "connectComet", { enumerable: true, get: function () { return tendermintclient_1.connectComet; } });
+Object.defineProperty(exports, "isComet38Client", { enumerable: true, get: function () { return tendermintclient_1.isComet38Client; } });
 Object.defineProperty(exports, "isTendermint34Client", { enumerable: true, get: function () { return tendermintclient_1.isTendermint34Client; } });
@@ -62,0 +67,0 @@ Object.defineProperty(exports, "isTendermint37Client", { enumerable: true, get: function () { return tendermintclient_1.isTendermint37Client; } });

build/tendermint34/adaptor/index.d.ts

@@ -1,3 +0,2 @@
-import { Adaptor } from "./types";
-export { Decoder, Encoder, Params, Responses } from "./types";
-export declare const adaptor34: Adaptor;
+export { Params } from "./requests";
+export { Responses } from "./responses";

build/tendermint34/adaptor/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.adaptor34 = void 0;
-const hasher_1 = require("../hasher");
-const requests_1 = require("./requests");
-const responses_1 = require("./responses");
-exports.adaptor34 = {
-    params: requests_1.Params,
-    responses: responses_1.Responses,
-    hashTx: hasher_1.hashTx,
-    hashBlock: hasher_1.hashBlock,
-};
+exports.Responses = exports.Params = void 0;
+var requests_1 = require("./requests");
+Object.defineProperty(exports, "Params", { enumerable: true, get: function () { return requests_1.Params; } });
+var responses_1 = require("./responses");
+Object.defineProperty(exports, "Responses", { enumerable: true, get: function () { return responses_1.Responses; } });
 //# sourceMappingURL=index.js.map

build/tendermint34/adaptor/responses.js

@@ -67,4 +67,4 @@ "use strict";
         events: data.events ? decodeEvents(data.events) : [],
-        gasWanted: (0, inthelpers_1.apiToSmallInt)(data.gas_wanted ?? "0"),
-        gasUsed: (0, inthelpers_1.apiToSmallInt)(data.gas_used ?? "0"),
+        gasWanted: (0, inthelpers_1.apiToBigInt)(data.gas_wanted ?? "0"),
+        gasUsed: (0, inthelpers_1.apiToBigInt)(data.gas_used ?? "0"),
     };
@@ -71,0 +71,0 @@ }

build/tendermint34/responses.d.ts

@@ -144,4 +144,4 @@ import { ReadonlyDate } from "readonly-date";
     readonly events: readonly Event[];
-    readonly gasWanted: number;
-    readonly gasUsed: number;
+    readonly gasWanted: bigint;
+    readonly gasUsed: bigint;
 }
@@ -148,0 +148,0 @@ export interface TxProof {

build/tendermint34/tendermint34client.d.ts

@@ -18,4 +18,2 @@ import { Stream } from "xstream";
     private readonly client;
-    private readonly p;
-    private readonly r;
     /**
@@ -22,0 +20,0 @@ * Use `Tendermint34Client.connect` or `Tendermint34Client.create` to create an instance.

build/tendermint34/tendermint34client.js

@@ -77,4 +77,2 @@ "use strict";
         this.client = client;
-        this.p = adaptor_1.adaptor34.params;
-        this.r = adaptor_1.adaptor34.responses;
     }
@@ -86,11 +84,11 @@ disconnect() {
         const query = { method: requests.Method.AbciInfo };
-        return this.doCall(query, this.p.encodeAbciInfo, this.r.decodeAbciInfo);
+        return this.doCall(query, adaptor_1.Params.encodeAbciInfo, adaptor_1.Responses.decodeAbciInfo);
     }
     async abciQuery(params) {
         const query = { params: params, method: requests.Method.AbciQuery };
-        return this.doCall(query, this.p.encodeAbciQuery, this.r.decodeAbciQuery);
+        return this.doCall(query, adaptor_1.Params.encodeAbciQuery, adaptor_1.Responses.decodeAbciQuery);
     }
     async block(height) {
         const query = { method: requests.Method.Block, params: { height: height } };
-        return this.doCall(query, this.p.encodeBlock, this.r.decodeBlock);
+        return this.doCall(query, adaptor_1.Params.encodeBlock, adaptor_1.Responses.decodeBlock);
     }
@@ -102,3 +100,3 @@ async blockResults(height) {
         };
-        return this.doCall(query, this.p.encodeBlockResults, this.r.decodeBlockResults);
+        return this.doCall(query, adaptor_1.Params.encodeBlockResults, adaptor_1.Responses.decodeBlockResults);
     }
@@ -115,3 +113,3 @@ /**
         const query = { params: params, method: requests.Method.BlockSearch };
-        const resp = await this.doCall(query, this.p.encodeBlockSearch, this.r.decodeBlockSearch);
+        const resp = await this.doCall(query, adaptor_1.Params.encodeBlockSearch, adaptor_1.Responses.decodeBlockSearch);
         return {
@@ -164,3 +162,3 @@ ...resp,
         };
-        return this.doCall(query, this.p.encodeBlockchain, this.r.decodeBlockchain);
+        return this.doCall(query, adaptor_1.Params.encodeBlockchain, adaptor_1.Responses.decodeBlockchain);
     }
@@ -174,3 +172,3 @@ /**
         const query = { params: params, method: requests.Method.BroadcastTxSync };
-        return this.doCall(query, this.p.encodeBroadcastTx, this.r.decodeBroadcastTxSync);
+        return this.doCall(query, adaptor_1.Params.encodeBroadcastTx, adaptor_1.Responses.decodeBroadcastTxSync);
     }
@@ -184,3 +182,3 @@ /**
         const query = { params: params, method: requests.Method.BroadcastTxAsync };
-        return this.doCall(query, this.p.encodeBroadcastTx, this.r.decodeBroadcastTxAsync);
+        return this.doCall(query, adaptor_1.Params.encodeBroadcastTx, adaptor_1.Responses.decodeBroadcastTxAsync);
     }
@@ -194,23 +192,23 @@ /**
         const query = { params: params, method: requests.Method.BroadcastTxCommit };
-        return this.doCall(query, this.p.encodeBroadcastTx, this.r.decodeBroadcastTxCommit);
+        return this.doCall(query, adaptor_1.Params.encodeBroadcastTx, adaptor_1.Responses.decodeBroadcastTxCommit);
     }
     async commit(height) {
         const query = { method: requests.Method.Commit, params: { height: height } };
-        return this.doCall(query, this.p.encodeCommit, this.r.decodeCommit);
+        return this.doCall(query, adaptor_1.Params.encodeCommit, adaptor_1.Responses.decodeCommit);
     }
     async genesis() {
         const query = { method: requests.Method.Genesis };
-        return this.doCall(query, this.p.encodeGenesis, this.r.decodeGenesis);
+        return this.doCall(query, adaptor_1.Params.encodeGenesis, adaptor_1.Responses.decodeGenesis);
     }
     async health() {
         const query = { method: requests.Method.Health };
-        return this.doCall(query, this.p.encodeHealth, this.r.decodeHealth);
+        return this.doCall(query, adaptor_1.Params.encodeHealth, adaptor_1.Responses.decodeHealth);
     }
     async numUnconfirmedTxs() {
         const query = { method: requests.Method.NumUnconfirmedTxs };
-        return this.doCall(query, this.p.encodeNumUnconfirmedTxs, this.r.decodeNumUnconfirmedTxs);
+        return this.doCall(query, adaptor_1.Params.encodeNumUnconfirmedTxs, adaptor_1.Responses.decodeNumUnconfirmedTxs);
     }
     async status() {
         const query = { method: requests.Method.Status };
-        return this.doCall(query, this.p.encodeStatus, this.r.decodeStatus);
+        return this.doCall(query, adaptor_1.Params.encodeStatus, adaptor_1.Responses.decodeStatus);
     }
@@ -222,3 +220,3 @@ subscribeNewBlock() {
         };
-        return this.subscribe(request, this.r.decodeNewBlockEvent);
+        return this.subscribe(request, adaptor_1.Responses.decodeNewBlockEvent);
     }
@@ -230,3 +228,3 @@ subscribeNewBlockHeader() {
         };
-        return this.subscribe(request, this.r.decodeNewBlockHeaderEvent);
+        return this.subscribe(request, adaptor_1.Responses.decodeNewBlockHeaderEvent);
     }
@@ -241,3 +239,3 @@ subscribeTx(query) {
         };
-        return this.subscribe(request, this.r.decodeTxEvent);
+        return this.subscribe(request, adaptor_1.Responses.decodeTxEvent);
     }
@@ -251,3 +249,3 @@ /**
         const query = { params: params, method: requests.Method.Tx };
-        return this.doCall(query, this.p.encodeTx, this.r.decodeTx);
+        return this.doCall(query, adaptor_1.Params.encodeTx, adaptor_1.Responses.decodeTx);
     }
@@ -261,3 +259,3 @@ /**
         const query = { params: params, method: requests.Method.TxSearch };
-        return this.doCall(query, this.p.encodeTxSearch, this.r.decodeTxSearch);
+        return this.doCall(query, adaptor_1.Params.encodeTxSearch, adaptor_1.Responses.decodeTxSearch);
     }
@@ -290,3 +288,3 @@ // this should paginate through all txSearch options to ensure it returns all results.
         };
-        return this.doCall(query, this.p.encodeValidators, this.r.decodeValidators);
+        return this.doCall(query, adaptor_1.Params.encodeValidators, adaptor_1.Responses.decodeValidators);
     }
@@ -331,3 +329,3 @@ async validatorsAll(height) {
         }
-        const req = this.p.encodeSubscribe(request);
+        const req = adaptor_1.Params.encodeSubscribe(request);
         const eventStream = this.client.listen(req);
@@ -334,0 +332,0 @@ return eventStream.map((event) => {

build/tendermint37/adaptor/index.d.ts

@@ -1,3 +0,2 @@
-import { Adaptor } from "./types";
-export { Decoder, Encoder, Params, Responses } from "./types";
-export declare const adaptor37: Adaptor;
+export { Params } from "./requests";
+export { Responses } from "./responses";

build/tendermint37/adaptor/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.adaptor37 = void 0;
-const hasher_1 = require("../hasher");
-const requests_1 = require("./requests");
-const responses_1 = require("./responses");
-exports.adaptor37 = {
-    params: requests_1.Params,
-    responses: responses_1.Responses,
-    hashTx: hasher_1.hashTx,
-    hashBlock: hasher_1.hashBlock,
-};
+exports.Responses = exports.Params = void 0;
+var requests_1 = require("./requests");
+Object.defineProperty(exports, "Params", { enumerable: true, get: function () { return requests_1.Params; } });
+var responses_1 = require("./responses");
+Object.defineProperty(exports, "Responses", { enumerable: true, get: function () { return responses_1.Responses; } });
 //# sourceMappingURL=index.js.map

build/tendermint37/adaptor/responses.js

@@ -67,4 +67,4 @@ "use strict";
         events: data.events ? decodeEvents(data.events) : [],
-        gasWanted: (0, inthelpers_1.apiToSmallInt)(data.gas_wanted ?? "0"),
-        gasUsed: (0, inthelpers_1.apiToSmallInt)(data.gas_used ?? "0"),
+        gasWanted: (0, inthelpers_1.apiToBigInt)(data.gas_wanted ?? "0"),
+        gasUsed: (0, inthelpers_1.apiToBigInt)(data.gas_used ?? "0"),
     };
@@ -71,0 +71,0 @@ }

build/tendermint37/responses.d.ts

@@ -149,4 +149,4 @@ import { ReadonlyDate } from "readonly-date";
     readonly events: readonly Event[];
-    readonly gasWanted: number;
-    readonly gasUsed: number;
+    readonly gasWanted: bigint;
+    readonly gasUsed: bigint;
 }
@@ -153,0 +153,0 @@ export interface TxProof {

build/tendermint37/tendermint37client.d.ts

@@ -18,4 +18,2 @@ import { Stream } from "xstream";
     private readonly client;
-    private readonly p;
-    private readonly r;
     /**
@@ -22,0 +20,0 @@ * Use `Tendermint37Client.connect` or `Tendermint37Client.create` to create an instance.

build/tendermint37/tendermint37client.js

@@ -77,4 +77,2 @@ "use strict";
         this.client = client;
-        this.p = adaptor_1.adaptor37.params;
-        this.r = adaptor_1.adaptor37.responses;
     }
@@ -86,11 +84,11 @@ disconnect() {
         const query = { method: requests.Method.AbciInfo };
-        return this.doCall(query, this.p.encodeAbciInfo, this.r.decodeAbciInfo);
+        return this.doCall(query, adaptor_1.Params.encodeAbciInfo, adaptor_1.Responses.decodeAbciInfo);
     }
     async abciQuery(params) {
         const query = { params: params, method: requests.Method.AbciQuery };
-        return this.doCall(query, this.p.encodeAbciQuery, this.r.decodeAbciQuery);
+        return this.doCall(query, adaptor_1.Params.encodeAbciQuery, adaptor_1.Responses.decodeAbciQuery);
     }
     async block(height) {
         const query = { method: requests.Method.Block, params: { height: height } };
-        return this.doCall(query, this.p.encodeBlock, this.r.decodeBlock);
+        return this.doCall(query, adaptor_1.Params.encodeBlock, adaptor_1.Responses.decodeBlock);
     }
@@ -102,3 +100,3 @@ async blockResults(height) {
         };
-        return this.doCall(query, this.p.encodeBlockResults, this.r.decodeBlockResults);
+        return this.doCall(query, adaptor_1.Params.encodeBlockResults, adaptor_1.Responses.decodeBlockResults);
     }
@@ -115,3 +113,3 @@ /**
         const query = { params: params, method: requests.Method.BlockSearch };
-        const resp = await this.doCall(query, this.p.encodeBlockSearch, this.r.decodeBlockSearch);
+        const resp = await this.doCall(query, adaptor_1.Params.encodeBlockSearch, adaptor_1.Responses.decodeBlockSearch);
         return {
@@ -164,3 +162,3 @@ ...resp,
         };
-        return this.doCall(query, this.p.encodeBlockchain, this.r.decodeBlockchain);
+        return this.doCall(query, adaptor_1.Params.encodeBlockchain, adaptor_1.Responses.decodeBlockchain);
     }
@@ -174,3 +172,3 @@ /**
         const query = { params: params, method: requests.Method.BroadcastTxSync };
-        return this.doCall(query, this.p.encodeBroadcastTx, this.r.decodeBroadcastTxSync);
+        return this.doCall(query, adaptor_1.Params.encodeBroadcastTx, adaptor_1.Responses.decodeBroadcastTxSync);
     }
@@ -184,3 +182,3 @@ /**
         const query = { params: params, method: requests.Method.BroadcastTxAsync };
-        return this.doCall(query, this.p.encodeBroadcastTx, this.r.decodeBroadcastTxAsync);
+        return this.doCall(query, adaptor_1.Params.encodeBroadcastTx, adaptor_1.Responses.decodeBroadcastTxAsync);
     }
@@ -194,23 +192,23 @@ /**
         const query = { params: params, method: requests.Method.BroadcastTxCommit };
-        return this.doCall(query, this.p.encodeBroadcastTx, this.r.decodeBroadcastTxCommit);
+        return this.doCall(query, adaptor_1.Params.encodeBroadcastTx, adaptor_1.Responses.decodeBroadcastTxCommit);
     }
     async commit(height) {
         const query = { method: requests.Method.Commit, params: { height: height } };
-        return this.doCall(query, this.p.encodeCommit, this.r.decodeCommit);
+        return this.doCall(query, adaptor_1.Params.encodeCommit, adaptor_1.Responses.decodeCommit);
     }
     async genesis() {
         const query = { method: requests.Method.Genesis };
-        return this.doCall(query, this.p.encodeGenesis, this.r.decodeGenesis);
+        return this.doCall(query, adaptor_1.Params.encodeGenesis, adaptor_1.Responses.decodeGenesis);
     }
     async health() {
         const query = { method: requests.Method.Health };
-        return this.doCall(query, this.p.encodeHealth, this.r.decodeHealth);
+        return this.doCall(query, adaptor_1.Params.encodeHealth, adaptor_1.Responses.decodeHealth);
     }
     async numUnconfirmedTxs() {
         const query = { method: requests.Method.NumUnconfirmedTxs };
-        return this.doCall(query, this.p.encodeNumUnconfirmedTxs, this.r.decodeNumUnconfirmedTxs);
+        return this.doCall(query, adaptor_1.Params.encodeNumUnconfirmedTxs, adaptor_1.Responses.decodeNumUnconfirmedTxs);
     }
     async status() {
         const query = { method: requests.Method.Status };
-        return this.doCall(query, this.p.encodeStatus, this.r.decodeStatus);
+        return this.doCall(query, adaptor_1.Params.encodeStatus, adaptor_1.Responses.decodeStatus);
     }
@@ -222,3 +220,3 @@ subscribeNewBlock() {
         };
-        return this.subscribe(request, this.r.decodeNewBlockEvent);
+        return this.subscribe(request, adaptor_1.Responses.decodeNewBlockEvent);
     }
@@ -230,3 +228,3 @@ subscribeNewBlockHeader() {
         };
-        return this.subscribe(request, this.r.decodeNewBlockHeaderEvent);
+        return this.subscribe(request, adaptor_1.Responses.decodeNewBlockHeaderEvent);
     }
@@ -241,3 +239,3 @@ subscribeTx(query) {
         };
-        return this.subscribe(request, this.r.decodeTxEvent);
+        return this.subscribe(request, adaptor_1.Responses.decodeTxEvent);
     }
@@ -251,3 +249,3 @@ /**
         const query = { params: params, method: requests.Method.Tx };
-        return this.doCall(query, this.p.encodeTx, this.r.decodeTx);
+        return this.doCall(query, adaptor_1.Params.encodeTx, adaptor_1.Responses.decodeTx);
     }
@@ -261,3 +259,3 @@ /**
         const query = { params: params, method: requests.Method.TxSearch };
-        return this.doCall(query, this.p.encodeTxSearch, this.r.decodeTxSearch);
+        return this.doCall(query, adaptor_1.Params.encodeTxSearch, adaptor_1.Responses.decodeTxSearch);
     }
@@ -290,3 +288,3 @@ // this should paginate through all txSearch options to ensure it returns all results.
         };
-        return this.doCall(query, this.p.encodeValidators, this.r.decodeValidators);
+        return this.doCall(query, adaptor_1.Params.encodeValidators, adaptor_1.Responses.decodeValidators);
     }
@@ -331,3 +329,3 @@ async validatorsAll(height) {
         }
-        const req = this.p.encodeSubscribe(request);
+        const req = adaptor_1.Params.encodeSubscribe(request);
         const eventStream = this.client.listen(req);
@@ -334,0 +332,0 @@ return eventStream.map((event) => {

build/tendermintclient.d.ts

@@ -0,6 +1,19 @@
+import { Comet38Client } from "./comet38";
+import { HttpEndpoint } from "./rpcclients";
 import { Tendermint34Client } from "./tendermint34";
 import { Tendermint37Client } from "./tendermint37";
-/** A TendermintClient is either a Tendermint34Client or a Tendermint37Client */
+/**
+ * A TendermintClient is either a Tendermint34Client or a Tendermint37Client
+ *
+ * @deprecated use `CometClient`
+ */
 export type TendermintClient = Tendermint34Client | Tendermint37Client;
-export declare function isTendermint34Client(client: TendermintClient): client is Tendermint34Client;
-export declare function isTendermint37Client(client: TendermintClient): client is Tendermint37Client;
+/** A CometClient is either a Tendermint34Client, Tendermint37Client or a Comet38Client */
+export type CometClient = Tendermint34Client | Tendermint37Client | Comet38Client;
+export declare function isTendermint34Client(client: CometClient): client is Tendermint34Client;
+export declare function isTendermint37Client(client: CometClient): client is Tendermint37Client;
+export declare function isComet38Client(client: CometClient): client is Comet38Client;
+/**
+ * Auto-detects the version of the backend and uses a suitable client.
+ */
+export declare function connectComet(endpoint: string | HttpEndpoint): Promise<CometClient>;

build/tendermintclient.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isTendermint37Client = exports.isTendermint34Client = void 0;
+exports.connectComet = exports.isComet38Client = exports.isTendermint37Client = exports.isTendermint34Client = void 0;
+const comet38_1 = require("./comet38");
 const tendermint34_1 = require("./tendermint34");
@@ -14,2 +15,29 @@ const tendermint37_1 = require("./tendermint37");
 exports.isTendermint37Client = isTendermint37Client;
+function isComet38Client(client) {
+    return client instanceof comet38_1.Comet38Client;
+}
+exports.isComet38Client = isComet38Client;
+/**
+ * Auto-detects the version of the backend and uses a suitable client.
+ */
+async function connectComet(endpoint) {
+    // Tendermint/CometBFT 0.34/0.37/0.38 auto-detection. Starting with 0.37 we seem to get reliable versions again 🎉
+    // Using 0.34 as the fallback.
+    let out;
+    const tm37Client = await tendermint37_1.Tendermint37Client.connect(endpoint);
+    const version = (await tm37Client.status()).nodeInfo.version;
+    if (version.startsWith("0.37.")) {
+        out = tm37Client;
+    }
+    else if (version.startsWith("0.38.")) {
+        tm37Client.disconnect();
+        out = await comet38_1.Comet38Client.connect(endpoint);
+    }
+    else {
+        tm37Client.disconnect();
+        out = await tendermint34_1.Tendermint34Client.connect(endpoint);
+    }
+    return out;
+}
+exports.connectComet = connectComet;
 //# sourceMappingURL=tendermintclient.js.map

package.json

 {
   "name": "@cosmjs/tendermint-rpc",
-  "version": "0.31.3",
+  "version": "0.32.0-rc.1",
   "description": "Tendermint RPC clients",
@@ -45,9 +45,9 @@ "contributors": [
   "dependencies": {
-    "@cosmjs/crypto": "^0.31.3",
-    "@cosmjs/encoding": "^0.31.3",
-    "@cosmjs/json-rpc": "^0.31.3",
-    "@cosmjs/math": "^0.31.3",
-    "@cosmjs/socket": "^0.31.3",
-    "@cosmjs/stream": "^0.31.3",
-    "@cosmjs/utils": "^0.31.3",
+    "@cosmjs/crypto": "^0.32.0-rc.1",
+    "@cosmjs/encoding": "^0.32.0-rc.1",
+    "@cosmjs/json-rpc": "^0.32.0-rc.1",
+    "@cosmjs/math": "^0.32.0-rc.1",
+    "@cosmjs/socket": "^0.32.0-rc.1",
+    "@cosmjs/stream": "^0.32.0-rc.1",
+    "@cosmjs/utils": "^0.32.0-rc.1",
     "axios": "^0.21.2",
@@ -91,3 +91,4 @@ "readonly-date": "^1.0.0",
     "webpack-cli": "^4.6.0"
-  }
+  },
+  "stableVersion": "0.31.3"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

422088

increased by36.96%

Number of package files

122

increased by20.79%

Lines of code

6897

increased by38.63%

Dependency changes

• + Added@cosmjs/crypto@0.32.4(transitive)

• + Added@cosmjs/encoding@0.32.4(transitive)

• + Added@cosmjs/json-rpc@0.32.4(transitive)

• + Added@cosmjs/math@0.32.4(transitive)

• + Added@cosmjs/socket@0.32.4(transitive)

• + Added@cosmjs/stream@0.32.4(transitive)

• + Added@cosmjs/utils@0.32.4(transitive)

• - Removed@cosmjs/crypto@0.31.3(transitive)

• - Removed@cosmjs/encoding@0.31.3(transitive)

• - Removed@cosmjs/json-rpc@0.31.3(transitive)

• - Removed@cosmjs/math@0.31.3(transitive)

• - Removed@cosmjs/socket@0.31.3(transitive)

• - Removed@cosmjs/stream@0.31.3(transitive)

• - Removed@cosmjs/utils@0.31.3(transitive)

• Updated@cosmjs/crypto@^0.32.0-rc.1

• Updated@cosmjs/encoding@^0.32.0-rc.1

• Updated@cosmjs/json-rpc@^0.32.0-rc.1

• Updated@cosmjs/math@^0.32.0-rc.1

• Updated@cosmjs/socket@^0.32.0-rc.1

• Updated@cosmjs/stream@^0.32.0-rc.1

• Updated@cosmjs/utils@^0.32.0-rc.1