From 77df3c7556a2ebb80c76059c4effbb5c856c5fd4 Mon Sep 17 00:00:00 2001 From: Ganesh Vanahalli Date: Fri, 27 Dec 2024 10:07:58 -0600 Subject: [PATCH] fix stubPublisher in express_lane_service_test.go --- execution/gethexec/express_lane_service.go | 8 ++---- .../gethexec/express_lane_service_test.go | 26 ++++++++++--------- 2 files changed, 16 insertions(+), 18 deletions(-) diff --git a/execution/gethexec/express_lane_service.go b/execution/gethexec/express_lane_service.go index 6dbcc4e9af..c8339feac7 100644 --- a/execution/gethexec/express_lane_service.go +++ b/execution/gethexec/express_lane_service.go @@ -361,14 +361,10 @@ func (es *expressLaneService) sequenceExpressLaneSubmission( if err := es.transactionPublisher.PublishTimeboostedTransaction( ctx, nextMsg.Transaction, - msg.Options, + nextMsg.Options, ); err != nil { - txHash := common.Hash{} - if nextMsg.Transaction != nil { - txHash = nextMsg.Transaction.Hash() - } // If the tx fails we return an error with all the necessary info for the controller to successfully try again - return fmt.Errorf("express lane transaction of sequence number: %d and transaction hash: %v, failed with an error: %w", nextMsg.SequenceNumber, txHash, err) + return fmt.Errorf("express lane transaction of sequence number: %d and transaction hash: %v, failed with an error: %w", nextMsg.SequenceNumber, nextMsg.Transaction.Hash(), err) } // Increase the global round sequence number. control.sequence += 1 diff --git a/execution/gethexec/express_lane_service_test.go b/execution/gethexec/express_lane_service_test.go index 6ec62b937b..86484db62a 100644 --- a/execution/gethexec/express_lane_service_test.go +++ b/execution/gethexec/express_lane_service_test.go @@ -297,8 +297,10 @@ func makeStubPublisher(els *expressLaneService) *stubPublisher { } } +var emptyTx = types.NewTransaction(0, common.MaxAddress, big.NewInt(0), 0, big.NewInt(0), nil) + func (s *stubPublisher) PublishTimeboostedTransaction(parentCtx context.Context, tx *types.Transaction, options *arbitrum_types.ConditionalOptions) error { - if tx == nil { + if tx.Hash() != emptyTx.Hash() { return errors.New("oops, bad tx") } control, _ := s.els.roundControl.Get(0) @@ -369,23 +371,23 @@ func Test_expressLaneService_sequenceExpressLaneSubmission_outOfOrder(t *testing messages := []*timeboost.ExpressLaneSubmission{ { SequenceNumber: 10, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, { SequenceNumber: 5, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, { SequenceNumber: 1, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, { SequenceNumber: 4, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, { SequenceNumber: 2, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, } for _, msg := range messages { @@ -396,7 +398,7 @@ func Test_expressLaneService_sequenceExpressLaneSubmission_outOfOrder(t *testing require.Equal(t, 2, len(stubPublisher.publishedTxOrder)) require.Equal(t, 3, len(els.messagesBySequenceNumber)) // Processed txs are deleted - err := els.sequenceExpressLaneSubmission(ctx, &timeboost.ExpressLaneSubmission{SequenceNumber: 3, Transaction: &types.Transaction{}}) + err := els.sequenceExpressLaneSubmission(ctx, &timeboost.ExpressLaneSubmission{SequenceNumber: 3, Transaction: emptyTx}) require.NoError(t, err) require.Equal(t, 5, len(stubPublisher.publishedTxOrder)) } @@ -417,23 +419,23 @@ func Test_expressLaneService_sequenceExpressLaneSubmission_erroredTx(t *testing. messages := []*timeboost.ExpressLaneSubmission{ { SequenceNumber: 1, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, { SequenceNumber: 3, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, { SequenceNumber: 2, - Transaction: nil, + Transaction: types.NewTransaction(0, common.MaxAddress, big.NewInt(0), 0, big.NewInt(0), []byte{1}), }, { SequenceNumber: 2, - Transaction: &types.Transaction{}, + Transaction: emptyTx, }, } for _, msg := range messages { - if msg.Transaction == nil { + if msg.Transaction.Hash() != emptyTx.Hash() { err := els.sequenceExpressLaneSubmission(ctx, msg) require.ErrorContains(t, err, "oops, bad tx") } else {