Upgrade to Rust 1.62.0

.github/workflows/ci.yml

@@ -9,7 +9,7 @@ on:
   workflow_call:
 
 env:
-  rust_version: 1.61.0
+  rust_version: 1.62.0
   rust_toolchain_components: clippy,rustfmt
 
 jobs:

.github/workflows/pull-request-bot.yml

@@ -28,7 +28,7 @@ concurrency:
 
 env:
   java_version: 11
-  rust_version: 1.61.0
+  rust_version: 1.62.0
   rust_toolchain_components: clippy,rustfmt
   apt_dependencies: libssl-dev gnuplot jq
 

.github/workflows/release.yml

@@ -10,7 +10,7 @@ concurrency:
   cancel-in-progress: true
 
 env:
-  rust_version: 1.61.0
+  rust_version: 1.62.0
 
 name: Release smithy-rs
 on:

aws/rust-runtime/aws-endpoint/src/lib.rs

@@ -283,8 +283,7 @@ mod test {
             props.insert(region.clone());
             props.insert(SigningService::from_static("qldb"));
             props.insert(
-                EndpointShim::from_arc(provider)
-                    .resolve_endpoint(&Params::new(Some(region.clone()))),
+                EndpointShim::from_arc(provider).resolve_endpoint(&Params::new(Some(region))),
             );
         };
         let req = AwsEndpointStage.apply(req).expect("should succeed");
@@ -314,8 +313,7 @@ mod test {
             props.insert(region.clone());
             props.insert(SigningService::from_static("qldb"));
             props.insert(
-                EndpointShim::from_arc(provider)
-                    .resolve_endpoint(&Params::new(Some(region.clone()))),
+                EndpointShim::from_arc(provider).resolve_endpoint(&Params::new(Some(region))),
             );
         };
         let req = AwsEndpointStage.apply(req).expect("should succeed");

aws/rust-runtime/aws-http/src/content_encoding.rs

@@ -376,7 +376,7 @@ mod tests {
 
     impl SputteringBody {
         fn len(&self) -> usize {
-            self.parts.iter().flat_map(|b| b).map(|b| b.len()).sum()
+            self.parts.iter().flatten().map(|b| b.len()).sum()
         }
     }
 
@@ -462,7 +462,7 @@ mod tests {
         };
 
         let timeout_duration = Duration::from_secs(3);
-        if let Err(_) = tokio::time::timeout(timeout_duration, test_fut).await {
+        if (tokio::time::timeout(timeout_duration, test_fut).await).is_err() {
             panic!("test_aws_chunked_encoding timed out after {timeout_duration:?}");
         }
     }
@@ -513,7 +513,7 @@ mod tests {
         };
 
         let timeout_duration = Duration::from_secs(3);
-        if let Err(_) = tokio::time::timeout(timeout_duration, test_fut).await {
+        if (tokio::time::timeout(timeout_duration, test_fut).await).is_err() {
             panic!(
                 "test_aws_chunked_encoding_sputtering_body timed out after {timeout_duration:?}"
             );

aws/rust-runtime/aws-http/src/recursion_detection.rs

@@ -160,7 +160,7 @@ mod test {
             )
         }
         assert_ok(validate_headers(
-            &augmented_req.http().headers(),
+            augmented_req.http().headers(),
             test_case.request_headers_after(),
         ))
     }

aws/rust-runtime/aws-http/src/retry.rs

@@ -143,7 +143,7 @@ mod test {
     ) -> Result<SdkSuccess<()>, SdkError<E>> {
         Err(SdkError::ServiceError {
             err,
-            raw: operation::Response::new(raw.map(|b| SdkBody::from(b))),
+            raw: operation::Response::new(raw.map(SdkBody::from)),
         })
     }
 
@@ -265,9 +265,7 @@ mod test {
             policy.classify_retry(
                 Result::<SdkSuccess<()>, SdkError<UnmodeledError>>::Err(SdkError::ResponseError {
                     err: Box::new(UnmodeledError),
-                    raw: operation::Response::new(
-                        http::Response::new("OK").map(|b| SdkBody::from(b))
-                    ),
+                    raw: operation::Response::new(http::Response::new("OK").map(SdkBody::from)),
                 })
                 .as_ref()
             ),

aws/rust-runtime/aws-inlineable/src/http_body_checksum.rs

@@ -265,7 +265,7 @@ mod tests {
         for i in 0..10000 {
             let line = format!("This is a large file created for testing purposes {}", i);
             file.as_file_mut().write(line.as_bytes()).unwrap();
-            crc32c_checksum.update(&line.as_bytes());
+            crc32c_checksum.update(line.as_bytes());
         }
 
         let body = ByteStream::read_from()

aws/rust-runtime/aws-inlineable/tests/middleware_e2e_test.rs

@@ -82,7 +82,7 @@ fn test_operation() -> Operation<TestOperationParser, AwsResponseRetryClassifier
             .body(SdkBody::from("request body"))
             .unwrap(),
     )
-    .augment(|req, mut conf| {
+    .augment(|req, conf| {
         conf.insert(
             EndpointShim::from_resolver(aws_endpoint::partition::endpoint::Metadata {
                 uri_template: "test-service.{region}.amazonaws.com",
@@ -93,7 +93,7 @@ fn test_operation() -> Operation<TestOperationParser, AwsResponseRetryClassifier
             .resolve_endpoint(&Params::new(Some(Region::new("test-region")))),
         );
         aws_http::auth::set_provider(
-            &mut conf,
+            conf,
             SharedCredentialsProvider::new(Credentials::new(
                 "access_key",
                 "secret_key",

aws/rust-runtime/aws-sigv4/src/event_stream.rs

@@ -159,7 +159,7 @@ mod tests {
             security_token: None,
             region: "us-east-1",
             service_name: "testservice",
-            time: (UNIX_EPOCH + Duration::new(123_456_789_u64, 1234u32)).into(),
+            time: (UNIX_EPOCH + Duration::new(123_456_789_u64, 1234u32)),
             settings: (),
         };
 
@@ -197,7 +197,7 @@ mod tests {
             security_token: None,
             region: "us-east-1",
             service_name: "testservice",
-            time: (UNIX_EPOCH + Duration::new(123_456_789_u64, 1234u32)).into(),
+            time: (UNIX_EPOCH + Duration::new(123_456_789_u64, 1234u32)),
             settings: (),
         };
 

aws/rust-runtime/aws-sigv4/src/http_request/canonical_request.rs

@@ -597,7 +597,7 @@ mod tests {
             region: "us-east-1",
             service: "iam",
         };
-        assert_eq!(format!("{}\n", scope.to_string()), expected);
+        assert_eq!(format!("{}\n", scope), expected);
     }
 
     #[test]

aws/rust-runtime/aws-sigv4/src/http_request/settings.rs

@@ -10,7 +10,7 @@ use std::time::Duration;
 pub type SigningParams<'a> = crate::SigningParams<'a, SigningSettings>;
 
 /// HTTP-specific signing settings
-#[derive(Debug, PartialEq)]
+#[derive(Debug, PartialEq, Eq)]
 #[non_exhaustive]
 pub struct SigningSettings {
     /// Specifies how to encode the request URL when signing. Some services do not decode

gradle.properties

@@ -4,7 +4,7 @@
 #
 
 # Rust MSRV (entered into the generated README)
-rust.msrv=1.61.0
+rust.msrv=1.62.0
 
 org.gradle.jvmargs=-Xmx1024M
 

rust-runtime/aws-smithy-async/src/future/fn_stream.rs

@@ -200,7 +200,7 @@ mod test {
             Box::pin(async move {
                 for i in 0..5 {
                     if i != 2 {
-                        if let Err(_) = tx.send(Ok(i)).await {
+                        if (tx.send(Ok(i)).await).is_err() {
                             return;
                         }
                     } else {

rust-runtime/aws-smithy-checksums/src/lib.rs

@@ -82,7 +82,7 @@ impl ChecksumAlgorithm {
     }
 }
 
-#[derive(Debug, PartialEq)]
+#[derive(Debug, PartialEq, Eq)]
 pub enum Error {
     UnknownChecksumAlgorithm(String),
 }

rust-runtime/aws-smithy-eventstream/src/frame.rs

@@ -96,7 +96,7 @@ mod value {
 
     /// Event Stream frame header value.
     #[non_exhaustive]
-    #[derive(Clone, Debug, PartialEq)]
+    #[derive(Clone, Debug, PartialEq, Eq)]
     pub enum HeaderValue {
         Bool(bool),
         Byte(i8),
@@ -300,7 +300,7 @@ pub use value::HeaderValue;
 
 /// Event Stream header.
 #[non_exhaustive]
-#[derive(Clone, Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq, Eq)]
 #[cfg_attr(feature = "derive-arbitrary", derive(arbitrary::Arbitrary))]
 pub struct Header {
     name: StrBytes,
@@ -368,7 +368,7 @@ pub fn write_headers_to<B: BufMut>(headers: &[Header], mut buffer: B) -> Result<
 
 /// Event Stream message.
 #[non_exhaustive]
-#[derive(Clone, Debug, PartialEq)]
+#[derive(Clone, Debug, PartialEq, Eq)]
 pub struct Message {
     headers: Vec<Header>,
     payload: Bytes,
@@ -601,7 +601,7 @@ mod message_tests {
             0x36,
         ];
 
-        let result = Message::read_from(&mut Bytes::from_static(&data)).unwrap();
+        let result = Message::read_from(&mut Bytes::from_static(data)).unwrap();
         assert_eq!(result.headers(), Vec::new());
 
         let expected_payload = b"{'foo':'bar'}";
@@ -620,7 +620,7 @@ mod message_tests {
             0x7d, 0x8D, 0x9C, 0x08, 0xB1,
         ];
 
-        let result = Message::read_from(&mut Bytes::from_static(&data)).unwrap();
+        let result = Message::read_from(&mut Bytes::from_static(data)).unwrap();
         assert_eq!(
             result.headers(),
             vec![Header::new(

rust-runtime/aws-smithy-eventstream/src/str_bytes.rs

@@ -151,7 +151,7 @@ mod tests {
         let str_bytes: StrBytes = valid_utf8.into();
         assert_eq!(valid_utf8.as_bytes(), str_bytes.as_bytes());
         assert_eq!(valid_utf8, str_bytes.as_str());
-        assert_eq!(valid_utf8, str_bytes.clone().as_str());
+        assert_eq!(valid_utf8, str_bytes.as_str());
     }
 
     #[test]

rust-runtime/aws-smithy-http-server-python/Cargo.toml

@@ -25,8 +25,8 @@ hyper = { version = "0.14.20", features = ["server", "http1", "http2", "tcp", "s
 num_cpus = "1.13.1"
 parking_lot = "0.12.1"
 pin-project-lite = "0.2"
-pyo3 = "0.16.5"
-pyo3-asyncio = { version = "0.16.0", features = ["tokio-runtime"] }
+pyo3 = "0.17.0"
+pyo3-asyncio = { version = "0.17.0", features = ["tokio-runtime"] }
 signal-hook = { version = "0.3.14", features = ["extended-siginfo"] }
 socket2 = { version = "0.4.4", features = ["all"] }
 thiserror = "1.0.32"

rust-runtime/aws-smithy-http-server-python/src/types.rs

@@ -26,7 +26,7 @@ use crate::PyError;
 
 /// Python Wrapper for [aws_smithy_types::Blob].
 #[pyclass]
-#[derive(Debug, Clone, PartialEq)]
+#[derive(Debug, Clone, PartialEq, Eq)]
 pub struct Blob(aws_smithy_types::Blob);
 
 impl Blob {
@@ -88,7 +88,7 @@ impl<'blob> From<&'blob Blob> for &'blob aws_smithy_types::Blob {
 
 /// Python Wrapper for [aws_smithy_types::date_time::DateTime].
 #[pyclass]
-#[derive(Debug, Clone, PartialEq)]
+#[derive(Debug, Clone, PartialEq, Eq)]
 pub struct DateTime(aws_smithy_types::date_time::DateTime);
 
 #[pyclass]

rust-runtime/aws-smithy-http-server/src/instrumentation/sensitivity/sensitive.rs

@@ -93,9 +93,9 @@ mod tests {
         let sensitive = Sensitive(inner);
         let actual = format!("{}", sensitive);
         let expected = if cfg!(feature = "unredacted-logging") {
-            format!("{}", inner)
+            inner.to_string()
         } else {
-            format!("{}", REDACTED)
+            REDACTED.to_string()
         };
         assert_eq!(actual, expected)
     }

rust-runtime/aws-smithy-http-server/src/instrumentation/sensitivity/uri/label.rs

@@ -186,7 +186,7 @@ mod tests {
         let originals = EXAMPLES.into_iter().map(Uri::from_static);
         for original in originals {
             let expected = original.path().to_string();
-            let output = Label::new(&original.path(), |_| false, None).to_string();
+            let output = Label::new(original.path(), |_| false, None).to_string();
             assert_eq!(output, expected, "original = {original}");
         }
     }
@@ -222,7 +222,7 @@ mod tests {
         let originals = EXAMPLES.into_iter().map(Uri::from_static);
         let expecteds = ALL_EXAMPLES.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Label::new(&original.path(), |_| true, None).to_string();
+            let output = Label::new(original.path(), |_| true, None).to_string();
             assert_eq!(output, expected.path(), "original = {original}");
         }
     }
@@ -258,7 +258,7 @@ mod tests {
         let originals = EXAMPLES.into_iter().map(Uri::from_static);
         let expecteds = GREEDY_EXAMPLES.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Label::new(&original.path(), |_| false, Some(GreedyLabel::new(1, 0))).to_string();
+            let output = Label::new(original.path(), |_| false, Some(GreedyLabel::new(1, 0))).to_string();
             assert_eq!(output, expected.path(), "original = {original}");
         }
     }
@@ -294,7 +294,7 @@ mod tests {
         let originals = EXAMPLES.into_iter().map(Uri::from_static);
         let expecteds = GREEDY_EXAMPLES_OFFSET.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Label::new(&original.path(), |_| false, Some(GreedyLabel::new(1, 1))).to_string();
+            let output = Label::new(original.path(), |_| false, Some(GreedyLabel::new(1, 1))).to_string();
             assert_eq!(output, expected.path(), "original = {original}");
         }
     }
@@ -321,7 +321,7 @@ mod tests {
         let originals = EXTRA_EXAMPLES_UNREDACTED.into_iter().map(Uri::from_static);
         let expecteds = EXTRA_EXAMPLES_REDACTED.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Label::new(&original.path(), |_| false, Some(GreedyLabel::new(2, 5))).to_string();
+            let output = Label::new(original.path(), |_| false, Some(GreedyLabel::new(2, 5))).to_string();
             assert_eq!(output, expected.path(), "original = {original}");
         }
     }

rust-runtime/aws-smithy-http-server/src/instrumentation/sensitivity/uri/query.rs

@@ -131,7 +131,7 @@ mod tests {
         let originals = EXAMPLES.into_iter().chain(QUERY_STRING_EXAMPLES).map(Uri::from_static);
         for original in originals {
             if let Some(query) = original.query() {
-                let output = Query::new(&query, |_| QueryMarker::default()).to_string();
+                let output = Query::new(query, |_| QueryMarker::default()).to_string();
                 assert_eq!(output, query, "original = {original}");
             }
         }
@@ -142,7 +142,7 @@ mod tests {
         let originals = QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         let expecteds = ALL_KEYS_QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Query::new(&original.query().unwrap(), |_| QueryMarker {
+            let output = Query::new(original.query().unwrap(), |_| QueryMarker {
                 key: true,
                 value: false,
             })
@@ -156,7 +156,7 @@ mod tests {
         let originals = QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         let expecteds = ALL_VALUES_QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Query::new(&original.query().unwrap(), |_| QueryMarker {
+            let output = Query::new(original.query().unwrap(), |_| QueryMarker {
                 key: false,
                 value: true,
             })
@@ -170,7 +170,7 @@ mod tests {
         let originals = QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         let expecteds = ALL_PAIRS_QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Query::new(&original.query().unwrap(), |_| QueryMarker { key: true, value: true }).to_string();
+            let output = Query::new(original.query().unwrap(), |_| QueryMarker { key: true, value: true }).to_string();
             assert_eq!(output, expected.query().unwrap(), "original = {original}");
         }
     }
@@ -180,7 +180,7 @@ mod tests {
         let originals = QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         let expecteds = X_QUERY_STRING_EXAMPLES.into_iter().map(Uri::from_static);
         for (original, expected) in originals.zip(expecteds) {
-            let output = Query::new(&original.query().unwrap(), |key| QueryMarker {
+            let output = Query::new(original.query().unwrap(), |key| QueryMarker {
                 key: false,
                 value: key == "x",
             })

rust-runtime/aws-smithy-http-server/src/protocols.rs

@@ -8,7 +8,7 @@ use crate::rejection::MissingContentTypeReason;
 use crate::request::RequestParts;
 
 /// Supported protocols.
-#[derive(Debug, Clone, Copy, PartialEq)]
+#[derive(Debug, Clone, Copy, PartialEq, Eq)]
 pub enum Protocol {
     RestJson1,
     RestXml,
@@ -190,7 +190,7 @@ mod tests {
                         );
                         assert_eq!(found_mime, invalid_mime.parse::<mime::Mime>().ok());
                     }
-                    _ => panic!("Unexpected `MissingContentTypeReason`: {}", e.to_string()),
+                    _ => panic!("Unexpected `MissingContentTypeReason`: {}", e),
                 },
             }
         }