Update rust to 2025-01-15

mirrord/agent/Dockerfile

@@ -25,12 +25,12 @@ COPY Cargo.toml Cargo.lock CHANGELOG.md README.md LICENSE rust-toolchain.toml /a
 # so we remove from the workspace
 RUN sed -i '/members = \[/,/\]/c\members = [\n    "mirrord/*",\n]' /app/Cargo.toml
 
-RUN cargo +nightly-2024-10-11 chef prepare --recipe-path recipe.json
+RUN cargo +nightly-2025-01-15 chef prepare --recipe-path recipe.json
 
 FROM chef AS builder
 
 COPY --from=planner /app/recipe.json recipe.json
-RUN cargo +nightly-2024-10-11 chef cook --release --zigbuild --target $(cat /.platform) --recipe-path recipe.json
+RUN cargo +nightly-2025-01-15 chef cook --release --zigbuild --target $(cat /.platform) --recipe-path recipe.json
 
 # Copy order is important here, since we want the cache to be invalidated as less as possible
 # so we start with the most static files, then the most dynamic ones
@@ -44,7 +44,7 @@ COPY Cargo.toml Cargo.lock CHANGELOG.md README.md LICENSE rust-toolchain.toml /a
 # so we remove from the workspace
 RUN sed -i '/members = \[/,/\]/c\members = [\n    "mirrord/*",\n]' /app/Cargo.toml
 
-RUN cargo +nightly-2024-10-11 zigbuild -Z bindeps --manifest-path /app/mirrord/agent/Cargo.toml --target $(cat /.platform) --release
+RUN cargo +nightly-2025-01-15 zigbuild -Z bindeps --manifest-path /app/mirrord/agent/Cargo.toml --target $(cat /.platform) --release
 RUN cp /app/target/$(cat /.platform)/release/mirrord-agent /mirrord-agent
 
 FROM ghcr.io/metalbear-co/ci-agent-runtime:latest

mirrord/agent/src/steal/orig_dst.rs

@@ -77,14 +77,14 @@ mod linux {
 
                 let arr = sa.sin6_addr.s6_addr;
                 let ip = Ipv6Addr::new(
-                    (arr[0] as u16) << 8 | (arr[1] as u16),
-                    (arr[2] as u16) << 8 | (arr[3] as u16),
-                    (arr[4] as u16) << 8 | (arr[5] as u16),
-                    (arr[6] as u16) << 8 | (arr[7] as u16),
-                    (arr[8] as u16) << 8 | (arr[9] as u16),
-                    (arr[10] as u16) << 8 | (arr[11] as u16),
-                    (arr[12] as u16) << 8 | (arr[13] as u16),
-                    (arr[14] as u16) << 8 | (arr[15] as u16),
+                    ((arr[0] as u16) << 8) | (arr[1] as u16),
+                    ((arr[2] as u16) << 8) | (arr[3] as u16),
+                    ((arr[4] as u16) << 8) | (arr[5] as u16),
+                    ((arr[6] as u16) << 8) | (arr[7] as u16),
+                    ((arr[8] as u16) << 8) | (arr[9] as u16),
+                    ((arr[10] as u16) << 8) | (arr[11] as u16),
+                    ((arr[12] as u16) << 8) | (arr[13] as u16),
+                    ((arr[14] as u16) << 8) | (arr[15] as u16),
                 );
 
                 let port = sa.sin6_port;

mirrord/cli/Dockerfile

@@ -14,15 +14,15 @@ RUN cargo install [email protected]
 FROM chef AS planner
 
 COPY . /build/
-RUN cargo +nightly-2024-10-11 chef prepare --recipe-path recipe.json
+RUN cargo +nightly-2025-01-15 chef prepare --recipe-path recipe.json
 
 FROM chef AS builder
 
 COPY --from=planner /build/recipe.json recipe.json
-RUN cargo +nightly-2024-10-11 chef cook --release --zigbuild --target $(cat /.platform) --recipe-path recipe.json
+RUN cargo +nightly-2025-01-15 chef cook --release --zigbuild --target $(cat /.platform) --recipe-path recipe.json
 
 COPY . /build/
-RUN cargo +nightly-2024-10-11 zigbuild -p mirrord -p mirrord-layer -Z bindeps --target $(cat /.platform) --release --locked
+RUN cargo +nightly-2025-01-15 zigbuild -p mirrord -p mirrord-layer -Z bindeps --target $(cat /.platform) --release --locked
 RUN cp /build/target/$(cat /.platform)/release/mirrord /mirrord
 RUN cp /build/target/$(cat /.platform)/release/libmirrord_layer.so /libmirrord_layer.so
 

mirrord/intproxy/src/proxies/outgoing/net_protocol_ext.rs

@@ -202,15 +202,13 @@
                         "failed to send all bytes",
                     ))?;
                 }
 
                 Ok(())
             }
             InnerConnectedSocket::TcpStream(stream) => {
-                stream.write_all(bytes).await.map_err(Into::into)
-            }
+                stream.write_all(bytes).await}
             InnerConnectedSocket::UnixStream(stream) => {
-                stream.write_all(bytes).await.map_err(Into::into)
-            }
+                stream.write_all(bytes).await}
         }
     }
 

mirrord/kube/src/api/container/targetless.rs

@@ -27,7 +27,7 @@ where
     }
 }
 
-impl<'c, T> ContainerApi<JobVariant<T>> for Targetless<'c, JobVariant<T>>
+impl<T> ContainerApi<JobVariant<T>> for Targetless<'_, JobVariant<T>>
 where
     T: ContainerVariant<Update = Pod>,
 {

mirrord/layer/src/debugger_ports.rs

@@ -233,7 +233,7 @@ impl DebuggerType {
                                 .split(',')
                                 .find_map(|arg| arg.strip_prefix("address="))
                         })
-                        .and_then(|full_address| full_address.split(':').last())
+                        .and_then(|full_address| full_address.split(':').next_back())
                         .and_then(|port| port.parse::<u16>().ok())
                         .map(|port| SocketAddr::new(IpAddr::V4(Ipv4Addr::LOCALHOST), port))
                 } else {

mirrord/layer/src/file/ops.rs

@@ -119,8 +119,10 @@ impl Drop for RemoteFile {
         // operation to complete. The write operation is hooked and at some point tries to lock
         // `OPEN_FILES`, which means the thread deadlocks with itself (we call
         // `OPEN_FILES.lock()?.remove()` and then while still locked, `OPEN_FILES.lock()` again)
-        Self::remote_close(self.fd).expect(
-            "mirrord failed to send close file message to main layer thread. Error: {err:?}",
+        let result = Self::remote_close(self.fd);
+        assert!(
+            result.is_ok(),
+            "mirrord failed to send close file message to main layer thread. Error: {result:?}",
         );
     }
 }

mirrord/operator/src/client.rs

@@ -404,7 +404,6 @@ where
             layer_config.kube_context.clone(),
         )
         .await
-        .map_err(KubeApiError::from)
         .map_err(OperatorApiError::CreateKubeClient)?;
 
         client_config.headers.push((

mirrord/protocol/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "mirrord-protocol"
-version = "1.13.3"
+version = "1.13.4"
 authors.workspace = true
 description.workspace = true
 documentation.workspace = true

mirrord/protocol/src/error.rs

@@ -318,7 +318,7 @@
             io::ErrorKind::WriteZero => ErrorKindInternal::WriteZero,
             io::ErrorKind::StorageFull => ErrorKindInternal::StorageFull,
             io::ErrorKind::NotSeekable => ErrorKindInternal::NotSeekable,
-            io::ErrorKind::FilesystemQuotaExceeded => ErrorKindInternal::FilesystemQuotaExceeded,
+            io::ErrorKind::QuotaExceeded => ErrorKindInternal::FilesystemQuotaExceeded,
             io::ErrorKind::FileTooLarge => ErrorKindInternal::FileTooLarge,
             io::ErrorKind::ResourceBusy => ErrorKindInternal::ResourceBusy,
             io::ErrorKind::ExecutableFileBusy => ErrorKindInternal::ExecutableFileBusy,

mirrord/vpn/src/agent.rs

@@ -42,8 +42,7 @@ impl VpnAgent {
                     _ => None,
                 },
             )
-            .await
-            .map_err(VpnError::from)?
+            .await?
         else {
             return Err(VpnError::AgentUnexpectedResponse);
         };
@@ -79,8 +78,7 @@ impl VpnAgent {
                     _ => None,
                 },
             )
-            .await
-            .map_err(VpnError::from)?;
+            .await?;
 
         match response {
             Some(ServerVpn::NetworkConfiguration(network)) => Ok(network),

rust-toolchain.toml

@@ -1,4 +1,4 @@
 [toolchain]
-channel = "nightly-2024-10-11"
+channel = "nightly-2025-01-15"
 components = [ "rustfmt", "clippy", "rustc" ]
 profile = "minimal"