tandem-memory 0.6.9

Memory storage and embedding utilities for Tandem
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

/// Trusted ownership coordinates for turning one session into project memory.
/// Callers derive this from authenticated runtime context, never request-body
/// tenant or subject fields.
#[derive(Debug, Clone, PartialEq, Eq)]
pub struct ScopedMemoryConsolidationRequest {
    pub tenant_scope: MemoryTenantScope,
    pub org_unit: Option<String>,
    pub subject: Option<String>,
    pub project_id: String,
    pub session_id: String,
}

fn consolidation_chunk_has_exact_ownership(
    chunk: &MemoryChunk,
    request: &ScopedMemoryConsolidationRequest,
) -> bool {
    chunk.subject == request.subject
        && crate::types::owner_org_unit_id_from_metadata(chunk.metadata.as_ref())
            == request.org_unit
}

fn memory_chunk_visible_to_access_filter(
    chunk: &MemoryChunk,
    access_filter: Option<&crate::types::MemoryAccessFilter>,
) -> bool {
    if access_filter.is_none()
        && crate::types::MemorySourceAccessTarget::from_chunk(chunk).is_none()
        && !crate::knowledge_scope::metadata_has_knowledge_scope(chunk.metadata.as_ref())
    {
        return true;
    }
    access_filter
        .map(|filter| filter.allows_chunk(chunk))
        .unwrap_or(false)
}

/// Create memory manager with default database path.
pub async fn create_memory_manager(app_data_dir: &Path) -> MemoryResult<MemoryManager> {
    let db_path = app_data_dir.join("tandem_memory.db");
    MemoryManager::new(&db_path).await
}