From 5f4c6edee448fc89bf5bc67631abcce82a2d5a27 Mon Sep 17 00:00:00 2001
From: Alexis Sellier <self@cloudhead.io>
Date: Fri, 10 Feb 2023 22:09:32 +0100
Subject: [PATCH] node: Simulator logging improvements

---
 radicle-node/src/test/simulator.rs | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/radicle-node/src/test/simulator.rs b/radicle-node/src/test/simulator.rs
index 9f3f7317..d6168bea 100644
--- a/radicle-node/src/test/simulator.rs
+++ b/radicle-node/src/test/simulator.rs
@@ -84,10 +84,7 @@ impl fmt::Display for Scheduled {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         match &self.input {
             Input::Received(from, msgs) => {
-                for msg in msgs {
-                    write!(f, "{} <- {} ({:?})", self.node, from, msg)?;
-                }
-                Ok(())
+                write!(f, "{} <- {} ({:?})", self.node, from, msgs)
             }
             Input::Connected {
                 id: addr,
@@ -611,6 +608,20 @@ impl<S: WriteStorage + 'static, G: Signer> Simulation<S, G> {
                 }
             }
             Io::Fetch(fetch) => {
+                if fetch.initiated {
+                    log::info!(
+                        target: "sim",
+                        "{:05} {} ~> {} ({})",
+                        self.elapsed().as_millis(), node, fetch.remote, fetch.rid
+                    );
+                } else {
+                    log::info!(
+                        target: "sim",
+                        "{:05} {} <~ {} ({})",
+                        self.elapsed().as_millis(), node, fetch.remote, fetch.rid
+                    );
+                }
+
                 if self.is_fallible() {
                     self.inbox.insert(
                         self.time + LocalDuration::from_secs(3),