feat: switch to tracing for logging

Cargo.toml

@@ -9,6 +9,10 @@ default-run = "crabe_async"
 tokio = { version = "1", features = ["rt-multi-thread", "net", "sync", "time", "macros", "signal"] }
 futures-util = "0.3.31"
 
+# logging
+tracing = "0.1.41"
+tracing-subscriber = "0.3.19"
+
 # path planning
 rrt = "0.7.0"
 rand = "0.8.5"

src/main.rs

@@ -11,6 +11,7 @@ use crabe_async::{
 };
 use std::time::Duration;
 use tokio::{join, select, time::sleep};
+use tracing::{info, Level};
 
 // #[derive(Debug, Clone, Copy)]
 // enum HaltedState {
@@ -327,8 +328,14 @@ async fn update_world_with_vision_forever(mut world: World, real: bool) {
 /// Simulation of a real control loop
 #[tokio::main]
 async fn main() {
+    tracing_subscriber::fmt().init();
+
+    // options which will come from cli
     let color = TeamColor::Blue;
     let real = false;
+
+    info!("Starting up Coral (color: {:?}, real: {})", color, real);
+
     let world = World::default_with_team_color(color);
     let gc = GameController::new(None, None);
     let controller = SimRobotController::new(color).await;

src/viewer.rs

@@ -41,6 +41,7 @@ use tokio::{
     net::{TcpListener, TcpStream},
     sync::Notify,
 };
+use tracing::info;
 
 use crate::{
     math::{Point2, Vec2},
@@ -171,7 +172,7 @@ pub async fn init() {
     // Create the event loop and TCP listener we'll accept connections on.
     let try_socket = TcpListener::bind(&addr).await;
     let listener = try_socket.expect("Failed to bind");
-    println!("Listening on: {}", addr);
+    info!("viewer server listening at: {}", addr);
 
     let new_frame_notify_clone = new_frame_notify.clone();
     tokio::spawn(async move {
@@ -193,13 +194,13 @@ async fn accept_connection(new_frame_notifier: Arc<Notify>, stream: TcpStream) {
     let addr = stream
         .peer_addr()
         .expect("connected streams should have a peer address");
-    println!("Peer address: {}", addr);
+    info!(%addr, "new viewer client connected");
 
     let mut ws_stream = tokio_tungstenite::accept_async(stream)
         .await
         .expect("Error during the websocket handshake occurred");
 
-    println!("New WebSocket connection: {}", addr);
+    info!(%addr, "upgraded to websocket");
 
     while !ws_stream.is_terminated() {
         new_frame_notifier.notified().await;

src/world/mod.rs

@@ -6,6 +6,7 @@ pub use ball::Ball;
 pub use robot::{AllyRobot, AvoidanceMode, EnnemyRobot, GotoError, RobotId};
 use serde::{Deserialize, Serialize};
 use tokio::{sync::Notify, time::sleep};
+use tracing::warn;
 
 use crate::{
     league_protocols::vision_packet::SslGeometryFieldSize,
@@ -78,7 +79,7 @@ impl World {
 
     pub async fn allies_detection(&self) {
         while self.team.lock().unwrap_ignore_poison().is_empty() {
-            println!("[WARNING] not detecting any ally robots yet, waiting 1s.");
+            warn!("not detecting any ally robots yet, waiting 1s.");
             sleep(Duration::from_secs(1)).await;
         }
     }