logos-blockchain/lssa
1
0
Fork 0
mirror of https://github.com/logos-blockchain/lssa.git synced 2026-01-07 15:53:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: test commented

Browse Source
This commit is contained in:
Pravdyvy 2025-11-26 15:13:40 +02:00
parent e9d7e224b0
commit c9b911836b
1 changed files with 54 additions and 56 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

110
integration_tests/src/test_suite_map.rs
View File

@ -1157,77 +1157,75 @@ pub fn prepare_function_map() -> HashMap<String, TestFunction> {
info!("Success!"); info!("Success!");
} }
// // #[nssa_integration_test]
// pub async fn test_success_private_transfer_to_another_owned_account_cont_run_path() {
// info!(
// "########## test_success_private_transfer_to_another_owned_account_cont_run_path ##########"
// );
// let continious_run_handle = tokio::spawn(wallet::execute_continious_run());
#[nssa_integration_test] // let from: AccountId = ACC_SENDER_PRIVATE.parse().unwrap();
pub async fn test_success_private_transfer_to_another_owned_account_cont_run_path() {
info!(
"########## test_success_private_transfer_to_another_owned_account_cont_run_path ##########"
);
let continious_run_handle = tokio::spawn(wallet::execute_continious_run());
let from: AccountId = ACC_SENDER_PRIVATE.parse().unwrap(); // let command = Command::Account(AccountSubcommand::New(NewSubcommand::Private {}));
let command = Command::Account(AccountSubcommand::New(NewSubcommand::Private {})); // let sub_ret = wallet::execute_subcommand(command).await.unwrap();
// let SubcommandReturnValue::RegisterAccount {
// account_id: to_account_id,
// } = sub_ret
// else {
// panic!("FAILED TO REGISTER ACCOUNT");
// };
let sub_ret = wallet::execute_subcommand(command).await.unwrap(); // let wallet_config = fetch_config().await.unwrap();
let SubcommandReturnValue::RegisterAccount { // let seq_client = SequencerClient::new(wallet_config.sequencer_addr.clone()).unwrap();
account_id: to_account_id, // let wallet_storage = WalletCore::start_from_config_update_chain(wallet_config.clone())
} = sub_ret // .await
else { // .unwrap();
panic!("FAILED TO REGISTER ACCOUNT");
};
let wallet_config = fetch_config().await.unwrap(); // let (to_keys, _) = wallet_storage
let seq_client = SequencerClient::new(wallet_config.sequencer_addr.clone()).unwrap(); // .storage
let wallet_storage = WalletCore::start_from_config_update_chain(wallet_config.clone()) // .user_data
.await // .user_private_accounts
.unwrap(); // .get(&to_account_id)
// .cloned()
// .unwrap();
let (to_keys, _) = wallet_storage // let command = Command::AuthTransfer(AuthTransferSubcommand::Send {
.storage // from: make_private_account_input_from_str(&from.to_string()),
.user_data // to: None,
.user_private_accounts // to_npk: Some(hex::encode(to_keys.nullifer_public_key.0)),
.get(&to_account_id) // to_ipk: Some(hex::encode(to_keys.incoming_viewing_public_key.0)),
.cloned() // amount: 100,
.unwrap(); // });
let command = Command::AuthTransfer(AuthTransferSubcommand::Send { // let sub_ret = wallet::execute_subcommand(command).await.unwrap();
from: make_private_account_input_from_str(&from.to_string()), // let SubcommandReturnValue::PrivacyPreservingTransfer { tx_hash } = sub_ret else {
to: None, // panic!("FAILED TO SEND TX");
to_npk: Some(hex::encode(to_keys.nullifer_public_key.0)), // };
to_ipk: Some(hex::encode(to_keys.incoming_viewing_public_key.0)),
amount: 100,
});
let sub_ret = wallet::execute_subcommand(command).await.unwrap(); // let tx = fetch_privacy_preserving_tx(&seq_client, tx_hash.clone()).await;
let SubcommandReturnValue::PrivacyPreservingTransfer { tx_hash } = sub_ret else {
panic!("FAILED TO SEND TX");
};
let tx = fetch_privacy_preserving_tx(&seq_client, tx_hash.clone()).await; // println!("Waiting for next blocks to check if continoius run fetch account");
// tokio::time::sleep(Duration::from_secs(TIME_TO_WAIT_FOR_BLOCK_SECONDS)).await;
// tokio::time::sleep(Duration::from_secs(TIME_TO_WAIT_FOR_BLOCK_SECONDS)).await;
println!("Waiting for next blocks to check if continoius run fetch account"); // let wallet_storage = WalletCore::start_from_config_update_chain(wallet_config)
tokio::time::sleep(Duration::from_secs(TIME_TO_WAIT_FOR_BLOCK_SECONDS)).await; // .await
tokio::time::sleep(Duration::from_secs(TIME_TO_WAIT_FOR_BLOCK_SECONDS)).await; // .unwrap();
let wallet_storage = WalletCore::start_from_config_update_chain(wallet_config) // assert_eq!(tx.message.new_commitments.len(), 2);
.await // for commitment in tx.message.new_commitments.into_iter() {
.unwrap(); // assert!(verify_commitment_is_in_state(commitment, &seq_client).await);
// }
assert_eq!(tx.message.new_commitments.len(), 2); // let to_res_acc = wallet_storage.get_account_private(&to_account_id).unwrap();
for commitment in tx.message.new_commitments.into_iter() {
assert!(verify_commitment_is_in_state(commitment, &seq_client).await);
}
let to_res_acc = wallet_storage.get_account_private(&to_account_id).unwrap(); // assert_eq!(to_res_acc.balance, 100);
assert_eq!(to_res_acc.balance, 100); // continious_run_handle.abort();
continious_run_handle.abort(); // info!("Success!");
// }
info!("Success!");
}
#[nssa_integration_test] #[nssa_integration_test]
pub async fn test_success_deshielded_transfer_to_another_account() { pub async fn test_success_deshielded_transfer_to_another_account() {