-
Notifications
You must be signed in to change notification settings - Fork 76
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #224 from ralexstokes/latest-payload-utils-from-reth
Latest payload utils from reth
- Loading branch information
Showing
10 changed files
with
201 additions
and
218 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,2 +1,93 @@ | ||
| pub mod compat; | ||
| pub mod payload_job; | ||
| pub mod compat { | ||
| use ethereum_consensus::{ | ||
| deneb::{ | ||
| mainnet as spec, | ||
| polynomial_commitments::{KzgCommitment, KzgProof}, | ||
| Blob, | ||
| }, | ||
| primitives::{Bytes32, ExecutionAddress}, | ||
| ssz::prelude::{ByteList, ByteVector, List, U256}, | ||
| }; | ||
| use mev_rs::types::{BlobsBundle, ExecutionPayload}; | ||
| use reth::primitives::{Address, BlobTransactionSidecar, Bloom, SealedBlock, B256}; | ||
|
|
||
| pub fn to_bytes32(value: B256) -> Bytes32 { | ||
| Bytes32::try_from(value.as_ref()).unwrap() | ||
| } | ||
|
|
||
| pub fn to_bytes20(value: Address) -> ExecutionAddress { | ||
| ExecutionAddress::try_from(value.as_ref()).unwrap() | ||
| } | ||
|
|
||
| fn to_byte_vector(value: Bloom) -> ByteVector<256> { | ||
| ByteVector::<256>::try_from(value.as_ref()).unwrap() | ||
| } | ||
|
|
||
| // TODO: support multiple forks | ||
| pub fn to_execution_payload(value: &SealedBlock) -> ExecutionPayload { | ||
| let hash = value.hash(); | ||
| let header = &value.header; | ||
| let transactions = &value.body; | ||
| let withdrawals = &value.withdrawals; | ||
| let transactions = transactions | ||
| .iter() | ||
| .map(|t| spec::Transaction::try_from(t.envelope_encoded().as_ref()).unwrap()) | ||
| .collect::<Vec<_>>(); | ||
| let withdrawals = withdrawals | ||
| .as_ref() | ||
| .unwrap() | ||
| .iter() | ||
| .map(|w| spec::Withdrawal { | ||
| index: w.index as usize, | ||
| validator_index: w.validator_index as usize, | ||
| address: to_bytes20(w.address), | ||
| amount: w.amount, | ||
| }) | ||
| .collect::<Vec<_>>(); | ||
|
|
||
| let payload = spec::ExecutionPayload { | ||
| parent_hash: to_bytes32(header.parent_hash), | ||
| fee_recipient: to_bytes20(header.beneficiary), | ||
| state_root: to_bytes32(header.state_root), | ||
| receipts_root: to_bytes32(header.receipts_root), | ||
| logs_bloom: to_byte_vector(header.logs_bloom), | ||
| prev_randao: to_bytes32(header.mix_hash), | ||
| block_number: header.number, | ||
| gas_limit: header.gas_limit, | ||
| gas_used: header.gas_used, | ||
| timestamp: header.timestamp, | ||
| extra_data: ByteList::try_from(header.extra_data.as_ref()).unwrap(), | ||
| base_fee_per_gas: U256::from(header.base_fee_per_gas.unwrap_or_default()), | ||
| block_hash: to_bytes32(hash), | ||
| transactions: TryFrom::try_from(transactions).unwrap(), | ||
| withdrawals: TryFrom::try_from(withdrawals).unwrap(), | ||
| blob_gas_used: header.blob_gas_used.unwrap(), | ||
| excess_blob_gas: header.excess_blob_gas.unwrap(), | ||
| }; | ||
| ExecutionPayload::Deneb(payload) | ||
| } | ||
|
|
||
| pub fn to_blobs_bundle(sidecars: &[BlobTransactionSidecar]) -> BlobsBundle { | ||
| let mut commitments = List::default(); | ||
| let mut proofs = List::default(); | ||
| let mut blobs = List::default(); | ||
|
|
||
| // TODO: perform length checks to avoid panic on `push` | ||
| for sidecar in sidecars { | ||
| for commitment in &sidecar.commitments { | ||
| let commitment = KzgCommitment::try_from(commitment.as_slice()).unwrap(); | ||
| commitments.push(commitment); | ||
| } | ||
| for proof in &sidecar.proofs { | ||
| let proof = KzgProof::try_from(proof.as_slice()).unwrap(); | ||
| proofs.push(proof); | ||
| } | ||
| for blob in &sidecar.blobs { | ||
| let blob = Blob::try_from(blob.as_ref()).unwrap(); | ||
| blobs.push(blob); | ||
| } | ||
| } | ||
|
|
||
| BlobsBundle { commitments, proofs, blobs } | ||
| } | ||
| } |
This file was deleted.
Oops, something went wrong.