diff --git a/crates/created-swarm/src/swarm.rs b/crates/created-swarm/src/swarm.rs index 3f53dbd621..26d9fef5aa 100644 --- a/crates/created-swarm/src/swarm.rs +++ b/crates/created-swarm/src/swarm.rs @@ -522,6 +522,7 @@ pub async fn create_swarm_with_runtime( let thread_pinner = Arc::new(test_utils::pinning::DUMMY); let node = Node::new( + peer_id, resolved.clone(), core_distributor, thread_pinner, diff --git a/nox/src/main.rs b/nox/src/main.rs index a8db578651..29cc4aa66a 100644 --- a/nox/src/main.rs +++ b/nox/src/main.rs @@ -225,6 +225,7 @@ async fn start_fluence( .wrap_err("Failed to get default system service distros")?; let mut node: Box> = Node::new( + peer_id, config, core_distributor, thread_pinner, diff --git a/nox/src/node.rs b/nox/src/node.rs index 1070389376..f114459a36 100644 --- a/nox/src/node.rs +++ b/nox/src/node.rs @@ -165,6 +165,7 @@ async fn setup_listener( impl Node { pub async fn new( + peer_id: PeerId, config: ResolvedConfig, core_distributor: Arc, thread_pinner: Arc, @@ -312,6 +313,7 @@ impl Node { }; let builtins_config = BuiltinsConfig::new( + peer_id, services_config, config.dir_config.services_persistent_dir.clone(), config.node_config.allowed_effectors.clone(), @@ -893,6 +895,7 @@ mod tests { let thread_pinner = Arc::new(test_utils::pinning::DUMMY); let mut node: Box> = Node::new( + PeerId::random(), config, core_distributor, thread_pinner, diff --git a/particle-builtins/src/builtins.rs b/particle-builtins/src/builtins.rs index 2175f1c2ea..b9d223a112 100644 --- a/particle-builtins/src/builtins.rs +++ b/particle-builtins/src/builtins.rs @@ -125,6 +125,8 @@ pub struct Builtins { #[derive(Debug)] pub struct BuiltinsConfig { + pub peer_id: PeerId, + pub particle_app_services: ParticleAppServicesConfig, /// Dir to store .wasm modules and their configs pub modules_dir: PathBuf, @@ -140,6 +142,7 @@ pub struct BuiltinsConfig { impl BuiltinsConfig { pub fn new( + peer_id: PeerId, particle_app_services: ParticleAppServicesConfig, persistent_dir: PathBuf, allowed_effectors: HashMap>, @@ -193,6 +196,7 @@ impl BuiltinsConfig { .collect::<_>() }; Ok(Self { + peer_id, particle_app_services, blueprint_dir, modules_dir, @@ -407,10 +411,10 @@ where let decider = function_args.filter_map(JValue::as_str).any(|s| s.contains("decider")); if decider { // if log comes from decider, log it as INFO - log::info!(target: "run-console", "{}", json!(args.function_args)); + tracing::info!(target: "run-console", peer_id = self.config.peer_id.to_string(), "{}", json!(args.function_args)); } else { // log everything else as DEBUG - log::debug!(target: "run-console", "{}", json!(args.function_args)); + tracing::debug!(target: "run-console", peer_id = self.config.peer_id.to_string(), "{}", json!(args.function_args)); } wrap_unit(Ok(())) }