Tweak log levels for some logs

The principles behind the changes were:
- if there is an interaction with the outside (eg. upload/download) -
  INFO
- inter-actor messages and other communication - DEBUG
- message payloads (they can be very large and there's no reason to
  print them multiple times) - TRACE
- implementation-level event that should be of no concern to the user,
  isn't a lot of data, and should be called once or few times - DEBUG

Signed-off-by: Marcel Guzik <[email protected]>

crates/common/download/src/download.rs

@@ -431,7 +431,6 @@ async fn save_chunks_to_file_at(
     writer.seek(SeekFrom::Start(offset))?;
 
     while let Some(bytes) = response.chunk().await? {
-        debug!("read response chunk, size={size}", size = bytes.len());
         writer.write_all(&bytes)?;
     }
     Ok(())

crates/common/flockfile/src/unix.rs

@@ -11,7 +11,6 @@ use std::path::Path;
 use std::path::PathBuf;
 use tracing::debug;
 use tracing::error;
-use tracing::info;
 use tracing::warn;
 
 const LOCK_CHILD_DIRECTORY: &str = "lock/";
@@ -100,7 +99,7 @@ impl Flockfile {
             source: err,
         })?;
 
-        info!(r#"Lockfile created {:?}"#, &path);
+        debug!(r#"Lockfile created {:?}"#, &path);
         Ok(Flockfile {
             handle: Some(file),
             path,

crates/core/tedge_actors/src/message_boxes.rs

@@ -97,7 +97,7 @@ use crate::RuntimeRequest;
 use async_trait::async_trait;
 use futures::channel::mpsc;
 use futures::StreamExt;
-use log::info;
+use log::debug;
 use std::fmt::Debug;
 
 /// Either a message or a [RuntimeRequest]
@@ -184,25 +184,25 @@ impl<Input: Debug> LoggingReceiver<Input> {
 impl<Input: Send + Debug> MessageReceiver<Input> for LoggingReceiver<Input> {
     async fn try_recv(&mut self) -> Result<Option<Input>, RuntimeRequest> {
         let message = self.receiver.try_recv().await;
-        info!(target: &self.name, "recv {:?}", message);
+        debug!(target: &self.name, "recv {:?}", message);
         message
     }
 
     async fn recv_message(&mut self) -> Option<WrappedInput<Input>> {
         let message = self.receiver.recv_message().await;
-        info!(target: &self.name, "recv {:?}", message);
+        debug!(target: &self.name, "recv {:?}", message);
         message
     }
 
     async fn recv(&mut self) -> Option<Input> {
         let message = self.receiver.recv().await;
-        info!(target: &self.name, "recv {:?}", message);
+        debug!(target: &self.name, "recv {:?}", message);
         message
     }
 
     async fn recv_signal(&mut self) -> Option<RuntimeRequest> {
         let message = self.receiver.recv_signal().await;
-        info!(target: &self.name, "recv {:?}", message);
+        debug!(target: &self.name, "recv {:?}", message);
         message
     }
 }
@@ -247,7 +247,7 @@ impl<Output: Debug + Send + Sync + 'static> Sender<Output> for LoggingSender<Out
 }
 
 pub fn log_message_sent<I: Debug>(target: &str, message: I) {
-    info!(target: target, "send {message:?}");
+    debug!(target: target, "send {message:?}");
 }
 
 /// The basic message box to send and receive messages

crates/core/tedge_actors/src/runtime.rs

@@ -260,7 +260,7 @@ where
     for (running_as, sender) in a {
         match sender.send(RuntimeRequest::Shutdown).await {
             Ok(()) => {
-                info!(target: "Runtime", "Successfully sent shutdown request to {running_as}")
+                debug!(target: "Runtime", "Successfully sent shutdown request to {running_as}")
             }
             Err(e) => {
                 error!(target: "Runtime", "Failed to send shutdown request to {running_as}: {e:?}")

crates/extensions/c8y_http_proxy/src/actor.rs

@@ -377,7 +377,7 @@ impl C8YHttpProxyActor {
                 .header("Content-Type", "text/plain")
                 .body(config_content.to_string()))
         };
-        debug!(target: self.name(), "Uploading config file to URL: {}", self.end_point
+        info!(target: self.name(), "Uploading config file to URL: {}", self.end_point
         .get_url_for_event_binary_upload(&event_response_id));
         let http_result = self.execute(device_id.clone(), build_request).await??;
 
@@ -415,7 +415,7 @@ impl C8YHttpProxyActor {
             download_info.auth = Some(Auth::new_bearer(token.as_str()));
         }
 
-        debug!(target: self.name(), "Downloading from: {:?}", download_info.url());
+        info!(target: self.name(), "Downloading from: {:?}", download_info.url());
         let downloader: Downloader =
             Downloader::with_permission(request.file_path, request.file_permissions);
         downloader.download(&download_info).await?;

crates/extensions/c8y_log_manager/src/actor.rs

@@ -14,6 +14,7 @@ use c8y_api::utils::bridge::is_c8y_bridge_up;
 use c8y_http_proxy::handle::C8YHttpProxy;
 use log::error;
 use log::info;
+use log::trace;
 use log_manager::LogPluginConfig;
 use tedge_actors::fan_in_message_type;
 use tedge_actors::Actor;
@@ -66,7 +67,9 @@ impl LogManagerActor {
             for smartrest_message in payload.split('\n') {
                 let result = match smartrest_message.split(',').next().unwrap_or_default() {
                     "522" => {
-                        info!("Log request received: {payload}");
+                        let topic = &message.topic.name;
+                        info!("Log request received on topic: {topic}");
+                        trace!("payload: {payload}");
                         match get_smartrest_device_id(payload) {
                             Some(device_id) if device_id == self.config.device_id => {
                                 // retrieve smartrest object from payload