use chrono::{DateTime, Utc};
use crate::core::consolidation_engine::{ConsolidateOptions, ImportCounts, import_session_into};
use crate::core::knowledge::ProjectKnowledge;
use crate::core::memory_archive::MemoryStore;
use crate::core::memory_capacity::{reclaim_preview, reclaim_store, reclaim_target};
use crate::core::memory_lifecycle::LifecycleReport;
use crate::core::memory_policy::MemoryPolicy;
use crate::core::procedural_memory::{ProceduralStore, retention_cmp};
use crate::core::session::SessionState;
pub(crate) fn load_policy_or_error() -> Result<MemoryPolicy, String> {
crate::tools::knowledge_shared::load_policy_or_error()
}
#[derive(Debug, Default)]
pub(crate) struct KnowledgeConsolidationReport {
pub session_id: Option<String>,
pub session_items: usize,
pub imported_decisions: usize,
pub imported_findings: usize,
pub facts: usize,
pub active_facts: usize,
pub archived_facts: usize,
pub fact_capacity_target: usize,
pub fact_capacity_archived: usize,
pub patterns: usize,
pub patterns_capacity_target: usize,
pub patterns_compacted: usize,
pub history: usize,
pub history_capacity_target: usize,
pub history_compacted: usize,
pub procedures: usize,
pub procedure_capacity_target: usize,
pub procedures_compacted: usize,
pub lifecycle: LifecycleReport,
pub dry_run: bool,
}
pub(crate) fn consolidate_project_knowledge(
project_root: &str,
) -> Result<KnowledgeConsolidationReport, String> {
consolidate_project_knowledge_with(project_root, &ConsolidateOptions::manual())
}
pub(crate) fn consolidate_project_knowledge_with(
project_root: &str,
opts: &ConsolidateOptions,
) -> Result<KnowledgeConsolidationReport, String> {
let policy = load_policy_or_error()?;
let session = if opts.import_session {
SessionState::load_latest_for_project_root(project_root)
} else {
None
};
if opts.dry_run {
return Ok(dry_run_report(
project_root,
session.as_ref(),
opts,
&policy,
));
}
let watermark = if opts.incremental {
session.as_ref().and_then(|s| s.last_consolidate_ts)
} else {
None
};
if opts.incremental
&& let Some(s) = session.as_ref()
&& !has_new_session_items(s, watermark)
{
return Ok(KnowledgeConsolidationReport {
session_id: Some(s.id.clone()),
..Default::default()
});
}
let (_knowledge, report) = ProjectKnowledge::mutate_locked(project_root, |knowledge| {
run_consolidation_locked(knowledge, session.as_ref(), opts, &policy, watermark)
})
.map_err(|e| format!("Consolidation done but save failed: {e}"))?;
let report = report?;
if opts.incremental
&& let Some(mut s) = session
{
s.last_consolidate_ts = Some(Utc::now());
let _ = s.save();
}
if opts.emit_event {
crate::core::events::emit(crate::core::events::EventKind::KnowledgeUpdate {
category: "memory".to_string(),
key: "consolidation".to_string(),
action: "run".to_string(),
});
}
Ok(report)
}
fn run_consolidation_locked(
knowledge: &mut ProjectKnowledge,
session: Option<&SessionState>,
opts: &ConsolidateOptions,
policy: &MemoryPolicy,
watermark: Option<DateTime<Utc>>,
) -> Result<KnowledgeConsolidationReport, String> {
let mut imported = ImportCounts::default();
let mut session_id = None;
let mut history_compacted = 0usize;
if opts.import_session
&& let Some(s) = session
{
session_id = Some(s.id.clone());
imported = import_session_into(knowledge, s, opts, policy, watermark);
let task_desc = s
.task
.as_ref()
.map_or_else(|| "(no task)".into(), |t| t.description.clone());
let summary = format!(
"Session {}: {} — {} findings, {} decisions consolidated",
s.id, task_desc, imported.findings, imported.decisions
);
history_compacted += knowledge.consolidate(&summary, vec![s.id.clone()], policy)?;
}
let lifecycle = if opts.run_lifecycle {
knowledge.run_memory_lifecycle(policy)?
} else {
LifecycleReport::default()
};
let mut patterns_compacted = 0usize;
if opts.reclaim_stores {
patterns_compacted = reclaim_patterns(knowledge, policy)?;
history_compacted += reclaim_history(knowledge, policy)?;
}
let (procedures, procedure_capacity_target, procedures_compacted) = if opts.reclaim_stores {
reclaim_procedures(&knowledge.project_hash, policy)?
} else {
procedure_counts(&knowledge.project_hash, policy)
};
let active_facts = knowledge.facts.iter().filter(|f| f.is_current()).count();
let archived_facts = knowledge.facts.len().saturating_sub(active_facts);
let headroom = policy.lifecycle.reclaim_headroom_pct;
Ok(KnowledgeConsolidationReport {
session_id,
session_items: imported.total(),
imported_decisions: imported.decisions,
imported_findings: imported.findings,
facts: knowledge.facts.len(),
active_facts,
archived_facts,
fact_capacity_target: reclaim_target(policy.knowledge.max_facts, headroom),
fact_capacity_archived: lifecycle.capacity_archived,
patterns: knowledge.patterns.len(),
patterns_capacity_target: reclaim_target(policy.knowledge.max_patterns, headroom),
patterns_compacted,
history: knowledge.history.len(),
history_capacity_target: reclaim_target(policy.knowledge.max_history, headroom),
history_compacted,
procedures,
procedure_capacity_target,
procedures_compacted,
lifecycle,
dry_run: false,
})
}
fn dry_run_report(
project_root: &str,
session: Option<&SessionState>,
opts: &ConsolidateOptions,
policy: &MemoryPolicy,
) -> KnowledgeConsolidationReport {
let mut knowledge =
ProjectKnowledge::load(project_root).unwrap_or_else(|| ProjectKnowledge::new(project_root));
let headroom = policy.lifecycle.reclaim_headroom_pct;
let enabled = policy.lifecycle.reclaim_enabled;
let mut imported = ImportCounts::default();
let mut session_id = None;
if opts.import_session
&& let Some(s) = session
{
session_id = Some(s.id.clone());
let watermark = if opts.incremental {
s.last_consolidate_ts
} else {
None
};
imported = import_session_into(&mut knowledge, s, opts, policy, watermark);
}
let lifecycle = if opts.run_lifecycle {
let cfg = crate::core::memory_lifecycle::LifecycleConfig::from_policy(policy);
let decayed =
crate::core::memory_lifecycle::apply_confidence_decay(&mut knowledge.facts, &cfg);
let consolidated = crate::core::memory_lifecycle::consolidate_similar(
&mut knowledge.facts,
cfg.consolidation_similarity,
);
let (quality, _) = crate::core::memory_lifecycle::compact(&mut knowledge.facts, &cfg);
let capacity_archived =
reclaim_preview(knowledge.facts.len(), cfg.max_facts, headroom, enabled);
LifecycleReport {
decayed_count: decayed,
consolidated_count: consolidated,
archived_count: quality + capacity_archived,
compacted_count: quality + capacity_archived,
capacity_archived,
remaining_facts: knowledge.facts.len().saturating_sub(capacity_archived),
}
} else {
LifecycleReport::default()
};
let history_compacted = reclaim_preview(
knowledge.history.len(),
policy.knowledge.max_history,
headroom,
enabled,
);
let patterns_compacted = reclaim_preview(
knowledge.patterns.len(),
policy.knowledge.max_patterns,
headroom,
enabled,
);
let procedures_len =
ProceduralStore::load(&knowledge.project_hash).map_or(0, |s| s.procedures.len());
let procedures_compacted = reclaim_preview(
procedures_len,
policy.procedural.max_procedures,
headroom,
enabled,
);
let active_facts = knowledge.facts.iter().filter(|f| f.is_current()).count();
let archived_facts = knowledge.facts.len().saturating_sub(active_facts);
KnowledgeConsolidationReport {
session_id,
session_items: imported.total(),
imported_decisions: imported.decisions,
imported_findings: imported.findings,
facts: knowledge.facts.len(),
active_facts,
archived_facts,
fact_capacity_target: reclaim_target(policy.knowledge.max_facts, headroom),
fact_capacity_archived: lifecycle.capacity_archived,
patterns: knowledge.patterns.len(),
patterns_capacity_target: reclaim_target(policy.knowledge.max_patterns, headroom),
patterns_compacted,
history: knowledge.history.len(),
history_capacity_target: reclaim_target(policy.knowledge.max_history, headroom),
history_compacted,
procedures: procedures_len,
procedure_capacity_target: reclaim_target(policy.procedural.max_procedures, headroom),
procedures_compacted,
lifecycle,
dry_run: true,
}
}
fn has_new_session_items(session: &SessionState, watermark: Option<DateTime<Utc>>) -> bool {
let is_new = |ts: DateTime<Utc>| watermark.is_none_or(|w| ts > w);
session.findings.iter().any(|f| is_new(f.timestamp))
|| session.decisions.iter().any(|d| is_new(d.timestamp))
}
fn reclaim_history(
knowledge: &mut ProjectKnowledge,
policy: &MemoryPolicy,
) -> Result<usize, String> {
reclaim_store(
MemoryStore::History,
Some(&knowledge.project_hash),
&mut knowledge.history,
policy.knowledge.max_history,
policy.lifecycle.reclaim_headroom_pct,
policy.lifecycle.reclaim_enabled,
|a, b| {
b.timestamp
.cmp(&a.timestamp)
.then_with(|| b.summary.cmp(&a.summary))
},
)
.map(|archived| archived.len())
}
fn reclaim_patterns(
knowledge: &mut ProjectKnowledge,
policy: &MemoryPolicy,
) -> Result<usize, String> {
reclaim_store(
MemoryStore::Patterns,
Some(&knowledge.project_hash),
&mut knowledge.patterns,
policy.knowledge.max_patterns,
policy.lifecycle.reclaim_headroom_pct,
policy.lifecycle.reclaim_enabled,
|a, b| {
b.created_at
.cmp(&a.created_at)
.then_with(|| a.pattern_type.cmp(&b.pattern_type))
.then_with(|| a.description.cmp(&b.description))
},
)
.map(|archived| archived.len())
}
fn reclaim_procedures(
project_hash: &str,
policy: &MemoryPolicy,
) -> Result<(usize, usize, usize), String> {
let target = reclaim_target(
policy.procedural.max_procedures,
policy.lifecycle.reclaim_headroom_pct,
);
let Some(mut store) = ProceduralStore::load(project_hash) else {
return Ok((0, target, 0));
};
let archived = reclaim_store(
MemoryStore::Procedures,
Some(project_hash),
&mut store.procedures,
policy.procedural.max_procedures,
policy.lifecycle.reclaim_headroom_pct,
policy.lifecycle.reclaim_enabled,
retention_cmp,
);
let archived = archived?;
let compacted = archived.len();
if compacted > 0 {
store
.save()
.map_err(|e| format!("Procedure capacity compact failed: {e}"))?;
}
Ok((store.procedures.len(), target, compacted))
}
fn procedure_counts(project_hash: &str, policy: &MemoryPolicy) -> (usize, usize, usize) {
let target = reclaim_target(
policy.procedural.max_procedures,
policy.lifecycle.reclaim_headroom_pct,
);
let len = ProceduralStore::load(project_hash).map_or(0, |s| s.procedures.len());
(len, target, 0)
}
pub(crate) fn consolidate_all_project_knowledge_with(
opts: &ConsolidateOptions,
) -> Result<Vec<(String, KnowledgeConsolidationReport)>, String> {
let roots = ProjectKnowledge::list_project_roots()?;
let mut reports = Vec::with_capacity(roots.len());
for root in roots {
let report = consolidate_project_knowledge_with(&root, opts)
.map_err(|e| format!("Consolidation failed for {}: {e}", project_label(&root)))?;
reports.push((root, report));
}
Ok(reports)
}
pub(crate) fn format_consolidation_report(report: &KnowledgeConsolidationReport) -> String {
let session_line = match report.session_id.as_deref() {
Some(session_id) => {
format!(
"Session import: {session_id} ({} item(s))",
report.session_items
)
}
None => "Session import: none (no active session)".to_string(),
};
let banner = if report.dry_run {
"DRY RUN — preview only, no changes written\n"
} else {
""
};
let body = format!(
"{banner}{session_line}\n\
Facts: {} active, {} archived, {} total (target <= {}, archived-to-target {})\n\
Patterns: {} (target <= {}, compacted {}), History: {} (target <= {}, compacted {})\n\
Procedures: {} (target <= {}, compacted {})\n\
Lifecycle: decayed {}, consolidated {}, archived {}, compacted {}, remaining {}",
report.active_facts,
report.archived_facts,
report.facts,
report.fact_capacity_target,
report.fact_capacity_archived,
report.patterns,
report.patterns_capacity_target,
report.patterns_compacted,
report.history,
report.history_capacity_target,
report.history_compacted,
report.procedures,
report.procedure_capacity_target,
report.procedures_compacted,
report.lifecycle.decayed_count,
report.lifecycle.consolidated_count,
report.lifecycle.archived_count,
report.lifecycle.compacted_count,
report.lifecycle.remaining_facts
);
let archived_total = report.fact_capacity_archived
+ report.patterns_compacted
+ report.history_compacted
+ report.procedures_compacted;
if archived_total > 0 {
let verb = if report.dry_run {
"would archive"
} else {
"archived"
};
format!(
"{body}\n{verb} {archived_total} item(s) — restore with: lean-ctx knowledge restore"
)
} else {
body
}
}
pub(crate) fn format_all_consolidation_reports(
reports: &[(String, KnowledgeConsolidationReport)],
) -> String {
if reports.is_empty() {
return "No project knowledge stores found.".to_string();
}
let mut out = format!("Projects consolidated: {}", reports.len());
for (project_root, report) in reports {
out.push_str("\n\nProject: ");
out.push_str(project_label(project_root));
out.push('\n');
out.push_str(&format_consolidation_report(report));
}
out
}
fn project_label(project_root: &str) -> &str {
if project_root.trim().is_empty() {
"(empty project root)"
} else {
project_root
}
}