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

relay_tx

Browse source
This commit is contained in:
hinto.janai 2024-10-14 20:31:33 -04:00
parent 294df3f163
commit 08b5ff2f05
No known key found for this signature in database
GPG key ID: D47CE05FA175A499
2 changed files with 24 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -499,7 +499,7 @@ async fn banned(
/// <https://github.com/monero-project/monero/blob/cc73fe71162d564ffda8e549b79a350bca53c454/src/rpc/core_rpc_server.cpp#L2880-L2932>
async fn flush_transaction_pool(
state: CupratedRpcHandler,
mut state: CupratedRpcHandler,
request: FlushTransactionPoolRequest,
) -> Result<FlushTransactionPoolResponse, Error> {
let tx_hashes = request
@ -508,7 +508,7 @@ async fn flush_transaction_pool(
.map(helper::hex_to_hash)
.collect::<Result<Vec<[u8; 32]>, _>>()?;
txpool::flush(tx_hashes).await?;
txpool::flush(&mut state.txpool_manager, tx_hashes).await?;
Ok(FlushTransactionPoolResponse { status: Status::Ok })
}
@ -648,10 +648,17 @@ async fn get_alternate_chains(
/// <https://github.com/monero-project/monero/blob/cc73fe71162d564ffda8e549b79a350bca53c454/src/rpc/core_rpc_server.cpp#L3254-L3304>
async fn relay_tx(
state: CupratedRpcHandler,
mut state: CupratedRpcHandler,
request: RelayTxRequest,
) -> Result<RelayTxResponse, Error> {
todo!();
let tx_hashes = request
.txids
.into_iter()
.map(helper::hex_to_hash)
.collect::<Result<Vec<[u8; 32]>, _>>()?;
txpool::relay(&mut state.txpool_manager, tx_hashes).await?;
Ok(RelayTxResponse { status: Status::Ok })
}

14
binaries/cuprated/src/rpc/request/txpool.rs
View file

@ -49,7 +49,19 @@ pub(crate) async fn size(txpool_read: &mut TxpoolReadHandle) -> Result<u64, Erro
}
/// TODO
pub(crate) async fn flush(tx_hashes: Vec<[u8; 32]>) -> Result<(), Error> {
pub(crate) async fn flush(
txpool_manager: &mut Infallible,
tx_hashes: Vec<[u8; 32]>,
) -> Result<(), Error> {
todo!();
Ok(())
}
/// TODO
pub(crate) async fn relay(
txpool_manager: &mut Infallible,
tx_hashes: Vec<[u8; 32]>,
) -> Result<(), Error> {
todo!();
Ok(())
}