small log fixes

Author: erhant

compute/src/reqres/task.rs

@@ -124,7 +124,7 @@ impl TaskResponder {
                 // prepare signed and encrypted payload
                 log::info!(
                     "Publishing {} result for {}",
-                    "task".green(),
+                    "task".yellow(),
                     task_output.task_id
                 );
                 let payload = TaskResponsePayload::new(

compute/src/workers/task.rs

@@ -1,3 +1,4 @@
+use colored::Colorize;
 use dkn_p2p::libp2p::request_response::ResponseChannel;
 use dkn_workflows::{Entry, ExecutionError, Executor, Workflow};
 use libsecp256k1::PublicKey;
@@ -76,7 +77,7 @@ impl TaskWorker {
             let task = self.task_rx.recv().await;
 
             if let Some(task) = task {
-                log::info!("Processing task {} (single)", task.task_id);
+                log::info!("Processing {} {} (single)", "task".yellow(), task.task_id);
                 TaskWorker::execute((task, &self.publish_tx)).await
             } else {
                 return self.shutdown();

p2p/src/behaviour.rs

@@ -1,6 +1,6 @@
 use eyre::Result;
 use libp2p::identity::{Keypair, PublicKey};
-use libp2p::{identify, request_response, PeerId, StreamProtocol};
+use libp2p::{identify, request_response, StreamProtocol};
 use std::time::Duration;
 
 #[derive(libp2p::swarm::NetworkBehaviour)]

p2p/src/client.rs

@@ -288,7 +288,7 @@ impl DriaP2PClient {
                 ..
             } => {
                 log::info!(
-                    "Connection (id: {connection_id}) established with peer {peer_id} ({} connections) at {:?}",
+                    "Connection ({connection_id}) established with peer {peer_id} ({} connections) at {:?}",
                     num_established,
                     endpoint
                 );
@@ -302,9 +302,11 @@ impl DriaP2PClient {
                 cause,
             } => {
                 log::warn!(
-                    "Connection (id: {connection_id}) closed for {peer_id} ({} connections)\nCause: {}",
+                    "Connection ({connection_id}) closed for {peer_id} ({} connections)\nCause: {}",
                     num_established,
-                    cause.map(|c| c.to_string()).unwrap_or("Unknown".to_string())
+                    cause
+                        .map(|c| c.to_string())
+                        .unwrap_or("Unknown".to_string())
                 );
 
                 if endpoint.is_dialer() {
@@ -325,11 +327,11 @@ impl DriaP2PClient {
                 address,
                 listener_id,
             } => {
-                log::warn!("Listener {listener_id} expired: {address}");
+                log::warn!("Listener ({listener_id}) expired: {address}");
             }
 
             SwarmEvent::ListenerError { listener_id, error } => {
-                log::error!("Listener {listener_id} error: {error}");
+                log::error!("Listener ({listener_id}) failed: {error}");
             }
 
             event => log::debug!("Unhandled Swarm Event: {:?}", event),