asp/keep
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: add missing item_service argument to AsyncItemService::new

Browse Source 
Co-authored-by: aider (openai/andrew/openrouter/qwen/qwen3-coder) <aider@aider.chat>
This commit is contained in:
Andrew Phillips
2025-08-25 20:29:48 -03:00
parent 1f11351d9b
commit 4abb9794e0
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/modes/server/mcp/tools.rs
View File

@@ -69,7 +69,7 @@ impl KeepTools {
metadata.len() metadata.len()
); );
let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone()); let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone(), self.state.item_service.clone());
let item_with_meta = service let item_with_meta = service
.save_item_from_mcp(content.as_bytes().to_vec(), tags, metadata) .save_item_from_mcp(content.as_bytes().to_vec(), tags, metadata)
.await .await
@@ -90,7 +90,7 @@ impl KeepTools {
.and_then(|v| v.as_i64()) .and_then(|v| v.as_i64())
.ok_or_else(|| ToolError::InvalidArguments("Missing or invalid 'id' field".to_string()))?; .ok_or_else(|| ToolError::InvalidArguments("Missing or invalid 'id' field".to_string()))?;
let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone()); let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone(), self.state.item_service.clone());
let item_with_content = match service.get_item_content(item_id).await { let item_with_content = match service.get_item_content(item_id).await {
Ok(iwc) => iwc, Ok(iwc) => iwc,
@@ -124,7 +124,7 @@ impl KeepTools {
.map(|arr| arr.iter().filter_map(|v| v.as_str().map(|s| s.to_string())).collect()) .map(|arr| arr.iter().filter_map(|v| v.as_str().map(|s| s.to_string())).collect())
.unwrap_or_default(); .unwrap_or_default();
let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone()); let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone(), self.state.item_service.clone());
let item_with_meta = match service.find_item(vec![], tags, HashMap::new()).await { let item_with_meta = match service.find_item(vec![], tags, HashMap::new()).await {
Ok(iwm) => iwm, Ok(iwm) => iwm,
@@ -171,7 +171,7 @@ impl KeepTools {
.and_then(|v| v.as_u64()) .and_then(|v| v.as_u64())
.unwrap_or(0) as usize; .unwrap_or(0) as usize;
let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone()); let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone(), self.state.item_service.clone());
let mut items_with_meta = service.list_items(tags, HashMap::new()).await.map_err(|e| ToolError::Other(anyhow::Error::from(e)))?; let mut items_with_meta = service.list_items(tags, HashMap::new()).await.map_err(|e| ToolError::Other(anyhow::Error::from(e)))?;
// Sort by timestamp (newest first) and apply pagination // Sort by timestamp (newest first) and apply pagination
@@ -224,7 +224,7 @@ impl KeepTools {
}).collect()) }).collect())
.unwrap_or_default(); .unwrap_or_default();
let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone()); let service = AsyncItemService::new(self.state.data_dir.clone(), self.state.db.clone(), self.state.item_service.clone());
let mut items_with_meta = service.list_items(tags.clone(), metadata.clone()).await.map_err(|e| ToolError::Other(anyhow::Error::from(e)))?; let mut items_with_meta = service.list_items(tags.clone(), metadata.clone()).await.map_err(|e| ToolError::Other(anyhow::Error::from(e)))?;
// Sort by timestamp (newest first) // Sort by timestamp (newest first)