fix: bump MSRV to 1.71.1

.changelog/unreleased/breaking-changes/1118-bump-msrv.md

@@ -0,0 +1,2 @@
+- [ibc] Increase minimum supported Rust version to 1.71.1
+  ([\#1118](https://github.com/cosmos/ibc-rs/issues/1118))

.changelog/unreleased/improvements/1101-use-let-else-over-downcast.md

@@ -0,0 +1,2 @@
+- [ibc-primitives] use `let-else` over `downcast!()` and remove `utils/macros`
+  module as a result ([\#1118](https://github.com/cosmos/ibc-rs/issues/1118))

.github/workflows/rust.yml

@@ -157,3 +157,48 @@ jobs:
         with:
           command: test
           args: --no-default-features --no-fail-fast --no-run
+
+  test-msrv:
+    timeout-minutes: 30
+    env:
+      CARGO_MSRV_VERSION: 0.16.0-beta.20
+      MSRV: 1.71.1
+    strategy:
+      matrix:
+        param:
+          [
+            { os: ubuntu-latest, system: unknown-linux-gnu },
+            { os: macos-latest, system: apple-darwin },
+          ]
+    runs-on: ${{ matrix.param.os }}
+    steps:
+      - uses: actions/checkout@v2
+
+      - name: Download cargo-msrv
+        uses: dsaltares/fetch-gh-release-asset@master
+        with:
+          repo: foresterre/cargo-msrv
+          version: "tags/v${{ env.CARGO_MSRV_VERSION }}"
+          file: "cargo-msrv-x86_64-${{ matrix.param.system }}-v${{ env.CARGO_MSRV_VERSION }}.tgz"
+
+      - uses: actions-rs/toolchain@v1
+        with:
+          toolchain: ${{ env.MSRV }}
+          override: true
+      - uses: Swatinem/rust-cache@v1
+
+      - name: Install cargo-msrv
+        run: |
+          tar -xzf "cargo-msrv-x86_64-${{ matrix.param.system }}-v${{ env.CARGO_MSRV_VERSION }}.tgz"
+          mv "cargo-msrv-x86_64-${{ matrix.param.system }}-v${{ env.CARGO_MSRV_VERSION }}/cargo-msrv" ~/.cargo/bin
+          cargo msrv --version
+
+      - name: Calculate MSRV
+        run: cargo msrv --output-format minimal --min 1.64.0
+
+      - name: Build with MSRV
+        uses: actions-rs/cargo@v1
+        with:
+          toolchain: ${{ env.MSRV }}
+          command: build
+          args: --all-features

Cargo.toml

@@ -43,7 +43,7 @@ exclude = [
 version      = "0.50.0"
 license      = "Apache-2.0"
 edition      = "2021"
-rust-version = "1.64"
+rust-version = "1.71.1"
 readme       = "README.md"
 repository   = "https://github.com/cosmos/ibc-rs"
 authors      = ["Informal Systems <hello@informal.systems>"]

README.md

@@ -16,9 +16,9 @@
 [![Build Status][build-image]][build-link]
 [![Code Coverage][codecov-image]][codecov-link]
 [![Apache 2.0 Licensed][license-image]][license-link]
-![Rust Stable][rustc-image]
-![Rust 1.64+][rustc-version]
-![Lines of Code][loc-image]
+![Version][crates-io-version]
+![Downloads][crates-io-downloads]
+![Rust Stable][msrv-image]
 
 </div>
 </div>
@@ -94,11 +94,11 @@ specific language governing permissions and limitations under the License.
 [build-link]: https://github.com/cosmos/ibc-rs/actions?query=workflow%3ARust
 [codecov-image]: https://codecov.io/gh/cosmos/ibc-rs/branch/main/graph/badge.svg?token=wUm2aLCOu
 [codecov-link]: https://codecov.io/gh/cosmos/ibc-rs
-[loc-image]: https://tokei.rs/b1/github/cosmos/ibc-rs
-[license-image]: https://img.shields.io/badge/license-Apache2.0-blue.svg
+[license-image]: https://img.shields.io/crates/l/ibc
 [license-link]: https://github.com/cosmos/ibc-rs/blob/main/LICENSE
-[rustc-image]: https://img.shields.io/badge/rustc-stable-blue.svg
-[rustc-version]: https://img.shields.io/badge/rustc-1.60+-blue.svg
+[crates-io-version]: https://img.shields.io/crates/v/ibc.svg
+[crates-io-downloads]: https://img.shields.io/crates/d/ibc.svg
+[msrv-image]: https://img.shields.io/crates/msrv/ibc
 
 [//]: # (general links)
 [ibc]: https://github.com/cosmos/ibc

ibc-apps/ics20-transfer/src/module.rs

@@ -170,13 +170,10 @@
     ctx_b: &mut impl TokenTransferExecutionContext,
     packet: &Packet,
 ) -> (ModuleExtras, Acknowledgement) {
-    let data = match serde_json::from_slice::<PacketData>(&packet.data) {
-        Ok(data) => data,
-        Err(_) => {
-            let ack =
-                AcknowledgementStatus::error(TokenTransferError::PacketDataDeserialization.into());
-            return (ModuleExtras::empty(), ack.into());
-        }
+    let Ok(data) = serde_json::from_slice::<PacketData>(&packet.data) else {
+        let ack =
+            AcknowledgementStatus::error(TokenTransferError::PacketDataDeserialization.into());
+        return (ModuleExtras::empty(), ack.into());
     };
 
     let (mut extras, ack) = match process_recv_packet_execute(ctx_b, packet, data.clone()) {
@@ -225,26 +222,21 @@
     acknowledgement: &Acknowledgement,
     _relayer: &Signer,
 ) -> (ModuleExtras, Result<(), TokenTransferError>) {
-    let data = match serde_json::from_slice::<PacketData>(&packet.data) {
-        Ok(data) => data,
-        Err(_) => {
-            return (
-                ModuleExtras::empty(),
-                Err(TokenTransferError::PacketDataDeserialization),
-            );
-        }
+    let Ok(data) = serde_json::from_slice::<PacketData>(&packet.data) else {
+        return (
+            ModuleExtras::empty(),
+            Err(TokenTransferError::PacketDataDeserialization),
+        );
     };
 
-    let acknowledgement =
-        match serde_json::from_slice::<AcknowledgementStatus>(acknowledgement.as_ref()) {
-            Ok(ack) => ack,
-            Err(_) => {
-                return (
-                    ModuleExtras::empty(),
-                    Err(TokenTransferError::AckDeserialization),
-                );
-            }
-        };
+    let Ok(acknowledgement) =
+        serde_json::from_slice::<AcknowledgementStatus>(acknowledgement.as_ref())
+    else {
+        return (
+            ModuleExtras::empty(),
+            Err(TokenTransferError::AckDeserialization),
+        );
+    };
 
     if !acknowledgement.is_successful() {
         if let Err(err) = refund_packet_token_execute(ctx, packet, &data) {
@@ -290,14 +282,11 @@
     packet: &Packet,
     _relayer: &Signer,
 ) -> (ModuleExtras, Result<(), TokenTransferError>) {
-    let data = match serde_json::from_slice::<PacketData>(&packet.data) {
-        Ok(data) => data,
-        Err(_) => {
-            return (
-                ModuleExtras::empty(),
-                Err(TokenTransferError::PacketDataDeserialization),
-            );
-        }
+    let Ok(data) = serde_json::from_slice::<PacketData>(&packet.data) else {
+        return (
+            ModuleExtras::empty(),
+            Err(TokenTransferError::PacketDataDeserialization),
+        );
     };
 
     if let Err(err) = refund_packet_token_execute(ctx, packet, &data) {
@@ -347,7 +336,7 @@
         // Check that it's the same output as ibc-go
         // Note: this also implicitly checks that the ack bytes are non-empty,
         // which would make the conversion to `Acknowledgement` panic
-        assert_eq!(ack_success, r#"{"result":"AQ=="}"#.as_bytes());
+        assert_eq!(ack_success, br#"{"result":"AQ=="}"#);
     }
 
     #[test]
@@ -361,7 +350,7 @@
         // which would make the conversion to `Acknowledgement` panic
         assert_eq!(
             ack_error,
-            r#"{"error":"failed to deserialize packet data"}"#.as_bytes()
+            br#"{"error":"failed to deserialize packet data"}"#
         );
     }
 

ibc-apps/ics20-transfer/types/src/error.rs

@@ -84,12 +84,12 @@
     fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
         match &self {
             Self::ContextError(e) => Some(e),
-            Self::InvalidIdentifier(e) => Some(e),
-            Self::InvalidTracePortId {
+            Self::InvalidIdentifier(e)
+            | Self::InvalidTracePortId {
                 validation_error: e,
                 ..
-            } => Some(e),
-            Self::InvalidTraceChannelId {
+            }
+            | Self::InvalidTraceChannelId {
                 validation_error: e,
                 ..
             } => Some(e),

ibc-apps/ics721-nft-transfer/src/module.rs

@@ -172,13 +172,9 @@
     ctx_b: &mut impl NftTransferExecutionContext,
     packet: &Packet,
 ) -> (ModuleExtras, Acknowledgement) {
-    let data = match serde_json::from_slice::<PacketData>(&packet.data) {
-        Ok(data) => data,
-        Err(_) => {
-            let ack =
-                AcknowledgementStatus::error(NftTransferError::PacketDataDeserialization.into());
-            return (ModuleExtras::empty(), ack.into());
-        }
+    let Ok(data) = serde_json::from_slice::<PacketData>(&packet.data) else {
+        let ack = AcknowledgementStatus::error(NftTransferError::PacketDataDeserialization.into());
+        return (ModuleExtras::empty(), ack.into());
     };
 
     let (mut extras, ack) = match process_recv_packet_execute(ctx_b, packet, data.clone()) {
@@ -227,26 +223,21 @@
     acknowledgement: &Acknowledgement,
     _relayer: &Signer,
 ) -> (ModuleExtras, Result<(), NftTransferError>) {
-    let data = match serde_json::from_slice::<PacketData>(&packet.data) {
-        Ok(data) => data,
-        Err(_) => {
-            return (
-                ModuleExtras::empty(),
-                Err(NftTransferError::PacketDataDeserialization),
-            );
-        }
+    let Ok(data) = serde_json::from_slice::<PacketData>(&packet.data) else {
+        return (
+            ModuleExtras::empty(),
+            Err(NftTransferError::PacketDataDeserialization),
+        );
     };
 
-    let acknowledgement =
-        match serde_json::from_slice::<AcknowledgementStatus>(acknowledgement.as_ref()) {
-            Ok(ack) => ack,
-            Err(_) => {
-                return (
-                    ModuleExtras::empty(),
-                    Err(NftTransferError::AckDeserialization),
-                );
-            }
-        };
+    let Ok(acknowledgement) =
+        serde_json::from_slice::<AcknowledgementStatus>(acknowledgement.as_ref())
+    else {
+        return (
+            ModuleExtras::empty(),
+            Err(NftTransferError::AckDeserialization),
+        );
+    };
 
     if !acknowledgement.is_successful() {
         if let Err(err) = refund_packet_nft_execute(ctx, packet, &data) {
@@ -289,14 +280,11 @@
     packet: &Packet,
     _relayer: &Signer,
 ) -> (ModuleExtras, Result<(), NftTransferError>) {
-    let data = match serde_json::from_slice::<PacketData>(&packet.data) {
-        Ok(data) => data,
-        Err(_) => {
-            return (
-                ModuleExtras::empty(),
-                Err(NftTransferError::PacketDataDeserialization),
-            );
-        }
+    let Ok(data) = serde_json::from_slice::<PacketData>(&packet.data) else {
+        return (
+            ModuleExtras::empty(),
+            Err(NftTransferError::PacketDataDeserialization),
+        );
     };
 
     if let Err(err) = refund_packet_nft_execute(ctx, packet, &data) {
@@ -346,7 +334,7 @@
         // Check that it's the same output as ibc-go
         // Note: this also implicitly checks that the ack bytes are non-empty,
         // which would make the conversion to `Acknowledgement` panic
-        assert_eq!(ack_success, r#"{"result":"AQ=="}"#.as_bytes());
+        assert_eq!(ack_success, br#"{"result":"AQ=="}"#);
     }
 
     #[test]
@@ -359,7 +347,7 @@
         // which would make the conversion to `Acknowledgement` panic
         assert_eq!(
             ack_error,
-            r#"{"error":"failed to deserialize packet data"}"#.as_bytes()
+            br#"{"error":"failed to deserialize packet data"}"#
         );
     }
 

ibc-apps/ics721-nft-transfer/types/src/data.rs

@@ -161,7 +161,7 @@ impl borsh::BorshSerialize for DataValue {
             Some(mime) => mime.to_string(),
             None => String::default(),
         };
-        borsh::BorshSerialize::serialize(&mime.to_string(), writer)?;
+        borsh::BorshSerialize::serialize(&mime, writer)?;
         Ok(())
     }
 }

ibc-apps/ics721-nft-transfer/types/src/error.rs

@@ -97,16 +97,16 @@
     fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
         match &self {
             Self::ContextError(e) => Some(e),
-            Self::InvalidIdentifier(e) => Some(e),
             Self::InvalidUri {
                 validation_error: e,
                 ..
             } => Some(e),
-            Self::InvalidTracePortId {
+            Self::InvalidIdentifier(e)
+            | Self::InvalidTracePortId {
                 validation_error: e,
                 ..
-            } => Some(e),
-            Self::InvalidTraceChannelId {
+            }
+            | Self::InvalidTraceChannelId {
                 validation_error: e,
                 ..
             } => Some(e),

ibc-clients/ics07-tendermint/src/client_state.rs

@@ -85,7 +85,6 @@ mod tests {
     use ibc_core_client::types::Height;
     use ibc_core_commitment_types::specs::ProofSpecs;
     use ibc_core_host::types::identifiers::ChainId;
-    use tests::common::validate_proof_height;
 
     use super::*;
 
@@ -109,7 +108,7 @@ mod tests {
             id: ChainId::new("ibc-1").unwrap(),
             trust_level: TrustThreshold::ONE_THIRD,
             trusting_period: Duration::new(64000, 0),
-            unbonding_period: Duration::new(128000, 0),
+            unbonding_period: Duration::new(128_000, 0),
             max_clock_drift: Duration::new(3, 0),
             latest_height: Height::new(1, 10).expect("Never fails"),
             proof_specs: ProofSpecs::default(),

ibc-clients/ics07-tendermint/src/client_state/execution.rs

@@ -259,7 +259,7 @@
     // this consensus state should not be used for packet verification as
     // the root is empty. The next consensus state submitted using update
     // will be usable for packet-verification.
-    let sentinel_root = "sentinel_root".as_bytes().to_vec();
+    let sentinel_root = b"sentinel_root".to_vec();
     let new_consensus_state = ConsensusStateType::new(
         sentinel_root.into(),
         upgraded_tm_cons_state.timestamp(),