feat(ci): bump rust version to 1.86 (#6193)

Signed-off-by: Dori Medini <[email protected]>

Author: dorimedini-starkware

crates/apollo_http_server/src/metrics_test.rs

@@ -62,7 +62,7 @@ async fn add_tx_metrics_test(#[case] index: u16, #[case] tx: impl GatewayTransac
     let http_client = add_tx_http_client(mock_gateway_client, 14 + index).await;
 
     // Send transactions to the server.
-    for _ in std::iter::repeat(()).take(SUCCESS_TXS_TO_SEND + FAILURE_TXS_TO_SEND) {
+    for _ in std::iter::repeat_n((), SUCCESS_TXS_TO_SEND + FAILURE_TXS_TO_SEND) {
         http_client.add_tx(tx.clone()).await;
     }
 

crates/apollo_mempool/src/mempool.rs

@@ -53,7 +53,7 @@ struct CommitHistory {
 
 impl CommitHistory {
     fn new(capacity: usize) -> Self {
-        CommitHistory { commits: std::iter::repeat(AddressToNonce::new()).take(capacity).collect() }
+        CommitHistory { commits: std::iter::repeat_n(AddressToNonce::new(), capacity).collect() }
     }
 
     fn push(&mut self, commit: AddressToNonce) -> AddressToNonce {

crates/apollo_rpc/src/rpc_metrics/rpc_metrics_test.rs

@@ -182,19 +182,19 @@ async fn server_metrics() {
         for line in metrics.split('\n').filter(|line| line.contains("V0_8")) {
             if line.contains("rpc_incoming_requests{method=\"blockNumber\"") {
                 println!("{}", line);
-                line.split(' ').last().unwrap().clone_into(&mut incoming_block_number);
+                line.split(' ').next_back().unwrap().clone_into(&mut incoming_block_number);
             }
             if line.contains("rpc_failed_requests{method=\"blockNumber\"") {
                 println!("{}", line);
-                line.split(' ').last().unwrap().clone_into(&mut failing_block_number);
+                line.split(' ').next_back().unwrap().clone_into(&mut failing_block_number);
             }
             if line.contains("rpc_incoming_requests{method=\"getStateUpdate\"") {
                 println!("{}", line);
-                line.split(' ').last().unwrap().clone_into(&mut incoming_get_state_update);
+                line.split(' ').next_back().unwrap().clone_into(&mut incoming_get_state_update);
             }
             if line.contains("rpc_failed_requests{method=\"getStateUpdate\"") {
                 println!("{}", line);
-                line.split(' ').last().unwrap().clone_into(&mut failing_get_state_update);
+                line.split(' ').next_back().unwrap().clone_into(&mut failing_get_state_update);
             }
         }
         (

crates/apollo_rpc/src/v0_8/api/test.rs

@@ -448,10 +448,10 @@ async fn get_block_transaction_count() {
     // Ask for pending block
     let pending_transaction_count = 3;
     let mut rng = get_rng();
-    pending_data.write().await.block.transactions_mutable().extend(
-        iter::repeat(ClientTransaction::get_test_instance(&mut rng))
-            .take(pending_transaction_count),
-    );
+    pending_data.write().await.block.transactions_mutable().extend(iter::repeat_n(
+        ClientTransaction::get_test_instance(&mut rng),
+        pending_transaction_count,
+    ));
     let res = module.call::<_, usize>(method_name, [BlockId::Tag(Tag::Pending)]).await.unwrap();
     assert_eq!(res, pending_transaction_count);
 

rust-toolchain.toml

@@ -1,5 +1,5 @@
 [toolchain]
-channel = "1.85"
+channel = "1.86"
 components = ["rustc-dev"]
 profile = "default"
 targets = ["x86_64-unknown-linux-gnu"]