Sergio
53dbdf0f1d
Workspace en 4 ejes (core/modules/apps/shared):
- core/: 24 crates de arje (Init systemd-compatible: ente-card, ente-zero,
ente-kernel, ente-bus, ente-cas, ente-soma, ente-wasm, ente-snapshot,
ente-brain, ente-echo, ente-policy-provider, + 12 crates *-compat)
- modules/semantic_dht/: 5 crates de minga (minga-core con AST/CAS/MST,
minga-p2p con libp2p Kad, minga-store, minga-vfs, minga-cli)
- modules/ui_engine/: 11 crates de yahweh (libs/{core,theme,bus,providers},
widgets/{tree,splitter,tabs,tiled,container_core,text_input})
- apps/: 5 crates de yahweh (file_explorer, database_explorer, text_viewer,
image_viewer, yahweh-shell)
- shared_wit/protocol.wit: handshake/lifecycle inicial
Cargo.toml unificado: thiserror bumped a 2 (transparente para arje), tokio
"full", paths intra-workspace de yahweh redirigidos a su nueva ubicación.
cargo check --workspace: 0 errores, 17 warnings (dead code preexistente).
Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
62 lines
2.0 KiB
Rust
62 lines
2.0 KiB
Rust
//! Persistencia del fractal. Captura el estado live (Cards encarnadas con
|
|
//! sus identidades preservadas) a un blob JSON. Al restaurar, las mismas
|
|
//! Ulids vuelven a la vida — los PIDs cambian (kernel no los preserva) pero
|
|
//! el grafo se reconstruye con la misma topología.
|
|
//!
|
|
//! Lo que NO se persiste:
|
|
//! - PIDs (irrelevantes tras reboot)
|
|
//! - bus_connections (runtime-only)
|
|
//! - pending_invokes (en vuelo, se descartan)
|
|
//! - device presence (uevents reconstruyen el índice)
|
|
|
|
use ente_card::EntityCard;
|
|
use serde::{Deserialize, Serialize};
|
|
use std::path::Path;
|
|
use ulid::Ulid;
|
|
|
|
pub const SNAPSHOT_VERSION: u16 = 1;
|
|
|
|
#[derive(Debug, Clone, Serialize, Deserialize)]
|
|
pub struct FractalSnapshot {
|
|
pub version: u16,
|
|
pub timestamp_ms: u64,
|
|
pub seed_id: Ulid,
|
|
pub seed_label: String,
|
|
/// Cards live al momento del checkpoint, excluyendo la Semilla.
|
|
/// Al restaurar se inyectan en `genesis` con sus Ulids originales.
|
|
pub entes: Vec<EntityCard>,
|
|
}
|
|
|
|
impl FractalSnapshot {
|
|
pub fn write(&self, path: &Path) -> anyhow::Result<()> {
|
|
let bytes = serde_json::to_vec_pretty(self)?;
|
|
if let Some(parent) = path.parent() {
|
|
std::fs::create_dir_all(parent).ok();
|
|
}
|
|
// Escritura atómica: temp file + rename.
|
|
let tmp = path.with_extension("tmp");
|
|
std::fs::write(&tmp, &bytes)?;
|
|
std::fs::rename(&tmp, path)?;
|
|
Ok(())
|
|
}
|
|
|
|
pub fn read(path: &Path) -> anyhow::Result<Self> {
|
|
let bytes = std::fs::read(path)?;
|
|
let snap: FractalSnapshot = serde_json::from_slice(&bytes)?;
|
|
if snap.version != SNAPSHOT_VERSION {
|
|
anyhow::bail!(
|
|
"snapshot version {} no soportada (esperada {})",
|
|
snap.version, SNAPSHOT_VERSION
|
|
);
|
|
}
|
|
Ok(snap)
|
|
}
|
|
}
|
|
|
|
pub fn now_ms() -> u64 {
|
|
std::time::SystemTime::now()
|
|
.duration_since(std::time::UNIX_EPOCH)
|
|
.map(|d| d.as_millis() as u64)
|
|
.unwrap_or(0)
|
|
}
|