Add sleep after Argo CD Install (#89)

src/argocd.rs

@@ -1,6 +1,6 @@
 use crate::{
     error::{CommandError, CommandOutput},
-    utils::{run_command, run_command_with_envs, StringPair},
+    utils::{self, run_command, run_command_with_envs, StringPair},
 };
 use base64::prelude::*;
 use log::{debug, error, info};
@@ -140,7 +140,7 @@ impl ArgoCDInstallation {
                     }
                     Err(_) => {
                         counter += 1;
-                        tokio::time::sleep(tokio::time::Duration::from_secs(2)).await;
+                        utils::sleep(2).await;
                         debug!("⏳ Retrying to get secret {}", secret_name);
                         None
                     }
@@ -156,11 +156,9 @@ impl ArgoCDInstallation {
             })?
         };
 
-        // sleep for 5 seconds
-        tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
+        utils::sleep(5).await;
 
         // log into Argo CD
-
         let username = "admin";
         debug!(
             "Logging in to Argo CD with username, {} and password, {}",

src/extract.rs

@@ -1,6 +1,6 @@
 use crate::argocd::ArgoCDInstallation;
 use crate::error::CommandError;
-use crate::utils::{run_command, spawn_command, write_to_file};
+use crate::utils::{self, run_command, spawn_command, write_to_file};
 use crate::{apply_manifest, Branch};
 use log::{debug, error, info};
 use serde_yaml::Value;
@@ -159,7 +159,7 @@ pub async fn get_resources(
         }
 
         if applications.len() == processed_apps.len() {
-            tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
+            utils::sleep(5).await;
             continue;
         }
 
@@ -204,7 +204,7 @@ pub async fn get_resources(
             );
         }
 
-        tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
+        utils::sleep(5).await;
     }
 
     info!(
@@ -237,7 +237,7 @@ pub async fn delete_applications() -> Result<(), Box<dyn Error>> {
         debug!("🗑 Deleting Applications");
 
         let mut child = spawn_command("kubectl delete applications.argoproj.io --all -A", None);
-        tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
+        utils::sleep(5).await;
         if run_command("kubectl get applications -A --no-headers")
             .map(|e| e.stdout.trim().is_empty())
             .unwrap_or_default()
@@ -246,7 +246,7 @@ pub async fn delete_applications() -> Result<(), Box<dyn Error>> {
             break;
         }
 
-        tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
+        utils::sleep(5).await;
         if run_command("kubectl get applications -A --no-headers")
             .map(|e| e.stdout.trim().is_empty())
             .unwrap_or_default()

src/main.rs

@@ -335,6 +335,8 @@ async fn run() -> Result<(), Box<dyn Error>> {
 
     argocd.install_argo_cd(debug).await?;
 
+    utils::sleep(5).await;
+
     let temp_folder = "temp";
     create_folder_if_not_exists(temp_folder)?;
 
@@ -377,7 +379,7 @@ async fn run() -> Result<(), Box<dyn Error>> {
         extract::get_resources(&argocd, &base_branch, timeout, output_folder, temp_folder).await?;
         if found_target_apps {
             extract::delete_applications().await?;
-            tokio::time::sleep(tokio::time::Duration::from_secs(5)).await;
+            utils::sleep(5).await;
         }
     }
     if found_target_apps {

src/parsing.rs

@@ -311,7 +311,10 @@ fn from_resource_to_application(
             filtered_apps.len()
         );
     } else {
-        info!("🤖 Found {} Application[Sets]", number_of_apps_before_filtering);
+        info!(
+            "🤖 Found {} Application[Sets]",
+            number_of_apps_before_filtering
+        );
     }
 
     filtered_apps

src/utils.rs

@@ -104,3 +104,8 @@ pub fn write_to_file(file_name: &str, content: &str) -> Result<(), Box<dyn Error
     fs::write(file_name, content)?;
     Ok(())
 }
+
+pub async fn sleep(seconds: u64) {
+    debug!("Sleeping for {} seconds", seconds);
+    tokio::time::sleep(tokio::time::Duration::from_secs(seconds)).await;
+}