feat(taiko-client): add --epoch.minTip flag (#17726)

packages/taiko-client/cmd/flags/proposer.go

@@ -82,6 +82,13 @@ var (
 		Value:    0,
 		EnvVars:  []string{"EPOCH_MIN_TX_LIST_BYTES"},
 	}
+	MinTip = &cli.Uint64Flag{
+		Name:     "epoch.minTip",
+		Usage:    "Minimum tip for a transaction to propose",
+		Category: proposerCategory,
+		Value:    0,
+		EnvVars:  []string{"EPOCH_MIN_TIP"},
+	}
 	MinProposingInternal = &cli.DurationFlag{
 		Name:     "epoch.minProposingInterval",
 		Usage:    "Minimum time interval to force proposing a block, even if there are no transaction in mempool",
@@ -155,6 +162,7 @@ var ProposerFlags = MergeFlags(CommonFlags, []cli.Flag{
 	ExtraData,
 	MinGasUsed,
 	MinTxListBytes,
+	MinTip,
 	MinProposingInternal,
 	MaxProposedTxListsPerEpoch,
 	ProverEndpoints,

packages/taiko-client/pkg/rpc/engine.go

@@ -99,15 +99,16 @@ func (c *EngineClient) ExchangeTransitionConfiguration(
 	return result, nil
 }
 
-// TxPoolContent fetches the transaction pool content from the L2 execution engine.
-func (c *EngineClient) TxPoolContent(
+// TxPoolContentWithMinTip fetches the transaction pool content from the L2 execution engine.
+func (c *EngineClient) TxPoolContentWithMinTip(
 	ctx context.Context,
 	beneficiary common.Address,
 	baseFee *big.Int,
 	blockMaxGasLimit uint64,
 	maxBytesPerTxList uint64,
 	locals []string,
 	maxTransactionsLists uint64,
+	minTip uint64,
 ) ([]*miner.PreBuiltTxList, error) {
 	timeoutCtx, cancel := context.WithTimeout(ctx, defaultTimeout)
 	defer cancel()
@@ -116,13 +117,14 @@ func (c *EngineClient) TxPoolContent(
 	if err := c.CallContext(
 		timeoutCtx,
 		&result,
-		"taikoAuth_txPoolContent",
+		"taikoAuth_txPoolContentWithMinTip",
 		beneficiary,
 		baseFee,
 		blockMaxGasLimit,
 		maxBytesPerTxList,
 		locals,
 		maxTransactionsLists,
+		minTip,
 	); err != nil {
 		return nil, err
 	}

packages/taiko-client/pkg/rpc/methods.go

@@ -255,6 +255,7 @@ func (c *Client) GetPoolContent(
 	maxBytesPerTxList uint64,
 	locals []common.Address,
 	maxTransactionsLists uint64,
+	minTip uint64,
 ) ([]*miner.PreBuiltTxList, error) {
 	ctxWithTimeout, cancel := CtxWithTimeoutOrDefault(ctx, defaultTimeout)
 	defer cancel()
@@ -285,14 +286,15 @@ func (c *Client) GetPoolContent(
 		localsArg = append(localsArg, local.Hex())
 	}
 
-	return c.L2Engine.TxPoolContent(
+	return c.L2Engine.TxPoolContentWithMinTip(
 		ctxWithTimeout,
 		beneficiary,
 		baseFeeInfo.Basefee,
 		uint64(blockMaxGasLimit),
 		maxBytesPerTxList,
 		localsArg,
 		maxTransactionsLists,
+		minTip,
 	)
 }
 

packages/taiko-client/proposer/config.go

@@ -32,6 +32,7 @@ type Config struct {
 	LocalAddressesOnly         bool
 	MinGasUsed                 uint64
 	MinTxListBytes             uint64
+	MinTip                     uint64
 	MinProposingInternal       time.Duration
 	MaxProposedTxListsPerEpoch uint64
 	ProposeBlockTxGasLimit     uint64
@@ -113,6 +114,7 @@ func NewConfigFromCliContext(c *cli.Context) (*Config, error) {
 		LocalAddressesOnly:         c.Bool(flags.TxPoolLocalsOnly.Name),
 		MinGasUsed:                 c.Uint64(flags.MinGasUsed.Name),
 		MinTxListBytes:             c.Uint64(flags.MinTxListBytes.Name),
+		MinTip:                     c.Uint64(flags.MinTip.Name),
 		MinProposingInternal:       c.Duration(flags.MinProposingInternal.Name),
 		MaxProposedTxListsPerEpoch: c.Uint64(flags.MaxProposedTxListsPerEpoch.Name),
 		ProposeBlockTxGasLimit:     c.Uint64(flags.TxGasLimit.Name),

packages/taiko-client/proposer/proposer.go

@@ -202,6 +202,7 @@ func (p *Proposer) fetchPoolContent(filterPoolContent bool) ([]types.Transaction
 		rpc.BlockMaxTxListBytes,
 		p.LocalAddresses,
 		p.MaxProposedTxListsPerEpoch,
+		p.MinTip,
 	)
 	if err != nil {
 		return nil, fmt.Errorf("failed to fetch transaction pool content: %w", err)

packages/taiko-client/proposer/proposer_test.go

@@ -182,6 +182,7 @@ func (s *ProposerTestSuite) TestProposeOpNoEmptyBlock() {
 			rpc.BlockMaxTxListBytes,
 			p.LocalAddresses,
 			p.MaxProposedTxListsPerEpoch,
+			0,
 		)
 		time.Sleep(time.Second)
 	}