diff --git a/server/src/service/events/io.rs b/server/src/service/events/io.rs index e3434c53..a4cf1dde 100644 --- a/server/src/service/events/io.rs +++ b/server/src/service/events/io.rs @@ -31,9 +31,10 @@ pub fn subscribe_to_watcher(buffer: EventBuffer, mut rx: broadcast::Receiver { if let Some(from) = from_stage { + let story_name = lookup_story_name(&item_id); buffer.push(StoredEvent::StageTransition { story_id: item_id, - story_name: String::new(), + story_name, from_stage: from, to_stage: stage, timestamp_ms: now_ms(), @@ -41,17 +42,19 @@ pub fn subscribe_to_watcher(buffer: EventBuffer, mut rx: broadcast::Receiver { + let story_name = lookup_story_name(&story_id); buffer.push(StoredEvent::MergeFailure { story_id, - story_name: String::new(), + story_name, reason, timestamp_ms: now_ms(), }); } Ok(WatcherEvent::StoryBlocked { story_id, reason }) => { + let story_name = lookup_story_name(&story_id); buffer.push(StoredEvent::StoryBlocked { story_id, - story_name: String::new(), + story_name, reason, timestamp_ms: now_ms(), }); @@ -68,3 +71,10 @@ pub fn subscribe_to_watcher(buffer: EventBuffer, mut rx: broadcast::Receiver String { + crate::crdt_state::read_item(story_id) + .map(|view| view.name().to_string()) + .unwrap_or_default() +}