feat: State compression

pueue/tests/daemon/integration/restore.rs

@@ -1,12 +1,21 @@
 use pueue_lib::{network::message::TaskSelection, state::GroupStatus};
+use rstest::rstest;
 
 use crate::{helper::*, internal_prelude::*};
 
 /// The daemon should start in the same state as before shutdown, if no tasks are queued.
 /// This function tests for the running state.
+#[rstest]
+#[case(true)]
+#[case(false)]
 #[tokio::test]
-async fn test_start_running() -> Result<()> {
-    let (settings, _tempdir) = daemon_base_setup()?;
+async fn test_start_running(#[case] compress: bool) -> Result<()> {
+    let (mut settings, tempdir) = daemon_base_setup()?;
+    settings.daemon.compress_status_file = compress;
+    settings
+        .save(&Some(tempdir.path().join("pueue.yml")))
+        .context("Couldn't write pueue config to temporary directory")?;
+
     let mut child = standalone_daemon(&settings.shared).await?;
     let shared = &settings.shared;
 
@@ -31,9 +40,17 @@ async fn test_start_running() -> Result<()> {
 
 /// The daemon should start in the same state as before shutdown, if no tasks are queued.
 /// This function tests for the paused state.
+#[rstest]
+#[case(true)]
+#[case(false)]
 #[tokio::test]
-async fn test_start_paused() -> Result<()> {
-    let (settings, _tempdir) = daemon_base_setup()?;
+async fn test_start_paused(#[case] compress: bool) -> Result<()> {
+    let (mut settings, tempdir) = daemon_base_setup()?;
+    settings.daemon.compress_status_file = compress;
+    settings
+        .save(&Some(tempdir.path().join("pueue.yml")))
+        .context("Couldn't write pueue config to temporary directory")?;
+
     let mut child = standalone_daemon(&settings.shared).await?;
     let shared = &settings.shared;
 

pueue/tests/daemon/state_backward_compatibility.rs

@@ -4,7 +4,7 @@ use pueue::daemon::internal_state::state::InternalState;
 use pueue_lib::settings::Settings;
 use tempfile::TempDir;
 
-use crate::internal_prelude::*;
+use crate::{helper::enable_logger, internal_prelude::*};
 
 /// 4.0.0 introduced numerous breaking changes.
 /// From here on, we now aim to once again have full backward compatibility.
@@ -17,19 +17,21 @@ use crate::internal_prelude::*;
 /// This should be handled as well.
 #[test]
 fn test_restore_from_old_state() -> Result<()> {
+    enable_logger();
     better_panic::install();
     let old_state = include_str!("data/v4.0.0_state.json");
 
     let temp_dir = TempDir::new()?;
-    let temp_path = temp_dir.path();
+    let temp_path = temp_dir.path().to_path_buf();
 
     // Open new file and write old state to it.
-    let temp_state_path = temp_dir.path().join("state.json");
+    let temp_state_path = temp_path.join("state.json");
     let mut file = File::create(temp_state_path)?;
     file.write_all(old_state.as_bytes())?;
 
     let mut settings = Settings::default();
-    settings.shared.pueue_directory = Some(temp_path.to_path_buf());
+    settings.shared.pueue_directory = Some(temp_path);
+    debug!("{settings:#?}");
 
     let state =
         InternalState::restore_state(&settings).context("Failed to restore state in test")?;

pueue/tests/tests.rs

@@ -4,6 +4,7 @@ mod internal_prelude {
         eyre::{bail, eyre, WrapErr},
         Result,
     };
+    pub use tracing::debug;
 }
 
 #[cfg(unix)]

pueue_lib/src/settings.rs

@@ -218,7 +218,7 @@ impl Default for Daemon {
             pause_all_on_failure: false,
             callback: None,
             callback_log_lines: default_callback_log_lines(),
-            compress_status_file: true,
+            compress_status_file: false,
             shell_command: None,
             env_vars: HashMap::new(),
         }

pueue_lib/tests/settings_backward_compatibility.rs

@@ -14,7 +14,7 @@ use pueue_lib::settings::Settings;
 /// On top of simply having old settings, I also removed a few default fields.
 /// This should be handled as well.
 #[test]
-fn test_restore_from_old_state() -> Result<()> {
+fn test_restore_from_old_settings() -> Result<()> {
     better_panic::install();
     let old_settings_path = PathBuf::from(env!("CARGO_MANIFEST_DIR"))
         .join("tests")