feat(memory): 引入 User/Peer 记忆隔离模型

crates/ov_cli/README.md

@@ -27,8 +27,7 @@ Create `~/.openviking/ovcli.conf`:
   "url": "http://localhost:1933",
   "api_key": "your-api-key",
   "account": "acme",
-  "user": "alice",
-  "agent_id": "assistant-1"
+  "user": "alice"
 }
 ```
 
@@ -132,7 +131,7 @@ ov find "API authentication" --threshold 0.7 --limit 5
 ov ls viking://resources --recursive
 
 # Temporarily override identity from CLI flags
-ov --account acme --user alice --agent-id assistant-2 ls viking://
+ov --account acme --user alice ls viking://
 
 # Glob search
 ov glob "**/*.md" --uri viking://resources

crates/ov_cli/src/base_client.rs

@@ -145,7 +145,6 @@ pub struct BaseClient {
     pub(crate) api_key: Option<String>,
     pub(crate) account: Option<String>,
     pub(crate) user: Option<String>,
-    pub(crate) agent_id: Option<String>,
     pub(crate) profile_enabled: bool,
     pub(crate) extra_headers: Option<std::collections::HashMap<String, String>>,
 }
@@ -164,7 +163,6 @@ impl BaseClient {
             api_key: None,
             account: None,
             user: None,
-            agent_id: None,
             profile_enabled: false,
             extra_headers: None,
         }
@@ -173,7 +171,6 @@ impl BaseClient {
     pub fn new(
         base_url: impl Into<String>,
         api_key: Option<String>,
-        agent_id: Option<String>,
         account: Option<String>,
         user: Option<String>,
         timeout_secs: f64,
@@ -191,7 +188,6 @@ impl BaseClient {
             api_key,
             account,
             user,
-            agent_id,
             profile_enabled,
             extra_headers,
         }
@@ -213,10 +209,6 @@ impl BaseClient {
         self.user.as_deref()
     }
 
-    pub fn agent_id(&self) -> Option<&str> {
-        self.agent_id.as_deref()
-    }
-
     pub fn api_key(&self) -> Option<&str> {
         self.api_key.as_deref()
     }
@@ -232,11 +224,6 @@ impl BaseClient {
                 headers.insert("X-API-Key", value);
             }
         }
-        if let Some(agent_id) = &self.agent_id {
-            if let Ok(value) = reqwest::header::HeaderValue::from_str(agent_id) {
-                headers.insert("X-OpenViking-Agent", value);
-            }
-        }
         if let Some(account) = &self.account {
             if let Ok(value) = reqwest::header::HeaderValue::from_str(account) {
                 headers.insert("X-OpenViking-Account", value);
@@ -315,7 +302,10 @@ impl BaseClient {
         })
     }
 
-    pub(crate) fn create_client_with_timeout(&self, timeout: std::time::Duration) -> Result<ReqwestClient> {
+    pub(crate) fn create_client_with_timeout(
+        &self,
+        timeout: std::time::Duration,
+    ) -> Result<ReqwestClient> {
         ReqwestClient::builder()
             .timeout(timeout)
             .build()
@@ -386,10 +376,7 @@ impl BaseClient {
         let url = format!("{}{}", self.base_url, path);
         let client = self.create_client_with_timeout(timeout)?;
 
-        let request = client
-            .post(&url)
-            .headers(self.build_headers())
-            .json(body);
+        let request = client.post(&url).headers(self.build_headers()).json(body);
         let request = if self.profile_enabled {
             request.query(&[("profile", "1")])
         } else {
@@ -409,11 +396,7 @@ impl BaseClient {
         body: &B,
     ) -> Result<T> {
         let url = format!("{}{}", self.base_url, path);
-        let request = self
-            .http
-            .put(&url)
-            .headers(self.build_headers())
-            .json(body);
+        let request = self.http.put(&url).headers(self.build_headers()).json(body);
         let request = if self.profile_enabled {
             request.query(&[("profile", "1")])
         } else {
@@ -587,18 +570,10 @@ mod tests {
 
     #[test]
     fn append_profile_query_adds_flag_when_enabled() {
-        let client = BaseClient::new(
-            "http://localhost:1933",
-            None,
-            None,
-            None,
-            None,
-            5.0,
-            true,
-            None,
-        );
+        let client = BaseClient::new("http://localhost:1933", None, None, None, 5.0, true, None);
 
-        let params = client.append_profile_query(&[("to_uri".to_string(), "viking://x".to_string())]);
+        let params =
+            client.append_profile_query(&[("to_uri".to_string(), "viking://x".to_string())]);
 
         assert_eq!(
             params,
@@ -611,16 +586,7 @@ mod tests {
 
     #[test]
     fn append_profile_query_keeps_existing_profile_flag() {
-        let client = BaseClient::new(
-            "http://localhost:1933",
-            None,
-            None,
-            None,
-            None,
-            5.0,
-            true,
-            None,
-        );
+        let client = BaseClient::new("http://localhost:1933", None, None, None, 5.0, true, None);
 
         let params = client.append_profile_query(&[("profile".to_string(), "1".to_string())]);
 
@@ -649,7 +615,11 @@ impl<'a> FileUploader<'a> {
         self
     }
 
-    pub fn zip_directory(&self, dir_path: &Path, ignore_dirs: Option<&str>) -> Result<NamedTempFile> {
+    pub fn zip_directory(
+        &self,
+        dir_path: &Path,
+        ignore_dirs: Option<&str>,
+    ) -> Result<NamedTempFile> {
         if !dir_path.is_dir() {
             return Err(Error::Network(format!(
                 "Path {} is not a directory",
@@ -778,7 +748,10 @@ impl<'a> FileUploader<'a> {
 
         if let Some(pb) = pb {
             if total_size > 0 {
-                pb.finish_with_message(format!("Compression complete: {:.2} MiB → {:.2} MiB", original_size_mb, zip_size_mb));
+                pb.finish_with_message(format!(
+                    "Compression complete: {:.2} MiB → {:.2} MiB",
+                    original_size_mb, zip_size_mb
+                ));
             } else {
                 pb.finish_with_message(format!("Compression complete: {:.2} MiB", zip_size_mb));
             }
@@ -849,15 +822,22 @@ impl<'a> FileUploader<'a> {
         let file_size = file_content.len() as u64;
 
         if verbose {
-            eprintln!("Uploading: {} ({:.2} MB)", file_name, file_size as f64 / 1024.0 / 1024.0);
+            eprintln!(
+                "Uploading: {} ({:.2} MB)",
+                file_name,
+                file_size as f64 / 1024.0 / 1024.0
+            );
         }
 
         let pb = ProgressBar::new_spinner();
-        pb.set_message(format!("Uploading {} ({:.2} MB)...", file_name, file_size as f64 / 1024.0 / 1024.0));
+        pb.set_message(format!(
+            "Uploading {} ({:.2} MB)...",
+            file_name,
+            file_size as f64 / 1024.0 / 1024.0
+        ));
         pb.enable_steady_tick(std::time::Duration::from_millis(100));
 
-        let part = reqwest::multipart::Part::bytes(file_content)
-            .file_name(file_name.to_string());
+        let part = reqwest::multipart::Part::bytes(file_content).file_name(file_name.to_string());
 
         let part = part
             .mime_str("application/octet-stream")

crates/ov_cli/src/client.rs

@@ -19,7 +19,6 @@ impl HttpClient {
     pub fn new(
         base_url: impl Into<String>,
         api_key: Option<String>,
-        agent_id: Option<String>,
         account: Option<String>,
         user: Option<String>,
         timeout_secs: f64,
@@ -30,7 +29,6 @@ impl HttpClient {
             base: BaseClient::new(
                 base_url,
                 api_key,
-                agent_id,
                 account,
                 user,
                 timeout_secs,
@@ -44,10 +42,6 @@ impl HttpClient {
         self.base.user_id()
     }
 
-    pub fn agent_id(&self) -> Option<&str> {
-        self.base.agent_id()
-    }
-
     pub fn api_key(&self) -> Option<&str> {
         self.base.api_key()
     }
@@ -146,7 +140,8 @@ impl HttpClient {
         verbose: bool,
         ignore_dirs: Option<&str>,
     ) -> Result<tempfile::NamedTempFile> {
-        self.create_uploader().zip_directory_with_progress(dir_path, verbose, ignore_dirs)
+        self.create_uploader()
+            .zip_directory_with_progress(dir_path, verbose, ignore_dirs)
     }
 
     async fn upload_temp_file(&self, file_path: &Path) -> Result<String> {
@@ -377,6 +372,7 @@ impl HttpClient {
         until: Option<String>,
         time_field: Option<String>,
         level: Option<Vec<i32>>,
+        peer_id: Option<String>,
     ) -> Result<serde_json::Value> {
         let body = serde_json::json!({
             "query": query,
@@ -387,6 +383,7 @@ impl HttpClient {
             "until": until,
             "time_field": time_field,
             "level": level,
+            "peer_id": peer_id,
         });
         self.post("/api/v1/search/find", &body).await
     }
@@ -402,6 +399,7 @@ impl HttpClient {
         until: Option<String>,
         time_field: Option<String>,
         level: Option<Vec<i32>>,
+        peer_id: Option<String>,
     ) -> Result<serde_json::Value> {
         let body = serde_json::json!({
             "query": query,
@@ -413,6 +411,7 @@ impl HttpClient {
             "until": until,
             "time_field": time_field,
             "level": level,
+            "peer_id": peer_id,
         });
         self.post("/api/v1/search/search", &body).await
     }
@@ -1154,7 +1153,8 @@ impl HttpClient {
     pub async fn trigger_watch_by_uri(&self, to_uri: &str) -> Result<serde_json::Value> {
         let params = vec![("to_uri".to_string(), to_uri.to_string())];
         let empty = serde_json::json!({});
-        self.post_with_query("/api/v1/watches/trigger", &empty, &params).await
+        self.post_with_query("/api/v1/watches/trigger", &empty, &params)
+            .await
     }
 }
 
@@ -1190,7 +1190,6 @@ mod tests {
         let client = BaseClient::new(
             "http://localhost:1933",
             Some("test-key".to_string()),
-            Some("assistant-1".to_string()),
             Some("acme".to_string()),
             Some("alice".to_string()),
             5.0,

crates/ov_cli/src/commands/admin.rs

@@ -68,7 +68,9 @@ pub async fn list_users(
     output_format: OutputFormat,
     compact: bool,
 ) -> Result<()> {
-    let response = client.admin_list_users(account_id, limit, name, role).await?;
+    let response = client
+        .admin_list_users(account_id, limit, name, role)
+        .await?;
     output_success(&response, output_format, compact);
     Ok(())
 }

crates/ov_cli/src/commands/content.rs

@@ -46,15 +46,7 @@ pub async fn write(
     output_format: OutputFormat,
     compact: bool,
 ) -> Result<()> {
-    let result = client
-        .write(
-            uri,
-            content,
-            mode,
-            wait,
-            timeout,
-        )
-        .await?;
+    let result = client.write(uri, content, mode, wait, timeout).await?;
     crate::output::output_success(result, output_format, compact);
     Ok(())
 }
@@ -133,17 +125,7 @@ mod tests {
 
         assert_eq!(
             rendered,
-            Some(
-                [
-                    "content",
-                    "",
-                    "profile",
-                    "line one",
-                    "line two",
-                    "",
-                ]
-                .join("\n")
-            )
+            Some(["content", "", "profile", "line one", "line two", "",].join("\n"))
         );
     }
 }

crates/ov_cli/src/commands/filesystem.rs

@@ -80,7 +80,10 @@ pub async fn rm(
 ) -> Result<()> {
     let result = client.rm(uri, recursive).await?;
 
-    let message = if let Some(count) = result.get("estimated_deleted_count").and_then(|v| v.as_u64()) {
+    let message = if let Some(count) = result
+        .get("estimated_deleted_count")
+        .and_then(|v| v.as_u64())
+    {
         format!("Removed: {} ({} items)", uri, count)
     } else {
         format!("Removed: {}", uri)
@@ -128,7 +131,10 @@ fn output_message_result(
     match output_format {
         OutputFormat::Json => output_success(result, output_format, compact),
         OutputFormat::Table => {
-            println!("{}", crate::output::append_profile_to_rendered(message, &result));
+            println!(
+                "{}",
+                crate::output::append_profile_to_rendered(message, &result)
+            );
         }
     }
 }