build!: upgrade MSRV to v1.89

Author: paolobarbolini

.github/workflows/ci.yml

@@ -70,8 +70,8 @@ jobs:
             rust: beta
           - name: nightly
             rust: nightly
-          - name: 1.85.0
-            rust: 1.85.0
+          - name: 1.89.0
+            rust: 1.89.0
 
     steps:
       - uses: actions/checkout@v5

Cargo.toml

@@ -13,7 +13,7 @@ resolver = "2"
 edition = "2024"
 license = "MIT OR Apache-2.0"
 repository = "https://github.com/M4SS-Code/watermelon"
-rust-version = "1.85"
+rust-version = "1.89"
 
 [workspace.lints.rust]
 unsafe_code = "deny"

watermelon-mini/src/proto/connector.rs

@@ -198,12 +198,9 @@ pub(crate) async fn connect(
         #[cfg(feature = "non-standard-zstd")]
         match conn {
             Connection::Streaming(streaming) => {
-                if zstd {
-                    if let Some(zstd_compression_level) = flags.zstd_compression_level {
-                        let stream = streaming.socket_mut().0.take().unwrap();
-                        streaming.socket_mut().0 =
-                            Some(stream.upgrade_zstd(zstd_compression_level));
-                    }
+                if zstd && let Some(zstd_compression_level) = flags.zstd_compression_level {
+                    let stream = streaming.socket_mut().0.take().unwrap();
+                    streaming.socket_mut().0 = Some(stream.upgrade_zstd(zstd_compression_level));
                 }
             }
             Connection::Websocket(_websocket) => {}

watermelon-proto/src/headers/name.rs

@@ -82,10 +82,10 @@ impl HeaderName {
     )]
     #[must_use]
     pub fn from_dangerous_value(value: ByteString) -> Self {
-        if cfg!(debug_assertions) {
-            if let Err(err) = validate_header_name(&value) {
-                panic!("HeaderName {value:?} isn't valid {err:?}");
-            }
+        if cfg!(debug_assertions)
+            && let Err(err) = validate_header_name(&value)
+        {
+            panic!("HeaderName {value:?} isn't valid {err:?}");
         }
         Self(UniCase::new(value))
     }

watermelon-proto/src/headers/value.rs

@@ -53,10 +53,10 @@ impl HeaderValue {
         reason = "The header validation is only made in debug"
     )]
     pub fn from_dangerous_value(value: ByteString) -> Self {
-        if cfg!(debug_assertions) {
-            if let Err(err) = validate_header_value(&value) {
-                panic!("HeaderValue {value:?} isn't valid {err:?}");
-            }
+        if cfg!(debug_assertions)
+            && let Err(err) = validate_header_value(&value)
+        {
+            panic!("HeaderValue {value:?} isn't valid {err:?}");
         }
         Self(value)
     }

watermelon-proto/src/queue_group.rs

@@ -54,10 +54,10 @@ impl QueueGroup {
         reason = "The queue group validation is only made in debug"
     )]
     pub fn from_dangerous_value(value: ByteString) -> Self {
-        if cfg!(debug_assertions) {
-            if let Err(err) = validate_queue_group(&value) {
-                panic!("QueueGroup {value:?} isn't valid {err:?}");
-            }
+        if cfg!(debug_assertions)
+            && let Err(err) = validate_queue_group(&value)
+        {
+            panic!("QueueGroup {value:?} isn't valid {err:?}");
         }
         Self(value)
     }

watermelon-proto/src/subject.rs

@@ -55,10 +55,10 @@ impl Subject {
     )]
     #[must_use]
     pub fn from_dangerous_value(value: ByteString) -> Self {
-        if cfg!(debug_assertions) {
-            if let Err(err) = validate_subject(&value) {
-                panic!("Subject {value:?} isn't valid {err:?}");
-            }
+        if cfg!(debug_assertions)
+            && let Err(err) = validate_subject(&value)
+        {
+            panic!("Subject {value:?} isn't valid {err:?}");
         }
         Self(value)
     }