Cuprate/cuprate
Cuprate/cuprate
1
0
Fork 0
mirror of https://github.com/Cuprate/cuprate.git synced 2025-01-25 20:15:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

get_transaction_pool_backlog

Browse source
This commit is contained in:
hinto.janai 2024-10-14 20:43:24 -04:00
parent 2daf2555bb
commit a10ed59201
No known key found for this signature in database
GPG key ID: D47CE05FA175A499
1 changed files with 13 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
binaries/cuprated/src/rpc/json.rs
View file

@ -41,7 +41,7 @@ use cuprate_rpc_types::{
SetBansRequest, SetBansResponse, SubmitBlockRequest, SubmitBlockResponse, SyncInfoRequest, SetBansRequest, SetBansResponse, SubmitBlockRequest, SubmitBlockResponse, SyncInfoRequest,
SyncInfoResponse, SyncInfoResponse,
}, },
misc::{BlockHeader, ChainInfo, GetBan, HardforkEntry, HistogramEntry, Status}, misc::{BlockHeader, ChainInfo, GetBan, HardforkEntry, HistogramEntry, Status, TxBacklogEntry},
CORE_RPC_VERSION, CORE_RPC_VERSION,
}; };
@ -680,12 +680,22 @@ async fn sync_info(
/// <https://github.com/monero-project/monero/blob/cc73fe71162d564ffda8e549b79a350bca53c454/src/rpc/core_rpc_server.cpp#L3332-L3350> /// <https://github.com/monero-project/monero/blob/cc73fe71162d564ffda8e549b79a350bca53c454/src/rpc/core_rpc_server.cpp#L3332-L3350>
async fn get_transaction_pool_backlog( async fn get_transaction_pool_backlog(
state: CupratedRpcHandler, mut state: CupratedRpcHandler,
request: GetTransactionPoolBacklogRequest, request: GetTransactionPoolBacklogRequest,
) -> Result<GetTransactionPoolBacklogResponse, Error> { ) -> Result<GetTransactionPoolBacklogResponse, Error> {
let backlog = txpool::backlog(&mut state.txpool_read)
.await?
.into_iter()
.map(|entry| TxBacklogEntry {
weight: entry.weight,
fee: entry.fee,
time_in_pool: entry.time_in_pool.as_secs(),
})
.collect();
Ok(GetTransactionPoolBacklogResponse { Ok(GetTransactionPoolBacklogResponse {
base: ResponseBase::OK, base: ResponseBase::OK,
backlog: todo!(), backlog,
}) })
} }