lean_ctx/core/context_package/
export.rs

1//! Export a context package from the current session (#293).
2
3use std::path::{Path, PathBuf};
4
5use chrono::Utc;
6
7use super::bundle::{ContextPackage, FORMAT_VERSION, KnowledgeFact, PackageMetadata, SessionSlice};
8use crate::core::session::SessionState;
9use crate::core::session_summary;
10
11/// Export the current session as a context package (JSON file).
12///
13/// Returns the path where the package was written.
14pub fn save_package(
15    session: &SessionState,
16    project_root: &str,
17    agent_id: Option<&str>,
18    description: Option<&str>,
19    output_path: Option<&Path>,
20) -> Result<PathBuf, String> {
21    let pkg = build_package(session, project_root, agent_id, description);
22    let json = serde_json::to_string_pretty(&pkg).map_err(|e| e.to_string())?;
23    // A package is a portable derived store (findings, decisions, knowledge):
24    // admitted as a whole, and only written if it still parses (G5, E3).
25    let json = crate::core::context_admission::recovery::admit_for_storage(&json)
26        .filter(|admitted| serde_json::from_str::<ContextPackage>(admitted).is_ok())
27        .ok_or("package withheld by the context gateway")?;
28
29    let path = output_path.map_or_else(|| default_path(project_root, &session.id), PathBuf::from);
30
31    if let Some(parent) = path.parent() {
32        std::fs::create_dir_all(parent).map_err(|e| e.to_string())?;
33    }
34    std::fs::write(&path, json).map_err(|e| e.to_string())?;
35    Ok(path)
36}
37
38fn build_package(
39    session: &SessionState,
40    project_root: &str,
41    agent_id: Option<&str>,
42    description: Option<&str>,
43) -> ContextPackage {
44    let summaries = session_summary::list(project_root);
45    let knowledge = load_knowledge_facts(project_root);
46
47    ContextPackage {
48        format_version: FORMAT_VERSION,
49        created_at: Utc::now(),
50        project_root: project_root.to_string(),
51        session_id: session.id.clone(),
52        metadata: PackageMetadata {
53            agent_id: agent_id.map(str::to_string),
54            description: description.map(str::to_string),
55            tool_calls: session.stats.total_tool_calls,
56            tokens_saved: session.stats.total_tokens_saved,
57        },
58        session: SessionSlice {
59            task: session.task.clone(),
60            findings: session.findings.clone(),
61            decisions: session.decisions.clone(),
62            files: session.files_touched.clone(),
63            next_steps: session.next_steps.clone(),
64            test_results: session.test_results.clone(),
65        },
66        summaries,
67        knowledge,
68    }
69}
70
71fn load_knowledge_facts(project_root: &str) -> Vec<KnowledgeFact> {
72    let Some(pk) = crate::core::knowledge::ProjectKnowledge::load(project_root) else {
73        return Vec::new();
74    };
75    pk.facts
76        .iter()
77        .filter(|f| f.is_current() && f.confidence >= 0.5)
78        .take(100)
79        .map(|f| KnowledgeFact {
80            origin: f.origin.clone(),
81            category: f.category.clone(),
82            key: f.key.clone(),
83            value: f.value.clone(),
84            confidence: f.confidence,
85            created_at: f.created_at,
86        })
87        .collect()
88}
89
90fn default_path(project_root: &str, session_id: &str) -> PathBuf {
91    let hash = crate::core::project_hash::hash_project_root(project_root);
92    let dir = crate::core::data_dir::lean_ctx_data_dir()
93        .unwrap_or_else(|_| PathBuf::from(".lean-ctx"))
94        .join("packages")
95        .join(hash);
96    let short = session_id.split('-').next().unwrap_or(session_id);
97    dir.join(format!("{short}.ctx.json"))
98}
lean_ctx/core/context_package/export.rs

lean_ctx/core/context_package/
export.rs
