pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-04-23 02:37:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Stabilize transactionBroadcast methods (#1540)

Browse Source 
Signed-off-by: Alexandru Vasile <alexandru.vasile@parity.io>
Co-authored-by: Niklas Adolfsson <niklasadolfsson1@gmail.com>
This commit is contained in:
Alexandru Vasile
2024-04-20 14:58:58 +03:00
committed by GitHub
parent 240080a67e
commit c57df0845c
2 changed files with 13 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
testing/integration-tests/src/full_client/client/unstable_rpcs.rs
+7 -10
View File
@@ -318,7 +318,7 @@ async fn next_operation_event<
}
#[tokio::test]
async fn transaction_unstable_broadcast() {
async fn transaction_v1_broadcast() {
let bob = dev::bob();
let bob_address: MultiAddress<AccountId32, u32> = bob.public_key().into();
@@ -346,7 +346,7 @@ async fn transaction_unstable_broadcast() {
// Submit the transaction.
let _operation_id = rpc
.transaction_unstable_broadcast(&tx_bytes)
.transaction_v1_broadcast(&tx_bytes)
.await
.unwrap()
.expect("Server is not overloaded by 1 tx; qed");
@@ -383,7 +383,7 @@ async fn transaction_unstable_broadcast() {
}
#[tokio::test]
async fn transaction_unstable_stop() {
async fn transaction_v1_stop() {
let bob = dev::bob();
let bob_address: MultiAddress<AccountId32, u32> = bob.public_key().into();
@@ -392,7 +392,7 @@ async fn transaction_unstable_stop() {
// Cannot stop an operation that was not started.
let _err = rpc
.transaction_unstable_stop("non-existent-operation-id")
.transaction_v1_stop("non-existent-operation-id")
.await
.unwrap_err();
@@ -409,15 +409,12 @@ async fn transaction_unstable_stop() {
// Submit the transaction.
let operation_id = rpc
.transaction_unstable_broadcast(&tx_bytes)
.transaction_v1_broadcast(&tx_bytes)
.await
.unwrap()
.expect("Server is not overloaded by 1 tx; qed");
rpc.transaction_unstable_stop(&operation_id).await.unwrap();
rpc.transaction_v1_stop(&operation_id).await.unwrap();
// Cannot stop it twice.
let _err = rpc
.transaction_unstable_stop(&operation_id)
.await
.unwrap_err();
let _err = rpc.transaction_v1_stop(&operation_id).await.unwrap_err();
}