Coverage / src/cli/identity.rs 72.0%

pub fn owner_home(ctx: &Ctx, flag: Option<PathBuf>) -> PathBuf {

    flag.or_else(|| ctx.config_owner_home()).unwrap_or_else(spectra_core::keys::default_home)

}

pub async fn init(ctx: &Ctx, owner_home_flag: Option<PathBuf>, name: Option<String>) -> Result<i32> {

    let data = &ctx.data;

    let db = data.join("spectra.db");

    if db.exists() {

        bail!("{} already holds a Spectra (spectra identity show)", data.display());

    }

    let home = owner_home(ctx, owner_home_flag);

    KeyPair::load_home(&home).with_context(|| {

        format!("the owner signs with their own identity: none usable in {} (spectra identity create, or --owner-home)", home.display())

    })?;

    std::fs::create_dir_all(data)?;

        std::fs::set_permissions(data, std::fs::Permissions::from_mode(0o700))?;

    let name = name.unwrap_or_else(hostname);

    let instance = KeyPair::instance(data, &name)?;

    let owner = spectra_core::keys::delegate(&home, instance.key, None)?;

    let ledger = Ledger::open(&db, Some(instance.clone())).await?;

    let mut first = vec![

        signed_event(&owner, "human", "identity.owner", identity_payload(&owner.identity)),

        signed_event(&instance, "system", "identity.instance", identity_payload(&instance.identity)),

    first.extend(spectra_core::conversation::default_channel_events());

    ledger.append(first).await?;

    ledger.checkpoint().await?;

    let home_s = home.display().to_string();

    std::fs::write(

        data.join("spectra.toml"),

        format!("# Spectra's configuration (spec §22.1).\n\n[owner]\nkey = \"{}\"\nhome = {}\n", owner.key.to_hex(), toml_str(&home_s)),

    println!("{} {}  {}", ui::done("Initialised"), ui::subject("Spectra"), ui::path(data.display()));

    println!("{}", ui::kv("owner", format!("{}{}{}", ui::author(&owner.identity.name), ui::sep(), ui::hash(owner.key.short(12)))));

    println!("{}", ui::kv("instance", format!("{}{}{}", name, ui::sep(), ui::hash(instance.key.short(12)))));

    println!("{}", ui::kv("ledger", format!("{}{}", ui::path(db.display()), ui::dim(" (verified with spectra admin verify)"))));

    println!();

    println!(

        ui::note(),

        ui::dim("then add agents with"),

        ui::id("spectra agent add NAME --kind KIND --project PROJECT --home DIR")

    Ok(0)

}

pub async fn show(ctx: &Ctx, json: bool) -> Result<i32> {

    if let Some(cfg) = ctx.remote()? {

        return show_remote(&cfg, json).await;

    }

    let ledger = Ledger::open_read_only(&ctx.db()?).await?;

    let p = Principals::load(&ledger).await?;

    let owner = p.owner().context("no owner is recorded")?;

    let instance = p.instance();

    let delegated = instance.is_some_and(|i| owner.delegates_to(&i.hash(), spectra_core::ids::now_ms()));

    if json {

        println!(

            serde_json::json!({

                "owner": { "name": owner.name, "key": owner.hash().to_hex() },

                "instance": instance.map(|i| serde_json::json!({ "name": i.name, "key": i.hash().to_hex(), "delegated": delegated })),

        return Ok(0);

}

pub async fn refresh_event(ledger: &Ledger, home: &Path) -> Result<Option<spectra_core::event::NewEvent>> {

    let p = Principals::load(ledger).await?;

    let recorded = p.owner().context("no owner is recorded (spectra init)")?.clone();

    rotation(&recorded, home)

}

pub fn rotation(recorded: &Identity, home: &Path) -> Result<Option<spectra_core::event::NewEvent>> {

    let pair = KeyPair::load_home(home)?;

    if pair.key == recorded.hash() {

        return Ok(None);

    }

    let mut chain = Vec::new();

    let mut at = pair.identity.clone();

    while let Some(prev) = at.previous {

        if prev == recorded.hash() {

            break;

    if at.previous != Some(recorded.hash()) && pair.identity.previous != Some(recorded.hash()) {

    }

    let mut payload = identity_payload(&pair.identity);

    payload["chain"] = chain.into();

    Ok(Some(signed_event(&pair, "human", "identity.rotated", payload)))

}

pub async fn recorded_owner(ledger: &Ledger, home: &Path) -> Result<KeyPair> {

    let p = Principals::load(ledger).await?;

    let recorded = p.owner().context("no owner is recorded (spectra init)")?.hash();

    let keys = home.join("keys");

    KeyPair::load(&keys.join(format!("{}.secret", recorded.to_hex())), &keys.join(format!("{}.identity", recorded.to_hex())))

        .with_context(|| format!("the recorded owner's key is not in {}", home.display()))

}

async fn show_remote(cfg: &super::connect::ClientCfg, json: bool) -> Result<i32> {

    let info = super::call(&spectra_mcp::client::Client::at(cfg.endpoint()?, None), "GET", "/api/v1/instance", None).await?;

    let owner_key = info["owner"].as_str().unwrap_or("").to_string();

    let instance_key = info["instance"]["key"].as_str().unwrap_or("").to_string();

    let home = spectra_core::keys::default_home();

    let me = KeyPair::load_home(&home).ok();

    let delegated = me.as_ref().is_some_and(|m| {

        spectra_core::identity::KeyId::from_hex(&instance_key).is_some_and(|k| m.identity.delegates_to(&k, spectra_core::ids::now_ms()))

    });

    if json {

        println!(

            serde_json::json!({

                "server": cfg.server,

                "owner": { "name": me.as_ref().map(|m| m.identity.name.clone()), "key": owner_key },

                "instance": { "name": info["name"], "key": instance_key, "delegated": delegated },

        return Ok(0);

}

pub fn create(name: &str, contact: &str, home: Option<PathBuf>, as_json: bool) -> Result<i32> {

    let home = home.unwrap_or_else(spectra_core::keys::default_home);

    let pair = KeyPair::create_home(&home, name.trim(), contact.trim())?;

    if as_json {

        println!("{}", serde_json::json!({ "name": pair.identity.name, "key": pair.key.to_hex(), "home": home.display().to_string() }));

        return Ok(0);

    }

    println!("{} {}  {}", ui::done("Created"), ui::subject("your identity"), ui::path(home.display()));

    println!("{}", ui::kv("name", ui::author(&pair.identity.name)));

    println!("{}", ui::kv("key", ui::hash(pair.key.to_hex())));

    println!("  {} {}", ui::note(), ui::dim("keep keys/ private: anyone with it can act as you"));

    println!(

        ui::note(),

        ui::dim("next: spectra init here, or on a server"),

        ui::id(format!("spectra init --owner {}", pair.key.to_hex()))

    Ok(0)

}

pub async fn init_for(ctx: &Ctx, owner_key: &str, name: Option<String>) -> Result<i32> {

    let key = owner_key.trim().to_ascii_lowercase();

    if key.len() != 64 || hex::decode(&key).is_err() {

        bail!("{owner_key} is not a KeyId (64 hex digits; the owner's `spectra identity show` prints it)");

    }

    let data = &ctx.data;

    let db = data.join("spectra.db");

    if db.exists() {

    }

    std::fs::create_dir_all(data)?;

        std::fs::set_permissions(data, std::fs::Permissions::from_mode(0o700))?;

    let name = name.unwrap_or_else(hostname);

    let instance = KeyPair::instance(data, &name)?;

    let ledger = Ledger::open(&db, Some(instance.clone())).await?;

    let mut first = vec![signed_event(&instance, "system", "identity.instance", identity_payload(&instance.identity))];

    first.extend(spectra_core::conversation::default_channel_events());

    ledger.append(first).await?;

    ledger.checkpoint().await?;

    std::fs::write(

        data.join("spectra.toml"),

        format!(

    println!("{} {}  {}", ui::done("Initialised"), ui::subject("Spectra"), ui::path(data.display()));

    println!("{}", ui::kv("owner", format!("{}{}", ui::hash(&key[..12]), ui::dim(" (named; not yet claimed)"))));

    println!("{}", ui::kv("instance", format!("{}{}{}", name, ui::sep(), ui::hash(instance.key.short(12)))));

    println!();

    println!("  {} {}", ui::note(), ui::dim("serve it to other machines: set [server] bind in spectra.toml, then spectra serve"));

    println!("  {} {}", ui::note(), ui::dim("then, on the owner's machine:"));

    println!("    {}", ui::id("spectra connect https://HOST:7350"));

    Ok(0)

}

fn hostname() -> String {

    std::fs::read_to_string("/etc/hostname")

        .ok()

        .map(|h| h.trim().to_string())

        .filter(|h| !h.is_empty())

        .unwrap_or_else(|| "spectra".into())

}

fn toml_str(s: &str) -> String {

    serde_json::to_string(s).unwrap_or_default()

}