From b4e8e42267b562b155fd3f41db10a50cf47a3354 Mon Sep 17 00:00:00 2001
From: Alex Emmet <111742636+Alex-Emmet@users.noreply.github.com>
Date: Wed, 18 Mar 2026 23:35:21 +0100
Subject: [PATCH] [Add] Connection Logging

---
 Cargo.lock            | 8 ++++----
 src/rho/connection.rs | 7 ++++++-
 2 files changed, 10 insertions(+), 5 deletions(-)
 mode change 100644 => 100755 src/rho/connection.rs

diff --git a/Cargo.lock b/Cargo.lock
index d3ca560..73a233b 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -700,7 +700,7 @@ dependencies = [
 [[package]]
 name = "epsilon-core"
 version = "0.1.0"
-source = "git+https://github.com/Tensamin/Epsilon.git#d5edc693a91954834a38c39517b79092983eac5c"
+source = "git+https://github.com/Tensamin/Epsilon.git#bafbf13f43a9f7092341ec102621e234438be163"
 dependencies = [
  "base64 0.22.1",
  "byteorder",
@@ -712,7 +712,7 @@ dependencies = [
 [[package]]
 name = "epsilon-native"
 version = "0.1.0"
-source = "git+https://github.com/Tensamin/Epsilon.git#d5edc693a91954834a38c39517b79092983eac5c"
+source = "git+https://github.com/Tensamin/Epsilon.git#bafbf13f43a9f7092341ec102621e234438be163"
 dependencies = [
  "epsilon-core",
  "quinn",
@@ -2780,9 +2780,9 @@ dependencies = [
 
 [[package]]
 name = "tinyvec"
-version = "1.10.0"
+version = "1.11.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "bfa5fdc3bce6191a1dbc8c02d5c8bffcf557bafa17c124c5264a458f1b0613fa"
+checksum = "3e61e67053d25a4e82c844e8424039d9745781b3fc4f32b8d55ed50f5f667ef3"
 dependencies = [
  "tinyvec_macros",
 ]
diff --git a/src/rho/connection.rs b/src/rho/connection.rs
old mode 100644
new mode 100755
index 59f88a0..2b530c7
--- a/src/rho/connection.rs
+++ b/src/rho/connection.rs
@@ -6,7 +6,7 @@ use tokio::sync::RwLock;
 
 use crate::{
     anonymous_clients::anonymous_client_connection::AnonymousClientConnection,
-    get_private_key, get_public_key, log_err, log_in, log_out,
+    get_private_key, get_public_key, log_cv_in, log_cv_out, log_err, log_in, log_out,
     omega::omega_connection::get_omega_connection,
     rho::{
         client_connection::ClientConnection, iota_connection::IotaConnection,
@@ -66,6 +66,8 @@ impl GeneralConnection {
                 }
             };
 
+            log_cv_in!(cv);
+
             if !*self.identified.read().await {
                 self.handle_identification(cv).await;
                 continue;
@@ -147,6 +149,7 @@ impl GeneralConnection {
                 )
                 .add_data(DataTypes::challenge, DataValue::Str(encrypted_challenge));
 
+            log_cv_out!(response);
             let _ = self.sender.send(&response).await;
         } else if let DataValue::Number(user_id) = cv.get_data(DataTypes::user_id) {
             *self.id.write().await = *user_id as u64;
@@ -204,6 +207,7 @@ impl GeneralConnection {
                 )
                 .add_data(DataTypes::challenge, DataValue::Str(encrypted_challenge));
 
+            log_cv_out!(response);
             let _ = self.sender.send(&response).await;
         }
     }
@@ -224,6 +228,7 @@ impl GeneralConnection {
                     .with_id(cv.get_id())
                     .add_data(DataTypes::accepted, DataValue::Bool(true));
 
+                log_cv_out!(response);
                 if let Err(_) = self.sender.send(&response).await {
                     return;
                 }