style: cargo fmt

Author: Yogthos

PLAN_LEARNING.md

@@ -58,7 +58,7 @@ Hermes has four layers that work together. We port all of them, adapted:
 
 ---
 
-## Phase 0 — Per-Project `.dirge/` Storage Infrastructure
+## Phase 0 — Per-Project `.dirge/` Storage Infrastructure and Review
 
 **Goal**: establish the `.dirge/` directory as the per-project equivalent
 of `~/.hermes/`. Every other phase writes into this tree.
@@ -82,6 +82,12 @@ or explicit override via `DIRGE_PROJECT_ROOT` env var).
 
 **Risk**: zero. Pure path resolution.
 
+We need to review current features like memories to identified ones that would be
+logically replaced by this system and flag anything that would be duplicate for
+removal after. If the features serve a different purpose then keep them. If they
+conflict or duplicate functionality we are introducing then remove or merge functionality
+as is sensible.
+
 ---
 
 ## Phase 1 — SQLite Session Database with FTS5

src/agent/agent_loop/integration.rs

@@ -611,7 +611,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         })
     }
@@ -770,7 +770,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 
@@ -911,7 +911,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason: StopReason::Stop,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 

src/agent/agent_loop/mod.rs

@@ -63,8 +63,7 @@ pub use integration::{
 };
 pub use message::{
     AssistantMessage, ContentBlock, DeltaPhase, LoopEvent, LoopMessage, StopReason, StreamEvent,
-    TokenUsage,
-    ToolResultMessage, UserMessage,
+    TokenUsage, ToolResultMessage, UserMessage,
 };
 #[cfg(feature = "plugin")]
 pub use plugin_hooks::{after_hook_from_plugin_manager, before_hook_from_plugin_manager};

src/agent/agent_loop/run.rs

@@ -716,7 +716,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         })
     }
@@ -959,7 +959,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 
@@ -1069,7 +1069,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason: StopReason::ToolUse,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 
@@ -1107,7 +1107,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason: StopReason::ToolUse,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 
@@ -1160,7 +1160,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 
@@ -1239,7 +1239,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 
@@ -1485,7 +1485,7 @@ mod tests {
                 crate::agent::agent_loop::message::StreamEvent::Done {
                     reason,
                     message: msg,
-                usage: None,
+                    usage: None,
                 },
             ]))
         });
@@ -1583,7 +1583,7 @@ mod tests {
                 crate::agent::agent_loop::message::StreamEvent::Done {
                     reason,
                     message: msg,
-                usage: None,
+                    usage: None,
                 },
             ]))
         });

src/agent/agent_loop/schema_flatten.rs

@@ -66,7 +66,11 @@ pub fn nest_arguments(flat_args: &Value) -> Value {
             let mut out = serde_json::Map::new();
             for (key, value) in map {
                 let path: Vec<String> = split_flat_key(key);
-                set_by_path(&mut out, path.iter().map(|s| s.as_str()).collect(), value.clone());
+                set_by_path(
+                    &mut out,
+                    path.iter().map(|s| s.as_str()).collect(),
+                    value.clone(),
+                );
             }
             Value::Object(out)
         }
@@ -170,9 +174,7 @@ fn set_by_path(target: &mut serde_json::Map<String, Value>, path: Vec<&str>, val
         if i == last {
             cur.insert(key.to_string(), value.clone());
         } else {
-            let needs_object = cur
-                .get(&key.to_string())
-                .map_or(true, |v| !v.is_object());
+            let needs_object = cur.get(&key.to_string()).map_or(true, |v| !v.is_object());
             if needs_object {
                 // Conflicting or missing intermediate — overwrite with object.
                 if cur.get(&key.to_string()).is_some() {

src/agent/agent_loop/steering.rs

@@ -406,7 +406,7 @@ mod tests {
             Box::pin(futures::stream::iter(vec![StreamEvent::Done {
                 reason,
                 message: msg,
-            usage: None,
+                usage: None,
             }]))
         });
 

src/agent/agent_loop/stream.rs

@@ -208,7 +208,11 @@ pub async fn stream_assistant_response(
                     })
                     .await;
             }
-            StreamEvent::Done { reason, message, usage } => {
+            StreamEvent::Done {
+                reason,
+                message,
+                usage,
+            } => {
                 let mut finalised = message;
                 finalised.stop_reason = reason;
                 finalize(context, &finalised, added_partial, emit).await;