diff --git a/crates/lavina-core/src/player.rs b/crates/lavina-core/src/player.rs index 87bc0ac..60046b5 100644 --- a/crates/lavina-core/src/player.rs +++ b/crates/lavina-core/src/player.rs @@ -276,11 +276,13 @@ impl PlayerRegistry { Ok(()) } + #[tracing::instrument(skip(self), name = "PlayerRegistry::get_player")] pub async fn get_player(&self, id: &PlayerId) -> Option { let inner = self.0.read().await; inner.players.get(id).map(|(handle, _)| handle.clone()) } + #[tracing::instrument(skip(self), name = "PlayerRegistry::stop_player")] pub async fn stop_player(&self, id: &PlayerId) -> Result> { let mut inner = self.0.write().await; if let Some((handle, fiber)) = inner.players.remove(id) { @@ -294,6 +296,7 @@ impl PlayerRegistry { } } + #[tracing::instrument(skip(self), name = "PlayerRegistry::get_or_launch_player")] pub async fn get_or_launch_player(&mut self, id: &PlayerId) -> PlayerHandle { let inner = self.0.read().await; if let Some((handle, _)) = inner.players.get(id) { @@ -318,6 +321,7 @@ impl PlayerRegistry { } } + #[tracing::instrument(skip(self), name = "PlayerRegistry::connect_to_player")] pub async fn connect_to_player(&mut self, id: &PlayerId) -> PlayerConnection { let player_handle = self.get_or_launch_player(id).await; player_handle.subscribe().await diff --git a/src/http.rs b/src/http.rs index 7543ed8..ae64676 100644 --- a/src/http.rs +++ b/src/http.rs @@ -100,6 +100,7 @@ fn endpoint_metrics(registry: MetricsRegistry) -> Response> { Response::new(Full::new(Bytes::from(buffer))) } +#[tracing::instrument(skip_all)] async fn endpoint_rooms(rooms: RoomRegistry) -> Response> { // TODO introduce management API types independent from core-domain types // TODO remove `Serialize` implementations from all core-domain types @@ -107,6 +108,7 @@ async fn endpoint_rooms(rooms: RoomRegistry) -> Response> { Response::new(room_list) } +#[tracing::instrument(skip_all)] async fn endpoint_create_player( request: Request, mut storage: Storage, @@ -122,6 +124,7 @@ async fn endpoint_create_player( Ok(response) } +#[tracing::instrument(skip_all)] async fn endpoint_stop_player( request: Request, players: PlayerRegistry, @@ -141,6 +144,7 @@ async fn endpoint_stop_player( Ok(response) } +#[tracing::instrument(skip_all)] async fn endpoint_set_password( request: Request, storage: Storage,