comtrya · martintc · Dec 4, 2023 · Nov 5, 2023
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/lib/Cargo.toml b/lib/Cargo.toml
@@ -38,6 +38,8 @@ trust-dns-resolver = "0.23.2"
 walkdir = "2.3"
 which = "5.0"
 whoami = "1.4"
+tar = "0.4.40"
+flate2 = "1.0.28"
 
 [target.'cfg(unix)'.dependencies]
 uzers = "0.11"

diff --git a/lib/src/atoms/file/mod.rs b/lib/src/atoms/file/mod.rs
@@ -6,6 +6,7 @@ mod create;
 mod decrypt;
 mod link;
 mod remove;
+mod unarchive;
 
 use super::Atom;
 pub use chmod::Chmod;
@@ -16,6 +17,7 @@ pub use create::Create;
 pub use decrypt::Decrypt;
 pub use link::Link;
 pub use remove::Remove;
+pub use unarchive::Unarchive;
 
 pub trait FileAtom: Atom {
     // Don't think this is needed? Validate soon

diff --git a/lib/src/atoms/file/unarchive.rs b/lib/src/atoms/file/unarchive.rs
@@ -0,0 +1,65 @@
+use std::{fs::File, path::PathBuf};
+
+use flate2::read::GzDecoder;
+use tar::Archive;
+
+use crate::atoms::{Atom, Outcome};
+
+use super::FileAtom;
+
+pub struct Unarchive {
+    pub origin: PathBuf,
+    pub dest: PathBuf,
+    pub force: bool,
+}
+
+impl FileAtom for Unarchive {
+    fn get_path(&self) -> &PathBuf {
+        &self.origin
+    }
+}
+
+impl Atom for Unarchive {
+    // Determine if this atom needs to run
+    fn plan(&self) -> anyhow::Result<Outcome> {
+        if self.dest.exists() {
+            if self.force {
+                return Ok(Outcome {
+                    side_effects: vec![],
+                    should_run: self.origin.exists(),
+                });
+            }
+            return Ok(Outcome {
+                side_effects: vec![],
+                should_run: false,
+            });
+        }
+
+        return Ok(Outcome {
+            side_effects: vec![],
+            should_run: self.origin.exists(),
+        });
+    }
+
+    // Apply new to old
+    fn execute(&mut self) -> anyhow::Result<()> {
+        let tar_gz = File::open(&self.origin)?;
+        let tar = GzDecoder::new(tar_gz);
+        let mut archive = Archive::new(tar);
+        archive.unpack(&self.dest)?;
+        Ok(())
+    }
+}
+
+impl std::fmt::Display for Unarchive {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        let origin_path = self.origin.display().to_string();
+        let dest_path = self.dest.display().to_string();
+
+        write!(
+            f,
+            "The archive {} to be decompressed to {}",
+            origin_path, dest_path
+        )
+    }
+}