ci: rust 1.88

Author: dorimedini-starkware

crates/apollo_batcher/src/batcher_test.rs

@@ -323,30 +323,22 @@ fn assert_proposal_metrics(
     assert_eq!(
         started,
         Some(expected_started),
-        "unexpected value proposal_started, expected {} got {:?}",
-        expected_started,
-        started,
+        "unexpected value proposal_started, expected {expected_started} got {started:?}",
     );
     assert_eq!(
         succeeded,
         Some(expected_succeeded),
-        "unexpected value proposal_succeeded, expected {} got {:?}",
-        expected_succeeded,
-        succeeded,
+        "unexpected value proposal_succeeded, expected {expected_succeeded} got {succeeded:?}",
     );
     assert_eq!(
         failed,
         Some(expected_failed),
-        "unexpected value proposal_failed, expected {} got {:?}",
-        expected_failed,
-        failed,
+        "unexpected value proposal_failed, expected {expected_failed} got {failed:?}",
     );
     assert_eq!(
         aborted,
         Some(expected_aborted),
-        "unexpected value proposal_aborted, expected {} got {:?}",
-        expected_aborted,
-        aborted,
+        "unexpected value proposal_aborted, expected {expected_aborted} got {aborted:?}",
     );
 }
 

crates/apollo_central_sync/src/sources/central/state_update_stream.rs

@@ -358,7 +358,7 @@ async fn download_class_if_necessary<TStarknetClient: StarknetReader>(
 
     // Check declared classes.
     if let Ok(Some(class)) = state_reader.get_class_definition_at(state_number, &class_hash) {
-        trace!("Class {:?} retrieved from storage.", class_hash);
+        trace!("Class {class_hash:?} retrieved from storage.");
         {
             let mut cache = cache.lock().expect("Failed to lock class cache.");
             cache.put(class_hash, ApiContractClass::ContractClass(class.clone()));
@@ -370,7 +370,7 @@ async fn download_class_if_necessary<TStarknetClient: StarknetReader>(
     if let Ok(Some(class)) =
         state_reader.get_deprecated_class_definition_at(state_number, &class_hash)
     {
-        trace!("Deprecated class {:?} retrieved from storage.", class_hash);
+        trace!("Deprecated class {class_hash:?} retrieved from storage.");
         {
             let mut cache = cache.lock().expect("Failed to lock class cache.");
             cache.put(class_hash, ApiContractClass::DeprecatedContractClass(class.clone()));
@@ -379,7 +379,7 @@ async fn download_class_if_necessary<TStarknetClient: StarknetReader>(
     }
 
     // Class not found in storage - download.
-    trace!("Downloading class {:?}.", class_hash);
+    trace!("Downloading class {class_hash:?}.");
     let client_class = apollo_starknet_client.class_by_hash(class_hash).await.map_err(Arc::new)?;
     match client_class {
         None => Ok(None),

crates/apollo_central_sync/src/sources/central_test.rs

@@ -124,7 +124,7 @@ async fn stream_block_headers_some_are_missing() {
         (false, true, "signature missing"),
     ];
     for (block_missing, signature_missing, test_case_description) in test_cases {
-        println!("Test case: {}", test_case_description);
+        println!("Test case: {test_case_description}");
         const START_BLOCK_NUMBER: u64 = 5;
         const END_BLOCK_NUMBER: u64 = 13;
         const MISSING_BLOCK_NUMBER: u64 = 9;

crates/apollo_class_manager/src/metrics.rs

@@ -56,13 +56,12 @@ pub(crate) fn increment_n_classes(cls_type: CairoClassType) {
 
 pub(crate) fn record_class_size<T>(class_type: ClassObjectType, class: &SerializedClass<T>) {
     let class_size = class.size().unwrap_or_else(|_| {
-        panic!("Illegally formatted {} class, should not have gotten into the system.", class_type)
+        panic!("Illegally formatted {class_type} class, should not have gotten into the system.")
     });
     let class_size = u32::try_from(class_size).unwrap_or_else(|_| {
         panic!(
-            "{} class size {} is bigger than what is allowed,
-            should not have gotten into the system.",
-            class_type, class_size
+            "{class_type} class size {class_size} is bigger than what is allowed,
+            should not have gotten into the system."
         )
     });
 

crates/apollo_compilation_utils/src/build_utils.rs

@@ -47,7 +47,7 @@ pub fn install_compiler_binary(
         .unwrap_or_else(|_| panic!("Failed to install {binary_name}"));
 
     if !install_command_status.success() {
-        panic!("Failed to install {}", binary_name);
+        panic!("Failed to install {binary_name}");
     }
 
     // Move the '{binary_name}' executable to a shared location.
@@ -59,7 +59,7 @@ pub fn install_compiler_binary(
         .expect("Failed to perform mv command.");
 
     if !move_command_status.success() {
-        panic!("Failed to move the {} binary to the shared folder.", binary_name);
+        panic!("Failed to move the {binary_name} binary to the shared folder.");
     }
 
     std::fs::remove_dir_all(temp_cargo_path).expect("Failed to remove the cargo directory.");

crates/apollo_compilation_utils/src/compiler_utils.rs

@@ -46,7 +46,7 @@ pub fn compile_with_args(
                 "Process exited with non-zero status but no signal (likely a handled error, e.g., \
                  memory allocation failure)."
             }
-            Some(sig) => &format!("Process terminated by unexpected signal: {}", sig),
+            Some(sig) => &format!("Process terminated by unexpected signal: {sig}"),
         };
 
         let stderr_output = String::from_utf8(compile_output.stderr)

crates/apollo_compilation_utils/src/resource_limits/resource_limits_test.rs

@@ -19,7 +19,7 @@ fn test_cpu_time_limit() {
     let status = command.spawn().expect("Failed to start CPU consuming process").wait().unwrap();
     assert!(start.elapsed().as_secs() <= cpu_limit);
     let signal = status.signal();
-    assert_eq!(signal, Some(9), "Process should terminate with SIGKILL (9) got {:?}", signal);
+    assert_eq!(signal, Some(9), "Process should terminate with SIGKILL (9) got {signal:?}");
 }
 
 #[rstest]
@@ -34,7 +34,7 @@ fn test_memory_size_limit() {
     let output = command.output().expect("Failed to start memory consuming process");
 
     let signal = output.status.signal();
-    assert!(signal.is_none(), "Exceeding memory usage should not cause a signal, got {:?}", signal);
+    assert!(signal.is_none(), "Exceeding memory usage should not cause a signal, got {signal:?}");
 
     let stderr = String::from_utf8_lossy(&output.stderr);
 
@@ -66,7 +66,7 @@ fn test_file_size_limit() {
     let status = command.spawn().expect("Failed to start disk consuming process").wait().unwrap();
     assert_eq!(std::fs::metadata(temp_file_path).unwrap().len(), file_limit);
     let signal = status.signal();
-    assert!(signal == Some(25), "Process should terminate with SIGXFSZ (25), got {:?}", signal);
+    assert!(signal == Some(25), "Process should terminate with SIGXFSZ (25), got {signal:?}");
 }
 
 #[rstest]

crates/apollo_compile_to_casm/build.rs

@@ -26,7 +26,7 @@ fn install_starknet_sierra_compile() {
 // available only after the build is completed. Most importantly, it is available during runtime.
 fn set_run_time_out_dir_env_var() {
     let out_dir = std::env::var("OUT_DIR").expect("OUT_DIR is not set");
-    println!("cargo:rustc-env=RUNTIME_ACCESSIBLE_OUT_DIR={}", out_dir);
+    println!("cargo:rustc-env=RUNTIME_ACCESSIBLE_OUT_DIR={out_dir}");
 }
 
 // Returns the OUT_DIR. This function is only operable at build time.

crates/apollo_compile_to_native/build_with_cairo_native.rs

@@ -25,7 +25,7 @@ fn install_starknet_native_compile() {
 // available only after the build is completed. Most importantly, it is available during runtime.
 fn set_run_time_out_dir_env_var() {
     let out_dir = std::env::var("OUT_DIR").expect("OUT_DIR is not set");
-    println!("cargo:rustc-env=RUNTIME_ACCESSIBLE_OUT_DIR={}", out_dir);
+    println!("cargo:rustc-env=RUNTIME_ACCESSIBLE_OUT_DIR={out_dir}");
 }
 
 // Returns the OUT_DIR. This function is only operable at build time.

crates/apollo_config/src/converters.rs

@@ -95,7 +95,7 @@ pub fn serialize_optional_vec_u8(optional_vector: &Option<Vec<u8>>) -> String {
         Some(vector) => {
             format!(
                 "0x{}",
-                vector.iter().map(|num| format!("{:02x}", num)).collect::<Vec<String>>().join("")
+                vector.iter().map(|num| format!("{num:02x}")).collect::<Vec<String>>().join("")
             )
         }
     }
@@ -125,8 +125,7 @@ where
         let byte_str = &hex_str[i..i + 2];
         let byte = u8::from_str_radix(byte_str, 16).map_err(|e| {
             D::Error::custom(format!(
-                "Couldn't deserialize vector. Failed to parse byte: {} {}",
-                byte_str, e
+                "Couldn't deserialize vector. Failed to parse byte: {byte_str} {e}"
             ))
         })?;
         vector.push(byte);