gioser

sergio/takana

> Una distribución Linux construida con un laboratorio funcional y hermético en el > sótano, y una terminal mutable, clásica y anárquica en el piso de arriba — diseñada > desde el suelo para que una IA programadora entienda, modifique y co…

TOML 815Rust 56Shell 37Markdown 291229 Definiciones

⎇ dcb83e1fd380c1ad5b1e49f266c1bd163d771d5f crates/takana-cli/src/metal.rs Rust · 713 líneas · 32.7 KB Historia Quién tocó qué crudo

feat(metal): --keep conserva el /home viejo, y los usuarios se crean con SU uid dcb83e1fd · Sergio ·

1//! `takana metal` — instalar takana EN ESTA MÁQUINA, con UN verbo.
2//!
3//! ══ POR QUÉ EXISTE ════════════════════════════════════════════════════════════════════════════
4//! El instalador funcionaba y no se podía usar. La forma de invocarlo era ésta:
5//!
6//! ```text
7//! sudo ./takana kernel kexec ./kernel --initrd ./takana-instalador.cpio.gz \
8//!      --cmdline 'console=ttyS0,115200 console=tty0' --jump
9//! ```
10//!
11//! Eso no es un instalador: es el motor con la tapa abierta. Quien lo teclea tiene que saber que
12//! existe `kexec`, que el payload va por `--initrd`, que sin `--jump` sólo se carga, y qué consola
13//! pedirle al kernel nuevo. Ninguna de esas cuatro cosas es una decisión del que instala.
14//!
15//! `takana metal` es la tapa. Tres verbos, y el orden en que se usan es el orden en que se leen:
16//!
17//! ```text
18//! takana metal check     ¿puede esta máquina instalarse sin USB?   (no toca nada)
19//! takana metal survey    ¿qué hay en los discos y qué se puede usar? (no toca nada)
20//! takana metal install   el viaje entero: comprueba, avisa y salta
21//! ```
22//!
23//! ── UN MOTOR, VARIAS CARAS (SDD 28 §8) ────────────────────────────────────────────────────────
24//! `survey` **no reimplementa el censo**: llama al mismo `takana-install-partition.sh --survey` que
25//! corre dentro del instalador. Con `--json` emite el contrato que consume una cara gráfica
26//! (churay). El riesgo que esto evita está medido en otro frente: dos censos divergen, y el que se
27//! equivoca no muestra de menos — formatea de más.
28//!
29//! ── EL CONTRATO, VERSIÓN 2 (2026-09-25) ───────────────────────────────────────────────────────
30//! La v1 alcanzaba para una LISTA y no para un DIBUJO: sin saber a qué disco pertenece cada fila ni
31//! en qué byte empieza, no se sabe qué va al lado de qué ni qué hueco queda entre dos. La v2 agrega
32//! lo que hace falta para pintar el terreno, y **ni un campo de decisión**: `veredicto` y `usable`
33//! siguen siendo los únicos que deciden, y siguen saliendo de acá.
34//!
35//! Por fila: `clase` (`particion` · `hueco` · `disco`), `disco`, `inicio_bytes`, `tamano_bytes`,
36//! `tipo_guid`. Y un array `discos` con el APARATO: `modelo`, `removible`, `tamano_bytes`,
37//! `sector_bytes`, `tabla`.
38//!
39//! ⚠ **`tamano_bytes` existe además de `mib` porque `mib` está redondeado**: una barra proporcional
40//! construida con MiB acumula error a lo largo del disco y el hueco final sale corrido.
41//!
42//! ⚠ **Un `hueco` NO tiene `dev` propio**: su `dev` es el del disco, y dos huecos del mismo disco
43//! traen el MISMO `dev`. Su identidad es `disco` + `inicio_bytes`. Una cara que los indexe por
44//! `dev` se queda con uno solo y pierde el otro sin que nada falle.
45//!
46//! ⚠ El aparato va en un array propio y **no repetido en cada fila**: un dato del disco copiado en
47//! cada partición se puede contradecir entre filas, y entonces hay que decidir a cuál creerle.
48//!
49//! ── LO QUE ESTE VERBO NO HACE ─────────────────────────────────────────────────────────────────
50//! No elige partición, no formatea y no escribe la NVRAM. Todo eso pasa DESPUÉS del salto, dentro
51//! del instalador, que es donde el disco destino puede estar desmontado. Acá sólo se comprueba, se
52//! avisa y se salta.
53
54use std::path::{Path, PathBuf};
55
56use anyhow::{bail, Context, Result};
57use clap::Subcommand;
58
59use crate::kernel_ab;
60
61/// Nombres con los que viaja el payload. Se buscan en ese orden dentro del directorio del paquete.
62const INITRD: &[&str] = &["takana-instalador.cpio.gz", "instalador.cpio.gz", "initramfs.cpio.gz"];
63const KERNEL: &[&str] = &["kernel/boot/bzImage", "bzImage", "boot/bzImage", "kernel"];
64const GUION: &[&str] = &[
65    "scripts/takana-install-partition.sh",
66    "takana-install-partition.sh",
67    "instalador/takana-install-partition.sh",
68];
69/// La consola por defecto pide las DOS: `ttyS0` es la única forma de ver por qué murió cuando no
70/// llega a pintar nada, y `tty0` es la pantalla del que instala.
71///
72/// ⚠ **El ORDEN no es cosmético: el kernel hace `/dev/console` = la ÚLTIMA `console=`.** Con `tty0`
73/// primero, `/dev/console` queda en el SERIAL — y el instalador interactivo, que lee y escribe por
74/// ahí, sale por un puerto que un portátil no tiene. La pantalla se queda en el último printk y el
75/// arranque parece colgado. `tty0` va ÚLTIMO.
76const CONSOLA: &str = "console=ttyS0,115200 console=tty0";
77
78#[derive(Subcommand)]
79pub enum MetalCmd {
80    /// ¿Puede esta máquina instalarse sin USB? Diagnóstico, no toca nada.
81    Check,
82    /// El terreno de esta máquina: qué hay en cada disco y qué se puede usar. No toca nada.
83    Survey {
84        /// Emitir el censo en JSON (el contrato que consume una cara gráfica).
85        #[arg(long)]
86        json: bool,
87        /// Directorio del paquete (por defecto, el del propio binario).
88        #[arg(long)]
89        payload: Option<PathBuf>,
90    },
91    /// Instalar takana en esta máquina: comprueba, avisa y salta al instalador.
92    Install {
93        /// Directorio del paquete (por defecto, el del propio binario).
94        #[arg(long)]
95        payload: Option<PathBuf>,
96        /// Partición destino, ya elegida. Sin esto, el instalador muestra el censo y pregunta.
97        /// **Usá `PARTUUID=…`**: los nombres `/dev/nvme…` no son estables entre arranques.
98        #[arg(long)]
99        root: Option<String>,
100        /// ESP a poblar. Sin esto se deduce del disco del destino.
101        #[arg(long)]
102        esp: Option<String>,
103        /// No formatear nada: instalar en el espacio SIN ASIGNAR más grande.
104        #[arg(long)]
105        free: bool,
106        /// CONSERVAR una partición y montarla en el sistema nuevo sin formatearla:
107        /// `--keep PARTUUID=…:/home`. Hoy el único punto admitido es `/home`. Los usuarios que
108        /// haya ahí se crean con **su mismo uid**, para que sus archivos sigan siendo suyos.
109        ///
110        /// ⚠ Viaja por la cmdline del kernel, que separa por ESPACIOS: un `LABEL=` con espacios no
111        /// se puede pasar por acá. Usá `PARTUUID=`, que además es la identidad estable.
112        #[arg(long)]
113        keep: Option<String>,
114        /// Disco sobre el que buscar el hueco de `--free`.
115        #[arg(long)]
116        disk: Option<String>,
117        /// No preguntar antes de saltar. **No** hace desatendido al instalador: eso es `--unattended`.
118        #[arg(long, short = 'y')]
119        yes: bool,
120        /// Desatendido de punta a punta: el instalador tampoco pregunta. Exige `--root` o `--free`.
121        #[arg(long)]
122        unattended: bool,
123        /// Cargar el instalador en memoria y NO saltar. Ensayo: no se pierde la sesión.
124        #[arg(long)]
125        load_only: bool,
126        /// Saltar aunque no haga falta. Normalmente el salto sólo ocurre si el destino es la raíz
127        /// viva; esto lo fuerza (arneses, y para probar el salto a propósito).
128        #[arg(long)]
129        jump: bool,
130        /// Consolas para el kernel del instalador.
131        #[arg(long, default_value = CONSOLA)]
132        console: String,
133    },
134}
135
136pub fn run(cmd: MetalCmd) -> Result<()> {
137    match cmd {
138        MetalCmd::Check => check(),
139        MetalCmd::Survey { json, payload } => survey(json, payload.as_deref()),
140        MetalCmd::Install {
141            payload, root, esp, free, keep, disk, yes, unattended, load_only, jump, console,
142        } => install(Instalacion {
143            payload, root, esp, free, keep, disk, yes, unattended, load_only, jump, console,
144        }),
145    }
146}
147
148struct Instalacion {
149    payload: Option<PathBuf>,
150    root: Option<String>,
151    esp: Option<String>,
152    free: bool,
153    keep: Option<String>,
154    disk: Option<String>,
155    yes: bool,
156    unattended: bool,
157    load_only: bool,
158    jump: bool,
159    console: String,
160}
161
162// ── dónde está el paquete ─────────────────────────────────────────────────────────────────────
163// Por defecto, JUNTO AL BINARIO y no en el directorio actual: el paquete se copia entero a un pen
164// drive o a `~/Descargas` y se corre con `sudo ./takana …`, muchas veces desde otro sitio. Buscar
165// en el cwd manda a «no encuentro el instalador» a alguien que lo tiene al lado.
166fn dir_del_binario() -> Option<PathBuf> {
167    std::env::current_exe().ok()?.parent().map(|p| p.to_path_buf())
168}
169
170fn buscar(dirs: &[PathBuf], nombres: &[&str]) -> Option<PathBuf> {
171    for d in dirs {
172        for n in nombres {
173            let p = d.join(n);
174            if p.is_file() {
175                return Some(p);
176            }
177        }
178    }
179    None
180}
181
182fn candidatos(payload: Option<&Path>) -> Vec<PathBuf> {
183    let mut v = Vec::new();
184    if let Some(p) = payload {
185        v.push(p.to_path_buf());
186    } else {
187        if let Some(d) = dir_del_binario() {
188            v.push(d);
189        }
190        v.push(PathBuf::from("."));
191        // El árbol del repo, para el que trabaja desde adentro.
192        v.push(PathBuf::from("work/instalador-salida"));
193        // ⚠ Y las rutas de un takana INSTALADO. Sin esto, `takana metal survey` sólo funcionaba
194        // con el paquete recién copiado: llamado desde una cara gráfica que encontró `takana` en
195        // el `PATH` —que es exactamente como lo va a encontrar churay— el binario está en
196        // `/usr/bin` y el censo no está al lado, así que el censo moría con «no encuentro
197        // takana-install-partition.sh». Medido el 2026-09-23 desde `churay-cli metal`.
198        for d in ["/usr/libexec/takana", "/usr/lib/takana", "/usr/share/takana"] {
199            v.push(PathBuf::from(d));
200        }
201    }
202    v
203}
204
205// ── check ─────────────────────────────────────────────────────────────────────────────────────
206fn check() -> Result<()> {
207    let (puede, motivos) = crate::kernel_cmd::kexec_probe();
208    if puede {
209        println!("✓ esta máquina puede instalarse SIN USB: el salto al instalador está disponible.");
210        println!("  Seguí con:  takana metal survey      (mirar el terreno, no toca nada)");
211        println!("              sudo takana metal install");
212        return Ok(());
213    }
214    println!("✗ esta máquina NO puede saltar al instalador desde el sistema que corre:");
215    for m in &motivos {
216        println!("  · {m}");
217    }
218    println!();
219    // ⚠ Sin root el diagnóstico NO es concluyente —el kernel contesta EPERM antes de decir si
220    // implementa el syscall— así que mandar al USB acá sería mandar a la solución cara por un
221    // problema que se arregla con `sudo`. Medido en esta misma caja: como uid 1001 el motivo es
222    // «falta root»; como root aparece el de verdad, que es otro.
223    if !crate::kernel_cmd::soy_root() {
224        println!("Antes de nada: repetilo con `sudo`. Sin privilegios este diagnóstico no distingue");
225        println!("«te falta ser root» de «tu kernel no lo trae», y son cosas distintas.");
226        std::process::exit(1);
227    }
228    println!("Eso NO quiere decir que no se pueda instalar: quiere decir que hay que arrancar el");
229    println!("instalador desde otro medio. La imagen USB hace exactamente lo mismo que el salto —el");
230    println!("instalador es el mismo— y no depende de lo que traiga el kernel de esta máquina.");
231    std::process::exit(1);
232}
233
234// ── survey ────────────────────────────────────────────────────────────────────────────────────
235fn survey(json: bool, payload: Option<&Path>) -> Result<()> {
236    let guion = buscar(&candidatos(payload), GUION)
237    .ok_or_else(|| {
238        anyhow::anyhow!(
239            "no encuentro `takana-install-partition.sh` junto al binario ni en el directorio actual.\n  \
240             Pasá --payload <directorio del paquete>."
241        )
242    })?;
243    let mut c = std::process::Command::new("sh");
244    c.arg(&guion).arg("--survey");
245    if json {
246        c.arg("--json");
247    }
248    let st = c
249        .status()
250        .with_context(|| format!("no puedo ejecutar {}", guion.display()))?;
251    if !st.success() {
252        bail!("el censo falló ({st})");
253    }
254    Ok(())
255}
256
257// ── install ───────────────────────────────────────────────────────────────────────────────────
258fn install(i: Instalacion) -> Result<()> {
259    if i.unattended && i.root.is_none() && !i.free {
260        bail!(
261            "--unattended sin destino: nadie va a estar ahí para elegirlo.\n  \
262             Dale --root PARTUUID=… (mirá `takana metal survey`) o --free."
263        );
264    }
265    let dirs = candidatos(i.payload.as_deref());
266    let initrd = buscar(&dirs, INITRD).ok_or_else(|| {
267        anyhow::anyhow!(
268            "no encuentro el instalador ({}) en:\n  {}\n  Pasá --payload <directorio del paquete>.",
269            INITRD.join(" / "),
270            dirs.iter().map(|d| d.display().to_string()).collect::<Vec<_>>().join("\n  ")
271        )
272    })?;
273    let bz = buscar(&dirs, KERNEL).ok_or_else(|| {
274        anyhow::anyhow!(
275            "encontré el instalador ({}) pero no su kernel ({}).\n  \
276             El paquete va entero: el instalador corre sobre SU kernel, no sobre el de esta máquina.",
277            initrd.display(),
278            KERNEL.join(" / ")
279        )
280    })?;
281    let guion = buscar(&dirs, GUION);
282
283    // ── 1) PRIMERO SE ELIGE, Y SE ELIGE ACÁ ───────────────────────────────────────────────────
284    //
285    // ⚠ **Esto era al revés y costó un cuelgue en metal.** El orden viejo era «saltá primero,
286    // elegí después»: toda la conversación pasaba DESPUÉS del kexec, en una máquina cuyo panel
287    // puede no volver a encenderse tras el salto. El usuario dijo que sí, la pantalla se fue a
288    // negro y se quedó así hasta apagar con el botón — el instalador estaba vivo del otro lado,
289    // pidiendo una tecla que nadie podía ver que estaba pidiendo.
290    //
291    // Ahora se elige en el sistema que TODAVÍA FUNCIONA, y lo de después va con la respuesta
292    // puesta. Un panel muerto pasa de ser un cuelgue a ser un detalle estético.
293    let mut destino = i.root.clone();
294    let mut usar_hueco = i.free;
295    let mut disco = i.disk.clone();
296    if destino.is_none() && !usar_hueco {
297        let g = guion.as_ref().ok_or_else(|| {
298            anyhow::anyhow!(
299                "no encuentro el censo (`takana-install-partition.sh`) junto al paquete, así que no \
300                 puedo preguntarte acá.\n  Pasá --root PARTUUID=… o --payload <dir del paquete>."
301            )
302        })?;
303        let elec = elegir(g)?;
304        match elec {
305            None => {
306                println!("nada hecho.");
307                return Ok(());
308            }
309            Some(e) => {
310                destino = e.dest;
311                usar_hueco = e.free;
312                if e.disk.is_some() {
313                    disco = e.disk;
314                }
315            }
316        }
317    }
318
319    // ── 2) ¿HACE FALTA SALTAR? ────────────────────────────────────────────────────────────────
320    // Sólo si el destino es la raíz VIVA: es la única partición que no se puede formatear desde
321    // adentro. Para cualquier otra, el salto sería matar la sesión del usuario sin necesidad.
322    let censo = censo_de(guion.as_deref());
323    let sobre_la_raiz = destino
324        .as_deref()
325        .map(|d| es_raiz_viva(&censo, d))
326        .unwrap_or(false);
327
328    let inst = Instalacion { root: destino.clone(), free: usar_hueco, disk: disco.clone(), ..i };
329
330    if !sobre_la_raiz && !inst.load_only && !inst.jump {
331        // El destino está libre: se instala DESDE ACÁ y esta sesión no se muere.
332        if let Some(g) = guion.as_ref() {
333            return instalar_aqui(g, &dirs, &inst);
334        }
335        println!("⚠ el destino no es la raíz viva, así que no haría falta saltar — pero no encuentro");
336        println!("  el censo junto al paquete para instalar desde acá. Sigo por el salto.");
337    }
338
339    // ── 3) EL SALTO: sólo acá, y explicando qué implica ───────────────────────────────────────
340    let (puede, motivos) = crate::kernel_cmd::kexec_probe();
341    if !puede {
342        println!("✗ el destino es la raíz que está corriendo AHORA, así que hay que soltarla antes");
343        println!("  de formatearla — y esta máquina no puede saltar:");
344        for m in &motivos {
345            println!("  · {m}");
346        }
347        println!();
348        if !crate::kernel_cmd::soy_root() {
349            println!("Repetilo con `sudo`: sin privilegios esto no es concluyente.");
350        } else {
351            println!("Quedan dos caminos, los dos sin tocar tu sistema actual:");
352            println!("  · instalar AL LADO, en espacio sin asignar:  takana metal install --free --disk /dev/…");
353            println!("  · la imagen USB, que hace exactamente lo mismo desde otro medio.");
354        }
355        std::process::exit(1);
356    }
357
358    let cmdline = cmdline_de(&inst);
359    println!();
360    println!("── el salto ──────────────────────────────────────────────────────────────────");
361    if sobre_la_raiz {
362        println!("  El destino es la raíz que estás usando: no se puede formatear desde adentro.");
363        println!("  Para soltarla, esta máquina salta a un instalador que corre en RAM.");
364    } else {
365        println!("  El destino NO es la raíz viva, así que este salto no haría falta: lo pediste");
366        println!("  a mano con --jump. El instalador corre igual, en RAM.");
367    }
368    println!();
369    println!("  destino:    {}", inst.root.as_deref().unwrap_or("el espacio sin asignar"));
370    println!("  instalador: {}  ({})", initrd.display(), tam(&initrd));
371    println!("  su kernel:  {}  ({})", bz.display(), tam(&bz));
372    println!();
373    println!("  Qué implica, en orden:");
374    println!("   1. TODO lo que está corriendo muere en el acto. Guardá antes.");
375    println!("   2. La pantalla puede quedarse en negro un rato, o no volver hasta el reinicio:");
376    println!("      un kexec no reinicia el hardware de vídeo. **No es un cuelgue** — ya no hay");
377    println!("      nada que preguntarte: la elección ya está hecha y el instalador la lleva puesta.");
378    println!("   3. Al terminar, la máquina reinicia sola.");
379    if en_sesion_grafica() {
380        println!();
381        println!("  ⚠ Esto parece una sesión GRÁFICA. El salto es mucho más sano desde una consola de");
382        println!("    texto: pasá a una con Ctrl+Alt+F2, entrá, y corré esto ahí.");
383    }
384    println!("──────────────────────────────────────────────────────────────────────────────");
385
386    if !inst.yes && !inst.load_only && !confirmar()? {
387        println!("nada hecho.");
388        return Ok(());
389    }
390
391    kernel_ab::kexec_cargar(&bz, Some(&initrd), &cmdline)?;
392    println!("✓ instalador cargado en memoria");
393    if inst.load_only {
394        println!("  (--load-only: no se salta. Queda cargado hasta el próximo reinicio.)");
395        return Ok(());
396    }
397    println!("⚡ saltando — a partir de acá no hace falta mirar nada.");
398    kernel_ab::kexec_saltar()
399}
400
401/// Lo que devolvió el menú.
402struct Eleccion {
403    dest: Option<String>,
404    free: bool,
405    disk: Option<String>,
406}
407
408/// Corre el censo en modo `--pick`: muestra el terreno, deja elegir y **no toca nada**.
409fn elegir(guion: &Path) -> Result<Option<Eleccion>> {
410    let tmp = std::env::temp_dir().join(format!("takana-eleccion.{}", std::process::id()));
411    let st = std::process::Command::new("sh")
412        .arg(guion)
413        .arg("--pick")
414        .arg(&tmp)
415        .status()
416        .with_context(|| format!("no puedo ejecutar {}", guion.display()))?;
417    if !st.success() {
418        let _ = std::fs::remove_file(&tmp);
419        return Ok(None);
420    }
421    let txt = std::fs::read_to_string(&tmp).unwrap_or_default();
422    let _ = std::fs::remove_file(&tmp);
423    let mut e = Eleccion { dest: None, free: false, disk: None };
424    for l in txt.lines() {
425        match l.split_once('=') {
426            Some(("DEST", v)) => e.dest = Some(v.to_string()),
427            Some(("DISK", v)) => e.disk = Some(v.to_string()),
428            Some(("FREE", _)) => e.free = true,
429            _ => {}
430        }
431    }
432    if e.dest.is_none() && !e.free {
433        return Ok(None);
434    }
435    Ok(Some(e))
436}
437
438/// El censo en JSON, o vacío si no se pudo. **Vacío no es «no hay discos»**: acá sólo se usa para
439/// una pregunta concreta —¿el destino es la raíz viva?— y no saberlo se trata como «no».
440fn censo_de(guion: Option<&Path>) -> String {
441    let Some(g) = guion else { return String::new() };
442    std::process::Command::new("sh")
443        .arg(g)
444        .args(["--survey", "--json"])
445        .output()
446        .ok()
447        .filter(|o| o.status.success())
448        .map(|o| String::from_utf8_lossy(&o.stdout).to_string())
449        .unwrap_or_default()
450}
451
452/// ¿El destino elegido es la raíz viva? Se lee del censo, que es quien lo decide.
453///
454/// Sin parsear JSON de verdad: se busca el bloque de esa partición y se mira si su veredicto es
455/// `RAIZ_VIVA`. Un formato de una línea por partición hace que esto sea exacto; si el censo
456/// cambiara de forma, esto deja de encontrar nada y el resultado es «no es la raíz» ⇒ se instala
457/// sin saltar y el instalador aborta con su propia guarda. Se equivoca del lado que no destruye.
458fn es_raiz_viva(censo_json: &str, destino: &str) -> bool {
459    let clave = destino.trim_start_matches("PARTUUID=").trim_start_matches("partuuid=");
460    for linea in censo_json.lines() {
461        let l = linea.trim();
462        if !l.starts_with('{') {
463            continue;
464        }
465        let casa = l.contains(&format!("\"partuuid\": \"{clave}\""))
466            || l.contains(&format!("\"dev\": \"{destino}\""));
467        if casa {
468            return l.contains("\"veredicto\": \"RAIZ_VIVA\"");
469        }
470    }
471    false
472}
473
474/// ¿Estamos dentro de una sesión gráfica? Sólo para AVISAR, nunca para decidir.
475///
476/// Un kexec no reinicia el hardware de vídeo, y saltar desde un compositor con la GPU tomada es la
477/// forma más fácil de quedarse con el panel apagado del otro lado. Desde una VT de texto el salto
478/// es mucho más sano. No se bloquea: se avisa, porque también hay quien sabe lo que hace.
479fn en_sesion_grafica() -> bool {
480    ["WAYLAND_DISPLAY", "DISPLAY", "XDG_SESSION_TYPE"]
481        .iter()
482        .any(|v| std::env::var(v).map(|x| !x.is_empty() && x != "tty").unwrap_or(false))
483}
484
485/// Instala **desde esta máquina**, sin saltar. Es el camino normal cuando el destino no es la raíz
486/// viva: no hay ninguna razón para matar la sesión del usuario.
487///
488/// El árbol que se copia vive comprimido dentro del initramfs del instalador, así que se
489/// desempaqueta primero — con el `busybox` que viaja en el paquete y no con el del host, que puede
490/// no existir (en las tres máquinas de este proyecto no hay `cpio`).
491fn instalar_aqui(guion: &Path, dirs: &[PathBuf], i: &Instalacion) -> Result<()> {
492    let bb = buscar(dirs, &["busybox", "bin/busybox"]).ok_or_else(|| {
493        anyhow::anyhow!(
494            "el paquete no trae `busybox`, que es con lo que se desempaqueta el árbol a instalar.\n  \
495             Rearmá el paquete con scripts/instalador-paquete.sh."
496        )
497    })?;
498    let initrd = buscar(dirs, INITRD).expect("ya se resolvió antes");
499
500    println!();
501    println!("── instalar desde acá, SIN saltar ────────────────────────────────────────────");
502    println!("  El destino no es la raíz que estás usando, así que no hace falta soltarla:");
503    println!("  esta sesión sigue viva y al terminar reiniciás cuando quieras.");
504    println!("  destino: {}", i.root.as_deref().unwrap_or("el espacio sin asignar"));
505    println!("──────────────────────────────────────────────────────────────────────────────");
506    if !i.yes && !confirmar()? {
507        println!("nada hecho.");
508        return Ok(());
509    }
510
511    let tmp = std::env::temp_dir().join(format!("takana-arbol.{}", std::process::id()));
512    std::fs::create_dir_all(&tmp)?;
513    println!("==> desempaquetando el árbol a instalar en {}", tmp.display());
514    let sh = format!(
515        "{bb} gzip -d -c {ird} | ( cd {d} && {bb} cpio -i -d --quiet )",
516        bb = bb.display(),
517        ird = initrd.display(),
518        d = tmp.display()
519    );
520    let st = std::process::Command::new("sh").arg("-c").arg(&sh).status()?;
521    if !st.success() {
522        bail!("no pude desempaquetar {}", initrd.display());
523    }
524
525    let mut c = std::process::Command::new("sh");
526    c.arg(guion);
527    if let Some(r) = &i.root {
528        c.arg("--root-part").arg(r);
529    }
530    if i.free {
531        c.arg("--use-free-space");
532    }
533    if let Some(d) = &i.disk {
534        c.arg("--disk").arg(d);
535    }
536    c.arg("--yes");
537    // Las herramientas y el árbol salen del paquete: acá no hay store del que resolverlas por hash.
538    for (v, rel) in [
539        ("TOOL_mke2fs", "bin/mke2fs"),
540        ("TOOL_sfdisk", "bin/sfdisk"),
541        ("TOOL_mmd", "bin/mmd"),
542        ("TOOL_mcopy", "bin/mcopy"),
543        ("TOOL_mdir", "bin/mdir"),
544    ] {
545        c.env(v, tmp.join(rel));
546    }
547    c.env("STAGE", tmp.join("payload/stage"))
548        .env("STAGE_LISTO", "1")
549        .env("KERNEL", tmp.join("payload/bzImage"))
550        .env("HAMMER", tmp.join("bin/takana"));
551    let st = c.status()?;
552    let _ = std::process::Command::new("rm").arg("-rf").arg(&tmp).status();
553    if !st.success() {
554        bail!("el instalador falló ({st})");
555    }
556    println!();
557    println!("✓ listo. Reiniciá cuando quieras y elegí takana en el firmware.");
558    Ok(())
559}
560
561/// La cmdline del instalador: las respuestas que ya se dieron viajan por acá, y las que no, no.
562/// Es el mismo canal que lee el `/init` del initramfs, así que **no hay nada horneado por máquina**.
563fn cmdline_de(i: &Instalacion) -> String {
564    let mut s = i.console.clone();
565    if let Some(r) = &i.root {
566        s.push_str(&format!(" takana.root={r}"));
567    }
568    if let Some(e) = &i.esp {
569        s.push_str(&format!(" takana.esp={e}"));
570    }
571    if let Some(d) = &i.disk {
572        s.push_str(&format!(" takana.disk={d}"));
573    }
574    if i.free {
575        s.push_str(" takana.free");
576    }
577    if let Some(k) = &i.keep {
578        s.push_str(&format!(" takana.keep={k}"));
579    }
580    if i.unattended {
581        s.push_str(" takana.yes");
582    }
583    s
584}
585
586fn tam(p: &Path) -> String {
587    match std::fs::metadata(p).map(|m| m.len()) {
588        Ok(b) if b >= 1 << 20 => format!("{} M", b >> 20),
589        Ok(b) => format!("{} K", b >> 10),
590        Err(_) => "?".to_string(),
591    }
592}
593
594/// Confirmación explícita. **No** acepta un `enter` pelado: el enter es lo que se aprieta sin leer,
595/// y lo que sigue mata la sesión.
596fn confirmar() -> Result<bool> {
597    use std::io::{BufRead, Write};
598    print!("¿Saltar al instalador? Escribí «si» para seguir: ");
599    std::io::stdout().flush().ok();
600    let mut l = String::new();
601    if std::io::stdin().lock().read_line(&mut l).is_err() {
602        return Ok(false);
603    }
604    let l = l.trim().to_lowercase();
605    Ok(l == "si" || l == "sí")
606}
607
608#[cfg(test)]
609mod tests {
610    use super::*;
611
612    fn base() -> Instalacion {
613        Instalacion {
614            payload: None, root: None, esp: None, free: false, keep: None, disk: None,
615            yes: false, unattended: false, load_only: false, jump: false,
616            console: CONSOLA.to_string(),
617        }
618    }
619
620    #[test]
621    fn sin_respuestas_la_cmdline_no_lleva_ninguna_maquina_adentro() {
622        // El punto entero de la generalización: un paquete sirve en cualquier máquina porque no
623        // trae respuestas horneadas. Si esto empieza a fallar, alguien volvió a hornear.
624        assert_eq!(cmdline_de(&base()), CONSOLA);
625    }
626
627    #[test]
628    fn las_respuestas_dadas_viajan_por_la_cmdline() {
629        let i = Instalacion {
630            root: Some("PARTUUID=55b5-0de7".into()),
631            esp: Some("PARTUUID=aaaa-bbbb".into()),
632            unattended: true,
633            ..base()
634        };
635        let c = cmdline_de(&i);
636        assert!(c.contains("takana.root=PARTUUID=55b5-0de7"), "{c}");
637        assert!(c.contains("takana.esp=PARTUUID=aaaa-bbbb"), "{c}");
638        assert!(c.contains("takana.yes"), "{c}");
639        assert!(!c.contains("takana.free"), "{c}");
640    }
641
642    #[test]
643    fn el_home_conservado_viaja_por_la_cmdline_y_no_aparece_si_no_se_pide() {
644        // Que `--keep` NO aparezca cuando no se pide es la mitad que importa: un `takana.keep=` de
645        // más en la cmdline haría que el instalador intente montar una partición que nadie nombró.
646        assert!(!cmdline_de(&base()).contains("takana.keep"), "sin --keep no viaja nada");
647        let i = Instalacion {
648            root: Some("PARTUUID=1111-2222".into()),
649            keep: Some("PARTUUID=3333-4444:/home".into()),
650            ..base()
651        };
652        let c = cmdline_de(&i);
653        assert!(c.contains("takana.keep=PARTUUID=3333-4444:/home"), "{c}");
654        // Y no se confunde con el destino: son dos particiones distintas y una se formatea.
655        assert!(c.contains("takana.root=PARTUUID=1111-2222"), "{c}");
656    }
657
658    #[test]
659    fn free_y_disk_viajan_juntos_y_sin_destino() {
660        let i = Instalacion { free: true, disk: Some("/dev/nvme0n1".into()), ..base() };
661        let c = cmdline_de(&i);
662        assert!(c.contains("takana.free"), "{c}");
663        assert!(c.contains("takana.disk=/dev/nvme0n1"), "{c}");
664        assert!(!c.contains("takana.root="), "{c}");
665    }
666
667    const CENSO: &str = r#"{
668  "version": 1,
669  "raiz_viva": "8:2",
670  "particiones": [
671    {"dev": "/dev/sda2", "partuuid": "AAAA", "mib": 6144, "veredicto": "RAIZ_VIVA", "usable": true},
672    {"dev": "/dev/sda5", "partuuid": "BBBB", "mib": 40960, "veredicto": "CANDIDATA", "usable": true}
673  ]
674}"#;
675
676    #[test]
677    fn el_salto_hace_falta_solo_para_la_raiz_viva() {
678        // Es la decisión que reordenó todo: saltar cuando no hace falta es matar la sesión del
679        // usuario por nada, y el cuelgue que lo destapó pasó justamente ahí.
680        assert!(es_raiz_viva(CENSO, "PARTUUID=AAAA"));
681        assert!(!es_raiz_viva(CENSO, "PARTUUID=BBBB"));
682        assert!(es_raiz_viva(CENSO, "/dev/sda2"));
683        assert!(!es_raiz_viva(CENSO, "/dev/sda5"));
684    }
685
686    #[test]
687    fn un_destino_que_el_censo_no_conoce_no_se_toma_por_la_raiz_viva() {
688        // Se equivoca del lado que NO destruye: si esto diera «sí», se saltaría sin necesidad; si
689        // da «no», se instala desde acá y la guarda del propio instalador aborta si el destino
690        // resulta ser la raíz. Un error de más contra un error que mata la sesión.
691        assert!(!es_raiz_viva(CENSO, "PARTUUID=ZZZZ"));
692        assert!(!es_raiz_viva("", "PARTUUID=AAAA"));
693        assert!(!es_raiz_viva("esto no es json", "PARTUUID=AAAA"));
694    }
695
696    #[test]
697    fn buscar_respeta_el_orden_de_los_nombres_y_de_los_directorios() {
698        let d = std::env::temp_dir().join(format!("metal-test-{}", std::process::id()));
699        let a = d.join("a");
700        let b = d.join("b");
701        std::fs::create_dir_all(&a).unwrap();
702        std::fs::create_dir_all(&b).unwrap();
703        std::fs::write(b.join("initramfs.cpio.gz"), b"x").unwrap();
704        std::fs::write(b.join("takana-instalador.cpio.gz"), b"x").unwrap();
705        // El directorio gana sobre el nombre: `a` no lo tiene, así que se cae a `b`.
706        let v = vec![a.clone(), b.clone()];
707        assert_eq!(buscar(&v, INITRD).unwrap(), b.join("takana-instalador.cpio.gz"));
708        std::fs::write(a.join("initramfs.cpio.gz"), b"x").unwrap();
709        // Y ahora `a` gana aunque su nombre sea el último de la lista: primero el directorio.
710        assert_eq!(buscar(&v, INITRD).unwrap(), a.join("initramfs.cpio.gz"));
711        std::fs::remove_dir_all(&d).ok();
712    }
713}