[WIP] 新前端工作台搭建

.gitignore

@@ -24,7 +24,6 @@ share/python-wheels/
 *.egg
 MANIFEST
 openviking.egg-info/
-data/
 
 # Rust
 target/

crates/ov_cli/src/client.rs

@@ -1,6 +1,7 @@
 use reqwest::{Client as ReqwestClient, StatusCode};
 use serde::de::DeserializeOwned;
 use serde_json::Value;
+use std::collections::HashSet;
 use std::fs::File;
 use std::path::Path;
 use tempfile::{Builder, NamedTempFile};
@@ -477,20 +478,63 @@ impl HttpClient {
 
     // ============ Search Methods ============
 
+    fn build_tags_filter(tags: &str) -> Result<Value> {
+        let mut tag_list: Vec<&str> = tags
+            .split(',')
+            .map(|s| s.trim())
+            .filter(|s| !s.is_empty())
+            .collect();
+
+        let mut seen = HashSet::new();
+        tag_list.retain(|s| seen.insert(*s));
+
+        if tag_list.is_empty() {
+            return Err(Error::Client(
+                "'tags' must contain at least one non-empty tag".to_string(),
+            ));
+        }
+
+        let conds: Vec<Value> = tag_list
+            .into_iter()
+            .map(|s| {
+                serde_json::json!({
+                    "op": "contains",
+                    "field": "tags",
+                    "substring": s
+                })
+            })
+            .collect();
+
+        Ok(if conds.len() == 1 {
+            conds[0].clone()
+        } else {
+            serde_json::json!({
+                "op": "and",
+                "conds": conds
+            })
+        })
+    }
+
     pub async fn find(
         &self,
         query: String,
         uri: String,
         node_limit: i32,
         threshold: Option<f64>,
+        tags: Option<String>,
     ) -> Result<serde_json::Value> {
-        let body = serde_json::json!({
-            "query": query,
-            "target_uri": uri,
-            "limit": node_limit,
-            "score_threshold": threshold,
-        });
-        self.post("/api/v1/search/find", &body).await
+        let mut body_map = serde_json::Map::new();
+        body_map.insert("query".to_string(), serde_json::json!(query));
+        body_map.insert("target_uri".to_string(), serde_json::json!(uri));
+        body_map.insert("limit".to_string(), serde_json::json!(node_limit));
+        if let Some(t) = threshold {
+            body_map.insert("score_threshold".to_string(), serde_json::json!(t));
+        }
+        if let Some(t) = tags {
+            let filter = Self::build_tags_filter(&t)?;
+            body_map.insert("filter".to_string(), filter);
+        }
+        self.post("/api/v1/search/find", &serde_json::Value::Object(body_map)).await
     }
 
     pub async fn search(
@@ -500,15 +544,23 @@ impl HttpClient {
         session_id: Option<String>,
         node_limit: i32,
         threshold: Option<f64>,
+        tags: Option<String>,
     ) -> Result<serde_json::Value> {
-        let body = serde_json::json!({
-            "query": query,
-            "target_uri": uri,
-            "session_id": session_id,
-            "limit": node_limit,
-            "score_threshold": threshold,
-        });
-        self.post("/api/v1/search/search", &body).await
+        let mut body_map = serde_json::Map::new();
+        body_map.insert("query".to_string(), serde_json::json!(query));
+        body_map.insert("target_uri".to_string(), serde_json::json!(uri));
+        if let Some(s) = session_id {
+            body_map.insert("session_id".to_string(), serde_json::json!(s));
+        }
+        body_map.insert("limit".to_string(), serde_json::json!(node_limit));
+        if let Some(t) = threshold {
+            body_map.insert("score_threshold".to_string(), serde_json::json!(t));
+        }
+        if let Some(t) = tags {
+            let filter = Self::build_tags_filter(&t)?;
+            body_map.insert("filter".to_string(), filter);
+        }
+        self.post("/api/v1/search/search", &serde_json::Value::Object(body_map)).await
     }
 
     pub async fn grep(
@@ -560,6 +612,7 @@ impl HttpClient {
         exclude: Option<String>,
         directly_upload_media: bool,
         watch_interval: f64,
+        tags: Option<String>,
     ) -> Result<serde_json::Value> {
         let path_obj = Path::new(path);
 
@@ -587,6 +640,7 @@ impl HttpClient {
                     "exclude": exclude,
                     "directly_upload_media": directly_upload_media,
                     "watch_interval": watch_interval,
+                    "tags": tags,
                 });
 
                 self.post("/api/v1/resources", &body).await
@@ -607,6 +661,7 @@ impl HttpClient {
                     "exclude": exclude,
                     "directly_upload_media": directly_upload_media,
                     "watch_interval": watch_interval,
+                    "tags": tags,
                 });
 
                 self.post("/api/v1/resources", &body).await

crates/ov_cli/src/commands/resources.rs

@@ -17,6 +17,7 @@ pub async fn add_resource(
     exclude: Option<String>,
     directly_upload_media: bool,
     watch_interval: f64,
+    tags: Option<String>,
     format: OutputFormat,
     compact: bool,
 ) -> Result<()> {
@@ -35,6 +36,7 @@ pub async fn add_resource(
             exclude,
             directly_upload_media,
             watch_interval,
+            tags,
         )
         .await?;
     output_success(&result, format, compact);

crates/ov_cli/src/commands/search.rs

@@ -8,11 +8,12 @@ pub async fn find(
     uri: &str,
     node_limit: i32,
     threshold: Option<f64>,
+    tags: Option<String>,
     output_format: OutputFormat,
     compact: bool,
 ) -> Result<()> {
     let result = client
-        .find(query.to_string(), uri.to_string(), node_limit, threshold)
+        .find(query.to_string(), uri.to_string(), node_limit, threshold, tags)
         .await?;
     output_success(&result, output_format, compact);
     Ok(())
@@ -25,6 +26,7 @@ pub async fn search(
     session_id: Option<String>,
     node_limit: i32,
     threshold: Option<f64>,
+    tags: Option<String>,
     output_format: OutputFormat,
     compact: bool,
 ) -> Result<()> {
@@ -35,6 +37,7 @@ pub async fn search(
             session_id,
             node_limit,
             threshold,
+            tags,
         )
         .await?;
     output_success(&result, output_format, compact);

crates/ov_cli/src/main.rs

@@ -146,6 +146,9 @@ enum Commands {
         /// Watch interval in minutes for automatic resource monitoring (0 = no monitoring)
         #[arg(long, default_value = "0")]
         watch_interval: f64,
+        /// Tags for the resource (comma-separated)
+        #[arg(long)]
+        tags: Option<String>,
     },
     /// Add a skill into OpenViking
     AddSkill {
@@ -377,6 +380,9 @@ enum Commands {
         /// Score threshold
         #[arg(short, long)]
         threshold: Option<f64>,
+        /// Filter by tags (comma-separated)
+        #[arg(long)]
+        tags: Option<String>,
     },
     /// Run context-aware retrieval
     Search {
@@ -399,6 +405,9 @@ enum Commands {
         /// Score threshold
         #[arg(short, long)]
         threshold: Option<f64>,
+        /// Filter by tags (comma-separated)
+        #[arg(long)]
+        tags: Option<String>,
     },
     /// Run content pattern search
     Grep {
@@ -666,6 +675,7 @@ async fn main() {
             exclude,
             no_directly_upload_media,
             watch_interval,
+            tags,
         } => {
             handle_add_resource(
                 path,
@@ -681,6 +691,7 @@ async fn main() {
                 exclude,
                 no_directly_upload_media,
                 watch_interval,
+                tags,
                 ctx,
             )
             .await
@@ -794,14 +805,16 @@ async fn main() {
             uri,
             node_limit,
             threshold,
-        } => handle_find(query, uri, node_limit, threshold, ctx).await,
+            tags,
+        } => handle_find(query, uri, node_limit, threshold, tags, ctx).await,
         Commands::Search {
             query,
             uri,
             session_id,
             node_limit,
             threshold,
-        } => handle_search(query, uri, session_id, node_limit, threshold, ctx).await,
+            tags,
+        } => handle_search(query, uri, session_id, node_limit, threshold, tags, ctx).await,
         Commands::Grep {
             uri,
             exclude_uri,
@@ -837,6 +850,7 @@ async fn handle_add_resource(
     exclude: Option<String>,
     no_directly_upload_media: bool,
     watch_interval: f64,
+    tags: Option<String>,
     ctx: CliContext,
 ) -> Result<()> {
     let is_url =
@@ -910,6 +924,7 @@ async fn handle_add_resource(
         exclude,
         directly_upload_media,
         watch_interval,
+        tags,
         ctx.output_format,
         ctx.compact,
     )
@@ -1271,12 +1286,16 @@ async fn handle_find(
     uri: String,
     node_limit: i32,
     threshold: Option<f64>,
+    tags: Option<String>,
     ctx: CliContext,
 ) -> Result<()> {
     let mut params = vec![format!("--uri={}", uri), format!("-n {}", node_limit)];
     if let Some(t) = threshold {
         params.push(format!("--threshold {}", t));
     }
+    if let Some(t) = &tags {
+        params.push(format!("--tags {}", t));
+    }
     params.push(format!("\"{}\"", query));
     print_command_echo("ov find", &params.join(" "), ctx.config.echo_command);
     let client = ctx.get_client();
@@ -1286,6 +1305,7 @@ async fn handle_find(
         &uri,
         node_limit,
         threshold,
+        tags,
         ctx.output_format,
         ctx.compact,
     )
@@ -1298,6 +1318,7 @@ async fn handle_search(
     session_id: Option<String>,
     node_limit: i32,
     threshold: Option<f64>,
+    tags: Option<String>,
     ctx: CliContext,
 ) -> Result<()> {
     let mut params = vec![format!("--uri={}", uri), format!("-n {}", node_limit)];
@@ -1307,6 +1328,9 @@ async fn handle_search(
     if let Some(t) = threshold {
         params.push(format!("--threshold {}", t));
     }
+    if let Some(t) = &tags {
+        params.push(format!("--tags {}", t));
+    }
     params.push(format!("\"{}\"", query));
     print_command_echo("ov search", &params.join(" "), ctx.config.echo_command);
     let client = ctx.get_client();
@@ -1317,6 +1341,7 @@ async fn handle_search(
         session_id,
         node_limit,
         threshold,
+        tags,
         ctx.output_format,
         ctx.compact,
     )

docs/en/api/02-resources.md

@@ -48,6 +48,7 @@ Add a resource to the knowledge base.
 | wait | bool | No | False | Wait for semantic processing to complete |
 | timeout | float | No | None | Timeout in seconds (only used when wait=True) |
 | watch_interval | float | No | 0 | Watch interval (minutes). >0 enables/updates watch; <=0 disables watch. Only takes effect when target is provided |
+| tags | str | No | None | Comma-separated list of tags to attach to the resource |
 
 **How local files and directories work**
 
@@ -75,7 +76,8 @@ When you call `add_resource()` repeatedly for the same resource URI, the system
 ```python
 result = client.add_resource(
     "./documents/guide.md",
-    reason="User guide documentation"
+    reason="User guide documentation",
+    tags="documentation,guide"
 )
 print(f"Added: {result['root_uri']}")
 
@@ -94,14 +96,15 @@ curl -X POST http://localhost:1933/api/v1/resources \
   -H "X-API-Key: your-key" \
   -d '{
     "path": "https://example.com/guide.md",
-    "reason": "User guide documentation"
+    "reason": "User guide documentation",
+    "tags": "documentation,guide"
   }'
 ```
 
 **CLI**
 
 ```bash
-openviking add-resource ./documents/guide.md --reason "User guide documentation"
+openviking add-resource ./documents/guide.md --reason "User guide documentation" --tags "documentation,guide"
 ```
 
 **Response**

docs/en/api/03-filesystem.md

@@ -254,7 +254,8 @@ List directory contents.
     "modTime": "2024-01-01T00:00:00Z",  # ISO timestamp
     "isDir": True,            # True if directory
     "uri": "viking://resources/docs/",  # Viking URI
-    "meta": {}                # Optional metadata
+    "meta": {},               # Optional metadata
+    "tags": "guide,api"       # Tags (for display only. Filtering is supported in find/search)
 }
 ```
 

docs/en/api/06-retrieval.md

@@ -27,6 +27,7 @@ Basic vector similarity search.
 | limit | int | No | 10 | Maximum number of results |
 | score_threshold | float | No | None | Minimum relevance score threshold |
 | filter | Dict | No | None | Metadata filters |
+| tags | str | No | None | Comma-separated list of tags to filter by (shortcut for filter) |
 
 **FindResult Structure**
 
@@ -51,6 +52,7 @@ class MatchedContext:
     category: str                    # Category
     score: float                     # Relevance score (0-1)
     match_reason: str                # Why this matched
+    tags: Optional[str]              # Comma-separated tags (if any)
     relations: List[RelatedContext]  # Related contexts
 ```
 
@@ -184,6 +186,7 @@ Search with session context and intent analysis.
 | limit | int | No | 10 | Maximum number of results |
 | score_threshold | float | No | None | Minimum relevance score threshold |
 | filter | Dict | No | None | Metadata filters |
+| tags | str | No | None | Comma-separated list of tags to filter by (shortcut for filter) |
 
 **Python SDK (Embedded / HTTP)**