Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
55 commits
Select commit Hold shift + click to select a range
7914369
initial p2p node impl in p2p crate
noot Sep 18, 2025
a082367
update args and add p2p node to flashblocks service
noot Sep 19, 2025
960ecf7
send built flashblocks to p2p layer
noot Sep 22, 2025
c03416d
implement generic message in p2p crate, concrete message in builder
noot Sep 22, 2025
5428121
implement incoming streams handler
noot Sep 24, 2025
847180e
implement PayloadHandler for handling incoming p2p payloads
noot Sep 24, 2025
fa98c77
support multiple stream protocols
noot Sep 24, 2025
590927c
make agent version configurable
noot Sep 24, 2025
192340d
merge w main
noot Sep 24, 2025
7ae5778
fmt
noot Sep 25, 2025
5b77ff1
clippy
noot Sep 25, 2025
3b66510
add known peers flag
noot Sep 25, 2025
380a5c1
update error handling for better logging in payload builder
noot Sep 25, 2025
fdfcc95
basic sync and execution pipeline implementation
noot Oct 5, 2025
f522f4f
merge w main
noot Oct 5, 2025
2ee1855
change p2p hex string to file path; add documentation for p2p crate
noot Oct 6, 2025
b20f773
fix optional flags
noot Oct 6, 2025
1105f6f
merge w base
noot Oct 6, 2025
15b6c03
bump op-revm, debugging sync
noot Oct 9, 2025
181689e
sync working but flashblock hash mismatch
noot Oct 11, 2025
2c30d3e
fix receipt calculation; hashes match when syncing
noot Oct 14, 2025
35715c7
update Message trait to have custom to/from string
noot Oct 14, 2025
1b1f345
cargo update
noot Oct 14, 2025
2b0e5cd
fix copilot issues
noot Oct 14, 2025
696030a
fix copilot issues
noot Oct 14, 2025
9fd7548
fix derive_more
noot Oct 14, 2025
3237890
fix copilot issues
noot Oct 14, 2025
1badb92
regenerate Cargo.lock
noot Oct 14, 2025
1a8fd45
merge w main
noot Oct 14, 2025
f3f47eb
revert dep changes
noot Oct 15, 2025
66f89ed
merge w base
noot Oct 15, 2025
0193f43
lint
noot Oct 15, 2025
378e139
remove unneeded struct
noot Oct 15, 2025
86a3633
execute flashblock cleanup
noot Oct 15, 2025
c8c26e0
add metrics
noot Oct 15, 2025
29e1a85
cleanup
noot Oct 15, 2025
27c4046
wip fix tests
noot Oct 16, 2025
37d46af
fix tests
noot Oct 16, 2025
986c99e
remove comment
noot Oct 16, 2025
6e6d9de
merge: wip
noot Oct 20, 2025
2525f48
Merge branch 'main' of https://github.com/flashbots/op-rbuilder into …
noot Oct 20, 2025
3e9ea53
merge
noot Oct 20, 2025
0d30052
update p2p args
noot Oct 20, 2025
9a9b31d
add max peer arg
noot Oct 21, 2025
9ebf706
lint
noot Oct 21, 2025
8603372
merge w base
noot Oct 22, 2025
5aa7e42
lint
noot Oct 22, 2025
31c527c
merge wip
noot Oct 27, 2025
7bb5c80
temp fix
noot Oct 27, 2025
5313e7d
rename metrics with payload_tx_ to payload_transaction_
noot Oct 27, 2025
22889f1
Merge branch 'noot/p2p' of https://github.com/flashbots/op-rbuilder i…
noot Oct 27, 2025
6c5c442
merge w base
noot Oct 27, 2025
21f5681
merge w main
noot Oct 27, 2025
2fc9fad
address comments
noot Oct 27, 2025
5094625
spawn_blocking for execute_flashblock
noot Oct 27, 2025
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
Prev Previous commit
Next Next commit
merge w main
  • Loading branch information
noot committed Oct 5, 2025
commit f522f4f04f95a6cbca71f549332880ffdf8e08a4
3 changes: 2 additions & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 2 additions & 0 deletions crates/op-rbuilder/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -128,6 +128,8 @@ moka = "0.12"
http = "1.0"
sha3 = "0.10"
ureq = "2.10"
reqwest = "0.12.23"
k256 = "0.13.4"

rollup-boost = { git = "https://github.com/flashbots/rollup-boost", rev = "b86af43969557bee18f17ec1d6bcd3e984f910b2" }

Expand Down
2 changes: 1 addition & 1 deletion crates/op-rbuilder/src/builders/flashblocks/payload.rs
Original file line number Diff line number Diff line change
Expand Up @@ -630,7 +630,7 @@ where
state,
best_txs,
target_gas_for_batch.min(ctx.block_gas_limit()),
total_da_per_batch,
target_da_per_batch,
)
.wrap_err("failed to execute best transactions")?;
// Extract last transactions
Expand Down
17 changes: 12 additions & 5 deletions crates/op-rbuilder/src/tests/flashblocks.rs
Original file line number Diff line number Diff line change
@@ -1,20 +1,17 @@
use alloy_consensus::Transaction;
use alloy_eips::Decodable2718;
use alloy_primitives::{Address, TxHash, U256, address, b128, b256};
use alloy_primitives::{Address, TxHash, U256, address};
use alloy_provider::Provider;
use alloy_sol_types::SolCall;
use macros::rb_test;
use op_alloy_consensus::OpTxEnvelope;
use std::time::Duration;

use crate::{
args::{FlashblocksArgs, OpRbuilderArgs},
tests::{
BUILDER_PRIVATE_KEY, BlockTransactionsExt, BundleOpts, ChainDriver, ChainDriverExt,
FUNDED_PRIVATE_KEY, LocalInstance, ONE_ETH, TransactionBuilderExt,
BlockTransactionsExt, BundleOpts, ChainDriver, LocalInstance, TransactionBuilderExt,
flashblocks_number_contract::FlashblocksNumber,
},
tx_signer::Signer,
};

// If the order of deployment from the signer changes the address will change
Expand All @@ -34,6 +31,7 @@ const FLASHBLOCKS_NUMBER_ADDRESS: Address = address!("5fbdb2315678afecb367f032d9
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -76,6 +74,7 @@ async fn smoke_dynamic_base(rbuilder: LocalInstance) -> eyre::Result<()> {
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -118,6 +117,7 @@ async fn smoke_dynamic_unichain(rbuilder: LocalInstance) -> eyre::Result<()> {
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -160,6 +160,7 @@ async fn smoke_classic_unichain(rbuilder: LocalInstance) -> eyre::Result<()> {
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -202,6 +203,7 @@ async fn smoke_classic_base(rbuilder: LocalInstance) -> eyre::Result<()> {
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -251,6 +253,7 @@ async fn unichain_dynamic_with_lag(rbuilder: LocalInstance) -> eyre::Result<()>
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -293,6 +296,7 @@ async fn dynamic_with_full_block_lag(rbuilder: LocalInstance) -> eyre::Result<()
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -357,6 +361,7 @@ async fn test_flashblock_min_filtering(rbuilder: LocalInstance) -> eyre::Result<
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -417,6 +422,7 @@ async fn test_flashblock_max_filtering(rbuilder: LocalInstance) -> eyre::Result<
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down Expand Up @@ -466,6 +472,7 @@ async fn test_flashblock_min_max_filtering(rbuilder: LocalInstance) -> eyre::Res
flashblocks_p2p_private_key_hex: String::new(),
flashblocks_known_peers: String::new(),
flashblocks_number_contract_address: None,
..Default::default()
},
..Default::default()
})]
Expand Down
Loading
You are viewing a condensed version of this merge commit. You can view the full changes here.