forked from ethereum-optimism/optimism
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
op-challenger: Support fetching preimage leaf data from transactions (e…
…thereum-optimism#9122) * op-challenger: Add methods retrieve leaf data from oracle contract bindings. * op-challenger: Add leaf fetcher to extract leaf data from transactions * op-challenger: Remove input length validations from DecodeInputData. * op-challenger: Update fetcher to work with InputData
- Loading branch information
Showing
8 changed files
with
747 additions
and
20 deletions.
There are no files selected for viewing
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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,116 @@ | ||
| package fetcher | ||
|
|
||
| import ( | ||
| "context" | ||
| "errors" | ||
| "fmt" | ||
| "math/big" | ||
|
|
||
| "github.com/ethereum-optimism/optimism/op-challenger/game/fault/contracts" | ||
| keccakTypes "github.com/ethereum-optimism/optimism/op-challenger/game/keccak/types" | ||
| "github.com/ethereum-optimism/optimism/op-service/sources/batching" | ||
| "github.com/ethereum/go-ethereum/common" | ||
| "github.com/ethereum/go-ethereum/core/types" | ||
| "github.com/ethereum/go-ethereum/log" | ||
| ) | ||
|
|
||
| var ( | ||
| ErrNoLeavesFound = errors.New("no leaves found in block") | ||
| ) | ||
|
|
||
| type L1Source interface { | ||
| TxsByNumber(ctx context.Context, number uint64) (types.Transactions, error) | ||
| FetchReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error) | ||
| ChainID(ctx context.Context) (*big.Int, error) | ||
| } | ||
|
|
||
| type Oracle interface { | ||
| Addr() common.Address | ||
| GetInputDataBlocks(ctx context.Context, block batching.Block, ident keccakTypes.LargePreimageIdent) ([]uint64, error) | ||
| DecodeInputData(data []byte) (*big.Int, keccakTypes.InputData, error) | ||
| } | ||
|
|
||
| type InputFetcher struct { | ||
| log log.Logger | ||
| source L1Source | ||
| } | ||
|
|
||
| func (f *InputFetcher) FetchInputs(ctx context.Context, blockHash common.Hash, oracle Oracle, ident keccakTypes.LargePreimageIdent) ([]keccakTypes.InputData, error) { | ||
| blockNums, err := oracle.GetInputDataBlocks(ctx, batching.BlockByHash(blockHash), ident) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed to retrieve leaf block nums: %w", err) | ||
| } | ||
| chainID, err := f.source.ChainID(ctx) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed to retrieve L1 chain ID: %w", err) | ||
| } | ||
| signer := types.LatestSignerForChainID(chainID) | ||
| var inputs []keccakTypes.InputData | ||
| for _, blockNum := range blockNums { | ||
| foundRelevantTx := false | ||
| txs, err := f.source.TxsByNumber(ctx, blockNum) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed getting tx for block %v: %w", blockNum, err) | ||
| } | ||
| for _, tx := range txs { | ||
| inputData, err := f.extractRelevantLeavesFromTx(ctx, oracle, signer, tx, ident) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if inputData != nil { | ||
| foundRelevantTx = true | ||
| inputs = append(inputs, *inputData) | ||
| } | ||
| } | ||
| if !foundRelevantTx { | ||
| // The contract said there was a relevant transaction in this block that we failed to find. | ||
| // There was either a reorg or the extraction logic is broken. | ||
| // Either way, abort this attempt to validate the preimage. | ||
| return nil, fmt.Errorf("%w %v", ErrNoLeavesFound, blockNum) | ||
| } | ||
| } | ||
| return inputs, nil | ||
| } | ||
|
|
||
| func (f *InputFetcher) extractRelevantLeavesFromTx(ctx context.Context, oracle Oracle, signer types.Signer, tx *types.Transaction, ident keccakTypes.LargePreimageIdent) (*keccakTypes.InputData, error) { | ||
| if tx.To() == nil || *tx.To() != oracle.Addr() { | ||
| f.log.Trace("Skip tx with incorrect to addr", "tx", tx.Hash(), "expected", oracle.Addr(), "actual", tx.To()) | ||
| return nil, nil | ||
| } | ||
| uuid, inputData, err := oracle.DecodeInputData(tx.Data()) | ||
| if errors.Is(err, contracts.ErrInvalidAddLeavesCall) { | ||
| f.log.Trace("Skip tx with invalid call data", "tx", tx.Hash(), "err", err) | ||
| return nil, nil | ||
| } else if err != nil { | ||
| return nil, err | ||
| } | ||
| if uuid.Cmp(ident.UUID) != 0 { | ||
| f.log.Trace("Skip tx with incorrect UUID", "tx", tx.Hash(), "expected", ident.UUID, "actual", uuid) | ||
| return nil, nil | ||
| } | ||
| sender, err := signer.Sender(tx) | ||
| if err != nil { | ||
| f.log.Trace("Skipping transaction with invalid sender", "tx", tx.Hash(), "err", err) | ||
| return nil, nil | ||
| } | ||
| if sender != ident.Claimant { | ||
| f.log.Trace("Skipping transaction with incorrect sender", "tx", tx.Hash(), "expected", ident.Claimant, "actual", sender) | ||
| return nil, nil | ||
| } | ||
| rcpt, err := f.source.FetchReceipt(ctx, tx.Hash()) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed to retrieve receipt for tx %v: %w", tx.Hash(), err) | ||
| } | ||
| if rcpt.Status != types.ReceiptStatusSuccessful { | ||
| f.log.Trace("Skipping transaction with failed receipt status", "tx", tx.Hash(), "status", rcpt.Status) | ||
| return nil, nil | ||
| } | ||
| return &inputData, nil | ||
| } | ||
|
|
||
| func NewPreimageFetcher(logger log.Logger, source L1Source) *InputFetcher { | ||
| return &InputFetcher{ | ||
| log: logger, | ||
| source: source, | ||
| } | ||
| } |
Oops, something went wrong.