feat: call actual erc20 (#5)

* 50k conns?

* rm: json parsing on testserver

* huge backlog

* allow get

* log concurrent

* limit to 1 worker

* 50 workers

* feat: hyper

* fix?

* actix -> axum

* Update main.rs

* rm batch factor

* 3 second measurement interval

* Update main.rs

* worker id

* request durr

* fix: workers

* Update network.rs

* fix ids

* feat: implied total rps

* Update network.rs

* Update network.rs

* Create genesis.json

* genalloc

* 25k

* start reth

* 50k again?

* wip: try one of 10k addrs

* even workers

* 20k conns

* Update main.rs

* back to 20 acc

* 100 accounts

* 100 acc

* 2500 accounts

* oops fix tx queue reporting

* feat: rand addr

* 500 accounts

* use existing people, log

* allow dead code

* Update tx_gen.rs

* lawging

* hrmf

* 1k accs

* 10k accounts

* wip: startup delay

* Update tx_queue.rs

* Update tx_queue.rs

* log

* moar thresholds

* Update tx_queue.rs

* feat: rayonify

* Update tx_gen.rs

* 50k connections?

* Revert "50k connections?"

This reverts commit 34ec48c.

* log rayon thread pool size

* Update tx_gen.rs

* Initialize Rayon with explicit thread count.

* Update tx_gen.rs

* Update tx_gen.rs

* feat: alternate ratelimit system

* Update tx_queue.rs

* Update tx_queue.rs

* Update tx_queue.rs

* Update tx_queue.rs

* Update tx_queue.rs

* hm

* thresholds

* Update tx_queue.rs

* Update tx_queue.rs

* Update tx_queue.rs

* thresholds

* Update tx_queue.rs

* fewer socket conns

* 10k connections

* 50k RPS?

* feat: longer ramp

* 35k rps?

* Update tx_queue.rs

* 25k

* Update start-reth.sh

* Update genesis.json

* Update start-reth.sh

* batch factor of 5

* fix: implied rps

* disable batching

* feat: even slower ramp up

* slightly faster

* feat: 50k genesis

* feat: better ramp

* oops

* worker ratio

* feat: pareto distribute recipients

* Update tx_gen.rs

* Empty the rate limiter.

* feat: empty rate limiter before AND after

* wip: can we remove first set avail?

* 15k tps

* 20k?

* 15k again

* feat: ramp up faster

* even faster

* faster!

* feat: erc20 precompile testing

* fix: bytes

* Update tx_gen.rs

* lower limit

* erc20 regular spam

* 15k>

* HIGH

* Update tx_queue.rs

* precompile

* Update tx_queue.rs

Author: transmissions11

crescendo/src/tx_queue.rs

@@ -10,14 +10,19 @@ use crate::workers::NUM_ACCOUNTS;
 
 const INITIAL_RATELIMIT: u64 = 100;
 #[rustfmt::skip]
-const RATELIMIT_THRESHOLDS: [(u32, u64); 6] = [
+const RATELIMIT_THRESHOLDS: [(u32, u64); 8] = [
     (NUM_ACCOUNTS / 16,     250),
     (NUM_ACCOUNTS / 8,      500),
     (NUM_ACCOUNTS,        1_000),
     (NUM_ACCOUNTS * 2,    2_500),
-    (NUM_ACCOUNTS * 4,   10_000),
-    (NUM_ACCOUNTS * 8,   15_000),
-    // (NUM_ACCOUNTS * 10, 20_000),
+    (NUM_ACCOUNTS * 4,    5_000),
+    // Avoid ramping up to max TPS before NUM_ACCOUNTS * ~5,
+    // as we want to make sure most storage slots have been
+    // touched + cached before we hit the max TPS. Why 5? See:
+    // https://grok.com/share/bGVnYWN5_e508360c-2313-4d31-8098-6d892f5bf1aa
+    (NUM_ACCOUNTS * 8,    7_500),
+    (NUM_ACCOUNTS * 10,  12_500),
+    (NUM_ACCOUNTS * 12,  15_000),
 ]; // Note: This must be sorted in ascending order of threshold!
 
 pub struct TxQueue {

crescendo/src/workers/tx_gen.rs

@@ -3,7 +3,9 @@ use std::sync::{LazyLock, Mutex};
 use std::time::Instant;
 
 use alloy::network::TxSignerSync;
-use alloy::primitives::{Bytes, TxKind, U256};
+use alloy::primitives::{address, TxKind, U256};
+use alloy::sol;
+use alloy::sol_types::SolCall;
 use alloy_consensus::{SignableTransaction, TxLegacy};
 use alloy_signer_local::coins_bip39::English;
 use alloy_signer_local::{MnemonicBuilder, PrivateKeySigner};
@@ -42,6 +44,12 @@ static SIGNER_LIST: LazyLock<Vec<PrivateKeySigner>> = LazyLock::new(|| {
     list
 });
 
+sol! {
+    interface ERC20 {
+        function transfer(address to, uint256 amount) external returns (bool);
+    }
+}
+
 pub fn tx_gen_worker(_worker_id: u32) {
     let mut rng = rand::rng();
 
@@ -68,10 +76,12 @@ pub fn tx_gen_worker(_worker_id: u32) {
                 chain_id: Some(CHAIN_ID),
                 nonce,
                 gas_price: 100_000_000_000, // 100 gwei
-                gas_limit: 25_000,          // 25k gas limit
-                to: TxKind::Call(recipient),
-                value: U256::from(rng.random_range(1..=10)),
-                input: Bytes::new(),
+                gas_limit: 100_000,         // 100k gas limit
+                to: TxKind::Call(address!("0x2000000000000000000000000000000000000001")),
+                value: U256::ZERO,
+                input: ERC20::transferCall { to: recipient, amount: U256::from(rng.random_range(1..=10)) }
+                    .abi_encode()
+                    .into(),
             },
         );