fix(p2p): cache responses to serve without roundtrip to db

CHANGELOG.md

@@ -41,6 +41,10 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 - [2310](https://github.com/FuelLabs/fuel-core/pull/2310): The `metrics` command-line parameter has been replaced with `disable-metrics`. Metrics are now enabled by default, with the option to disable them entirely or on a per-module basis.
 - [2341](https://github.com/FuelLabs/fuel-core/pull/2341): The maximum number of processed coins from the `coins_to_spend` query is limited to `max_inputs`.
 
+### Fixed
+
+- [2352](https://github.com/FuelLabs/fuel-core/pull/2352): Cache p2p responses to serve without roundtrip to db.
+
 ## [Version 0.39.0]
 
 ### Added

crates/metrics/src/p2p_metrics.rs

@@ -8,16 +8,22 @@ use std::sync::OnceLock;
 pub struct P2PMetrics {
     pub unique_peers: Counter,
     pub blocks_requested: Gauge,
+    pub p2p_req_res_cache_hits: Counter,
+    pub p2p_req_res_cache_misses: Counter,
 }
 
 impl P2PMetrics {
     fn new() -> Self {
         let unique_peers = Counter::default();
         let blocks_requested = Gauge::default();
+        let p2p_req_res_cache_hits = Counter::default();
+        let p2p_req_res_cache_misses = Counter::default();
 
         let metrics = P2PMetrics {
             unique_peers,
             blocks_requested,
+            p2p_req_res_cache_hits,
+            p2p_req_res_cache_misses,
         };
 
         let mut registry = global_registry().registry.lock();
@@ -33,6 +39,18 @@ impl P2PMetrics {
             metrics.blocks_requested.clone()
         );
 
+        registry.register(
+            "P2p_Req_Res_Cache_Hits",
+            "A Counter which keeps track of the number of cache hits for the p2p req/res protocol",
+            metrics.p2p_req_res_cache_hits.clone()
+        );
+
+        registry.register(
+            "P2p_Req_Res_Cache_Misses",
+            "A Counter which keeps track of the number of cache misses for the p2p req/res protocol",
+            metrics.p2p_req_res_cache_misses.clone()
+        );
+
         metrics
     }
 }
@@ -50,3 +68,11 @@ pub fn increment_unique_peers() {
 pub fn set_blocks_requested(count: usize) {
     p2p_metrics().blocks_requested.set(count as i64);
 }
+
+pub fn increment_p2p_req_res_cache_hits() {
+    p2p_metrics().p2p_req_res_cache_hits.inc();
+}
+
+pub fn increment_p2p_req_res_cache_misses() {
+    p2p_metrics().p2p_req_res_cache_misses.inc();
+}

crates/services/p2p/Cargo.toml

@@ -13,6 +13,7 @@ description = "Fuel client networking"
 [dependencies]
 anyhow = { workspace = true }
 async-trait = { workspace = true }
+dashmap = "6.1.0"
 fuel-core-chain-config = { workspace = true }
 fuel-core-metrics = { workspace = true } # TODO make this a feature
 fuel-core-services = { workspace = true, features = ["sync-processor"] }