Something went wrong. Try again.
ALPHA: wire is a tool to deploy nixos systems (contribution fork) forked from althaea.zone/wire
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185// SPDX-License-Identifier: AGPL-3.0-or-later// Copyright 2024-2025 wire Contributors
#![deny(clippy::pedantic)]#![feature(default_field_values)]
use std::process::Command;use std::sync::Arc;use std::sync::atomic::AtomicBool;
use crate::cli::Cli;use crate::cli::Partitions;use crate::cli::ToSubCommandModifiers;use crate::sigint::handle_signals;use crate::tracing_setup::setup_logging;use clap::CommandFactory;use clap::Parser;use clap_complete::CompleteEnv;use miette::IntoDiagnostic;use miette::Result;use signal_hook::consts::SIGINT;use signal_hook_tokio::Signals;use tracing::error;use tracing::warn;use wire_core::cache::InspectionCache;use wire_core::commands::common::get_hive_node_names;use wire_core::hive::Hive;use wire_core::hive::get_hive_location;use wire_core::hive::node::should_apply_locally;use wire_core::hive::plan::ApplyGoalArgs;use wire_core::hive::plan::Goal;
#[macro_use]extern crate enum_display_derive;
pub mod apply;mod cli;mod sigint;mod tracing_setup;
#[cfg(feature = "dhat-heap")]#[global_allocator]static ALLOC: dhat::Alloc = dhat::Alloc;
#[tokio::main]async fn main() -> Result<()> { #[cfg(feature = "dhat-heap")] let _profiler = dhat::Profiler::new_heap(); CompleteEnv::with_factory(Cli::command).complete();
let args = Cli::parse();
let modifiers = args.to_subcommand_modifiers(); // disable progress when running inspect mode. setup_logging( &args.verbose, !matches!(args.command, cli::Commands::Inspect { .. }) && !&args.no_progress, );
#[cfg(debug_assertions)] if args.markdown_help { clap_markdown::print_help_markdown::<Cli>(); return Ok(()); }
#[cfg(debug_assertions)] if let Some(path) = args.roff { clap_mangen::generate_to(Cli::command(), path).unwrap(); return Ok(()); }
if !check_nix_available() { miette::bail!("Nix is not available on this system."); }
let signals = Signals::new([SIGINT]).into_diagnostic()?; let signals_handle = signals.handle(); let should_shutdown = Arc::new(AtomicBool::new(false)); let signals_task = tokio::spawn(handle_signals(signals, should_shutdown.clone()));
let location = get_hive_location(args.path, modifiers).await?; let cache = Arc::new(InspectionCache::new().await);
match args.command { cli::Commands::Apply(apply_args) => { let mut hive = Hive::new_from_path(&location, cache.clone(), modifiers).await?; let goal = apply_args.goal.clone().try_into().unwrap();
// Respect user's --always-build-local arg hive.force_always_local(apply_args.always_build_local)?;
apply::apply( &mut hive, should_shutdown.clone(), location, apply_args.common, Partitions::default(), |name, node| { Goal::Apply(ApplyGoalArgs { goal, no_keys: apply_args.no_keys, reboot: apply_args.reboot, substitute_on_destination: apply_args.substitute_on_destination, should_apply_locally: should_apply_locally( node.allow_local_deployment, &name.0, ), handle_unreachable: apply_args.handle_unreachable.clone().into(), host_platform: node.host_platform.clone(), }) }, modifiers, cache.clone(), ) .await?; } cli::Commands::Build(build_args) => { let mut hive = Hive::new_from_path(&location, cache.clone(), modifiers).await?;
apply::apply( &mut hive, should_shutdown.clone(), location, build_args.common, build_args.partition.unwrap_or_default(), |_name, _node| Goal::Build, modifiers, cache.clone(), ) .await?; } cli::Commands::Inspect { json, selection } => println!("{}", { match selection { cli::Inspection::Full => { let hive = Hive::new_from_path(&location, cache.clone(), modifiers).await?; if json { serde_json::to_string(&hive).into_diagnostic()? } else { warn!("use --json to output something scripting suitable"); format!("{hive}") } } cli::Inspection::Names => { let names = get_hive_node_names(&location, modifiers).await?;
if json { serde_json::to_string(&names).into_diagnostic()? } else { names.join("\n") } } } }), }
if let Some(cache) = &*cache { cache.gc(should_shutdown).await.into_diagnostic()?; }
signals_handle.close(); signals_task.await.into_diagnostic()?;
Ok(())}
fn check_nix_available() -> bool { match Command::new("nix") .stdout(std::process::Stdio::null()) .stderr(std::process::Stdio::null()) .spawn() { Ok(_) => true, Err(e) => { if e.kind() != std::io::ErrorKind::NotFound { error!( "Something weird happened checking for nix availability, {}", e ); }
false } }}