use crate::errors::Error;
use crate::memory::lifecycle::{MemoryStatus, MemoryType};
use crate::memory_types::ConflictMemory as InternalConflictMemory;
use crate::memory_types::IngestPolicy;
use std::sync::{Arc, Mutex};
use crate::memory::MemoryStore;
pub(crate) struct StoreWrapper(pub(crate) Arc<Mutex<MemoryStore>>);
impl StoreWrapper {
#[allow(dead_code)] pub(crate) fn new(store: Arc<Mutex<MemoryStore>>) -> Self {
Self(store)
}
#[allow(dead_code)] pub(crate) fn ingest(
&self,
project_id: &str,
text: &str,
metadata: &str,
force: bool,
) -> Result<serde_json::Value, rmcp::ErrorData> {
let mut store = self.0.lock().unwrap();
let policy = if force {
IngestPolicy::Force
} else {
IngestPolicy::ConflictAware
};
match store
.ingest(project_id, text, Some(metadata), policy)
.map_err(|e| -> rmcp::ErrorData { e.into() })?
{
crate::memory_types::AddResult::Added { id } => {
Ok(serde_json::to_value(SuccessResponse {
id,
status: "added".to_string(),
})
.map_err(McpError::from_serde_error)?)
}
crate::memory_types::AddResult::Conflicts {
proposed,
conflicts,
} => Err(McpError::conflict(
&proposed,
conflicts
.into_iter()
.map(|c: InternalConflictMemory| ConflictMemory {
id: c.id,
content: c.content,
similarity: c.similarity,
})
.collect(),
)),
}
}
#[allow(dead_code)] pub(crate) fn ingest_with_type_status(
&self,
project_id: &str,
text: &str,
metadata: &str,
force: bool,
memory_type: MemoryType,
status: MemoryStatus,
) -> Result<serde_json::Value, rmcp::ErrorData> {
let mut store = self.0.lock().unwrap();
let policy = if force {
IngestPolicy::Force
} else {
IngestPolicy::ConflictAware
};
match store
.ingest_with_type_status(
project_id,
text,
Some(metadata),
policy,
memory_type,
status,
)
.map_err(|e| -> rmcp::ErrorData { e.into() })?
{
crate::memory_types::AddResult::Added { id } => {
Ok(serde_json::to_value(SuccessResponse {
id,
status: "added".to_string(),
})
.map_err(McpError::from_serde_error)?)
}
crate::memory_types::AddResult::Conflicts {
proposed,
conflicts,
} => Err(McpError::conflict(
&proposed,
conflicts
.into_iter()
.map(|c: InternalConflictMemory| ConflictMemory {
id: c.id,
content: c.content,
similarity: c.similarity,
})
.collect(),
)),
}
}
#[allow(dead_code)] pub(crate) fn supersede(
&self,
project_id: &str,
new_text: &str,
metadata: &str,
memory_type: MemoryType,
old_memory_id: &str,
) -> Result<serde_json::Value, rmcp::ErrorData> {
let mut store = self.0.lock().unwrap();
let metadata_str = if metadata == "null" {
None
} else {
Some(metadata)
};
let new_id = match store.supersede(
project_id,
new_text,
metadata_str,
memory_type,
old_memory_id,
) {
Ok(id) => id,
Err(err) => {
return Err(err.into());
}
};
serde_json::to_value(SuccessResponse {
id: new_id,
status: "superseded".to_string(),
})
.map_err(McpError::from_serde_error)
}
#[allow(dead_code)] pub(crate) fn search(
&self,
project_id: &str,
query: &str,
limit: usize,
recency_weight: f64,
memory_types: Option<Vec<&str>>,
statuses: Option<Vec<&str>>,
) -> Result<serde_json::Value, Error> {
let mut store = self.0.lock().unwrap();
let memories = store.search(
project_id,
query,
limit,
recency_weight,
crate::memory::SearchOptions {
memory_types,
statuses,
},
)?;
let results: Vec<serde_json::Value> = memories
.into_iter()
.map(|m| {
let metadata_value = match m.metadata {
Some(ref meta_str) if meta_str.trim() != "null" => {
serde_json::from_str::<serde_json::Value>(meta_str)
.unwrap_or_else(|_| serde_json::Value::String(meta_str.clone()))
}
_ => serde_json::Value::Null,
};
serde_json::json!({
"id": m.id,
"content": m.content,
"similarity": m.similarity.unwrap_or(0.0),
"created_at": m.created_at,
"updated_at": m.updated_at,
"project_id": m.project_id,
"metadata": metadata_value
})
})
.collect();
Ok(serde_json::to_value(results)?)
}
#[allow(dead_code)] pub(crate) fn search_hybrid(
&self,
project_id: &str,
query: &str,
limit: usize,
recency_weight: f64,
memory_types: Option<Vec<&str>>,
statuses: Option<Vec<&str>>,
) -> Result<serde_json::Value, Error> {
let mut store = self.0.lock().unwrap();
let options = crate::memory::SearchOptions {
memory_types,
statuses,
};
let memories = store.search_hybrid(project_id, query, limit, recency_weight, options)?;
let results: Vec<serde_json::Value> = memories
.into_iter()
.map(|m| {
let metadata_value = match m.metadata {
Some(ref meta_str) if meta_str.trim() != "null" => {
serde_json::from_str::<serde_json::Value>(meta_str)
.unwrap_or_else(|_| serde_json::Value::String(meta_str.clone()))
}
_ => serde_json::Value::Null,
};
serde_json::json!({
"id": m.id,
"content": m.content,
"similarity": m.similarity.unwrap_or(0.0),
"created_at": m.created_at,
"updated_at": m.updated_at,
"project_id": m.project_id,
"metadata": metadata_value
})
})
.collect();
Ok(serde_json::to_value(results)?)
}
pub(crate) fn list(
&self,
project_id: &str,
limit: usize,
memory_types: Option<&[&str]>,
statuses: Option<&[&str]>,
) -> Result<serde_json::Value, Error> {
let store = self.0.lock().unwrap();
let memories = store.list(project_id, limit, memory_types, statuses)?;
let results: Vec<serde_json::Value> = memories
.into_iter()
.map(|m| {
let metadata_value = match m.metadata {
Some(ref meta_str) if meta_str.trim() != "null" => {
serde_json::from_str::<serde_json::Value>(meta_str)
.unwrap_or_else(|_| serde_json::Value::String(meta_str.clone()))
}
_ => serde_json::Value::Null,
};
serde_json::json!({
"id": m.id,
"content": m.content,
"created_at": m.created_at,
"updated_at": m.updated_at,
"project_id": m.project_id,
"metadata": metadata_value
})
})
.collect();
Ok(serde_json::to_value(results)?)
}
#[allow(dead_code)]
pub(crate) fn inner(&self) -> &Arc<Mutex<MemoryStore>> {
&self.0
}
}
#[derive(serde::Serialize)]
struct SuccessResponse {
id: String,
status: String,
}
#[derive(serde::Serialize)]
pub struct ConflictMemory {
pub id: String,
pub content: String,
pub similarity: f64,
}
#[derive(Debug)]
pub struct McpError;
impl McpError {
pub fn invalid_input(message: &str) -> rmcp::ErrorData {
rmcp::ErrorData::new(
rmcp::model::ErrorCode::INVALID_REQUEST,
message.to_string(),
Some(serde_json::json!({"type": "invalid_input"})),
)
}
pub fn internal_error(message: &str) -> rmcp::ErrorData {
rmcp::ErrorData::new(
rmcp::model::ErrorCode::INTERNAL_ERROR,
message.to_string(),
Some(serde_json::json!({"type": "internal_error"})),
)
}
pub fn conflict(proposed: &str, conflicts: Vec<ConflictMemory>) -> rmcp::ErrorData {
rmcp::ErrorData::new(
rmcp::model::ErrorCode::INVALID_REQUEST,
format!(
"Proposed memory conflicts with {} existing memory(ies)",
conflicts.len()
),
Some(serde_json::json!({
"type": "conflict",
"proposed": proposed,
"conflicts": conflicts
})),
)
}
pub fn from_serde_error(e: serde_json::Error) -> rmcp::ErrorData {
rmcp::ErrorData::new(
rmcp::model::ErrorCode::INTERNAL_ERROR,
format!("Serialization error: {}", e),
Some(serde_json::json!({"type": "internal_error"})),
)
}
}
impl From<Error> for rmcp::ErrorData {
fn from(e: Error) -> Self {
match e {
Error::EmptyInput => McpError::invalid_input("Text cannot be empty"),
Error::InputTooLong {
max_length,
actual_length,
} => McpError::invalid_input(&format!(
"Input too long: {} characters (max: {})",
actual_length, max_length
)),
Error::InvalidInput(msg) => McpError::invalid_input(&msg),
Error::Validation(msg) => McpError::invalid_input(&msg),
Error::InvalidTimestamp { timestamp, error } => {
McpError::invalid_input(&format!("Invalid timestamp '{}': {}", timestamp, error))
}
Error::ContentTooLong {
token_count,
max_tokens,
} => McpError::invalid_input(&format!(
"Content exceeds {}-token embedding limit (measured: {} tokens)",
max_tokens, token_count
)),
Error::NotFound(msg) => rmcp::ErrorData::new(
rmcp::model::ErrorCode::INVALID_REQUEST,
msg,
Some(serde_json::json!({"type": "not_found"})),
),
_ => McpError::internal_error(&e.to_string()),
}
}
}