Merge pull request #6065 from nymtech/release/2025.17-isabirra

Author: benedettadavico

.github/workflows/ci-build-upload-binaries.yml

@@ -21,7 +21,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        platform: [ arc-ubuntu-22.04 ]
+        platform: [ arc-linux-latest ]
 
     runs-on: ${{ matrix.platform }}
     env:

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "nym-client"
-version = "1.1.62"
+version = "1.1.63"
 authors = ["Dave Hrycyszyn <futurechimp@users.noreply.github.com>", "Jędrzej Stuczyński <andrew@nymtech.net>"]
 description = "Implementation of the Nym Client"
 edition = "2021"

clients/native/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "nym-socks5-client"
-version = "1.1.62"
+version = "1.1.63"
 authors = ["Dave Hrycyszyn <futurechimp@users.noreply.github.com>"]
 description = "A SOCKS5 localhost proxy that converts incoming messages to Sphinx and sends them to a Nym address"
 edition = "2021"

clients/socks5/Cargo.toml

@@ -922,47 +922,48 @@ impl<R, S> FreshHandler<R, S> {
         S: AsyncRead + AsyncWrite + Unpin + Send,
         R: CryptoRng + RngCore + Send,
     {
-        let initial_request = match self.wait_for_initial_message().await {
-            Ok(req) => req,
-            Err(err) => {
-                self.send_and_forget_error_response(err).await;
-                return None;
-            }
-        };
+        loop {
+            let req = self.wait_for_initial_message().await;
+            let initial_request = match req {
+                Ok(req) => req,
+                Err(err) => {
+                    self.send_and_forget_error_response(err).await;
+                    return None;
+                }
+            };
 
-        // see if we managed to register the client through this request
-        let maybe_auth_res = match self.handle_initial_client_request(initial_request).await {
-            Ok(maybe_auth_res) => maybe_auth_res,
-            Err(err) => {
-                debug!("initial client request handling error: {err}");
-                self.send_and_forget_error_response(err).await;
-                return None;
-            }
-        };
+            // see if we managed to register the client through this request
+            let maybe_auth_res = match self.handle_initial_client_request(initial_request).await {
+                Ok(maybe_auth_res) => maybe_auth_res,
+                Err(err) => {
+                    debug!("initial client request handling error: {err}");
+                    self.send_and_forget_error_response(err).await;
+                    return None;
+                }
+            };
 
-        if let Some(registration_details) = maybe_auth_res {
-            let (mix_sender, mix_receiver) = mpsc::unbounded();
-            // Channel for handlers to ask other handlers if they are still active.
-            let (is_active_request_sender, is_active_request_receiver) = mpsc::unbounded();
-            self.shared_state.active_clients_store.insert_remote(
-                registration_details.address,
-                mix_sender,
-                is_active_request_sender,
-                registration_details.session_request_timestamp,
-            );
-
-            AuthenticatedHandler::upgrade(
-                self,
-                registration_details,
-                mix_receiver,
-                is_active_request_receiver,
-            )
-            .await
-            .inspect_err(|err| error!("failed to upgrade client handler: {err}"))
-            .ok();
-        }
+            if let Some(registration_details) = maybe_auth_res {
+                let (mix_sender, mix_receiver) = mpsc::unbounded();
+                // Channel for handlers to ask other handlers if they are still active.
+                let (is_active_request_sender, is_active_request_receiver) = mpsc::unbounded();
+                self.shared_state.active_clients_store.insert_remote(
+                    registration_details.address,
+                    mix_sender,
+                    is_active_request_sender,
+                    registration_details.session_request_timestamp,
+                );
 
-        None
+                return AuthenticatedHandler::upgrade(
+                    self,
+                    registration_details,
+                    mix_receiver,
+                    is_active_request_receiver,
+                )
+                .await
+                .inspect_err(|err| error!("failed to upgrade client handler: {err}"))
+                .ok();
+            }
+        }
     }
 
     pub(crate) async fn wait_for_initial_message(

gateway/src/node/client_handling/websocket/connection_handler/fresh.rs

@@ -4,7 +4,7 @@
 [package]
 name = "nym-api"
 license = "GPL-3.0"
-version = "1.1.65"
+version = "1.1.66"
 authors.workspace = true
 edition = "2021"
 rust-version.workspace = true

nym-api/Cargo.toml

@@ -4,7 +4,7 @@
 [package]
 name = "nym-network-requester"
 license = "GPL-3.0"
-version = "1.1.63"
+version = "1.1.64"
 authors.workspace = true
 edition.workspace = true
 rust-version = "1.70"

service-providers/network-requester/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "nym-cli"
-version = "1.1.62"
+version = "1.1.63"
 authors.workspace = true
 edition = "2021"
 license.workspace = true

tools/nym-cli/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "nymvisor"
-version = "0.1.27"
+version = "0.1.28"
 authors.workspace = true
 repository.workspace = true
 homepage.workspace = true