rmcp-memex 0.1.10

RAG/memory MCP server with LanceDB vector storage
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use anyhow::{anyhow, Result};
use rmcp_memex::{rag::RAGPipeline, storage::StorageManager};
use serde_json::json;
use std::sync::Arc;
use tokio::sync::Mutex;

#[tokio::test]
async fn memory_roundtrip_and_search() -> Result<()> {
    let tmp = tempfile::tempdir()?;
    let db_path = tmp.path().join(".lancedb");

    let storage = Arc::new(StorageManager::new(64, &db_path.to_string_lossy()).await?);
    storage.ensure_collection().await?;

    let mlx = Arc::new(Mutex::new(None));
    let rag = RAGPipeline::new(mlx, storage.clone()).await?;

    // Upsert a memory chunk
    rag.memory_upsert(
        "testns",
        "doc1".to_string(),
        "Ala ma kota".to_string(),
        json!({"lang": "pl"}),
    )
    .await?;

    // Read it back
    let fetched = rag
        .memory_get("testns", "doc1")
        .await?
        .ok_or_else(|| anyhow!("doc missing"))?;
    assert_eq!(fetched.text, "Ala ma kota");
    assert_eq!(fetched.namespace, "testns");

    // Semantic search within namespace
    let results = rag.memory_search("testns", "kota", 1).await?;
    assert!(!results.is_empty(), "expected at least one search result");
    assert_eq!(results[0].namespace, "testns");

    Ok(())
}