Add data availability service to node

nodes/nomos-node/Cargo.toml

@@ -25,6 +25,7 @@ nomos-mempool = { path = "../../nomos-services/mempool", features = ["mock"] }
 nomos-http = { path = "../../nomos-services/http", features = ["http"] }
 nomos-consensus = { path = "../../nomos-services/consensus" }
 nomos-libp2p = { path = "../../nomos-libp2p", optional = true }
+nomos-da = { path = "../../nomos-services/data-availability" }
 metrics = { path = "../../nomos-services/metrics", optional = true }
 tracing-subscriber = "0.3"
 consensus-engine = { path = "../../consensus-engine" }
@@ -34,7 +35,7 @@ serde_yaml = "0.9"
 color-eyre = "0.6.0"
 serde = "1"
 waku-bindings = { version = "0.1.1", optional = true }
-
+full-replication = { path = "../../nomos-da/full-replication" }
 
 [features]
 default = ["libp2p"]

nodes/nomos-node/src/config.rs

@@ -5,6 +5,8 @@ use std::{
 };
 
 use crate::Carnot;
+#[cfg(feature = "libp2p")]
+use crate::DataAvailability;
 use clap::{Parser, ValueEnum};
 use color_eyre::eyre::{self, eyre, Result};
 use hex::FromHex;
@@ -129,6 +131,8 @@ pub struct Config {
     pub consensus: <Carnot as ServiceData>::Settings,
     #[cfg(feature = "metrics")]
     pub metrics: <MetricsService<MapMetricsBackend<MetricsData>> as ServiceData>::Settings,
+    #[cfg(feature = "libp2p")]
+    pub da: <DataAvailability as ServiceData>::Settings,
 }
 
 impl Config {

nodes/nomos-node/src/lib.rs

@@ -1,16 +1,22 @@
-mod blob;
 mod config;
 mod tx;
 
 use color_eyre::eyre::Result;
 use consensus_engine::overlay::{FlatOverlay, RandomBeaconState, RoundRobin};
+#[cfg(feature = "libp2p")]
+use full_replication::{AbsoluteNumber, Attestation, Blob, Certificate, FullReplication};
 #[cfg(feature = "metrics")]
 use metrics::{backend::map::MapMetricsBackend, types::MetricsData, MetricsService};
 #[cfg(feature = "libp2p")]
 use nomos_consensus::network::adapters::libp2p::Libp2pAdapter as ConsensusLibp2pAdapter;
 #[cfg(feature = "waku")]
 use nomos_consensus::network::adapters::waku::WakuAdapter as ConsensusWakuAdapter;
 use nomos_consensus::CarnotConsensus;
+#[cfg(feature = "libp2p")]
+use nomos_da::{
+    backend::memory_cache::BlobCache, network::adapters::libp2p::Libp2pAdapter as DaLibp2pAdapter,
+    DataAvailabilityService,
+};
 use nomos_http::backends::axum::AxumBackend;
 use nomos_http::bridge::HttpBridgeService;
 use nomos_http::http::HttpService;
@@ -28,7 +34,6 @@ use nomos_network::NetworkService;
 use overwatch_derive::*;
 use overwatch_rs::services::handle::ServiceHandle;
 
-use crate::blob::Blob;
 pub use config::{Config, ConsensusArgs, HttpArgs, LogArgs, NetworkArgs, OverlayArgs};
 pub use tx::Tx;
 
@@ -53,6 +58,12 @@ pub type Carnot = CarnotConsensus<
     Blob,
 >;
 
+type DataAvailability = DataAvailabilityService<
+    FullReplication<AbsoluteNumber<Attestation, Certificate>>,
+    BlobCache<<Blob as nomos_core::da::blob::Blob>::Hash, Blob>,
+    DaLibp2pAdapter<Blob, Attestation>,
+>;
+
 #[derive(Services)]
 pub struct Nomos {
     logging: ServiceHandle<Logger>,
@@ -69,4 +80,6 @@ pub struct Nomos {
     bridges: ServiceHandle<HttpBridgeService>,
     #[cfg(feature = "metrics")]
     metrics: ServiceHandle<MetricsService<MapMetricsBackend<MetricsData>>>,
+    #[cfg(feature = "libp2p")]
+    da: ServiceHandle<DataAvailability>,
 }

nodes/nomos-node/src/main.rs

@@ -83,6 +83,8 @@ fn main() -> Result<()> {
             bridges: HttpBridgeSettings { bridges },
             #[cfg(feature = "metrics")]
             metrics: config.metrics,
+            #[cfg(feature = "libp2p")]
+            da: config.da,
         },
         None,
     )