chore: additional feature gating

Author: Taxrosdev

src/artifacts.rs

@@ -18,6 +18,7 @@ fn read_artifacts_file(artifacts_file_path: &Path) -> Vec<(String, String)> {
     lines
 }
 
+#[cfg(feature = "decoding")]
 pub fn get_artifact(artifact_name: &String, artifacts_file_path: &Path) -> Option<String> {
     let artifacts = read_artifacts_file(artifacts_file_path);
 
@@ -30,6 +31,7 @@ pub fn get_artifact(artifact_name: &String, artifacts_file_path: &Path) -> Optio
         .map(|artifact| artifact.1.clone())
 }
 
+#[cfg(feature = "encoding")]
 pub fn add_artifact(artifact_name: String, manifest_hash: String, artifacts_file_path: &Path) {
     let mut artifacts: Vec<(String, String)> = read_artifacts_file(&artifacts_file_path)
         .iter()
@@ -43,6 +45,7 @@ pub fn add_artifact(artifact_name: String, manifest_hash: String, artifacts_file
         .expect("Couldn't write artifacts file");
 }
 
+#[cfg(feature = "encoding")]
 fn serialize_artifacts(artifacts: Vec<(String, String)>) -> String {
     let mut string = String::new();
 
@@ -60,6 +63,7 @@ mod tests {
     use super::*;
 
     #[test]
+    #[cfg(all(feature = "encoding", feature = "decoding"))]
     fn simple_all() {
         let artifacts = vec![
             ("test1".to_string(), 1.to_string()),
@@ -86,6 +90,7 @@ mod tests {
     }
 
     #[test]
+    #[cfg(all(feature = "encoding", feature = "decoding"))]
     fn get_artifact_not_found() {
         let artifact_file_path = temp_dir().join("LCAS_test_artifact_not_found.test");
         // Ensure file is empty
@@ -97,6 +102,7 @@ mod tests {
     }
 
     #[test]
+    #[cfg(feature = "encoding")]
     fn add_artifact_overwrites_existing() {
         let artifact_file_path = temp_dir().join("LCAS_test_artifact_overwrite.test");
         add_artifact(
@@ -132,6 +138,7 @@ mod tests {
     }
 
     #[test]
+    #[cfg(feature = "encoding")]
     fn simple_serialize_artifacts() {
         let artifacts = vec![
             ("test1".to_string(), 1.to_string()),

src/compression.rs

@@ -1,8 +1,8 @@
-use std::io;
-
 // Compresses with ZSTD
 #[cfg(feature = "encoding")]
 pub fn compress_file(input: &Vec<u8>, level: i32) -> Vec<u8> {
+    use std::io;
+
     let mut buf = Vec::new();
 
     let mut encoder = zstd::stream::Encoder::new(&mut buf, level).unwrap();

src/hash.rs

@@ -1,11 +1,13 @@
 use xxhash_rust::xxh3::xxh3_64;
 
 // Hashes with xxh3
+#[cfg(any(feature = "decoding", feature = "encoding"))]
 pub fn hash(input: &Vec<u8>) -> String {
     xxh3_64(&input).to_string()
 }
 
 // Converts the manifest to a string, and then hashes it
+#[cfg(feature = "encoding")]
 pub fn hash_manifest(input: &Vec<(String, String, bool)>) -> String {
     // Not a true hash. Just a temporary place to dump data, which can then be hashed
     let mut current_hash = "".to_string();
@@ -25,18 +27,21 @@ mod tests {
     use super::*;
 
     #[test]
+    #[cfg(any(feature = "decoding", feature = "encoding"))]
     fn hash_stable() {
         let result = hash(&vec![1, 2, 3]);
         assert_eq!(result, "16991689376074199867");
     }
 
     #[test]
+    #[cfg(any(feature = "decoding", feature = "encoding"))]
     fn hash_empty_vec() {
         let result = hash(&vec![]);
         assert_eq!(result, "3244421341483603138");
     }
 
     #[test]
+    #[cfg(feature = "encoding")]
     fn hash_manifest_stable() {
         let manifest = vec![
             ("file1.txt".to_string(), "hash1".to_string(), false),
@@ -47,13 +52,15 @@ mod tests {
     }
 
     #[test]
+    #[cfg(feature = "encoding")]
     fn hash_manifest_empty() {
         let manifest: Vec<(String, String, bool)> = vec![];
         let result = hash_manifest(&manifest);
         assert_eq!(result, "3244421341483603138");
     }
 
     #[test]
+    #[cfg(feature = "encoding")]
     fn hash_manifest_single_entry() {
         let manifest = vec![("main.rs".to_string(), "abc123".to_string(), true)];
         let result = hash_manifest(&manifest);

src/lib.rs

@@ -1,10 +1,4 @@
-use std::{
-    fs::{self, create_dir_all, rename},
-    os::unix::fs::{PermissionsExt, symlink},
-    path::Path,
-};
-
-use crate::artifacts::get_artifact;
+use std::{fs, path::Path};
 
 mod artifacts;
 mod compression;
@@ -30,6 +24,7 @@ pub fn create_repo(repo_dir: &Path) -> Result<(), String> {
     Ok(())
 }
 
+#[cfg(feature = "decoding")]
 pub fn create_store(store_path: &Path) -> Result<(), String> {
     if store_path.exists() {
         return Err("Store already exists! Make sure the directory doesn't exist, or you're operating on the correct directory.".to_string());
@@ -103,6 +98,10 @@ pub fn build(input_dir: &Path, repo_dir: &Path, artifact_name: &String) -> Resul
 
 #[cfg(feature = "decoding")]
 pub fn install_artifact(artifact_name: &String, store_path: &Path, repo_cache_path: &Path) {
+    use crate::artifacts::get_artifact;
+    use std::fs::{create_dir_all, rename};
+    use std::os::unix::fs::symlink;
+
     assert!(store_path.is_absolute(), "Store path must be absolute!");
     assert!(
         repo_cache_path.is_absolute(),
@@ -163,6 +162,7 @@ pub fn install_artifact(artifact_name: &String, store_path: &Path, repo_cache_pa
     rename(&tmp_symlink, &final_symlink).unwrap();
 }
 
+#[cfg(feature = "decoding")]
 fn get_temp_file(potential: Option<u8>, dir: &Path) -> String {
     let potential = potential.unwrap_or_default();
 
@@ -175,7 +175,10 @@ fn get_temp_file(potential: Option<u8>, dir: &Path) -> String {
     };
 }
 
+#[cfg(feature = "decoding")]
 fn make_chunk_executable(chunk_hash: &String, store_path: &Path) {
+    use std::os::unix::fs::PermissionsExt;
+
     let chunk_path = store_path.join("chunks").join(chunk_hash);
 
     // Read initial permissions first