lifecycle::rebuild through meta

rebuild now does sync_agents (idempotent — no-op when the
rendered flake matches disk; recovers from a divergent meta
repo on the side) followed by lock_update_for_rebuild which
relocks just this agent's input and commits the lock change
if any. flake ref for nixos-container update flips from
applied/<n>#default to meta#<name>. new helper
meta::lock_update_for_rebuild is single-phase (no separate
finalize): rebuild has no failure-revert semantics — it always
wants the latest applied/<n>/main. spawn already syncs meta
before container create; rebuild now picks up the meta side
on every manual ↻ R3BU1LD.
This commit is contained in:
müde 2026-05-16 00:28:26 +02:00
parent 8f94e4379a
commit 4cb529351e
2 changed files with 30 additions and 5 deletions

View file

@ -265,14 +265,12 @@ pub async fn destroy(name: &str) -> Result<()> {
pub async fn rebuild( pub async fn rebuild(
name: &str, name: &str,
// hyperhive_flake + dashboard_port unused after the meta-flake hyperhive_flake: &str,
// overhaul; kept on the signature until callers are reworked.
_hyperhive_flake: &str,
agent_dir: &Path, agent_dir: &Path,
applied_dir: &Path, applied_dir: &Path,
claude_dir: &Path, claude_dir: &Path,
notes_dir: &Path, notes_dir: &Path,
_dashboard_port: u16, dashboard_port: u16,
) -> Result<()> { ) -> Result<()> {
validate(name)?; validate(name)?;
if let Some(other) = port_collision(name).await { if let Some(other) = port_collision(name).await {
@ -284,8 +282,19 @@ pub async fn rebuild(
setup_applied(applied_dir, None, name).await?; setup_applied(applied_dir, None, name).await?;
ensure_claude_dir(claude_dir)?; ensure_claude_dir(claude_dir)?;
ensure_state_dir(notes_dir)?; ensure_state_dir(notes_dir)?;
// Sync the meta flake (idempotent — no-op when the rendered
// flake matches disk) so a manual rebuild from the dashboard
// can also recover from a divergent meta repo (e.g. an agent
// got added directly via `nixos-container create` outside
// hive-c0re).
let agents = agents_for_meta(None).await?;
crate::meta::sync_agents(hyperhive_flake, dashboard_port, &agents).await?;
// Then bump just this agent's input — picks up whatever
// `applied/<n>/main` currently points at (deployed/<latest>).
// Commits the lock if it changed.
crate::meta::lock_update_for_rebuild(name).await?;
let container = container_name(name); let container = container_name(name);
let flake_ref = format!("{}#default", applied_dir.display()); let flake_ref = format!("{}#{name}", crate::meta::meta_dir().display());
set_nspawn_flags(&container, agent_dir, claude_dir, notes_dir)?; set_nspawn_flags(&container, agent_dir, claude_dir, notes_dir)?;
set_resource_limits(&container)?; set_resource_limits(&container)?;
systemd_daemon_reload().await?; systemd_daemon_reload().await?;

View file

@ -119,6 +119,22 @@ pub async fn abort_deploy() -> Result<()> {
git(&dir, &["restore", "flake.lock"]).await git(&dir, &["restore", "flake.lock"]).await
} }
/// One-shot used by the manual-rebuild path: relock just one
/// agent's input and commit the lock change if any. Single-phase
/// (no separate finalize) because rebuild has no failure-revert
/// semantics — it always wants the latest main.
#[allow(dead_code)] // wired up by lifecycle::rebuild in this commit
pub async fn lock_update_for_rebuild(name: &str) -> Result<()> {
let dir = meta_dir();
let input = format!("agent-{name}");
nix(&dir, &["flake", "lock", "--update-input", &input]).await?;
if !git_is_clean(&dir).await? {
git(&dir, &["add", "flake.lock"]).await?;
git_commit(&dir, &format!("rebuild {name}: lock update")).await?;
}
Ok(())
}
/// One-shot used by the auto-update path: pin the latest hyperhive /// One-shot used by the auto-update path: pin the latest hyperhive
/// rev, commit if the lock changed. Cheaper than `sync_agents` /// rev, commit if the lock changed. Cheaper than `sync_agents`
/// because the per-agent inputs aren't touched. /// because the per-agent inputs aren't touched.