feat: base subscribers on tracing

Signed-off-by: Will Killian <wkillian@nvidia.com>

Author: willkill07

ATTRIBUTIONS-Rust.md

@@ -58,6 +58,8 @@ bitflags = { version = "2", features = ["serde"] }
 thiserror = "2"
 tokio = { version = "1", default-features = false, features = ["rt", "macros", "sync"] }
 tokio-stream = { version = "0.1", default-features = false }
+tracing = "0.1"
+tracing-subscriber = { version = "0.3", default-features = false, features = ["registry", "std"] }
 typed-builder = "0.23.2"
 opentelemetry = { version = "0.31", default-features = false, features = ["trace"], optional = true }
 opentelemetry_sdk = { version = "0.31", default-features = false, features = ["trace"], optional = true }
@@ -74,6 +76,7 @@ web-sys = { version = "0.3", features = ["Headers", "Request", "RequestInit", "R
 tokio = { version = "1", features = ["rt", "macros", "sync", "test-util", "rt-multi-thread"] }
 futures = "0.3"
 opentelemetry_sdk = { version = "0.31", default-features = false, features = ["trace", "testing"] }
+tracing-subscriber = { version = "0.3", default-features = false, features = ["fmt", "registry", "std"] }
 serde_json = "1"
 
 [[test]]

Cargo.lock

@@ -424,7 +424,7 @@ impl Event {
 
     /// Return this event as canonical JSON.
     pub fn to_json_string(&self) -> serde_json::Result<String> {
-        serde_json::to_string(&self.try_to_json_value()?)
+        serde_json::to_string(self)
     }
 
     /// Return the lifecycle phase for scope events.

crates/core/Cargo.toml

@@ -21,4 +21,5 @@ pub use scope_stack::{
     restore_thread_scope_stack, scope_stack_active, set_thread_scope_stack,
     sync_thread_scope_stack, task_scope_push, task_scope_remove, task_scope_top,
 };
+pub(crate) use state::EventSubscriberSnapshot;
 pub use state::NemoRelayContextState;

crates/core/src/api/event.rs

@@ -200,7 +200,13 @@ impl ScopeStack {
         self.stack
             .iter()
             .filter_map(|handle| self.scope_registries.get(&handle.uuid))
-            .flat_map(|registries| registries.event_subscribers.values().cloned())
+            .flat_map(|registries| {
+                registries
+                    .event_subscribers
+                    .values()
+                    .chain(registries.anonymous_event_subscribers.values())
+                    .cloned()
+            })
             .collect()
     }
 }