feat(store)!: use zstd compression

Author: PlexSheep

Cargo.toml

@@ -19,6 +19,7 @@ daemonize = "0.5"
 bincode = "1.3.3"
 flagset = { version = "0.4.6", features = ["serde"] }
 thiserror = "2.0.0"
+zstd = "0.13.2"
 
 [[bin]] # client
 name = "netpulse"

src/store.rs

@@ -1,5 +1,5 @@
 use std::fs;
-use std::io::{BufReader, ErrorKind, Write};
+use std::io::{ErrorKind, Write};
 use std::path::PathBuf;
 
 use serde::{Deserialize, Serialize};
@@ -11,6 +11,7 @@ use crate::records::Check;
 pub const DB_NAME: &str = "netpulse.store";
 /// Path to the database of netpulse (combine with [DB_NAME])
 pub const DB_PATH: &str = "/var/lib/netpulse";
+pub const ZSTD_COMPRESSION_LEVEL: i32 = 4;
 
 #[derive(Debug, PartialEq, Eq, Hash, Deserialize, Serialize)]
 pub struct Store {
@@ -33,7 +34,7 @@ impl Store {
                 .expect("the store path has no parent directory"),
         )?;
 
-        let mut file = match fs::File::options()
+        let file = match fs::File::options()
             .read(false)
             .write(true)
             .append(false)
@@ -45,9 +46,10 @@ impl Store {
         };
 
         let store = Store::new();
+        let mut writer = zstd::Encoder::new(file, ZSTD_COMPRESSION_LEVEL)?;
 
-        file.write_all(&bincode::serialize(&store)?)?;
-        file.flush()?;
+        writer.write_all(&bincode::serialize(&store)?)?;
+        writer.flush()?;
         Ok(store)
     }
 
@@ -78,7 +80,7 @@ impl Store {
             },
         };
 
-        let reader = BufReader::new(file);
+        let reader = zstd::Decoder::new(file)?;
 
         Ok(bincode::deserialize_from(reader)?)
     }