From 0b97d2bf93c2487433c3c6b748cd09b619ed72fb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?J=C4=99drzej=20Stuczy=C5=84ski?=
 <jedrzej.stuczynski@gmail.com>
Date: Fri, 6 Mar 2026 15:37:49 +0000
Subject: [PATCH] wip

---
 nym-node/src/node/lp/control/egress/connection.rs      | 1 +
 nym-node/src/node/lp/control/ingress/client_handler.rs | 1 +
 nym-node/src/node/lp/control/ingress/node_handler.rs   | 2 ++
 nym-node/src/node/lp/forwarding/client_connection.rs   | 3 ++-
 4 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/nym-node/src/node/lp/control/egress/connection.rs b/nym-node/src/node/lp/control/egress/connection.rs
index 1467a2636f..0b2a56946f 100644
--- a/nym-node/src/node/lp/control/egress/connection.rs
+++ b/nym-node/src/node/lp/control/egress/connection.rs
@@ -124,6 +124,7 @@ pub(crate) struct NestedNodeConnectionHandler<S> {
 
     /// Channel for adding new client handle and handling control requests from `NestedConnectionsController`
     control_receiver: NestedNodeControlReceiver,
+    // client_streams: HashMap<StreamId, LpClientStream>,
 }
 
 impl<S> NestedNodeConnectionHandler<S>
diff --git a/nym-node/src/node/lp/control/ingress/client_handler.rs b/nym-node/src/node/lp/control/ingress/client_handler.rs
index 2a25aec4df..8f9370c724 100644
--- a/nym-node/src/node/lp/control/ingress/client_handler.rs
+++ b/nym-node/src/node/lp/control/ingress/client_handler.rs
@@ -43,6 +43,7 @@ pub struct LpClientConnectionHandler<S = TcpStream> {
     /// Tuple contains (stream, target_address) to verify subsequent forwards go to same exit.
     exit_stream: Option<(S, SocketAddr)>,
 
+    /// Forwarding channel for sending requests to the exit gateway and receiving responses.
     #[allow(dead_code)]
     forwarding_channel: Option<NestedClientConnection>,
 }
diff --git a/nym-node/src/node/lp/control/ingress/node_handler.rs b/nym-node/src/node/lp/control/ingress/node_handler.rs
index 5215c699a9..6ddb09ccea 100644
--- a/nym-node/src/node/lp/control/ingress/node_handler.rs
+++ b/nym-node/src/node/lp/control/ingress/node_handler.rs
@@ -127,6 +127,8 @@ pub struct LpIngressNodeConnectionHandler<S = TcpStream> {
     state: SharedLpNodeControlState,
     stats: LpConnectionStats,
     transport_session: LpTransportSession,
+    // LOCAL receiver index to stream id
+    // client_streams: HashMap<ReceiverIndex, ClientStreamId>,
 }
 
 impl<S> LpIngressNodeConnectionHandler<S>
diff --git a/nym-node/src/node/lp/forwarding/client_connection.rs b/nym-node/src/node/lp/forwarding/client_connection.rs
index 49dd255b9f..17af64471e 100644
--- a/nym-node/src/node/lp/forwarding/client_connection.rs
+++ b/nym-node/src/node/lp/forwarding/client_connection.rs
@@ -2,9 +2,10 @@
 // SPDX-License-Identifier: Apache-2.0
 
 use crate::node::lp::control::egress::connection::NestedNodeConnectionSender;
+use futures::channel::mpsc::UnboundedReceiver;
 
 pub(crate) type NestedClientConnectionSender = ();
-pub(crate) type NestedClientConnectionReceiver = ();
+pub(crate) type NestedClientConnectionReceiver = UnboundedReceiver<Vec<u8>>;
 
 pub(crate) struct NestedClientConnection {
     // handle for sending into `NestedNodeConnectionHandler`