aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/main.rs169
-rw-r--r--src/utils/activate.rs108
-rw-r--r--src/utils/mod.rs72
3 files changed, 184 insertions, 165 deletions
diff --git a/src/main.rs b/src/main.rs
index 7818652..cde4fc3 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -5,8 +5,6 @@ use tokio::process::Command;
use merge::Merge;
-use std::path::Path;
-
extern crate pretty_env_logger;
#[macro_use]
extern crate log;
@@ -158,69 +156,6 @@ async fn deploy_all_profiles(
Ok(())
}
-
-#[derive(PartialEq, Debug)]
-struct DeployFlake<'a> {
- repo: &'a str,
- node: Option<&'a str>,
- profile: Option<&'a str>,
-}
-
-fn parse_flake(flake: &str) -> DeployFlake {
- let flake_fragment_start = flake.find('#');
- let (repo, maybe_fragment) = match flake_fragment_start {
- Some(s) => (&flake[..s], Some(&flake[s + 1..])),
- None => (flake, None),
- };
-
- let (node, profile) = match maybe_fragment {
- Some(fragment) => {
- let fragment_profile_start = fragment.find('.');
- match fragment_profile_start {
- Some(s) => (Some(&fragment[..s]), Some(&fragment[s + 1..])),
- None => (Some(fragment), None),
- }
- }
- None => (None, None),
- };
-
- DeployFlake {
- repo,
- node,
- profile,
- }
-}
-
-#[test]
-fn test_parse_flake() {
- assert_eq!(
- parse_flake("../deploy/examples/system#example"),
- DeployFlake {
- repo: "../deploy/examples/system",
- node: Some("example"),
- profile: None
- }
- );
-
- assert_eq!(
- parse_flake("../deploy/examples/system#example.system"),
- DeployFlake {
- repo: "../deploy/examples/system",
- node: Some("example"),
- profile: Some("system")
- }
- );
-
- assert_eq!(
- parse_flake("../deploy/examples/system"),
- DeployFlake {
- repo: "../deploy/examples/system",
- node: None,
- profile: None,
- }
- );
-}
-
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
@@ -234,7 +169,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
match opts.subcmd {
SubCommand::Deploy(deploy_opts) => {
- let deploy_flake = parse_flake(deploy_opts.flake.as_str());
+ let deploy_flake = utils::parse_flake(deploy_opts.flake.as_str());
let test_flake_status = Command::new("nix")
.arg("eval")
@@ -364,102 +299,14 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
};
}
SubCommand::Activate(activate_opts) => {
- info!("Activating profile");
-
- Command::new("nix-env")
- .arg("-p")
- .arg(&activate_opts.profile_path)
- .arg("--set")
- .arg(&activate_opts.closure)
- .stdout(Stdio::null())
- .spawn()?
- .await?;
-
- if let (Some(bootstrap_cmd), false) = (
+ utils::activate::activate(
+ activate_opts.profile_path,
+ activate_opts.closure,
+ activate_opts.activate_cmd,
activate_opts.bootstrap_cmd,
- !Path::new(&activate_opts.profile_path).exists(),
- ) {
- let bootstrap_status = Command::new("bash")
- .arg("-c")
- .arg(&bootstrap_cmd)
- .env("PROFILE", &activate_opts.profile_path)
- .stdout(Stdio::null())
- .stderr(Stdio::null())
- .status()
- .await;
-
- match bootstrap_status {
- Ok(s) if s.success() => (),
- _ => {
- tokio::fs::remove_file(&activate_opts.profile_path).await?;
- good_panic!("Failed to execute bootstrap command");
- }
- }
- }
-
- if let Some(activate_cmd) = activate_opts.activate_cmd {
- let activate_status = Command::new("bash")
- .arg("-c")
- .arg(&activate_cmd)
- .env("PROFILE", &activate_opts.profile_path)
- .status()
- .await;
-
- match activate_status {
- Ok(s) if s.success() => (),
- _ if activate_opts.auto_rollback => {
- Command::new("nix-env")
- .arg("-p")
- .arg(&activate_opts.profile_path)
- .arg("--rollback")
- .stdout(Stdio::null())
- .stderr(Stdio::null())
- .spawn()?
- .await?;
-
- let c = Command::new("nix-env")
- .arg("-p")
- .arg(&activate_opts.profile_path)
- .arg("--list-generations")
- .output()
- .await?;
- let generations_list = String::from_utf8(c.stdout)?;
-
- let last_generation_line = generations_list
- .lines()
- .last()
- .expect("Expected to find a generation in list");
-
- let last_generation_id = last_generation_line
- .split_whitespace()
- .next()
- .expect("Expected to get ID from generation entry");
-
- debug!("Removing generation entry {}", last_generation_line);
- warn!("Removing generation by ID {}", last_generation_id);
-
- Command::new("nix-env")
- .arg("-p")
- .arg(&activate_opts.profile_path)
- .arg("--delete-generations")
- .arg(last_generation_id)
- .stdout(Stdio::null())
- .stderr(Stdio::null())
- .spawn()?
- .await?;
-
- // TODO: Find some way to make sure this command never changes, otherwise this will not work
- Command::new("bash")
- .arg("-c")
- .arg(&activate_cmd)
- .spawn()?
- .await?;
-
- good_panic!("Failed to execute activation command");
- }
- _ => {}
- }
- }
+ activate_opts.auto_rollback,
+ )
+ .await?;
}
}
diff --git a/src/utils/activate.rs b/src/utils/activate.rs
new file mode 100644
index 0000000..33774fd
--- /dev/null
+++ b/src/utils/activate.rs
@@ -0,0 +1,108 @@
+use std::process::Stdio;
+use tokio::process::Command;
+
+use std::path::Path;
+
+pub async fn activate(
+ profile_path: String,
+ closure: String,
+ activate_cmd: Option<String>,
+ bootstrap_cmd: Option<String>,
+ auto_rollback: bool,
+) -> Result<(), Box<dyn std::error::Error>> {
+ info!("Activating profile");
+
+ Command::new("nix-env")
+ .arg("-p")
+ .arg(&profile_path)
+ .arg("--set")
+ .arg(&closure)
+ .stdout(Stdio::null())
+ .spawn()?
+ .await?;
+
+ if let (Some(bootstrap_cmd), false) = (bootstrap_cmd, !Path::new(&profile_path).exists()) {
+ let bootstrap_status = Command::new("bash")
+ .arg("-c")
+ .arg(&bootstrap_cmd)
+ .env("PROFILE", &profile_path)
+ .stdout(Stdio::null())
+ .stderr(Stdio::null())
+ .status()
+ .await;
+
+ match bootstrap_status {
+ Ok(s) if s.success() => (),
+ _ => {
+ tokio::fs::remove_file(&profile_path).await?;
+ good_panic!("Failed to execute bootstrap command");
+ }
+ }
+ }
+
+ if let Some(activate_cmd) = activate_cmd {
+ let activate_status = Command::new("bash")
+ .arg("-c")
+ .arg(&activate_cmd)
+ .env("PROFILE", &profile_path)
+ .status()
+ .await;
+
+ match activate_status {
+ Ok(s) if s.success() => (),
+ _ if auto_rollback => {
+ Command::new("nix-env")
+ .arg("-p")
+ .arg(&profile_path)
+ .arg("--rollback")
+ .stdout(Stdio::null())
+ .stderr(Stdio::null())
+ .spawn()?
+ .await?;
+
+ let c = Command::new("nix-env")
+ .arg("-p")
+ .arg(&profile_path)
+ .arg("--list-generations")
+ .output()
+ .await?;
+ let generations_list = String::from_utf8(c.stdout)?;
+
+ let last_generation_line = generations_list
+ .lines()
+ .last()
+ .expect("Expected to find a generation in list");
+
+ let last_generation_id = last_generation_line
+ .split_whitespace()
+ .next()
+ .expect("Expected to get ID from generation entry");
+
+ debug!("Removing generation entry {}", last_generation_line);
+ warn!("Removing generation by ID {}", last_generation_id);
+
+ Command::new("nix-env")
+ .arg("-p")
+ .arg(&profile_path)
+ .arg("--delete-generations")
+ .arg(last_generation_id)
+ .stdout(Stdio::null())
+ .stderr(Stdio::null())
+ .spawn()?
+ .await?;
+
+ // TODO: Find some way to make sure this command never changes, otherwise this will not work
+ Command::new("bash")
+ .arg("-c")
+ .arg(&activate_cmd)
+ .spawn()?
+ .await?;
+
+ good_panic!("Failed to execute activation command");
+ }
+ _ => {}
+ }
+ }
+
+ Ok(())
+}
diff --git a/src/utils/mod.rs b/src/utils/mod.rs
index 764e2e9..935f470 100644
--- a/src/utils/mod.rs
+++ b/src/utils/mod.rs
@@ -1,10 +1,7 @@
use std::borrow::Cow;
use std::path::PathBuf;
-pub mod data;
-pub mod deploy;
-pub mod push;
-
+#[macro_export]
macro_rules! good_panic {
($($tts:tt)*) => {{
error!($($tts)*);
@@ -12,6 +9,73 @@ macro_rules! good_panic {
}}
}
+pub mod activate;
+pub mod data;
+pub mod deploy;
+pub mod push;
+
+#[derive(PartialEq, Debug)]
+pub struct DeployFlake<'a> {
+ pub repo: &'a str,
+ pub node: Option<&'a str>,
+ pub profile: Option<&'a str>,
+}
+
+pub fn parse_flake(flake: &str) -> DeployFlake {
+ let flake_fragment_start = flake.find('#');
+ let (repo, maybe_fragment) = match flake_fragment_start {
+ Some(s) => (&flake[..s], Some(&flake[s + 1..])),
+ None => (flake, None),
+ };
+
+ let (node, profile) = match maybe_fragment {
+ Some(fragment) => {
+ let fragment_profile_start = fragment.find('.');
+ match fragment_profile_start {
+ Some(s) => (Some(&fragment[..s]), Some(&fragment[s + 1..])),
+ None => (Some(fragment), None),
+ }
+ }
+ None => (None, None),
+ };
+
+ DeployFlake {
+ repo,
+ node,
+ profile,
+ }
+}
+
+#[test]
+fn test_parse_flake() {
+ assert_eq!(
+ parse_flake("../deploy/examples/system#example"),
+ DeployFlake {
+ repo: "../deploy/examples/system",
+ node: Some("example"),
+ profile: None
+ }
+ );
+
+ assert_eq!(
+ parse_flake("../deploy/examples/system#example.system"),
+ DeployFlake {
+ repo: "../deploy/examples/system",
+ node: Some("example"),
+ profile: Some("system")
+ }
+ );
+
+ assert_eq!(
+ parse_flake("../deploy/examples/system"),
+ DeployFlake {
+ repo: "../deploy/examples/system",
+ node: None,
+ profile: None,
+ }
+ );
+}
+
pub struct DeployData<'a> {
pub sudo: Option<String>,
pub ssh_user: Cow<'a, str>,
generated by cgit v1.2.3 (git 2.25.1) at 2024-12-23 18:12:49 +0000