eclaw 0.0.11

Personal AI assistant powered by Elph
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

mod bundled;
mod migrations;
mod paths;
mod settings;
mod trust;
mod version;
use elph_agent::{DatabaseSpec, InitProgress, ensure_databases, ensure_dirs};

pub use paths::Paths;

pub type InitError = elph_agent::InitError;
pub type Result<T> = std::result::Result<T, InitError>;

const INIT_STEPS: u64 = 4;

/// Create required directories and default files for a fresh Eclaw install.
pub async fn ensure(app_version: &str) -> Result<Paths> {
    let progress = InitProgress::new(INIT_STEPS).with_quiet_env("ECLAW_QUIET");
    progress.advance("Resolving home directories");
    let paths = Paths::resolve()?;
    run_init_steps(&paths, app_version, &progress).await?;
    progress.finish();
    Ok(paths)
}

/// Initialize a specific layout (useful in tests and custom installs).
#[allow(dead_code)]
pub async fn ensure_with_paths(paths: &Paths, app_version: &str) -> Result<()> {
    let progress = InitProgress::new(INIT_STEPS).with_quiet_env("ECLAW_QUIET");
    run_init_steps(paths, app_version, &progress).await?;
    progress.finish();
    Ok(())
}

/// Blocking wrapper for CLI startup code paths that are not async yet.
pub fn ensure_blocking(app_version: &str) -> Result<Paths> {
    tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .map_err(|err| InitError::Io(std::io::Error::other(err)))?
        .block_on(ensure(app_version))
}

async fn run_init_steps(paths: &Paths, app_version: &str, progress: &InitProgress) -> Result<()> {
    progress.advance("Creating directories");
    let mut dirs = vec![paths.config_dir.clone(), paths.data_dir.clone()];
    dirs.extend(paths.required_dirs());
    ensure_dirs(&dirs)?;

    progress.advance("Writing configuration");
    ensure_files(paths, app_version)?;

    progress.advance("Initializing databases");
    ensure_databases(&[
        DatabaseSpec {
            path: &paths.metadata_db_path(),
            migrations: migrations::metadata_migrations(),
        },
        DatabaseSpec {
            path: &paths.memory_db_path(),
            migrations: migrations::memory_migrations(),
        },
    ])
    .await?;

    Ok(())
}

fn ensure_files(paths: &Paths, app_version: &str) -> Result<()> {
    settings::Settings::ensure(paths)?;
    trust::TrustStore::ensure(paths)?;
    version::VersionFile::ensure(paths, app_version)?;
    bundled::BundledManifest::ensure(paths, app_version)?;
    Ok(())
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn ensure_creates_eclaw_layout() {
        let tmp = tempfile::tempdir().expect("tempdir");
        let paths = Paths::from_dirs(tmp.path().join("config"), tmp.path().join("data"));

        ensure_with_paths(&paths, "0.0.10-test").await.expect("ensure layout");

        assert!(paths.settings_path().exists());
        assert!(paths.trust_path().exists());
        assert!(paths.version_path().exists());
        assert!(paths.bundled_manifest_path().exists());
        assert!(paths.metadata_db_path().exists());
        assert!(paths.memory_db_path().exists());
        assert!(paths.bundled_dir().join("agents").is_dir());
        assert!(paths.bundled_dir().join("personas").is_dir());
        assert!(paths.bundled_dir().join("skills").is_dir());
        assert!(paths.bundled_dir().join("user-guide").is_dir());
        assert!(paths.prompts_dir().is_dir());
        assert!(paths.providers_dir().is_dir());
        assert!(paths.sessions_dir().is_dir());
        assert!(paths.skills_dir().is_dir());
        assert!(paths.worktrees_dir().is_dir());
        assert!(paths.attachments_dir().is_dir());
        assert!(paths.downloads_dir().is_dir());
        assert!(paths.logs_dir().is_dir());
        assert!(paths.vendor_dir().is_dir());
    }
}