Implement mempool endpoint

radixdlt · Nov 11, 2024 · 338e6ce · 338e6ce
1 parent 4b4086c
commit 338e6ce
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/core-rust/mesh-api-server/src/mesh_api/handlers/mempool.rs b/core-rust/mesh-api-server/src/mesh_api/handlers/mempool.rs
@@ -6,8 +6,17 @@ pub(crate) async fn handle_mempool(
 ) -> Result<Json<models::MempoolResponse>, ResponseError> {
     assert_matching_network(&request.network_identifier, &state.network)?;
 
-    // let database = state.state_manager.database.snapshot();
-    // let mapping_context = MappingContext::new(&state.network);
+    let mapping_context = MappingContext::new(&state.network);
+    let mempool = state.state_manager.mempool.read();
 
-    Ok(Json(models::MempoolResponse::new(vec![])))
+    Ok(Json(models::MempoolResponse::new(
+        mempool
+            .all_hashes_iter()
+            .map(|(intent_hash, _)| {
+                Ok(models::TransactionIdentifier {
+                    hash: to_api_transaction_hash_bech32m(&mapping_context, intent_hash)?,
+                })
+            })
+            .collect::<Result<Vec<_>, MappingError>>()?,
+    )))
 }