reduce logs to debug

tari-project · Apr 25, 2024 · 6338320 · 6338320
1 parent a25b6fd
commit 6338320
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 9 deletions.
diff --git a/applications/tari_generate/src/main.rs b/applications/tari_generate/src/main.rs
@@ -88,7 +88,7 @@ struct ScaffoldArgs {
     #[clap(long, short = 'c', alias = "config")]
     pub generator_config_file: Option<PathBuf>,
     #[clap(long, short = 'a')]
-    address: String,
+    template_address: String,
     #[clap(long, short = 'j')]
     dan_testing_jrpc_url: String,
 }
@@ -284,7 +284,7 @@ async fn scaffold(args: ScaffoldArgs) -> anyhow::Result<()> {
         output_path: "output/".into(),
         liquid: Some(generators::LiquidGeneratorOpts {
             skip_format: false,
-            variables: vec![("template_address".to_string(), Value::String(args.address.clone()))]
+            variables: vec![("template_address".to_string(), Value::String(args.template_address.clone()))]
                 .into_iter()
                 .collect(),
         }),
@@ -307,7 +307,7 @@ async fn scaffold(args: ScaffoldArgs) -> anyhow::Result<()> {
     let request = json!({
         "jsonrpc" : "2.0",
         "method": "get_template",
-        "params": [hex::decode(args.address)?],
+        "params": [hex::decode(args.template_address)?],
         "id": 1
     });
     let response = reqwest::Client::new()

diff --git a/applications/tari_indexer/log4rs_sample.yml b/applications/tari_indexer/log4rs_sample.yml
@@ -106,12 +106,16 @@ loggers:
       - stdout
     additive: false
 
+  tari::dan::networking:
+    level: debug
+    appenders:
+      - network
+    additive: true
+
   tari::dan:
     level: info
     appenders:
       - dan_layer
-      - stdout
-    additive: false
 
   tari::indexer:
     level: info

diff --git a/networking/core/src/worker.rs b/networking/core/src/worker.rs
@@ -519,6 +519,7 @@ where
                     relay_peer_id, renewal, limit
                 );
             },
+
             RelayClient(event) => {
                 info!(target: LOG_TARGET, "🌎️ RelayClient event: {:?}", event);
             },
@@ -905,7 +906,7 @@ where
                 let _ignore = reply.send(Ok(NegotiatedSubstream::new(peer_id, protocol, stream)));
             },
             InboundSubstreamOpen { notification } => {
-                info!(target: LOG_TARGET, "📥 Inbound substream open: protocol={}", notification.protocol);
+                debug!(target: LOG_TARGET, "📥 Inbound substream open: protocol={}", notification.protocol);
                 self.substream_notifiers.notify(notification);
             },
             InboundFailure {

diff --git a/networking/rpc_framework/src/server/mod.rs b/networking/rpc_framework/src/server/mod.rs
@@ -368,7 +368,7 @@ where
     }
 
     fn on_session_complete(&mut self, node_id: &PeerId) {
-        info!(target: LOG_TARGET, "Session complete for {}", node_id);
+        debug!(target: LOG_TARGET, "Session complete for {}", node_id);
         if let Some(v) = self.sessions.get_mut(node_id) {
             *v -= 1;
             if *v == 0 {
@@ -416,7 +416,7 @@ where
 
         match self.new_session_for(peer_id) {
             Ok(num_sessions) => {
-                info!(
+                debug!(
                     target: LOG_TARGET,
                     "NEW SESSION for {} ({} active) ", peer_id, num_sessions
                 );
@@ -446,7 +446,7 @@ where
                 #[cfg(feature = "metrics")]
                 num_sessions.inc();
                 service.start().await;
-                info!(target: LOG_TARGET, "END OF SESSION for {} ", peer_id,);
+                debug!(target: LOG_TARGET, "END OF SESSION for {} ", peer_id,);
                 #[cfg(feature = "metrics")]
                 num_sessions.dec();