Added minikube support

Author: dag-andersen

src/argocd.rs

@@ -9,6 +9,20 @@ use log::{debug, error, info};
 
 use crate::run_command;
 
+static ARGOCD_CMD_PARAMS_CM: &str = r#"
+apiVersion: v1
+kind: ConfigMap
+metadata:
+  labels:
+    app.kubernetes.io/name: argocd-cmd-params-cm
+    app.kubernetes.io/part-of: argocd
+  name: argocd-cmd-params-cm
+  namespace: argocd
+data:
+  reposerver.git.request.timeout: "150s"
+  reposerver.parallelism.limit: "300"
+"#;
+
 pub async fn install_argo_cd() -> Result<(), Box<dyn Error>> {
     info!("🦑 Installing Argo CD...");
 
@@ -30,19 +44,6 @@ pub async fn install_argo_cd() -> Result<(), Box<dyn Error>> {
     }
     info!("🦑 Waiting for Argo CD to start...");
 
-    static ARGOCD_CMD_PARAMS_CM: &str = r#"
-apiVersion: v1
-kind: ConfigMap
-metadata:
-  labels:
-    app.kubernetes.io/name: argocd-cmd-params-cm
-    app.kubernetes.io/part-of: argocd
-  name: argocd-cmd-params-cm
-  namespace: argocd
-data:
-  reposerver.git.request.timeout: "150s"
-  reposerver.parallelism.limit: "300"
-"#;
     // apply argocd-cmd-params-cm
     let mut child = Command::new("kubectl")
         .arg("apply")

src/kind.rs

@@ -1,8 +1,15 @@
 use log::{error, info};
-use std::{error::Error, process::Command};
+use std::error::Error;
 
 use crate::{run_command, utils::spawn_command};
 
+pub async fn is_installed() -> bool {
+    match run_command("kind version", None).await {
+        Ok(_) => true,
+        Err(_) => false,
+    }
+}
+
 pub async fn create_cluster(cluster_name: &str) -> Result<(), Box<dyn Error>> {
     // check if docker is running
     match run_command("docker ps", None).await {
@@ -14,16 +21,15 @@ pub async fn create_cluster(cluster_name: &str) -> Result<(), Box<dyn Error>> {
     }
 
     info!("🚀 Creating cluster...");
-    match Command::new("kind")
-        .arg("delete")
-        .arg("cluster")
-        .arg("--name")
-        .arg(cluster_name)
-        .output()
+    match run_command(
+        &format!("kind delete cluster --name {}", cluster_name),
+        None,
+    )
+    .await
     {
         Ok(o) => o,
         Err(e) => {
-            panic!("error: {}", e)
+            panic!("error: {}", String::from_utf8_lossy(&e.stderr))
         }
     };
 

src/main.rs

@@ -69,20 +69,23 @@ struct Opt {
     /// Secrets folder where the secrets are read from
     #[structopt(short, long, default_value = "./secrets", env)]
     secrets_folder: String,
+
+    /// Local cluster tool. Options: kind, minikube, auto. Default: Auto
+    #[structopt(long, env)]
+    local_cluster_tool: Option<String>,
+}
+
+#[derive(Debug)]
+enum ClusterTool {
+    Kind,
+    Minikube,
 }
 
 enum Branch {
     Base,
     Target,
 }
 
-fn apps_file(branch: &Branch) -> &'static str {
-    match branch {
-        Branch::Base => "apps_base_branch.yaml",
-        Branch::Target => "apps_target_branch.yaml",
-    }
-}
-
 impl std::fmt::Display for Branch {
     fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
         match self {
@@ -92,6 +95,13 @@ impl std::fmt::Display for Branch {
     }
 }
 
+fn apps_file(branch: &Branch) -> &'static str {
+    match branch {
+        Branch::Base => "apps_base_branch.yaml",
+        Branch::Target => "apps_target_branch.yaml",
+    }
+}
+
 static ERROR_MESSAGES: [&str; 6] = [
     "helm template .",
     "authentication required",
@@ -135,7 +145,20 @@ async fn main() -> Result<(), Box<dyn Error>> {
     let output_folder = opt.output_folder.as_str();
     let secrets_folder = opt.secrets_folder.as_str();
 
+    // select local cluster tool
+    let tool = match opt.local_cluster_tool {
+        Some(t) if t == "kind" => ClusterTool::Kind,
+        Some(t) if t == "minikube" => ClusterTool::Minikube,
+        _ if kind::is_installed().await => ClusterTool::Kind,
+        _ if minikube::is_installed().await => ClusterTool::Minikube,
+        _ => {
+            error!("❌ No local cluster tool found. Please install kind or minikube");
+            panic!("No local cluster tool found")
+        }
+    };
+
     info!("✨ Running with:");
+    info!("✨ - local-cluster-tool: {:?}", tool);
     info!("✨ - base-branch: {}", base_branch_name);
     info!("✨ - target-branch: {}", target_branch_name);
     info!("✨ - base-branch-folder: {}", base_branch_folder);
@@ -163,7 +186,10 @@ async fn main() -> Result<(), Box<dyn Error>> {
 
     let cluster_name = "argocd-diff-preview";
 
-    kind::create_cluster(&cluster_name).await?;
+    match tool {
+        ClusterTool::Kind => kind::create_cluster(&cluster_name).await?,
+        ClusterTool::Minikube => minikube::create_cluster().await?,
+    }
     argocd::install_argo_cd().await?;
 
     create_folder_if_not_exists(secrets_folder);
@@ -190,7 +216,10 @@ async fn main() -> Result<(), Box<dyn Error>> {
     tokio::time::sleep(tokio::time::Duration::from_secs(10)).await;
     get_resources(&Branch::Target, timeout, output_folder).await?;
 
-    kind::delete_cluster(&cluster_name);
+    match tool {
+        ClusterTool::Kind => kind::delete_cluster(&cluster_name),
+        ClusterTool::Minikube => minikube::delete_cluster(),
+    }
 
     diff::generate_diff(
         output_folder,

src/minikube.rs

@@ -0,0 +1,46 @@
+use log::{error, info};
+use std::error::Error;
+
+use crate::{run_command, utils::spawn_command};
+
+pub async fn is_installed() -> bool {
+    match run_command("minikube status", None).await {
+        Ok(_) => true,
+        Err(_) => false,
+    }
+}
+
+pub async fn create_cluster() -> Result<(), Box<dyn Error>> {
+    // check if docker is running
+    match run_command("docker ps", None).await {
+        Ok(_) => (),
+        Err(e) => {
+            error!("❌ Docker is not running");
+            panic!("error: {}", String::from_utf8_lossy(&e.stderr))
+        }
+    }
+
+    info!("🚀 Creating cluster...");
+    match run_command(&format!("minikube delete"), None).await {
+        Ok(o) => o,
+        Err(e) => {
+            panic!("error: {}", String::from_utf8_lossy(&e.stderr))
+        }
+    };
+
+    match run_command(&format!("minikube start"), None).await {
+        Ok(_) => {
+            info!("🚀 Cluster created successfully");
+            Ok(())
+        }
+        Err(e) => {
+            error!("❌ Failed to Create cluster");
+            panic!("error: {}", String::from_utf8_lossy(&e.stderr))
+        }
+    }
+}
+
+pub fn delete_cluster() {
+    info!("💥 Deleting cluster...");
+    spawn_command(&format!("minikube delete"), None);
+}