feat: close group views in quotes and payment verification

src/ant_protocol/chunk.rs

@@ -236,6 +236,12 @@ pub enum ChunkQuoteResponse {
         quote: Vec<u8>,
         /// `true` when the chunk already exists on this node (skip payment).
         already_stored: bool,
+        /// Up to `CLOSE_GROUP_SIZE` peer IDs (raw 32-byte BLAKE3 hashes) this
+        /// node considers closest to the content address, **excluding itself**
+        /// (the local node is filtered out by the DHT query). Clients combine
+        /// these views from multiple nodes to verify close-group quorum before
+        /// paying.
+        close_group: Vec<[u8; 32]>,
     },
     /// Quote generation failed.
     Error(ProtocolError),

src/devnet.rs

@@ -588,6 +588,7 @@ impl Devnet {
             evm: evm_config,
             cache_capacity: DEVNET_PAYMENT_CACHE_CAPACITY,
             local_rewards_address: rewards_address,
+            local_peer_id: *identity.peer_id().as_bytes(),
         };
         let payment_verifier = PaymentVerifier::new(payment_config);
         let metrics_tracker =
@@ -602,6 +603,7 @@ impl Devnet {
             Arc::new(storage),
             Arc::new(payment_verifier),
             Arc::new(quote_generator),
+            None,
         ))
     }
 
@@ -643,6 +645,10 @@ impl Devnet {
         *node.state.write().await = NodeState::Running;
 
         if let (Some(ref p2p), Some(ref protocol)) = (&node.p2p_node, &node.ant_protocol) {
+            // Inject P2P node into protocol handler for close-group lookups.
+            if protocol.set_p2p_node(Arc::clone(p2p)).is_err() {
+                warn!("P2P node already set on protocol handler for devnet node {index}");
+            }
             let mut events = p2p.subscribe_events();
             let p2p_clone = Arc::clone(p2p);
             let protocol_clone = Arc::clone(protocol);

src/node.rs

@@ -123,10 +123,14 @@ impl NodeBuilder {
             None
         };
 
+        // Wrap P2P node in Arc early so it can be shared with the protocol handler.
+        let p2p_node = Arc::new(p2p_node);
+
         // Initialize ANT protocol handler for chunk storage
         let ant_protocol = if self.config.storage.enabled {
             Some(Arc::new(
-                Self::build_ant_protocol(&self.config, &identity).await?,
+                Self::build_ant_protocol(&self.config, &identity, Some(Arc::clone(&p2p_node)))
+                    .await?,
             ))
         } else {
             info!("Chunk storage disabled");
@@ -135,7 +139,7 @@ impl NodeBuilder {
 
         let node = RunningNode {
             config: self.config,
-            p2p_node: Arc::new(p2p_node),
+            p2p_node,
             shutdown,
             events_tx,
             events_rx: Some(events_rx),
@@ -330,6 +334,7 @@ impl NodeBuilder {
     async fn build_ant_protocol(
         config: &NodeConfig,
         identity: &NodeIdentity,
+        p2p_node: Option<Arc<P2PNode>>,
     ) -> Result<AntProtocol> {
         // Create LMDB storage
         let storage_config = LmdbStorageConfig {
@@ -363,6 +368,7 @@ impl NodeBuilder {
             },
             cache_capacity: config.payment.cache_capacity,
             local_rewards_address: rewards_address,
+            local_peer_id: *identity.peer_id().as_bytes(),
         };
         let payment_verifier = PaymentVerifier::new(payment_config);
         // Safe: 5GB fits in usize on all supported 64-bit platforms.
@@ -379,6 +385,7 @@ impl NodeBuilder {
             Arc::new(storage),
             Arc::new(payment_verifier),
             Arc::new(quote_generator),
+            p2p_node,
         );
 
         info!(