Create basic structure of mempool network adapter for da sampling (#683)

* Create basic structure of mempool network adapter for da sampling

* Return blob instead from sample method

* fmt

nomos-da/network/core/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "nomos-da-core"
+name = "nomos-da-network-core"
 version = "0.1.0"
 edition = "2021"
 

nomos-da/network/core/src/lib.rs

@@ -2,3 +2,5 @@ pub mod dispersal;
 pub mod protocol;
 pub mod replication;
 pub mod sampling;
+
+pub type SubnetworkId = u32;

nomos-da/network/core/src/replication/behaviour.rs

@@ -12,12 +12,12 @@ use tracing::error;
 
 use subnetworks_assignations::MembershipHandler;
 
+use crate::SubnetworkId;
+
 use super::handler::{
     BehaviourEventToHandler, DaMessage, HandlerEventToBehaviour, ReplicationHandler,
 };
 
-pub type SubnetworkId = u32;
-
 type SwarmEvent = ToSwarm<ReplicationEvent, BehaviourEventToHandler>;
 
 /// Nomos DA BroadcastEvents to be bubble up to logic layers

nomos-services/mempool/Cargo.toml

@@ -12,6 +12,7 @@ futures = "0.3"
 linked-hash-map = { version = "0.5.6", optional = true }
 nomos-metrics = { path = "../../nomos-services/metrics" }
 nomos-network = { path = "../network" }
+nomos-da-network-core = { path = "../../nomos-da/network/core" }
 nomos-core = { path = "../../nomos-core" }
 full-replication = { path = "../../nomos-da/full-replication" }
 kzgrs-backend = { path = "../../nomos-da/kzgrs-backend" }

nomos-services/mempool/src/da/mod.rs

@@ -1,2 +1,3 @@
+mod network;
 pub mod service;
 pub mod verify;

nomos-services/mempool/src/da/network/adapters/libp2p.rs

@@ -0,0 +1 @@
+

nomos-services/mempool/src/da/network/adapters/mod.rs

@@ -0,0 +1 @@
+mod libp2p;

nomos-services/mempool/src/da/network/mod.rs

@@ -0,0 +1,29 @@
+use std::marker::PhantomData;
+
+use kzgrs_backend::common::blob::DaBlob;
+// crates
+use nomos_da_network_core::SubnetworkId;
+
+// internal
+pub mod adapters;
+// std
+
+// TODO: remove after using it in the service
+#[allow(dead_code)]
+#[async_trait::async_trait]
+pub trait DaNetworkAdapter {
+    // TODO: bound to proper da-backend trait
+    type Backend;
+    type Settings: Clone;
+    type Payload: Send + Sync + 'static;
+    type Key: Send + Sync + 'static;
+
+    async fn new(
+        settings: Self::Settings,
+        // TODO: hook da-network service instead of network service
+        // network_relay: OutboundRelay<<NetworkService<Self::Backend> as ServiceData>::Message>,
+        network_relay: PhantomData<()>,
+    ) -> Self;
+
+    async fn sample(&self, blob_id: &[u8], subnetwork_id: SubnetworkId) -> Option<DaBlob>;
+}