diff --git a/crates/plc_platform_core/src/event.rs b/crates/plc_platform_core/src/event.rs index 59ae745..6ac8b5f 100644 --- a/crates/plc_platform_core/src/event.rs +++ b/crates/plc_platform_core/src/event.rs @@ -161,8 +161,8 @@ pub async fn record_event( } } -/// Persists platform events to the `event` table and broadcasts via WebSocket. -pub async fn persist_and_broadcast( +/// Translates a PlatformEvent to an EventInsert and delegates to record_event. +pub async fn record_platform_event( event: &PlatformEvent, pool: &sqlx::PgPool, ws_manager: &WebSocketManager, diff --git a/crates/plc_platform_core/src/platform_context.rs b/crates/plc_platform_core/src/platform_context.rs index 2276ee3..3a28cce 100644 --- a/crates/plc_platform_core/src/platform_context.rs +++ b/crates/plc_platform_core/src/platform_context.rs @@ -35,7 +35,7 @@ impl PlatformContext { let cm = self.connection_manager.clone(); tokio::spawn(async move { // Persist + broadcast. - crate::event::persist_and_broadcast(&event, &pool, &ws_manager).await; + crate::event::record_platform_event(&event, &pool, &ws_manager).await; // Connection management side effects. match &event {