fix: remove unused meta plugin imports
Co-authored-by: aider (openai/andrew/openrouter/deepseek/deepseek-chat-v3.1) <aider@aider.chat>
This commit is contained in:
@@ -1,7 +1,9 @@
|
|||||||
use crate::common::PIPESIZE;
|
use crate::common::PIPESIZE;
|
||||||
|
use crate::config::Settings;
|
||||||
use crate::services::error::CoreError;
|
use crate::services::error::CoreError;
|
||||||
use crate::services::item_service::ItemService;
|
use crate::services::item_service::ItemService;
|
||||||
use crate::services::types::{ItemWithContent, ItemWithMeta};
|
use crate::services::types::{ItemWithContent, ItemWithMeta};
|
||||||
|
use clap::Command;
|
||||||
use rusqlite::Connection;
|
use rusqlite::Connection;
|
||||||
use std::collections::HashMap;
|
use std::collections::HashMap;
|
||||||
use std::io::Read;
|
use std::io::Read;
|
||||||
@@ -17,12 +19,26 @@ pub struct AsyncItemService {
|
|||||||
pub data_dir: PathBuf,
|
pub data_dir: PathBuf,
|
||||||
db: Arc<Mutex<Connection>>,
|
db: Arc<Mutex<Connection>>,
|
||||||
item_service: Arc<ItemService>,
|
item_service: Arc<ItemService>,
|
||||||
|
cmd: Arc<Mutex<Command>>,
|
||||||
|
settings: Arc<Settings>,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[allow(dead_code)]
|
#[allow(dead_code)]
|
||||||
impl AsyncItemService {
|
impl AsyncItemService {
|
||||||
pub fn new(data_dir: PathBuf, db: Arc<Mutex<Connection>>, item_service: Arc<ItemService>) -> Self {
|
pub fn new(
|
||||||
Self { data_dir, db, item_service }
|
data_dir: PathBuf,
|
||||||
|
db: Arc<Mutex<Connection>>,
|
||||||
|
item_service: Arc<ItemService>,
|
||||||
|
cmd: Command,
|
||||||
|
settings: Settings,
|
||||||
|
) -> Self {
|
||||||
|
Self {
|
||||||
|
data_dir,
|
||||||
|
db,
|
||||||
|
item_service,
|
||||||
|
cmd: Arc::new(Mutex::new(cmd)),
|
||||||
|
settings: Arc::new(settings),
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn get_item(&self, id: i64) -> Result<ItemWithMeta, CoreError> {
|
pub async fn get_item(&self, id: i64) -> Result<ItemWithMeta, CoreError> {
|
||||||
@@ -331,10 +347,14 @@ impl AsyncItemService {
|
|||||||
) -> Result<ItemWithMeta, CoreError> {
|
) -> Result<ItemWithMeta, CoreError> {
|
||||||
let db = self.db.clone();
|
let db = self.db.clone();
|
||||||
let item_service = self.item_service.clone();
|
let item_service = self.item_service.clone();
|
||||||
|
let cmd = self.cmd.clone();
|
||||||
|
let settings = self.settings.clone();
|
||||||
|
|
||||||
tokio::task::spawn_blocking(move || {
|
tokio::task::spawn_blocking(move || {
|
||||||
let mut conn = db.blocking_lock();
|
let mut conn = db.blocking_lock();
|
||||||
item_service.save_item_from_mcp(&content, &tags, &metadata, &mut conn)
|
let mut cmd = cmd.blocking_lock();
|
||||||
|
let settings = settings.as_ref();
|
||||||
|
item_service.save_item_from_mcp(&content, &tags, &metadata, &mut cmd, settings, &mut conn)
|
||||||
})
|
})
|
||||||
.await
|
.await
|
||||||
.unwrap()
|
.unwrap()
|
||||||
|
|||||||
Reference in New Issue
Block a user