Merge pull request #33 from astriaorg/noot/no-metro

remove all mentions of metro

cmd/geth/main.go

@@ -185,11 +185,6 @@ var (
 		utils.GRPCPortFlag,
 	}
 
-	metroFlags = []cli.Flag{
-		utils.MetroGRPCHostFlag,
-		utils.MetroGRPCPortFlag,
-	}
-
 	metricsFlags = []cli.Flag{
 		utils.MetricsEnabledFlag,
 		utils.MetricsEnabledExpensiveFlag,
@@ -253,7 +248,6 @@ func init() {
 	app.Flags = flags.Merge(
 		nodeFlags,
 		rpcFlags,
-		metroFlags,
 		consoleFlags,
 		debug.Flags,
 		metricsFlags,

cmd/utils/flags.go

@@ -811,20 +811,6 @@ var (
 		Category: flags.APICategory,
 	}
 
-	// Metro grpc address and port overrides
-	MetroGRPCHostFlag = &cli.StringFlag{
-		Name:     "metro.addr",
-		Usage:    "Metro gRPC server listening interface",
-		Value:    ethconfig.Defaults.MetroGRPCHost,
-		Category: flags.APICategory,
-	}
-	MetroGRPCPortFlag = &cli.IntFlag{
-		Name:     "metro.port",
-		Usage:    "Metro gRPC server listening port",
-		Value:    ethconfig.Defaults.MetroGRPCPort,
-		Category: flags.APICategory,
-	}
-
 	// Network Settings
 	MaxPeersFlag = &cli.IntFlag{
 		Name:     "maxpeers",
@@ -1905,14 +1891,6 @@ func SetEthConfig(ctx *cli.Context, stack *node.Node, cfg *ethconfig.Config) {
 		}
 	}
 
-	// metro
-	if ctx.IsSet(MetroGRPCHostFlag.Name) {
-		cfg.MetroGRPCHost = ctx.String(MetroGRPCHostFlag.Name)
-	}
-	if ctx.IsSet(MetroGRPCPortFlag.Name) {
-		cfg.MetroGRPCPort = ctx.Int(MetroGRPCPortFlag.Name)
-	}
-
 	// Override any default configs for hard coded networks.
 	switch {
 	case ctx.Bool(MainnetFlag.Name):

eth/api_backend.go

@@ -19,7 +19,6 @@ package eth
 import (
 	"context"
 	"errors"
-	"fmt"
 	"math/big"
 	"time"
 
@@ -352,10 +351,6 @@ func (b *EthAPIBackend) UnprotectedAllowed() bool {
 	return b.allowUnprotectedTxs
 }
 
-func (b *EthAPIBackend) MetroGRPCEndpoint() string {
-	return fmt.Sprintf("%s:%d", b.eth.config.MetroGRPCHost, b.eth.config.MetroGRPCPort)
-}
-
 func (b *EthAPIBackend) RPCGasCap() uint64 {
 	return b.eth.config.RPCGasCap
 }

eth/ethconfig/config.go

@@ -90,10 +90,6 @@ var Defaults = Config{
 	RPCEVMTimeout:           5 * time.Second,
 	GPO:                     FullNodeGPO,
 	RPCTxFeeCap:             1, // 1 ether
-
-	// Metro GRPC
-	MetroGRPCHost: "localhost",
-	MetroGRPCPort: 9090,
 }
 
 func init() {
@@ -211,10 +207,6 @@ type Config struct {
 
 	// OverrideShanghai (TODO: remove after the fork)
 	OverrideShanghai *uint64 `toml:",omitempty"`
-
-	// Metro GRPC Host and Port
-	MetroGRPCHost string `toml:",omitempty"`
-	MetroGRPCPort int    `toml:",omitempty"`
 }
 
 // CreateConsensusEngine creates a consensus engine for the given chain configuration.

internal/ethapi/backend.go

@@ -97,9 +97,6 @@ type Backend interface {
 	SubscribePendingLogsEvent(ch chan<- []*types.Log) event.Subscription
 	BloomStatus() (uint64, uint64)
 	ServiceFilter(ctx context.Context, session *bloombits.MatcherSession)
-
-	// Metro GRPC endpoint
-	MetroGRPCEndpoint() string
 }
 
 func GetAPIs(apiBackend Backend) []rpc.API {

internal/ethapi/transaction_args_test.go

@@ -264,7 +264,6 @@ func (b *backendMock) FeeHistory(ctx context.Context, blockCount uint64, lastBlo
 func (b *backendMock) ChainDb() ethdb.Database           { return nil }
 func (b *backendMock) AccountManager() *accounts.Manager { return nil }
 func (b *backendMock) ExtRPCEnabled() bool               { return false }
-func (b *backendMock) MetroGRPCEndpoint() string         { return "" }
 func (b *backendMock) RPCGasCap() uint64                 { return 0 }
 func (b *backendMock) RPCEVMTimeout() time.Duration      { return time.Second }
 func (b *backendMock) RPCTxFeeCap() float64              { return 0 }

les/api_backend.go

@@ -19,7 +19,6 @@ package les
 import (
 	"context"
 	"errors"
-	"fmt"
 	"math/big"
 	"time"
 
@@ -293,10 +292,6 @@ func (b *LesApiBackend) UnprotectedAllowed() bool {
 	return b.allowUnprotectedTxs
 }
 
-func (b *LesApiBackend) MetroGRPCEndpoint() string {
-	return fmt.Sprintf("%s:%d", b.eth.config.MetroGRPCHost, b.eth.config.MetroGRPCPort)
-}
-
 func (b *LesApiBackend) RPCGasCap() uint64 {
 	return b.eth.config.RPCGasCap
 }