Make fragment_size configurable

Author: Dentosal

committer/src/config.rs

@@ -106,6 +106,9 @@ pub struct EigenDaConfig {
     /// URL to an EigenDA RPC endpoint.
     #[serde(deserialize_with = "parse_url")]
     pub rpc: Url,
+    /// Blob fragment size.
+    /// Defaults to 3.5MB, as 4+MB errors out on the server side when checking for inclusion.
+    pub fragment_size: NonZeroU32,
     // Allocated throughput in MiB for the address corresponding to the key
     // pub throughput: f32,
 }

committer/src/setup.rs

@@ -1,4 +1,4 @@
-use std::{num::NonZeroU32, time::Duration};
+use std::time::Duration;
 
 use clock::SystemClock;
 use eigenda::{EigenDAClient, Throughput};
@@ -221,10 +221,12 @@ pub fn eigen_block_bundler(
     config: &config::Config,
     registry: &Registry,
 ) -> tokio::task::JoinHandle<()> {
-    // blob_size: 3.5MB, 4+MB errors out on the server side when checking for inclusion
     let bundler_factory = services::EigenBundlerFactory::new(
         bundle::Encoder::new(config.app.bundle.compression_level),
-        NonZeroU32::new(3_500_000).unwrap(), // TODO pass this via config
+        match &config.da_layer {
+            Some(DALayer::EigenDA(eigen_da)) => eigen_da.fragment_size,
+            other => panic!("Wrong DA layer configuration for Eigen bundler: {other:?}"),
+        },
         config.app.bundle.max_fragments_per_bundle,
     );