feat(protocol): ZLIB Compression (#264)

### Description

Adds zlib compression to the `ChannelOut`.

Closes #267

Cargo.toml

@@ -81,6 +81,7 @@ snap = "1.1.1"
 bincode = "1.3.3"
 ethereum_ssz = "0.8"
 brotli = { version = "7.0.0", default-features = false }
+miniz_oxide = "0.8.0"
 
 # rpc
 jsonrpsee = { version = "0.24", features = [

crates/protocol/Cargo.toml

@@ -25,8 +25,11 @@ alloy-rlp.workspace = true
 alloy-eips.workspace = true
 alloy-consensus.workspace = true
 
-# Misc
+# Compression
 brotli.workspace = true
+miniz_oxide.workspace = true
+
+# Misc
 tracing.workspace = true
 derive_more.workspace = true
 async-trait.workspace = true

crates/protocol/src/channel.rs

@@ -6,6 +6,9 @@ use op_alloy_genesis::RollupConfig;
 
 use crate::{block::BlockInfo, frame::Frame};
 
+/// The best compression.
+const BEST_COMPRESSION: u8 = 9;
+
 /// The frame overhead.
 const FRAME_V0_OVERHEAD: usize = 23;
 
@@ -75,7 +78,13 @@ impl<'a> ChannelOut<'a> {
             return Err(ChannelOutError::ChannelClosed);
         }
 
-        self.compressed = Some(crate::compress_brotli(&buf).into());
+        if self.config.is_fjord_active(batch.timestamp()) {
+            self.compressed = Some(crate::compress_brotli(&buf).into());
+        } else {
+            self.compressed =
+                Some(miniz_oxide::deflate::compress_to_vec(&buf, BEST_COMPRESSION).into());
+        }
+
         Ok(())
     }
 
@@ -84,12 +93,6 @@ impl<'a> ChannelOut<'a> {
         self.compressed.as_ref().map_or(0, |c| c.len())
     }
 
-    /// Accepts the raw compressed batch data into the [ChannelOut].
-    #[deprecated]
-    pub fn add_raw_compressed_batch(&mut self, compressed: Bytes) {
-        self.compressed = Some(compressed);
-    }
-
     /// Closes the channel if not already closed.
     pub fn close(&mut self) {
         self.closed = true;