logos-blockchain/logos-execution-zone
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-execution-zone.git synced 2026-08-10 15:03:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #33 from vacp2p/scenario_fix

Browse Source 
fix
This commit is contained in:
tyshko-rostyslav 2024-12-30 00:46:10 -05:00 committed by GitHub
commit ca61183993
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 28 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
node_core/src/lib.rs
View File

@ -398,15 +398,16 @@ impl NodeCore {
let accout = acc_map_read_guard.acc_map.get(&utxo.owner).unwrap(); let accout = acc_map_read_guard.acc_map.get(&utxo.owner).unwrap();
let nullifier = generate_nullifiers( generate_nullifiers(
&utxo, &utxo,
&accout &accout
.key_holder .key_holder
.utxo_secret_key_holder .utxo_secret_key_holder
.nullifier_secret_key .nullifier_secret_key
.to_bytes() .to_bytes()
.to_vec(), .to_vec(),
); )
};
let (resulting_balances, receipt) = prove_send_utxo_deshielded(utxo, receivers); let (resulting_balances, receipt) = prove_send_utxo_deshielded(utxo, receivers);
@ -557,10 +558,13 @@ impl NodeCore {
info!("Awaiting new blocks"); info!("Awaiting new blocks");
tokio::time::sleep(std::time::Duration::from_secs(BLOCK_GEN_DELAY_SECS)).await; tokio::time::sleep(std::time::Duration::from_secs(BLOCK_GEN_DELAY_SECS)).await;
let acc_map_read_guard = self.storage.read().await; {
let acc = acc_map_read_guard.acc_map.get(&acc_addr).unwrap(); let acc_map_read_guard = self.storage.read().await;
info!("New acconut public balance is {:?}", acc.balance); let acc = acc_map_read_guard.acc_map.get(&acc_addr).unwrap();;
info!("New acconut public balance is {:?}", acc.balance);
};
let (resp, new_utxo_hashes) = self let (resp, new_utxo_hashes) = self
.send_shielded_send_tx(acc_addr, 100, vec![(100, acc_addr)]) .send_shielded_send_tx(acc_addr, 100, vec![(100, acc_addr)])
@ -647,10 +651,12 @@ impl NodeCore {
info!("Awaiting new blocks"); info!("Awaiting new blocks");
tokio::time::sleep(std::time::Duration::from_secs(BLOCK_GEN_DELAY_SECS)).await; tokio::time::sleep(std::time::Duration::from_secs(BLOCK_GEN_DELAY_SECS)).await;
let acc_map_read_guard = self.storage.read().await; {
let acc = acc_map_read_guard.acc_map.get(&acc_addr).unwrap(); let acc_map_read_guard = self.storage.read().await;
let acc = acc_map_read_guard.acc_map.get(&acc_addr).unwrap();
info!("New acconut public balance is {:?}", acc.balance);
info!("New acconut public balance is {:?}", acc.balance);
}
let (resp, new_utxo_hashes) = self let (resp, new_utxo_hashes) = self
.send_shielded_send_tx(acc_addr, 100, vec![(100, acc_addr_rec)]) .send_shielded_send_tx(acc_addr, 100, vec![(100, acc_addr_rec)])
@ -710,9 +716,11 @@ impl NodeCore {
info!("Awaiting new blocks"); info!("Awaiting new blocks");
tokio::time::sleep(std::time::Duration::from_secs(BLOCK_GEN_DELAY_SECS)).await; tokio::time::sleep(std::time::Duration::from_secs(BLOCK_GEN_DELAY_SECS)).await;
let read_guard = self.storage.read().await; {
let acc_rec = read_guard.acc_map.get(&acc_addr_rec).unwrap(); let read_guard = self.storage.read().await;
let acc_rec = read_guard.acc_map.get(&acc_addr_rec).unwrap();
info!("New account public balance is {:?}", acc_rec.balance);
info!("New account public balance is {:?}", acc_rec.balance);
}
} }
} }