move compression to types

Author: tac0turtle

Cargo.lock

@@ -20,8 +20,6 @@ thiserror = "1.0"
 tracing = "0.1"
 futures = "0.3"
 async-trait = "0.1"
-zstd = "0.13"
-bytes = "1.5"
 
 [dev-dependencies]
 tokio-test = "0.4"

client/crates/client/Cargo.toml

@@ -11,18 +11,18 @@
 //! async fn main() -> Result<(), Box<dyn std::error::Error>> {
 //!     // Connect to a Evolve node
 //!     let client = Client::connect("http://localhost:50051").await?;
-//!     
+//!
 //!     // Check health
 //!     let health = HealthClient::new(&client);
 //!     let is_healthy = health.is_healthy().await?;
 //!     println!("Node healthy: {}", is_healthy);
-//!     
+//!
 //!     // Get namespace configuration
 //!     let config = ConfigClient::new(&client);
 //!     let namespace = config.get_namespace().await?;
 //!     println!("Header namespace: {}", namespace.header_namespace);
 //!     println!("Data namespace: {}", namespace.data_namespace);
-//!     
+//!
 //!     Ok(())
 //! }
 //! ```
@@ -42,7 +42,7 @@
 //!         .connect_timeout(Duration::from_secs(10))
 //!         .build()
 //!         .await?;
-//!     
+//!
 //!     Ok(())
 //! }
 //! ```
@@ -61,23 +61,22 @@
 //!         .tls()  // Enable TLS with default configuration
 //!         .build()
 //!         .await?;
-//!     
+//!
 //!     // Or with custom TLS configuration
 //!     let tls_config = ClientTlsConfig::new()
 //!         .domain_name("secure-node.ev.xyz");
-//!     
+//!
 //!     let client = Client::builder()
 //!         .endpoint("https://secure-node.ev.xyz")
 //!         .tls_config(tls_config)
 //!         .build()
 //!         .await?;
-//!     
+//!
 //!     Ok(())
 //! }
 //! ```
 
 pub mod client;
-pub mod compression;
 pub mod config;
 pub mod error;
 pub mod health;
@@ -87,9 +86,6 @@ pub mod store;
 
 // Re-export main types for convenience
 pub use client::{Client, ClientBuilder};
-pub use compression::{
-    compress_blob, decompress_blob, get_compression_info, BlobCompressor, CompressionInfo,
-};
 pub use config::ConfigClient;
 pub use error::{ClientError, Result};
 pub use health::HealthClient;

client/crates/client/src/lib.rs

@@ -25,3 +25,6 @@ walkdir = { workspace = true }
 prost = { workspace = true }
 prost-types = { workspace = true }
 tonic = { workspace = true, optional = true, features = ["transport"] }
+bytes = "1.5"
+thiserror = "1.0"
+zstd = "0.13"

client/crates/types/Cargo.toml

@@ -369,4 +369,4 @@ mod tests {
         assert!(info.compression_ratio < 1.0);
         assert!(info.compression_ratio > 0.0);
     }
-}
+}

client/crates/client/src/compression.rs renamed to client/crates/types/src/compression.rs

@@ -1,3 +1,5 @@
+pub mod compression;
+
 pub mod v1 {
     // Always include the pure message types (no tonic dependencies)
     #[cfg(not(feature = "grpc"))]
@@ -7,3 +9,9 @@ pub mod v1 {
     #[cfg(feature = "grpc")]
     include!("proto/evnode.v1.services.rs");
 }
+
+// Re-export compression types for convenience
+pub use compression::{
+    compress_blob, decompress_blob, get_compression_info, BlobCompressor, CompressionError,
+    CompressionInfo,
+};

client/crates/types/src/lib.rs

@@ -1,8 +1,8 @@
 //! Comprehensive tests for blob compression/decompression
 //! These tests match the behavior of the Go implementation
 
-use ev_client::compression::*;
-use ev_client::{compress_blob, decompress_blob, get_compression_info};
+use ev_types::compression::*;
+use ev_types::{compress_blob, decompress_blob, get_compression_info};
 
 #[test]
 fn test_zstd_compression() {
@@ -227,4 +227,4 @@ fn test_compression_with_different_levels() {
     for (level, size) in sizes {
         println!("  Level {level}: {size} bytes");
     }
-}
+}