diff --git a/poc-memory/src/agents/daemon.rs b/poc-memory/src/agents/daemon.rs index 869979e..8092b51 100644 --- a/poc-memory/src/agents/daemon.rs +++ b/poc-memory/src/agents/daemon.rs @@ -34,10 +34,6 @@ fn log_path() -> PathBuf { crate::config::get().data_dir.join(log_file()) } -fn projects_dir() -> PathBuf { - crate::config::get().projects_dir.clone() -} - // --- Logging --- const LOG_MAX_BYTES: u64 = 1_000_000; // 1MB, then truncate to last half @@ -181,7 +177,7 @@ fn job_daily_check(ctx: &ExecutionContext) -> Result<(), TaskError> { const MIN_SESSION_BYTES: u64 = 100_000; fn find_stale_sessions() -> Vec { - let projects = projects_dir(); + let projects = crate::config::get().projects_dir.clone(); if !projects.exists() { return Vec::new(); } diff --git a/poc-memory/src/agents/enrich.rs b/poc-memory/src/agents/enrich.rs index cd88e52..8146ec2 100644 --- a/poc-memory/src/agents/enrich.rs +++ b/poc-memory/src/agents/enrich.rs @@ -22,7 +22,7 @@ use crate::util::parse_timestamp_to_epoch; /// Compute the store dedup key for a transcript file. /// This is the same key experience_mine uses to mark a transcript as mined. -pub fn transcript_dedup_key(path: &str) -> Result { +fn transcript_dedup_key(path: &str) -> Result { let bytes = fs::read(path).map_err(|e| format!("read {}: {}", path, e))?; let mut hasher = DefaultHasher::new(); bytes.hash(&mut hasher); diff --git a/poc-memory/src/agents/knowledge.rs b/poc-memory/src/agents/knowledge.rs index 06ed246..d2f3fa2 100644 --- a/poc-memory/src/agents/knowledge.rs +++ b/poc-memory/src/agents/knowledge.rs @@ -21,10 +21,6 @@ use std::collections::{HashMap, HashSet}; use std::fs; use std::path::{Path, PathBuf}; -fn projects_dir() -> PathBuf { - crate::config::get().projects_dir.clone() -} - // --------------------------------------------------------------------------- // Action types // --------------------------------------------------------------------------- @@ -420,7 +416,7 @@ fn count_dialogue_turns(path: &Path) -> usize { /// Select conversation fragments for the observation extractor fn select_conversation_fragments(n: usize) -> Vec<(String, String)> { - let projects = projects_dir(); + let projects = crate::config::get().projects_dir.clone(); if !projects.exists() { return Vec::new(); } let mut jsonl_files: Vec = Vec::new(); diff --git a/poc-memory/src/store/mod.rs b/poc-memory/src/store/mod.rs index ee83ef5..5f0d71e 100644 --- a/poc-memory/src/store/mod.rs +++ b/poc-memory/src/store/mod.rs @@ -26,7 +26,13 @@ mod persist; mod ops; // Re-export everything callers need -pub use types::*; +pub use types::{ + memory_dir, nodes_path, + now_epoch, epoch_to_local, format_date, format_datetime, format_datetime_space, today, + Node, Relation, NodeType, Provenance, RelationType, + RetrievalEvent, Params, GapRecord, Store, + new_node, new_relation, +}; pub use parse::{MemoryUnit, parse_units}; pub use view::{StoreView, AnyView}; pub use persist::fsck;