style: apply cargo fmt

Author: mastwet

agent-diva-agent/src/agent_loop.rs

@@ -660,10 +660,9 @@ mod tests {
     // ── memory provider lifecycle wiring tests (Task 6) ──────────────
 
     use agent_diva_core::memory::{
-        PrefetchRequest, PrefetchResponse, PrefetchStatus, SessionEndRequest,
-        SessionEndResponse, SessionEndStatus, StartupStatus, SyncTurnRequest,
-        SyncTurnResponse, SyncTurnStatus, SystemPromptBlock, SystemPromptRequest,
-        SystemPromptResponse,
+        PrefetchRequest, PrefetchResponse, PrefetchStatus, SessionEndRequest, SessionEndResponse,
+        SessionEndStatus, StartupStatus, SyncTurnRequest, SyncTurnResponse, SyncTurnStatus,
+        SystemPromptBlock, SystemPromptRequest, SystemPromptResponse,
     };
     use std::sync::atomic::{AtomicBool, AtomicUsize, Ordering};
 
@@ -786,8 +785,7 @@ mod tests {
         let memory_provider = Arc::new(TrackingMemoryProvider::new());
 
         // ContextBuilder with injected provider
-        let builder = ContextBuilder::new(workspace)
-            .with_memory_provider(memory_provider.clone());
+        let builder = ContextBuilder::new(workspace).with_memory_provider(memory_provider.clone());
 
         let prompt = builder.build_system_prompt();
 
@@ -840,12 +838,10 @@ mod tests {
 
         assert_eq!(response.status, PrefetchStatus::Ready);
         assert!(response.prompt_block.is_some());
-        assert!(
-            response
-                .prompt_block
-                .unwrap()
-                .contains("recall provider boundary")
-        );
+        assert!(response
+            .prompt_block
+            .unwrap()
+            .contains("recall provider boundary"));
     }
 
     #[tokio::test]

agent-diva-agent/src/agent_loop/loop_turn.rs

@@ -699,15 +699,30 @@ fn derive_prefetch_intent(message: &str) -> String {
 
     let lower = trimmed.to_lowercase();
     let recall_words = [
-        "recall", "remember", "summarize", "summary", "review",
-        "history", "memory", "previous", "last", "recent",
-        "what", "how", "why", "when", "where", "who",
-        "list", "find", "search", "look", "check",
+        "recall",
+        "remember",
+        "summarize",
+        "summary",
+        "review",
+        "history",
+        "memory",
+        "previous",
+        "last",
+        "recent",
+        "what",
+        "how",
+        "why",
+        "when",
+        "where",
+        "who",
+        "list",
+        "find",
+        "search",
+        "look",
+        "check",
     ];
 
-    let has_recall_signal = recall_words.iter().any(|word| {
-        lower.contains(word)
-    });
+    let has_recall_signal = recall_words.iter().any(|word| lower.contains(word));
 
     if has_recall_signal {
         // Use a truncated version as the search intent.

agent-diva-agent/src/context.rs

@@ -415,9 +415,9 @@ fn default_identity_header() -> String {
 mod tests {
     use super::*;
     use agent_diva_core::memory::{
-        PrefetchRequest, PrefetchResponse, PrefetchStatus, SessionEndRequest,
-        SessionEndResponse, SessionEndStatus, SyncTurnRequest, SyncTurnResponse,
-        SyncTurnStatus, SystemPromptBlock, SystemPromptRequest, SystemPromptResponse,
+        PrefetchRequest, PrefetchResponse, PrefetchStatus, SessionEndRequest, SessionEndResponse,
+        SessionEndStatus, SyncTurnRequest, SyncTurnResponse, SyncTurnStatus, SystemPromptBlock,
+        SystemPromptRequest, SystemPromptResponse,
     };
     use std::fs;
     use std::sync::Arc;
@@ -528,9 +528,8 @@ mod tests {
 
     #[test]
     fn test_build_system_prompt_renders_degraded_startup_state() {
-        let rendered = render_startup_injection(SystemPromptResponse::degraded(
-            "wakeup generation failed",
-        ));
+        let rendered =
+            render_startup_injection(SystemPromptResponse::degraded("wakeup generation failed"));
 
         assert!(rendered.contains("status: degraded"));
         assert!(rendered.contains("wakeup generation failed"));

agent-diva-core/src/memory/manager.rs

@@ -2,9 +2,8 @@
 
 use super::provider::{
     MemoryProvider, PrefetchRequest, PrefetchResponse, PrefetchStatus, SessionEndRequest,
-    SessionEndResponse, SessionEndStatus, StartupInjectionShape, SyncTurnRequest,
-    SyncTurnResponse, SyncTurnStatus, SystemPromptBlock, SystemPromptRequest,
-    SystemPromptResponse,
+    SessionEndResponse, SessionEndStatus, StartupInjectionShape, SyncTurnRequest, SyncTurnResponse,
+    SyncTurnStatus, SystemPromptBlock, SystemPromptRequest, SystemPromptResponse,
 };
 use super::storage::{DailyNote, Memory};
 use parking_lot::Mutex;
@@ -220,7 +219,6 @@ impl MemoryManager {
             format!("## Long-term Memory\n{}", memory.content)
         }
     }
-
 }
 
 #[async_trait::async_trait]
@@ -383,7 +381,10 @@ mod tests {
             .unwrap();
 
         assert_eq!(result.status, SyncTurnStatus::Persisted);
-        assert_eq!(manager.load_memory().content, "Updated memory from sync_turn");
+        assert_eq!(
+            manager.load_memory().content,
+            "Updated memory from sync_turn"
+        );
         assert!(manager.load_history().contains("synchronized turn"));
     }
 

agent-diva-core/src/memory/provider.rs

@@ -382,10 +382,8 @@ pub trait MemoryProvider: Send + Sync {
     async fn sync_turn(&self, request: SyncTurnRequest) -> crate::Result<SyncTurnResponse>;
 
     /// Trigger shutdown/session-end rhythm work if needed.
-    async fn on_session_end(
-        &self,
-        request: SessionEndRequest,
-    ) -> crate::Result<SessionEndResponse>;
+    async fn on_session_end(&self, request: SessionEndRequest)
+        -> crate::Result<SessionEndResponse>;
 }
 
 #[cfg(test)]
@@ -419,7 +417,8 @@ mod tests {
 
         async fn sync_turn(&self, request: SyncTurnRequest) -> crate::Result<SyncTurnResponse> {
             Ok(SyncTurnResponse {
-                status: if request.memory_update_markdown.is_some() || request.history_entry.is_some()
+                status: if request.memory_update_markdown.is_some()
+                    || request.history_entry.is_some()
                 {
                     SyncTurnStatus::Persisted
                 } else {
@@ -461,29 +460,32 @@ mod tests {
                 intent: "recall-project-status".to_string(),
                 current_room: Some("roadmap".to_string()),
                 user_message: Some("what changed?".to_string()),
-        })
-        .await
-        .unwrap();
+            })
+            .await
+            .unwrap();
         assert_eq!(prefetch.status, PrefetchStatus::Ready);
-        assert_eq!(prefetch.prompt_block.as_deref(), Some("intent=recall-project-status room=roadmap"));
+        assert_eq!(
+            prefetch.prompt_block.as_deref(),
+            Some("intent=recall-project-status room=roadmap")
+        );
 
         let sync = provider
             .sync_turn(SyncTurnRequest {
                 workspace_root: PathBuf::from("/tmp/diva"),
                 memory_update_markdown: Some("updated".to_string()),
                 history_entry: None,
-        })
-        .await
-        .unwrap();
+            })
+            .await
+            .unwrap();
         assert_eq!(sync.status, SyncTurnStatus::Persisted);
 
         let shutdown = provider
             .on_session_end(SessionEndRequest {
                 workspace_root: PathBuf::from("/tmp/diva"),
                 session_id: Some("session-42".to_string()),
-        })
-        .await
-        .unwrap();
+            })
+            .await
+            .unwrap();
         assert_eq!(shutdown.status, SessionEndStatus::Triggered);
     }