Upgrade to SDK v0.43+

modules/src/application/mod.rs

@@ -1 +1,5 @@
 pub mod ics20_fungible_token_transfer;
+
+// TODO: These consts should move into the ICS27 namespace
+pub const ICS27_SEND_TYPE_URL: &str = "/cosmos.bank.v1beta1.MsgSend";
+pub const ICS27_REGISTER_TYPE_URL: &str = "/intertx.MsgRegister";

modules/src/ics02_client/msgs/create_client.rs

@@ -13,7 +13,7 @@ use crate::ics02_client::error::{Error, Kind};
 use crate::signer::Signer;
 use crate::tx_msg::Msg;
 
-pub(crate) const TYPE_URL: &str = "/ibc.core.client.v1.MsgCreateClient";
+pub const TYPE_URL: &str = "/ibc.core.client.v1.MsgCreateClient";
 
 /// A type of message that triggers the creation of a new on-chain (IBC) client.
 #[derive(Clone, Debug, PartialEq, Eq)]

modules/src/ics02_client/msgs/update_client.rs

@@ -13,7 +13,7 @@ use crate::ics24_host::identifier::ClientId;
 use crate::signer::Signer;
 use crate::tx_msg::Msg;
 
-pub(crate) const TYPE_URL: &str = "/ibc.core.client.v1.MsgUpdateClient";
+pub const TYPE_URL: &str = "/ibc.core.client.v1.MsgUpdateClient";
 
 /// A type of message that triggers the update of an on-chain (IBC) client with new headers.
 #[derive(Clone, Debug, PartialEq)] // TODO: Add Eq bound when possible

proto-compiler/README.md

@@ -15,7 +15,7 @@ cargo build --locked
 Run the following command to clone the Cosmos SDK and the IBC-Go repositories, and check out a specific commit:
 
 ```bash
-$ cargo run -- clone --out /tmp/cosmos --sdk-commit 7648bfca45b9d0897103ec739210607dce77c4fb --ibc-go-commit 333c1f338b2a14a1928a6f8ab64c37123c0e97b6
+$ cargo run -- clone --out /tmp/cosmos --sdk-commit 8cfa2c26738276d895caf9eb98b3f70616218e17 --ibc-go-commit d70f49c8f612d60f1b7e2f1d1f160f28988962e1
 ```
 
 Note:

proto-compiler/src/cmd/compile.rs

@@ -27,10 +27,9 @@ pub struct CompileCmd {
 
 impl CompileCmd {
     pub fn run(&self) {
-        let with_ibc = self.ibc.is_none();
         let tmp_sdk = TempDir::new("ibc-proto-sdk").unwrap();
         Self::output_version(&self.sdk, tmp_sdk.as_ref(), "COSMOS_SDK_COMMIT");
-        Self::compile_sdk_protos(&self.sdk, tmp_sdk.as_ref(), with_ibc);
+        Self::compile_sdk_protos(&self.sdk, tmp_sdk.as_ref(), self.ibc.clone());
 
         match &self.ibc {
             None => {
@@ -121,7 +120,7 @@ impl CompileCmd {
         }
     }
 
-    fn compile_sdk_protos(sdk_dir: &Path, out_dir: &Path, with_ibc: bool) {
+    fn compile_sdk_protos(sdk_dir: &Path, out_dir: &Path, ibc_dep: Option<PathBuf>) {
         println!(
             "[info ] Compiling Cosmos-SDK .proto files to Rust into '{}'...",
             out_dir.display()
@@ -130,7 +129,7 @@ impl CompileCmd {
         let root = env!("CARGO_MANIFEST_DIR");
 
         // Paths
-        let mut proto_paths = vec![
+        let proto_paths = vec![
             format!("{}/../proto/definitions/mock", root),
             format!("{}/proto/cosmos/auth", sdk_dir.display()),
             format!("{}/proto/cosmos/gov", sdk_dir.display()),
@@ -140,17 +139,18 @@ impl CompileCmd {
             format!("{}/proto/cosmos/upgrade", sdk_dir.display()),
         ];
 
-        if with_ibc {
-            // Use the IBC proto files from the SDK
-            proto_paths.push(format!("{}/proto/ibc", sdk_dir.display()));
-        }
 
-        let proto_includes_paths = [
+        let mut proto_includes_paths = vec![
             format!("{}/../proto", root),
             format!("{}/proto", sdk_dir.display()),
             format!("{}/third_party/proto", sdk_dir.display()),
         ];
 
+        if let Some(ibc_dir) = ibc_dep {
+            // Use the IBC proto files from the SDK
+            proto_includes_paths.push(format!("{}/proto", ibc_dir.display()),);
+        }
+
         // List available proto files
         let mut protos: Vec<PathBuf> = vec![];
         for proto_path in &proto_paths {

proto/src/prost/COSMOS_IBC_COMMIT

@@ -0,0 +1 @@
+d70f49c8f612d60f1b7e2f1d1f160f28988962e1

proto/src/prost/COSMOS_SDK_COMMIT

@@ -1 +1 @@
-7648bfca45b9d0897103ec739210607dce77c4fb
+8cfa2c26738276d895caf9eb98b3f70616218e17

proto/src/prost/cosmos.auth.v1beta1.rs

@@ -36,15 +36,22 @@ pub struct Params {
     #[prost(uint64, tag = "5")]
     pub sig_verify_cost_secp256k1: u64,
 }
-/// GenesisState defines the auth module's genesis state.
+/// QueryAccountsRequest is the request type for the Query/Accounts RPC method.
 #[derive(Clone, PartialEq, ::prost::Message)]
-pub struct GenesisState {
-    /// params defines all the paramaters of the module.
+pub struct QueryAccountsRequest {
+    /// pagination defines an optional pagination for the request.
     #[prost(message, optional, tag = "1")]
-    pub params: ::core::option::Option<Params>,
-    /// accounts are the accounts present at genesis.
-    #[prost(message, repeated, tag = "2")]
+    pub pagination: ::core::option::Option<super::super::base::query::v1beta1::PageRequest>,
+}
+/// QueryAccountsResponse is the response type for the Query/Accounts RPC method.
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct QueryAccountsResponse {
+    /// accounts are the existing accounts
+    #[prost(message, repeated, tag = "1")]
     pub accounts: ::prost::alloc::vec::Vec<::prost_types::Any>,
+    /// pagination defines the pagination in the response.
+    #[prost(message, optional, tag = "2")]
+    pub pagination: ::core::option::Option<super::super::base::query::v1beta1::PageResponse>,
 }
 /// QueryAccountRequest is the request type for the Query/Account RPC method.
 #[derive(Clone, PartialEq, ::prost::Message)]
@@ -104,6 +111,21 @@ pub mod query_client {
             let inner = tonic::client::Grpc::with_interceptor(inner, interceptor);
             Self { inner }
         }
+        #[doc = " Accounts returns all the existing accounts"]
+        pub async fn accounts(
+            &mut self,
+            request: impl tonic::IntoRequest<super::QueryAccountsRequest>,
+        ) -> Result<tonic::Response<super::QueryAccountsResponse>, tonic::Status> {
+            self.inner.ready().await.map_err(|e| {
+                tonic::Status::new(
+                    tonic::Code::Unknown,
+                    format!("Service was not ready: {}", e.into()),
+                )
+            })?;
+            let codec = tonic::codec::ProstCodec::default();
+            let path = http::uri::PathAndQuery::from_static("/cosmos.auth.v1beta1.Query/Accounts");
+            self.inner.unary(request.into_request(), path, codec).await
+        }
         #[doc = " Account returns account details based on address."]
         pub async fn account(
             &mut self,
@@ -148,3 +170,13 @@ pub mod query_client {
         }
     }
 }
+/// GenesisState defines the auth module's genesis state.
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct GenesisState {
+    /// params defines all the paramaters of the module.
+    #[prost(message, optional, tag = "1")]
+    pub params: ::core::option::Option<Params>,
+    /// accounts are the accounts present at genesis.
+    #[prost(message, repeated, tag = "2")]
+    pub accounts: ::prost::alloc::vec::Vec<::prost_types::Any>,
+}

proto/src/prost/cosmos.base.query.v1beta1.rs

@@ -27,6 +27,9 @@ pub struct PageRequest {
     /// is set.
     #[prost(bool, tag = "4")]
     pub count_total: bool,
+    /// reverse is set to true indicates that, results to be returned in the descending order.
+    #[prost(bool, tag = "5")]
+    pub reverse: bool,
 }
 /// PageResponse is to be embedded in gRPC response messages where the
 /// corresponding request message has used PageRequest.

proto/src/prost/cosmos.base.store.v1beta1.rs

@@ -1,3 +1,30 @@
+/// CommitInfo defines commit information used by the multi-store when committing
+/// a version/height.
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct CommitInfo {
+    #[prost(int64, tag = "1")]
+    pub version: i64,
+    #[prost(message, repeated, tag = "2")]
+    pub store_infos: ::prost::alloc::vec::Vec<StoreInfo>,
+}
+/// StoreInfo defines store-specific commit information. It contains a reference
+/// between a store name and the commit ID.
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct StoreInfo {
+    #[prost(string, tag = "1")]
+    pub name: ::prost::alloc::string::String,
+    #[prost(message, optional, tag = "2")]
+    pub commit_id: ::core::option::Option<CommitId>,
+}
+/// CommitID defines the committment information when a specific store is
+/// committed.
+#[derive(Clone, PartialEq, ::prost::Message)]
+pub struct CommitId {
+    #[prost(int64, tag = "1")]
+    pub version: i64,
+    #[prost(bytes = "vec", tag = "2")]
+    pub hash: ::prost::alloc::vec::Vec<u8>,
+}
 /// SnapshotItem is an item contained in a rootmulti.Store snapshot.
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct SnapshotItem {
@@ -34,30 +61,19 @@ pub struct SnapshotIavlItem {
     #[prost(int32, tag = "4")]
     pub height: i32,
 }
-/// CommitInfo defines commit information used by the multi-store when committing
-/// a version/height.
+/// StoreKVPair is a KVStore KVPair used for listening to state changes (Sets and Deletes)
+/// It optionally includes the StoreKey for the originating KVStore and a Boolean flag to distinguish between Sets and
+/// Deletes
 #[derive(Clone, PartialEq, ::prost::Message)]
-pub struct CommitInfo {
-    #[prost(int64, tag = "1")]
-    pub version: i64,
-    #[prost(message, repeated, tag = "2")]
-    pub store_infos: ::prost::alloc::vec::Vec<StoreInfo>,
-}
-/// StoreInfo defines store-specific commit information. It contains a reference
-/// between a store name and the commit ID.
-#[derive(Clone, PartialEq, ::prost::Message)]
-pub struct StoreInfo {
+pub struct StoreKvPair {
+    /// the store key for the KVStore this pair originates from
     #[prost(string, tag = "1")]
-    pub name: ::prost::alloc::string::String,
-    #[prost(message, optional, tag = "2")]
-    pub commit_id: ::core::option::Option<CommitId>,
-}
-/// CommitID defines the committment information when a specific store is
-/// committed.
-#[derive(Clone, PartialEq, ::prost::Message)]
-pub struct CommitId {
-    #[prost(int64, tag = "1")]
-    pub version: i64,
-    #[prost(bytes = "vec", tag = "2")]
-    pub hash: ::prost::alloc::vec::Vec<u8>,
+    pub store_key: ::prost::alloc::string::String,
+    /// true indicates a delete operation, false indicates a set operation
+    #[prost(bool, tag = "2")]
+    pub delete: bool,
+    #[prost(bytes = "vec", tag = "3")]
+    pub key: ::prost::alloc::vec::Vec<u8>,
+    #[prost(bytes = "vec", tag = "4")]
+    pub value: ::prost::alloc::vec::Vec<u8>,
 }