chore(taiko): remove tx forwarding

cmd/geth/config.go

@@ -192,11 +192,6 @@ func makeFullNode(ctx *cli.Context) *node.Node {
 		cfg.Eth.OverrideVerkle = &v
 	}
 
-	// CHANGE(taiko): set preconfirmation forwarding URL.
-	if ctx.IsSet(utils.PreconfirmationForwardingURLFlag.Name) {
-		cfg.Eth.PreconfirmationForwardingURL = ctx.String(utils.PreconfirmationForwardingURLFlag.Name)
-	}
-
 	backend, eth := utils.RegisterEthService(stack, &cfg.Eth)
 
 	// CHANGE(TAIKO): register Taiko RPC APIs.

cmd/geth/main.go

@@ -260,8 +260,6 @@ func init() {
 		debug.Flags,
 		metricsFlags,
 	)
-	// CHANGE(taiko): append Taiko flags into the original GETH flags
-	app.Flags = append(app.Flags, utils.TaikoFlag, utils.PreconfirmationForwardingURLFlag)
 
 	flags.AutoEnvVars(app.Flags, "GETH")
 

cmd/utils/taiko_flags.go

@@ -18,11 +18,6 @@ var (
 		Usage:    "Taiko network",
 		Category: flags.TaikoCategory,
 	}
-	PreconfirmationForwardingURLFlag = &cli.StringFlag{
-		Name:     "taiko.preconfirmationForwardingUrl",
-		Usage:    "URL to forward RPC requests before confirmation",
-		Category: flags.TaikoCategory,
-	}
 )
 
 // RegisterTaikoAPIs initializes and registers the Taiko RPC APIs.

eth/api_backend.go

@@ -44,11 +44,10 @@ import (
 
 // EthAPIBackend implements ethapi.Backend and tracers.Backend for full nodes
 type EthAPIBackend struct {
-	extRPCEnabled                bool
-	allowUnprotectedTxs          bool
-	eth                          *Ethereum
-	gpo                          *gasprice.Oracle
-	preconfirmationForwardingURL string // CHANGE(taiko): add preconfirmation forwarding URL
+	extRPCEnabled       bool
+	allowUnprotectedTxs bool
+	eth                 *Ethereum
+	gpo                 *gasprice.Oracle
 }
 
 // ChainConfig returns the active chain configuration.
@@ -432,8 +431,3 @@ func (b *EthAPIBackend) StateAtBlock(ctx context.Context, block *types.Block, re
 func (b *EthAPIBackend) StateAtTransaction(ctx context.Context, block *types.Block, txIndex int, reexec uint64) (*types.Transaction, vm.BlockContext, *state.StateDB, tracers.StateReleaseFunc, error) {
 	return b.eth.stateAtTransaction(ctx, block, txIndex, reexec)
 }
-
-// GetPreconfirmationForwardingURL returns the URL to forward RPC requests before confirmation.
-func (b *EthAPIBackend) GetPreconfirmationForwardingURL() string {
-	return b.preconfirmationForwardingURL
-}

eth/backend.go

@@ -96,8 +96,6 @@ type Ethereum struct {
 	lock sync.RWMutex // Protects the variadic fields (e.g. gas price and etherbase)
 
 	shutdownTracker *shutdowncheck.ShutdownTracker // Tracks if and when the node has shutdown ungracefully
-
-	PreconfirmationForwardingURL string // CHANGE(taiko): add preconfirmation forwarding URL
 }
 
 // New creates a new Ethereum object (including the initialisation of the common Ethereum object),
@@ -257,7 +255,7 @@ func New(stack *node.Node, config *ethconfig.Config) (*Ethereum, error) {
 	eth.miner.SetExtra(makeExtraData(config.Miner.ExtraData))
 
 	// CHANGE(taiko): set up the pre-confirmation forwarding URL
-	eth.APIBackend = &EthAPIBackend{stack.Config().ExtRPCEnabled(), stack.Config().AllowUnprotectedTxs, eth, nil, config.PreconfirmationForwardingURL}
+	eth.APIBackend = &EthAPIBackend{stack.Config().ExtRPCEnabled(), stack.Config().AllowUnprotectedTxs, eth, nil}
 	if eth.APIBackend.allowUnprotectedTxs {
 		log.Info("Unprotected transactions allowed")
 	}

eth/ethconfig/config.go

@@ -157,9 +157,6 @@ type Config struct {
 
 	// OverrideVerkle (TODO: remove after the fork)
 	OverrideVerkle *uint64 `toml:",omitempty"`
-
-	// CHANGE(taiko): add preconfirmation forwarding URL
-	PreconfirmationForwardingURL string
 }
 
 // CreateConsensusEngine creates a consensus engine for the given chain config.

internal/ethapi/api.go

@@ -1974,18 +1974,6 @@ func (api *TransactionAPI) FillTransaction(ctx context.Context, args Transaction
 // SendRawTransaction will add the signed transaction to the transaction pool.
 // The sender is responsible for signing the transaction and using the correct nonce.
 func (api *TransactionAPI) SendRawTransaction(ctx context.Context, input hexutil.Bytes) (common.Hash, error) {
-	// CHANGE(taiko): Forward the request to the preconf node if specified.
-	if forwardURL := api.b.GetPreconfirmationForwardingURL(); forwardURL != "" {
-		log.Info("Forwarding SendRawTransaction request", "forwardURL", forwardURL)
-		// Forward the raw transaction to the specified URL
-		h, err := forward[string](forwardURL, "eth_sendRawTransaction", []interface{}{input.String()})
-		if err == nil && h != nil {
-			return common.HexToHash(*h), nil
-		} else {
-			return common.Hash{}, err
-		}
-	}
-
 	tx := new(types.Transaction)
 	if err := tx.UnmarshalBinary(input); err != nil {
 		return common.Hash{}, err

internal/ethapi/api_test.go

@@ -3400,8 +3400,3 @@ func testRPCResponseWithFile(t *testing.T, testid int, result interface{}, rpc s
 func addressToHash(a common.Address) common.Hash {
 	return common.BytesToHash(a.Bytes())
 }
-
-// CHANGE(taiko): add preconfirmation forwarding URL
-func (b testBackend) GetPreconfirmationForwardingURL() string {
-	return ""
-}

internal/ethapi/backend.go

@@ -96,9 +96,6 @@ type Backend interface {
 	SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscription
 	BloomStatus() (uint64, uint64)
 	ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)
-
-	// CHANGE(taiko): add preconfirmation forwarding URL
-	GetPreconfirmationForwardingURL() string
 }
 
 func GetAPIs(apiBackend Backend) []rpc.API {

internal/ethapi/transaction_args_test.go

@@ -405,8 +405,3 @@ func (b *backendMock) SubscribeRemovedLogsEvent(ch chan<- core.RemovedLogsEvent)
 }
 
 func (b *backendMock) Engine() consensus.Engine { return nil }
-
-// CHANGE(taiko): add preconfirmation forwarding URL
-func (b *backendMock) GetPreconfirmationForwardingURL() string {
-	return ""
-}