Struct MultiUserMemoryManager 

pub struct MultiUserMemoryManager {

    pub user_memories: Cache<String, Arc<RwLock<MemorySystem>>>,
    pub audit_logs: Arc<DashMap<String, Arc<RwLock<VecDeque<AuditEvent>>>>>,
    pub shared_db: Arc<DB>,
    pub base_path: PathBuf,
    pub default_config: MemoryConfig,
    pub audit_log_counter: Arc<AtomicUsize>,
    pub graph_memories: Cache<String, Arc<RwLock<GraphMemory>>>,
    pub neural_ner: Arc<NeuralNer>,
    pub keyword_extractor: Arc<KeywordExtractor>,
    pub user_evictions: Arc<AtomicUsize>,
    pub server_config: ServerConfig,
    pub event_broadcaster: Sender<MemoryEvent>,
    pub streaming_extractor: Arc<StreamingMemoryExtractor>,
    pub prospective_store: Arc<ProspectiveStore>,
    pub todo_store: Arc<TodoStore>,
    pub file_store: Arc<FileMemoryStore>,
    pub feedback_store: Arc<RwLock<FeedbackStore>>,
    pub backup_engine: Arc<ShodhBackupEngine>,
    pub context_sessions: Arc<ContextSessions>,
    pub context_broadcaster: Sender<ContextStatus>,
    pub ab_test_manager: Arc<ABTestManager>,
    pub session_store: Arc<SessionStore>,
    pub relevance_engine: Arc<RelevanceEngine>,
    /* private fields */
}

Multi-user memory manager - central state for the server

Fields

user_memories: Cache<String, Arc<RwLock<MemorySystem>>>

Per-user memory systems with LRU eviction

audit_logs: Arc<DashMap<String, Arc<RwLock<VecDeque<AuditEvent>>>>>

Per-user audit logs (in-memory cache)

shared_db: Arc<DB>

Shared DB for all global stores (todos, reminders, files, feedback, audit)

base_path: PathBuf

Base storage path

default_config: MemoryConfig

Default config

audit_log_counter: Arc<AtomicUsize>

Counter for audit log rotation checks

graph_memories: Cache<String, Arc<RwLock<GraphMemory>>>

Per-user graph memory systems

neural_ner: Arc<NeuralNer>

Neural NER for automatic entity extraction

keyword_extractor: Arc<KeywordExtractor>

Statistical keyword extraction for graph population

user_evictions: Arc<AtomicUsize>

User eviction counter for metrics

server_config: ServerConfig

Server configuration

event_broadcaster: Sender<MemoryEvent>

SSE event broadcaster for real-time dashboard updates

streaming_extractor: Arc<StreamingMemoryExtractor>

Streaming memory extractor for implicit learning

prospective_store: Arc<ProspectiveStore>

Prospective memory store for reminders/intentions

todo_store: Arc<TodoStore>

GTD-style todo store

file_store: Arc<FileMemoryStore>

File memory store for codebase integration

feedback_store: Arc<RwLock<FeedbackStore>>

Implicit feedback store for memory reinforcement

backup_engine: Arc<ShodhBackupEngine>

Backup engine for automated and manual backups

context_sessions: Arc<ContextSessions>

Context status from Claude Code sessions

context_broadcaster: Sender<ContextStatus>

SSE broadcaster for context status updates

ab_test_manager: Arc<ABTestManager>

A/B testing manager for relevance scoring experiments

session_store: Arc<SessionStore>

Session tracking store

relevance_engine: Arc<RelevanceEngine>

Shared relevance engine for proactive memory surfacing (entity cache + learned weights persist)

Implementations

impl MultiUserMemoryManager

pub fn new(base_path: PathBuf, server_config: ServerConfig) -> Result<Self>

pub fn log_event( &self, user_id: &str, event_type: &str, memory_id: &str, details: &str, )

Log audit event (non-blocking with background persistence)

pub fn emit_event(&self, event: MemoryEvent)

Emit SSE event to all connected dashboard clients

pub fn subscribe_events(&self) -> Receiver<MemoryEvent>

Subscribe to SSE events

pub fn get_history( &self, user_id: &str, memory_id: Option<&str>, ) -> Vec<AuditEvent>

Get audit history for user

pub fn get_user_memory( &self, user_id: &str, ) -> Result<Arc<RwLock<MemorySystem>>>

Get or create memory system for a user

Uses double-checked locking to prevent TOCTOU races where concurrent first-access requests both miss the cache and try to open RocksDB. RocksDB holds exclusive file locks, so the second open would fail.

pub fn evict_user(&self, user_id: &str)

Evict a user’s memory and graph from in-memory caches (releases DB handles). Does NOT delete data — used before restore to release file locks.

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

Delete user data (GDPR compliance)

Cleans up:

1. In-memory caches (user_memories, graph_memories)
2. Shared RocksDB: todos, projects, todo indices, reminders, files, feedback, audit
3. Per-user filesystem: per-user RocksDB, graph DB, vector indices

pub fn get_stats(&self, user_id: &str) -> Result<MemoryStats>

Get statistics for a user

pub fn list_users(&self) -> Vec<String>

List all users

pub fn list_cached_users(&self) -> Vec<String>

List users currently loaded in the Moka cache (no filesystem scan)

pub fn get_audit_logs(&self, user_id: &str, limit: usize) -> Vec<AuditEvent>

Get audit logs for a user

pub fn flush_all_databases(&self) -> Result<()>

Flush all RocksDB databases

pub fn save_all_vector_indices(&self) -> Result<()>

Save all vector indices to disk

pub fn get_neural_ner(&self) -> Arc<NeuralNer>

Get neural NER for entity extraction

pub fn get_keyword_extractor(&self) -> Arc<KeywordExtractor>

Get keyword extractor for statistical term extraction

pub fn get_user_graph(&self, user_id: &str) -> Result<Arc<RwLock<GraphMemory>>>

Get or create graph memory for a user

Uses the same per-user creation lock as get_user_memory to prevent concurrent RocksDB open races on the graph directory.

pub fn get_user_graph_stats(&self, user_id: &str) -> Result<GraphStats>

Get graph statistics for a user

pub fn run_maintenance_all_users(&self) -> usize

Run maintenance on all cached user memories

pub fn streaming_extractor(&self) -> &Arc<StreamingMemoryExtractor>

Get the streaming extractor

pub fn backup_engine(&self) -> &Arc<ShodhBackupEngine>

Get the backup engine

pub fn ab_test_manager(&self) -> &Arc<ABTestManager>

Get the A/B test manager

pub fn todo_store(&self) -> &Arc<TodoStore>

Get the todo store

pub fn prospective_store(&self) -> &Arc<ProspectiveStore>

Get the prospective store

pub fn file_store(&self) -> &Arc<FileMemoryStore>

Get the file store

pub fn feedback_store(&self) -> &Arc<RwLock<FeedbackStore>>

Get the feedback store

pub fn session_store(&self) -> &Arc<SessionStore>

Get the session store

pub fn context_sessions(&self) -> &Arc<ContextSessions>

Get context sessions

pub fn subscribe_context(&self) -> Receiver<ContextStatus>

Subscribe to context status updates

pub fn broadcast_context(&self, status: ContextStatus)

Broadcast context status update

pub fn server_config(&self) -> &ServerConfig

Get server config

pub fn base_path(&self) -> &Path

Get base path

pub fn user_evictions(&self) -> usize

Get user evictions count

pub fn users_in_cache(&self) -> usize

Get users in cache count

pub fn check_and_emit_due_reminders(&self) -> usize

Active reminder check: scan all users for due reminders, mark them triggered, and emit REMINDER_DUE events to the broadcast channel.

Called by the dedicated 60-second reminder scheduler in main.rs. Returns the number of reminders triggered.

pub fn collect_secondary_store_refs(&self) -> Vec<(String, Arc<DB>)>

Collect references to all secondary store databases for comprehensive backup. All shared stores (todos, prospective, files, feedback, audit) share a single DB, so we return one reference. BackupEngine handles all CFs automatically.

pub fn run_backup_all_users(&self, max_backups: usize) -> usize

Run backups for all active users

pub fn process_experience_into_graph( &self, user_id: &str, experience: &Experience, memory_id: &MemoryId, ) -> Result<()>

Process an experience and extract entities/relationships into the graph

SHO-102: Improved graph building with:

• Neural NER entities
• Tags as Technology/Concept entities
• All-caps terms (API, TUI, NER, etc.)
• Issue IDs (SHO-XX pattern)
• Semantic similarity edges between memories