From db2221080e406e5675169909f33c26d110bb33bd Mon Sep 17 00:00:00 2001
From: alterdekim <alterwain@protonmail.com>
Date: Mon, 12 Aug 2024 05:08:32 +0300
Subject: [PATCH]  Changes to be committed: 	modified:   src/tcp_client.rs 
 modified:   src/tcp_server.rs

---
 src/tcp_client.rs | 4 ++--
 src/tcp_server.rs | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/tcp_client.rs b/src/tcp_client.rs
index deb0de8..f470f18 100644
--- a/src/tcp_client.rs
+++ b/src/tcp_client.rs
@@ -88,7 +88,6 @@ pub async fn client_mode(remote_addr: String) {
     tokio::spawn(async move {
         while let Ok(bytes) = rx.recv() {
             dev_writer.write(&bytes).unwrap();
-            info!("Wrote to tun");
         }
     });
 
@@ -103,6 +102,7 @@ pub async fn client_mode(remote_addr: String) {
         let mut buf = vec![0; 2048];
         loop {
             if let Ok(n) = sock_reader.read(&mut buf).await {
+                info!("Catch from socket: {:?}", &buf[..n]);
                 let vpn_packet: VpnPacket = bincode::deserialize(&buf[..n]).unwrap();
                 tx.send(vpn_packet.data).unwrap();
             }
@@ -113,8 +113,8 @@ pub async fn client_mode(remote_addr: String) {
         if let Ok(bytes) = mx.recv() {
             let vpn_packet = VpnPacket::init(bytes);
             let serialized_data = bincode::serialize(&vpn_packet).unwrap();
+            info!("Writing to sock: {:?}", serialized_data);
             sock_writer.write_all(&serialized_data).await.unwrap();
-            info!("Wrote to sock");
         }
     }
 }
\ No newline at end of file
diff --git a/src/tcp_server.rs b/src/tcp_server.rs
index 1350406..8036bb5 100644
--- a/src/tcp_server.rs
+++ b/src/tcp_server.rs
@@ -34,7 +34,6 @@ pub async fn server_mode() {
     tokio::spawn(async move {
         while let Ok(bytes) = rx.recv() {
             dev_writer.write(&bytes).unwrap();
-            info!("Wrote to tun");
         }
     });
 
@@ -59,7 +58,7 @@ pub async fn server_mode() {
                     let vpn_packet = VpnPacket::init(bytes);
                     let serialized_data = bincode::serialize(&vpn_packet).unwrap();
                     sock_writer.write_all(&serialized_data).await.unwrap();
-                    info!("Wrote to sock");
+                    info!("Wrote to sock: {:?}", serialized_data);
                 }
             }
         });
@@ -68,6 +67,7 @@ pub async fn server_mode() {
             let mut buf = vec![0; 2048];
             loop {
                 if let Ok(n) = sock_reader.read(&mut buf).await {
+                    info!("Catched from sock: {:?}", &buf[..n]);
                     let vpn_packet: VpnPacket = bincode::deserialize(&buf[..n]).unwrap();
                     thread_tx.send(vpn_packet.data).unwrap();
                 }