//! `spectra open`: sign in to Radar (spec §8.3). The owner's CLI signs a
//! request for a one-time link with the owner's key; the link, valid for a
//! minute, opens a level-2 browser session.

use super::identity::{owner_home, recorded_owner};
use super::{ui, Ctx};
use anyhow::{bail, Context, Result};
use spectra_core::ledger::Ledger;
use spectra_mcp::client::Client;
use std::path::PathBuf;

pub async fn open(ctx: &Ctx, owner_home_flag: Option<PathBuf>, launch: bool) -> Result<i32> {
    let socket = ctx.socket();
    if !Client::alive(&socket).await {
        bail!("Spectra is not serving {} (spectra serve)", ctx.data.display());
    }
    let home = owner_home(ctx, owner_home_flag);
    let ledger = Ledger::open_read_only(&ctx.db()?).await?;
    let owner = recorded_owner(&ledger, &home).await?;
    let r = Client::new(&socket, Some(owner)).send("POST", "/radar/link", &[], Vec::new()).await?;
    if r.status != 200 {
        bail!("the daemon refused the sign-in: {}", String::from_utf8_lossy(&r.body));
    }
    let url = r.json()?.get("url").and_then(|u| u.as_str()).map(String::from).context("no link in the answer")?;
    println!("{} {}", ui::done("Signed"), ui::subject("a one-time link to Radar, good for a minute"));
    println!("  {}", ui::id(&url));
    if launch
        && std::process::Command::new("xdg-open")
            .arg(&url)
            .stdout(std::process::Stdio::null())
            .stderr(std::process::Stdio::null())
            .spawn()
            .is_ok()
    {
        println!("  {} {}", ui::note(), ui::dim("opened in your browser"));
    }
    Ok(0)
}