diff --git a/libs/room/src/room.rs b/libs/room/src/room.rs index fb28891..cd896a1 100644 --- a/libs/room/src/room.rs +++ b/libs/room/src/room.rs @@ -161,8 +161,11 @@ impl RoomService { project_id: Uuid, user_id: Uuid, ) { - self.invalidate_room_list_cache_for_prefix(&format!("room:list:{}:{}:", project_id, user_id)) - .await; + self.invalidate_room_list_cache_for_prefix(&format!( + "room:list:{}:{}:", + project_id, user_id + )) + .await; } async fn invalidate_room_list_cache_for_prefix(&self, prefix: &str) { diff --git a/libs/room/src/service/ai_streaming.rs b/libs/room/src/service/ai_streaming.rs index 3dbcf85..9c5c37f 100644 --- a/libs/room/src/service/ai_streaming.rs +++ b/libs/room/src/service/ai_streaming.rs @@ -247,7 +247,10 @@ pub async fn process_message_ai_streaming( } }); - match chat_service.process_room_stream(request, stream_callback, room_tools).await { + match chat_service + .process_room_stream(request, stream_callback, room_tools) + .await + { Ok(result) => { // Store ordered chunks as JSON in thinking_content for ordered replay. // Uses {"__chunks__": [...]} marker so legacy plain-text still works.