Skip to content

fix: task sender nonce #1496

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
MauroToscano merged 1 commit into from
Nov 27, 2024
Merged

fix: task sender nonce #1496

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 4 additions & 8 deletions batcher/aligned-task-sender/src/commands.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
use aligned_sdk::core::types::{Network, ProvingSystemId, VerificationData};
use aligned_sdk::sdk::{deposit_to_aligned, get_nonce_from_ethereum, submit_multiple};
use aligned_sdk::sdk::{deposit_to_aligned, get_nonce_from_batcher, submit_multiple};
use ethers::prelude::*;
use ethers::utils::parse_ether;
use futures_util::StreamExt;
Expand Down Expand Up @@ -317,15 +317,15 @@ pub async fn send_infinite_proofs(args: SendInfiniteProofsArgs) {
info!("Starting senders!");
for (i, sender) in senders.iter().enumerate() {
// this is necessary because of the move
let eth_rpc_url = args.eth_rpc_url.clone();
let batcher_url = args.batcher_url.clone();
let wallet = sender.wallet.clone();
let verification_data = verification_data.clone();

// a thread to send tasks from each loaded wallet:
let handle = tokio::spawn(async move {
let mut nonce =
get_nonce_from_ethereum(&eth_rpc_url, wallet.address(), args.network.into())
loop {
let mut result = Vec::with_capacity(args.burst_size);
let nonce = get_nonce_from_batcher(&batcher_url, wallet.address())
.await
.inspect_err(|e| {
error!(
Expand All @@ -335,9 +335,6 @@ pub async fn send_infinite_proofs(args: SendInfiniteProofsArgs) {
)
})
.unwrap();

loop {
let mut result = Vec::with_capacity(args.burst_size);
while result.len() < args.burst_size {
let samples = verification_data
.choose_multiple(&mut thread_rng(), args.burst_size - result.len());
Expand Down Expand Up @@ -365,7 +362,6 @@ pub async fn send_infinite_proofs(args: SendInfiniteProofsArgs) {
match aligned_verification_data {
Ok(_) => {
debug!("Response received for sender {}", i);
nonce += U256::from(1);
}
Err(e) => {
error!(
Expand Down
Loading