Add tracing instrumentation

Signed-off-by: Matthias Beyer <mail@beyermatthias.de>

10 files changed, 13 insertions, 0 deletions

diff --git a/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs b/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs
index 49012c1..b128be7 100644
--- a/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs
+++ b/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs
@@ -19,6 +19,7 @@ impl BehaviourTest for ConnackFlagsAreSetAsReserved {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> {
         input
             .send(&[
diff --git a/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs b/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs
index 17525b6..1315a63 100644
--- a/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs
+++ b/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs
@@ -21,6 +21,7 @@ impl BehaviourTest for FirstPacketFromClientIsConnect {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, _input: Input, mut output: Output) -> Result<(), miette::Error> {
         output
             .wait_and_check(
diff --git a/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs b/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs
index a4c95ad..ea3d663 100644
--- a/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs
+++ b/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs
@@ -21,6 +21,7 @@ impl BehaviourTest for InvalidFirstPacketIsRejected {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> {
         input
             .send_packet(MConnect {
diff --git a/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs b/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs
index efe7a6d..cb77b80 100644
--- a/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs
+++ b/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs
@@ -21,6 +21,7 @@ impl BehaviourTest for InvalidUtf8IsRejected {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> {
         input
             .send_packet(MConnack {
diff --git a/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs b/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs
index 95dfeae..1e57928 100644
--- a/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs
+++ b/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs
@@ -27,6 +27,7 @@ impl BehaviourTest for PublishQos2IsAcked {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> {
         input
             .send_packet(MConnack {
diff --git a/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs b/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs
index fe5544d..5f80a66 100644
--- a/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs
+++ b/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs
@@ -27,6 +27,7 @@ impl BehaviourTest for PublishQosZeroWithIdentFails {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> {
         input
             .send_packet(MConnack {
diff --git a/mqtt-tester/src/behaviour/receiving_server_packet.rs b/mqtt-tester/src/behaviour/receiving_server_packet.rs
index f88888e..ee1e981 100644
--- a/mqtt-tester/src/behaviour/receiving_server_packet.rs
+++ b/mqtt-tester/src/behaviour/receiving_server_packet.rs
@@ -26,6 +26,7 @@ impl BehaviourTest for ReceivingServerPacket {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> {
         input
             .send_packet(MConnack {
diff --git a/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs b/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs
index 32283b6..1f1ad34 100644
--- a/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs
+++ b/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs
@@ -24,6 +24,7 @@ impl BehaviourTest for Utf8WithNullcharIsRejected {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> {
         input
             .send_packet(MConnack {
diff --git a/mqtt-tester/src/behaviour/wait_for_connect.rs b/mqtt-tester/src/behaviour/wait_for_connect.rs
index ab16677..1d643e3 100644
--- a/mqtt-tester/src/behaviour/wait_for_connect.rs
+++ b/mqtt-tester/src/behaviour/wait_for_connect.rs
@@ -19,6 +19,7 @@ impl BehaviourTest for WaitForConnect {
         vec![]
     }
 
+    #[tracing::instrument(skip_all)]
     async fn execute(&self, _input: Input, mut output: Output) -> Result<(), miette::Error> {
         output
             .wait_and_check(
diff --git a/mqtt-tester/src/client_report.rs b/mqtt-tester/src/client_report.rs
index c99c734..b22bfe1 100644
--- a/mqtt-tester/src/client_report.rs
+++ b/mqtt-tester/src/client_report.rs
@@ -199,6 +199,7 @@ macro_rules! wait_for_output {
     }};
 }
 
+#[tracing::instrument(skip_all)]
 async fn check_connect_packet_reserved_flag_zero(
     executable: &ClientExecutable,
 ) -> miette::Result<Report> {
@@ -252,6 +253,7 @@ fn find_connect_flags(bytes: &[u8]) -> Option<u8> {
     Some(getbyte!(connect_flag_position))
 }
 
+#[tracing::instrument(skip_all)]
 async fn check_connect_flag_username_set_username_present(
     executable: &ClientExecutable,
 ) -> miette::Result<Report> {
@@ -307,6 +309,7 @@ async fn check_connect_flag_username_set_username_present(
     })
 }
 
+#[tracing::instrument(skip_all)]
 async fn check_connect_flag_password_set_password_present(
     executable: &ClientExecutable,
 ) -> miette::Result<Report> {
@@ -362,6 +365,7 @@ async fn check_connect_flag_password_set_password_present(
     })
 }
 
+#[tracing::instrument(skip_all)]
 async fn check_connect_flag_username_zero_means_password_zero(
     executable: &ClientExecutable,
 ) -> miette::Result<Report> {