Struct SemanticFactStore 

pub struct SemanticFactStore { /* private fields */ }

Storage for semantic facts with indexing

Implementations

impl SemanticFactStore

pub fn new(db: Arc<DB>) -> Self

Create a new fact store backed by RocksDB

pub fn databases(&self) -> Vec<(&str, &Arc<DB>)>

Get references to all RocksDB databases for backup

pub fn store(&self, user_id: &str, fact: &SemanticFact) -> Result<()>

Store a semantic fact

pub fn store_batch( &self, user_id: &str, facts: &[SemanticFact], ) -> Result<usize>

Store multiple facts in a batch

pub fn get(&self, user_id: &str, fact_id: &str) -> Result<Option<SemanticFact>>

Get a fact by ID

pub fn update(&self, user_id: &str, fact: &SemanticFact) -> Result<()>

Update an existing fact (for reinforcement)

pub fn delete(&self, user_id: &str, fact_id: &str) -> Result<bool>

Delete a fact

pub fn list(&self, user_id: &str, limit: usize) -> Result<Vec<SemanticFact>>

List all facts for a user

pub fn find_by_entity( &self, user_id: &str, entity: &str, limit: usize, ) -> Result<Vec<SemanticFact>>

Find facts by related entity

pub fn find_by_type( &self, user_id: &str, fact_type: FactType, limit: usize, ) -> Result<Vec<SemanticFact>>

Find facts by type

pub fn search( &self, user_id: &str, query: &str, limit: usize, ) -> Result<Vec<SemanticFact>>

Search facts by keyword in fact content

pub fn stats(&self, user_id: &str) -> Result<FactStats>

Get statistics about stored facts

pub fn latest_fact_created_at(&self, user_id: &str) -> Option<i64>

Find the creation timestamp of the most recent fact for a user.

Used at startup to initialize the fact extraction watermark when no persisted watermark exists. Returns None if user has no facts.

pub fn find_decaying_facts( &self, user_id: &str, max_age_days: i64, ) -> Result<Vec<SemanticFact>>

Find facts that should decay (no reinforcement for too long)

pub fn find_similar( &self, user_id: &str, fact_content: &str, fact_entities: &[String], new_embedding: Option<&[f32]>, ) -> Result<Option<SemanticFact>>

Check if a similar fact already exists (hybrid dedup)

Multi-gate pipeline when embedding is provided:

1. Entity gate: at least 1 shared entity, OR both have zero entities
2. Polarity gate: same negation polarity (prevents merging contradictions)
3. Cosine gate: embedding similarity >= FACT_DEDUP_COSINE_THRESHOLD
4. Jaccard floor: word overlap >= FACT_DEDUP_JACCARD_FLOOR

Falls back to pure Jaccard (0.70) if no embedding is provided.

pub fn store_embedding( &self, user_id: &str, fact_id: &str, embedding: &[f32], ) -> Result<()>

Store pre-computed embedding vector for a fact

Key format: facts_embedding:{user_id}:{fact_id} → bincode Vec Stored separately from SemanticFact struct for backward compatibility.

pub fn get_embedding( &self, user_id: &str, fact_id: &str, ) -> Result<Option<Vec<f32>>>

Get pre-computed embedding vector for a fact

pub fn delete_embedding(&self, user_id: &str, fact_id: &str) -> Result<()>

Delete embedding for a fact (called during fact deletion)

pub fn list_users(&self, limit: usize) -> Result<Vec<String>>

List all unique user IDs that have facts