flags.go

// Copyright 2015 The go-ethereum Authors
// (original work)
// Copyright 2024 The Erigon Authors
// (modifications)
// This file is part of Erigon.
//
// Erigon is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// Erigon is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with Erigon. If not, see <http://www.gnu.org/licenses/>.

// Package utils contains internal helper functions for go-ethereum commands.
package utils

import (
	"crypto/ecdsa"
	"fmt"
	"math/big"
	"os"
	"path/filepath"
	"runtime"
	"strconv"
	"strings"
	"time"

	g "github.com/anacrolix/generics"
	"github.com/anacrolix/missinggo/v2/panicif"
	"github.com/c2h5oh/datasize"
	"github.com/holiman/uint256"
	"github.com/spf13/cobra"
	"github.com/spf13/pflag"
	"github.com/urfave/cli/v2"
	"golang.org/x/time/rate"

	"github.com/erigontech/erigon/cl/clparams"
	"github.com/erigontech/erigon/cl/clparams/devgenesis"
	"github.com/erigontech/erigon/cmd/downloader/downloadernat"
	"github.com/erigontech/erigon/cmd/utils/flags"
	"github.com/erigontech/erigon/common"
	libkzg "github.com/erigontech/erigon/common/crypto/kzg"
	"github.com/erigontech/erigon/common/dbg"
	"github.com/erigontech/erigon/common/log/v3"
	"github.com/erigontech/erigon/db/config3"
	"github.com/erigontech/erigon/db/datadir"
	"github.com/erigontech/erigon/db/downloader/downloadercfg"
	"github.com/erigontech/erigon/db/snapcfg"
	"github.com/erigontech/erigon/db/version"
	"github.com/erigontech/erigon/diagnostics/metrics"
	"github.com/erigontech/erigon/execution/builder/buildercfg"
	"github.com/erigontech/erigon/execution/chain/networkname"
	chainspec "github.com/erigontech/erigon/execution/chain/spec"
	"github.com/erigontech/erigon/execution/protocol/params"
	"github.com/erigontech/erigon/execution/protocol/rules/ethash/ethashcfg"
	"github.com/erigontech/erigon/execution/state/genesiswrite"
	"github.com/erigontech/erigon/execution/types"
	"github.com/erigontech/erigon/node/direct"
	"github.com/erigontech/erigon/node/ethconfig"
	"github.com/erigontech/erigon/node/logging"
	"github.com/erigontech/erigon/node/nodecfg"
	"github.com/erigontech/erigon/node/paths"
	"github.com/erigontech/erigon/p2p"
	"github.com/erigontech/erigon/p2p/enode"
	"github.com/erigontech/erigon/p2p/nat"
	"github.com/erigontech/erigon/p2p/netutil"
	"github.com/erigontech/erigon/polygon/heimdall"
	"github.com/erigontech/erigon/rpc/gasprice/gaspricecfg"
	"github.com/erigontech/erigon/rpc/rpccfg"
	"github.com/erigontech/erigon/txnprovider/shutter/shuttercfg"
	"github.com/erigontech/erigon/txnprovider/txpool/txpoolcfg"

	_ "github.com/erigontech/erigon/polygon/chain" // Register Polygon chains
)

// These are all the command line flags we support.
// If you add to this list, please remember to include the
// flag in the appropriate command definition.
//
// The flags are defined here so their names and help texts
// are the same for all commands.

var (
	// General settings
	DataDirFlag = flags.DirectoryFlag{
		Name:  "datadir",
		Usage: "Data directory for the databases",
		Value: flags.DirectoryString(paths.DefaultDataDir()),
	}
	NetworkIdFlag = cli.Uint64Flag{
		Name:  "networkid",
		Usage: "Explicitly set network id (integer)(For testnets: use --chain <testnet_name> instead)",
		Value: ethconfig.Defaults.NetworkID,
	}
	PersistReceiptsV2Flag = cli.BoolFlag{
		Name:    "persist.receipts",
		Aliases: []string{"experiment.persist.receipts.v2"},
		Usage:   "Download historical Receipts. If disabled: using state-history to re-exec transactions and generate Receipts - all RPC: eth_getLogs, eth_getBlockReceipts will work (just higher latency)",
		Value:   ethconfig.Defaults.PersistReceiptsCacheV2,
	}
	DevValidatorSeedFlag = cli.StringFlag{
		Name:  "dev-validator-seed",
		Usage: "Deterministic BLS key seed for embedded dev validator (enables PoS dev mode)",
		Value: "devnet",
	}
	DevValidatorCountFlag = cli.IntFlag{
		Name:  "dev-validator-count",
		Usage: "Number of validators for PoS dev mode",
		Value: 64,
	}
	DevSlotTimeFlag = cli.IntFlag{
		Name:  "dev.slot-time",
		Usage: "Slot duration in seconds for PoS dev mode (minimum: 2)",
		Value: 6,
	}
	ChainFlag = cli.StringFlag{
		Name:  "chain",
		Usage: "name of the network to join",
		// Can we remove this default? It can be destructive.
		// Giulio here after it broke CI: no, we cannot remove it.
		Value: networkname.Mainnet,
	}
	IdentityFlag = cli.StringFlag{
		Name:  "identity",
		Usage: "Custom node name",
	}
	WhitelistFlag = cli.StringFlag{
		Name:  "whitelist",
		Usage: "Comma separated block number-to-hash mappings to enforce (<number>=<hash>)",
	}
	OverrideOsakaFlag = cli.Uint64Flag{
		Name:  "override.osaka",
		Usage: "Manually specify the Osaka fork time, overriding the bundled setting",
	}
	OverrideAmsterdamFlag = cli.Uint64Flag{
		Name:  "override.amsterdam",
		Usage: "Manually specify the Amsterdam fork time, overriding the bundled setting",
	}
	KeepStoredChainConfigFlag = cli.BoolFlag{
		Name:  "keep.stored.chain.config",
		Usage: "Avoid overriding chain config already stored in the DB",
	}
	TrustedSetupFile = cli.StringFlag{
		Name:  "trusted-setup-file",
		Usage: "Absolute path to trusted_setup.json file",
	}
	// Ethash settings
	EthashCachesInMemoryFlag = cli.IntFlag{
		Name:  "ethash.cachesinmem",
		Usage: "Number of recent ethash caches to keep in memory (16MB each)",
		Value: ethconfig.Defaults.Ethash.CachesInMem,
	}
	EthashCachesLockMmapFlag = cli.BoolFlag{
		Name:  "ethash.cacheslockmmap",
		Usage: "Lock memory maps of recent ethash caches",
	}
	EthashDatasetDirFlag = flags.DirectoryFlag{
		Name:  "ethash.dagdir",
		Usage: "Directory to store the ethash mining DAGs",
		Value: flags.DirectoryString(ethconfig.Defaults.Ethash.DatasetDir),
	}
	EthashDatasetsLockMmapFlag = cli.BoolFlag{
		Name:  "ethash.dagslockmmap",
		Usage: "Lock memory maps for recent ethash mining DAGs",
	}
	ExternalConsensusFlag = cli.BoolFlag{
		Name:  "externalcl",
		Usage: "Enables the external consensus layer",
	}
	// Transaction pool settings
	TxPoolDisableFlag = cli.BoolFlag{
		Name:  "txpool.disable",
		Usage: "External pool and block producer, see ./cmd/txpool/readme.md for more info. Disabling internal txpool and block producer.",
		Value: false,
	}
	TxPoolGossipDisableFlag = cli.BoolFlag{
		Name:  "txpool.gossip.disable",
		Usage: "Disabling p2p gossip of txs. Any txs received by p2p - will be dropped. Some networks like 'Optimism execution engine'/'Optimistic Rollup' - using it to protect against MEV attacks",
		Value: txpoolcfg.DefaultConfig.NoGossip,
	}
	TxPoolPriceLimitFlag = cli.Uint64Flag{
		Name:  "txpool.pricelimit",
		Usage: "Minimum gas price (fee cap) limit to enforce for acceptance into the pool",
		Value: txpoolcfg.DefaultConfig.MinFeeCap,
	}
	TxPoolPriceBumpFlag = cli.Uint64Flag{
		Name:  "txpool.pricebump",
		Usage: "Price bump percentage to replace an already existing transaction",
		Value: txpoolcfg.DefaultConfig.PriceBump,
	}
	TxPoolBlobPriceBumpFlag = cli.Uint64Flag{
		Name:  "txpool.blobpricebump",
		Usage: "Price bump percentage to replace existing (type-3) blob transaction",
		Value: txpoolcfg.DefaultConfig.BlobPriceBump,
	}
	TxPoolAccountSlotsFlag = cli.Uint64Flag{
		Name:  "txpool.accountslots",
		Usage: "Minimum number of executable transaction slots guaranteed per account",
		Value: txpoolcfg.DefaultConfig.AccountSlots,
	}
	TxPoolBlobSlotsFlag = cli.Uint64Flag{
		Name:  "txpool.blobslots",
		Usage: "Max allowed total number of blobs (within type-3 txs) per account",
		Value: txpoolcfg.DefaultConfig.BlobSlots,
	}
	TxPoolTotalBlobPoolLimit = cli.Uint64Flag{
		Name:  "txpool.totalblobpoollimit",
		Usage: "Total limit of number of all blobs in txs within the txpool",
		Value: txpoolcfg.DefaultConfig.TotalBlobPoolLimit,
	}
	TxPoolGlobalSlotsFlag = cli.IntFlag{
		Name:  "txpool.globalslots",
		Usage: "Maximum number of executable transaction slots for all accounts",
		Value: txpoolcfg.DefaultConfig.PendingSubPoolLimit,
	}
	TxPoolGlobalBaseFeeSlotsFlag = cli.IntFlag{
		Name:  "txpool.globalbasefeeslots",
		Usage: "Maximum number of non-executable transactions where only not enough baseFee",
		Value: txpoolcfg.DefaultConfig.BaseFeeSubPoolLimit,
	}
	TxPoolGlobalQueueFlag = cli.IntFlag{
		Name:  "txpool.globalqueue",
		Usage: "Maximum number of non-executable transaction slots for all accounts",
		Value: txpoolcfg.DefaultConfig.QueuedSubPoolLimit,
	}
	TxPoolTraceSendersFlag = cli.StringFlag{
		Name:  "txpool.trace.senders",
		Usage: "Comma separated list of addresses, whose transactions will traced in transaction pool with debug printing",
		Value: "",
	}
	TxPoolCommitEveryFlag = cli.DurationFlag{
		Name:  "txpool.commit.every",
		Usage: "How often transactions should be committed to the storage",
		Value: txpoolcfg.DefaultConfig.CommitEvery,
	}
	TxPoolQueuedDormancyFlag = cli.DurationFlag{
		Name:  "txpool.queued.dormancy",
		Usage: "Evict queued transactions from senders with no on-chain state changes for this duration (e.g. 3h, 2h30m; 0 to disable)",
		Value: txpoolcfg.DefaultConfig.QueuedDormancyDuration,
	}

	// Block builder/proposer settings
	ProposingDisableFlag = cli.BoolFlag{
		Name:  "proposer.disable",
		Usage: "Disables PoS proposer",
	}
	MinerGasLimitFlag = cli.Uint64Flag{
		Name:  "miner.gaslimit",
		Usage: "Target gas limit for mined blocks",
	}
	MinerEtherbaseFlag = cli.StringFlag{
		Name:  "miner.etherbase",
		Usage: "Public address for block mining rewards",
		Value: "0",
	}
	MinerExtraDataFlag = cli.StringFlag{
		Name:  "miner.extradata",
		Usage: "Block extra data set by the miner (default = client version)",
	}
	BuilderMaxBlobsFlag = cli.Uint64Flag{
		Name:  "builder.maxblobs",
		Usage: "Cap the number of blob transactions included in a built block",
	}

	VMEnableDebugFlag = cli.BoolFlag{
		Name:  "vmdebug",
		Usage: "Record information useful for VM and contract debugging",
	}
	InsecureUnlockAllowedFlag = cli.BoolFlag{
		Name:  "allow-insecure-unlock",
		Usage: "Allow insecure account unlocking when account-related RPCs are exposed by http",
	}
	RPCGlobalGasCapFlag = cli.Uint64Flag{
		Name:  "rpc.gascap",
		Usage: "Sets a cap on gas that can be used in eth_call/estimateGas (0=infinite)",
		Value: ethconfig.Defaults.RPCGasCap,
	}
	RPCGlobalTxFeeCapFlag = cli.Float64Flag{
		Name:  "rpc.txfeecap",
		Usage: "Sets a cap on transaction fee (in ether) that can be sent via the RPC APIs (0 = no cap)",
		Value: ethconfig.Defaults.RPCTxFeeCap,
	}
	// Logging and debug settings
	EthStatsURLFlag = cli.StringFlag{
		Name:  "ethstats",
		Usage: "Reporting URL of a ethstats service (nodename:secret@host:port)",
		Value: "",
	}
	FakePoWFlag = cli.BoolFlag{
		Name:  "fakepow",
		Usage: "Disables proof-of-work verification",
	}
	// RPC settings
	IPCDisabledFlag = cli.BoolFlag{
		Name:  "ipcdisable",
		Usage: "Disable the IPC-RPC server",
	}
	IPCPathFlag = flags.DirectoryFlag{
		Name:  "ipcpath",
		Usage: "Filename for IPC socket/pipe within the datadir (explicit paths escape it)",
	}
	GraphQLEnabledFlag = cli.BoolFlag{
		Name:  "graphql",
		Usage: "Enable the graphql endpoint",
		Value: nodecfg.DefaultConfig.GraphQLEnabled,
	}
	HTTPEnabledFlag = cli.BoolFlag{
		Name:  "http",
		Usage: "JSON-RPC server (enabled by default). Use --http=false to disable it",
		Value: true,
	}
	HTTPServerEnabledFlag = cli.BoolFlag{
		Name:  "http.enabled",
		Usage: "JSON-RPC HTTP server (enabled by default). Use --http.enabled=false to disable it",
		Value: true,
	}
	HTTPListenAddrFlag = cli.StringFlag{
		Name:  "http.addr",
		Usage: "HTTP-RPC server listening interface",
		Value: nodecfg.DefaultHTTPHost,
	}
	HTTPPortFlag = cli.IntFlag{
		Name:  "http.port",
		Usage: "HTTP-RPC server listening port",
		Value: nodecfg.DefaultHTTPPort,
	}
	AuthRpcAddr = cli.StringFlag{
		Name:  "authrpc.addr",
		Usage: "HTTP-RPC server listening interface for the Engine API",
		Value: nodecfg.DefaultHTTPHost,
	}
	AuthRpcPort = cli.UintFlag{
		Name:  "authrpc.port",
		Usage: "HTTP-RPC server listening port for the Engine API",
		Value: nodecfg.DefaultAuthRpcPort,
	}

	JWTSecretPath = cli.StringFlag{
		Name:  "authrpc.jwtsecret",
		Usage: "Path to the token that ensures safe connection between CL and EL",
		Value: "",
	}

	HttpCompressionFlag = cli.BoolFlag{
		Name:  "http.compression",
		Usage: "Enable compression over HTTP-RPC. Use --http.compression=false to disable it",
		Value: true,
	}
	WsCompressionFlag = cli.BoolFlag{
		Name:  "ws.compression",
		Usage: "Enable compression over WebSocket (enabled by default in case WS-RPC is enabled). Use --ws.enabled=false to disable it",
		Value: true,
	}
	HTTPCORSDomainFlag = cli.StringFlag{
		Name:  "http.corsdomain",
		Usage: "Comma separated list of domains from which to accept cross origin requests (browser enforced)",
		Value: "",
	}
	HTTPVirtualHostsFlag = cli.StringFlag{
		Name:  "http.vhosts",
		Usage: "Comma separated list of virtual hostnames from which to accept requests (server enforced). Accepts 'any' or '*' as wildcard.",
		Value: strings.Join(nodecfg.DefaultConfig.HTTPVirtualHosts, ","),
	}
	AuthRpcVirtualHostsFlag = cli.StringFlag{
		Name:  "authrpc.vhosts",
		Usage: "Comma separated list of virtual hostnames from which to accept Engine API requests (server enforced). Accepts 'any' or '*' as wildcard.",
		Value: strings.Join(nodecfg.DefaultConfig.HTTPVirtualHosts, ","),
	}
	HTTPApiFlag = cli.StringFlag{
		Name:  "http.api",
		Usage: "API's offered over the HTTP-RPC interface",
		Value: "eth,erigon,engine",
	}
	RpcBatchConcurrencyFlag = cli.UintFlag{
		Name:  "rpc.batch.concurrency",
		Usage: "Does limit amount of goroutines to process 1 batch request. Means 1 batch request can't overload server. 1 batch still can have unlimited amount of request",
		Value: 2,
	}
	RpcStreamingDisableFlag = cli.BoolFlag{
		Name:  "rpc.streaming.disable",
		Usage: "Erigon has enabled json streaming for some heavy endpoints (like trace_*). It's a trade-off: greatly reduce amount of RAM (in some cases from 30GB to 30mb), but it produce invalid json format if error happened in the middle of streaming (because json is not streaming-friendly format)",
	}
	RpcBatchLimit = cli.IntFlag{
		Name:  "rpc.batch.limit",
		Usage: "Maximum number of requests in a batch",
		Value: 100,
	}
	RpcReturnDataLimit = cli.IntFlag{
		Name:  "rpc.returndata.limit",
		Usage: "Maximum number of bytes returned from eth_call or similar invocations",
		Value: 100_000,
	}
	HTTPTraceFlag = cli.BoolFlag{
		Name:  "http.trace",
		Usage: "Print all HTTP requests to logs with INFO level",
	}
	HTTPDebugSingleFlag = cli.BoolFlag{
		Name:    "http.dbg.single",
		Aliases: []string{"rpc.dbg.single"},
		Usage:   "Allow pass HTTP header 'dbg: true' to print more detailed logs - how this request was executed",
	}
	DBReadConcurrencyFlag = cli.IntFlag{
		Name:  "db.read.concurrency",
		Usage: "Does limit amount of parallel db reads. Default: equal to GOMAXPROCS (or number of CPU)",
		Value: min(max(10, runtime.GOMAXPROCS(-1)*64), 9_000),
	}
	RpcMaxConcurrentRequestsFlag = cli.IntFlag{
		Name:  "rpc.max.concurrency",
		Usage: "Maximum number of concurrent HTTP RPC requests (HTTP admission control). 0 = use db.read.concurrency, -1 = unlimited (no admission control)",
		Value: 0,
	}
	WsMaxConnectionsFlag = cli.IntFlag{
		Name:  "ws.max.connections",
		Usage: "Maximum number of concurrent WebSocket connections. 0 = unlimited",
		Value: 0,
	}
	RpcAccessListFlag = cli.StringFlag{
		Name:  "rpc.accessList",
		Usage: "Specify granular (method-by-method) API allowlist",
	}

	RpcGasCapFlag = cli.UintFlag{
		Name:  "rpc.gascap",
		Usage: "Sets a cap on gas that can be used in eth_call/estimateGas",
		Value: 50000000,
	}
	RpcBlockRangeLimit = cli.IntFlag{
		Name:  "rpc.blockrange.limit",
		Usage: "Maximum block range (end - begin) allowed for range queries (0 = unlimited)",
		Value: 1_000,
	}
	RpcGetLogsMaxResults = cli.IntFlag{
		Name:  "rpc.logs.maxresults",
		Usage: "Maximum number of logs returned by eth_getLogs, erigon_getLogs, erigon_getLatestLogs (0 = unlimited)",
		Value: 20_000,
	}
	RpcTraceCompatFlag = cli.BoolFlag{
		Name:  "trace.compat",
		Usage: "Bug for bug compatibility with OE for trace_ routines",
	}
	RpcGethCompatFlag = cli.BoolFlag{
		Name:  "rpc.gethcompat",
		Usage: "Enables Geth-compatible storage iteration order for debug_storageRangeAt (sorted by keccak256 hash). Disabled by default for performance.",
	}
	RpcTxSyncDefaultTimeoutFlag = cli.DurationFlag{
		Name:  "rpc.txsync.defaulttimeout",
		Usage: "Default timeout for eth_sendRawTransactionSync (default: 25 secs).",
		Value: rpccfg.DefaultRpcTxSyncDefaultTimeout,
	}
	RpcTxSyncMaxTimeoutFlag = cli.DurationFlag{
		Name:  "rpc.txsync.maxtimeout",
		Usage: "Maximum allowed timeout for eth_sendRawTransactionSync (default: 1 min).",
		Value: rpccfg.DefaultRpcTxSyncMaxTimeout,
	}

	TxpoolApiAddrFlag = cli.StringFlag{
		Name:  "txpool.api.addr",
		Usage: "TxPool api network address, for example: 127.0.0.1:9090 (default: use value of --private.api.addr)",
	}

	TraceMaxtracesFlag = cli.UintFlag{
		Name:  "trace.maxtraces",
		Usage: "Sets a limit on traces that can be returned in trace_filter",
		Value: 200,
	}

	HTTPPathPrefixFlag = cli.StringFlag{
		Name:  "http.rpcprefix",
		Usage: "HTTP path prefix on which JSON-RPC is served. Use '/' to serve on all paths.",
		Value: "",
	}
	TLSFlag = cli.BoolFlag{
		Name:  "tls",
		Usage: "Enable TLS handshake",
	}
	TLSCertFlag = cli.StringFlag{
		Name:  "tls.cert",
		Usage: "Specify certificate",
		Value: "",
	}
	TLSKeyFlag = cli.StringFlag{
		Name:  "tls.key",
		Usage: "Specify key file",
		Value: "",
	}
	TLSCACertFlag = cli.StringFlag{
		Name:  "tls.cacert",
		Usage: "Specify certificate authority",
		Value: "",
	}
	WSEnabledFlag = cli.BoolFlag{
		Name:  "ws",
		Usage: "Enable the WS-RPC server",
	}
	WSListenAddrFlag = cli.StringFlag{
		Name:  "ws.addr",
		Usage: "WS-RPC server listening interface",
		Value: nodecfg.DefaultWSHost,
	}
	WSPortFlag = cli.IntFlag{
		Name:  "ws.port",
		Usage: "WS-RPC server listening port",
		Value: nodecfg.DefaultWSPort,
	}
	WSApiFlag = cli.StringFlag{
		Name:  "ws.api",
		Usage: "API's offered over the WS-RPC interface",
		Value: "",
	}
	WSAllowedOriginsFlag = cli.StringFlag{
		Name:  "ws.origins",
		Usage: "Origins from which to accept websockets requests",
		Value: "",
	}
	WSPathPrefixFlag = cli.StringFlag{
		Name:  "ws.rpcprefix",
		Usage: "HTTP path prefix on which JSON-RPC is served. Use '/' to serve on all paths.",
		Value: "",
	}
	WSSubscribeLogsChannelSize = cli.IntFlag{
		Name:  "ws.api.subscribelogs.channelsize",
		Usage: "Size of the channel used for websocket logs subscriptions",
		Value: 8192,
	}
	ExecFlag = cli.StringFlag{
		Name:  "exec",
		Usage: "Execute JavaScript statement",
	}
	PreloadJSFlag = cli.StringFlag{
		Name:  "preload",
		Usage: "Comma separated list of JavaScript files to preload into the console",
	}
	AllowUnprotectedTxs = cli.BoolFlag{
		Name:  "rpc.allow-unprotected-txs",
		Usage: "Allow for unprotected (non-EIP155 signed) transactions to be submitted via RPC",
	}
	StateCacheFlag = cli.StringFlag{
		Name:  "state.cache",
		Value: "0MB",
		Usage: "Amount of data to store in StateCache (enabled if no --datadir set). Set 0 to disable StateCache. Defaults to 0MB",
	}

	// Network Settings
	MaxPeersFlag = cli.IntFlag{
		Name:  "maxpeers",
		Usage: "Maximum number of network peers per protocol version (network disabled if set to 0)",
		Value: nodecfg.DefaultConfig.P2P.MaxPeers,
	}
	MaxPendingPeersFlag = cli.IntFlag{
		Name:  "maxpendpeers",
		Usage: "Maximum number of TCP connections pending to become connected peers (per protocol version)",
		Value: nodecfg.DefaultConfig.P2P.MaxPendingPeers,
	}
	ListenPortFlag = cli.IntFlag{
		Name:  "port",
		Usage: "Network listening port",
		Value: 30303,
	}
	P2pProtocolVersionFlag = cli.UintSliceFlag{
		Name:  "p2p.protocol",
		Usage: "Version of eth p2p protocol",
		Value: cli.NewUintSlice(nodecfg.DefaultConfig.P2P.ProtocolVersion...),
	}
	P2pProtocolAllowedPorts = cli.UintSliceFlag{
		Name:  "p2p.allowed-ports",
		Usage: "Allowed ports to pick for different eth p2p protocol versions as follows <porta>,<portb>,..,<porti>",
		Value: cli.NewUintSlice(uint(ListenPortFlag.Value), 30304, 30305, 30306, 30307),
	}
	SentryAddrFlag = cli.StringFlag{
		Name:  "sentry.api.addr",
		Usage: "Comma separated sentry addresses '<host>:<port>,<host>:<port>'",
	}
	SentryLogPeerInfoFlag = cli.BoolFlag{
		Name:  "sentry.log-peer-info",
		Usage: "Log detailed peer info when a peer connects or disconnects. Enable to integrate with observer.",
	}
	DownloaderAddrFlag = cli.StringFlag{
		Name:  "downloader.api.addr",
		Usage: "downloader address '<host>:<port>'",
	}
	BootnodesFlag = cli.StringFlag{
		Name:  "bootnodes",
		Usage: "Comma separated enode URLs for P2P discovery bootstrap",
		Value: "",
	}
	StaticPeersFlag = cli.StringFlag{
		Name:  "staticpeers",
		Usage: "Comma separated enode URLs to connect to",
		Value: "",
	}
	TrustedPeersFlag = cli.StringFlag{
		Name:  "trustedpeers",
		Usage: "Comma separated enode URLs which are always allowed to connect, even above the peer limit",
		Value: "",
	}
	NodeKeyFileFlag = cli.StringFlag{
		Name:  "nodekey",
		Usage: "P2P node key file",
	}
	NodeKeyHexFlag = cli.StringFlag{
		Name:  "nodekeyhex",
		Usage: "P2P node key as hex (for testing)",
	}
	NATFlag = cli.StringFlag{
		Name: "nat",
		Usage: `NAT port mapping mechanism (any|none|upnp|pmp|stun|extip:<IP>)
			 "" or "none"         Default - do not nat
			 "extip:77.12.33.4"   Will assume the local machine is reachable on the given IP
			 "any"                Uses the first auto-detected mechanism
			 "upnp"               Uses the Universal Plug and Play protocol
			 "pmp"                Uses NAT-PMP with an auto-detected gateway address
			 "pmp:192.168.0.1"    Uses NAT-PMP with the given gateway address
			 "stun"               Uses STUN to detect an external IP using a default server
			 "stun:<server>"      Uses STUN to detect an external IP using the given server (host:port)
`,
		Value: "",
	}
	NoDiscoverFlag = cli.BoolFlag{
		Name:  "nodiscover",
		Usage: "Disables the peer discovery mechanism (manual peer addition)",
	}
	DiscoveryV4Flag = cli.BoolFlag{
		Name:    "discovery.v4",
		Aliases: []string{"discv4"},
		Usage:   "Enables the V4 discovery mechanism",
		Value:   nodecfg.DefaultConfig.P2P.DiscoveryV4,
	}
	DiscoveryV5Flag = cli.BoolFlag{
		Name: "discovery.v5",
		// The first is for old Geth style, and the second is Erigon backward compatibility.
		Aliases: []string{"discv5", "v5disc"},
		Usage:   "Enables the V5 discovery mechanism",
		Value:   nodecfg.DefaultConfig.P2P.DiscoveryV5,
	}
	NetrestrictFlag = cli.StringFlag{
		Name:  "netrestrict",
		Usage: "Restricts network communication to the given IP networks (CIDR masks)",
	}
	DNSDiscoveryFlag = cli.StringFlag{
		Name:  "discovery.dns",
		Usage: "Sets DNS discovery entry points (use \"\" to disable DNS)",
	}

	// ATM the url is left to the user and deployment to
	JSpathFlag = cli.StringFlag{
		Name:  "jspath",
		Usage: "JavaScript root path for `loadScript`",
		Value: ".",
	}

	// Gas price oracle settings
	GpoBlocksFlag = cli.IntFlag{
		Name:  "gpo.blocks",
		Usage: "Number of recent blocks to check for gas prices",
		Value: ethconfig.Defaults.GPO.Blocks,
	}
	GpoPercentileFlag = cli.IntFlag{
		Name:  "gpo.percentile",
		Usage: "Suggested gas price is the given percentile of a set of recent transaction gas prices",
		Value: ethconfig.Defaults.GPO.Percentile,
	}
	GpoMaxGasPriceFlag = cli.Uint64Flag{
		Name:  "gpo.maxprice",
		Usage: "Maximum gas price will be recommended by gpo",
		Value: ethconfig.Defaults.GPO.MaxPrice.Uint64(),
	}

	// Metrics flags
	MetricsEnabledFlag = cli.BoolFlag{
		Name:  "metrics",
		Usage: "Enable metrics collection and reporting",
	}

	// MetricsHTTPFlag defines the endpoint for a stand-alone metrics HTTP endpoint.
	// Since the pprof service enables sensitive/vulnerable behavior, this allows a user
	// to enable a public-OK metrics endpoint without having to worry about ALSO exposing
	// other profiling behavior or information.
	MetricsHTTPFlag = cli.StringFlag{
		Name:  "metrics.addr",
		Usage: "Enable stand-alone metrics HTTP server listening interface",
		Value: metrics.DefaultConfig.HTTP,
	}
	MetricsPortFlag = cli.IntFlag{
		Name:  "metrics.port",
		Usage: "Metrics HTTP server listening port",
		Value: metrics.DefaultConfig.Port,
	}

	SnapKeepBlocksFlag = cli.BoolFlag{
		Name:  ethconfig.FlagSnapKeepBlocks,
		Usage: "Keep ancient blocks in db (useful for debug)",
	}
	SnapStopFlag = cli.BoolFlag{
		Name:  ethconfig.FlagSnapStop,
		Usage: "Workaround to stop producing new snapshots, if you meet some snapshots-related critical bug. It will stop move historical data from DB to new immutable snapshots. DB will grow and may slightly slow-down - and removing this flag in future will not fix this effect (db size will not greatly reduce).",
	}
	SnapStateStopFlag = cli.BoolFlag{
		Name:  ethconfig.FlagSnapStateStop,
		Usage: "Workaround to stop producing new state files, if you meet some state-related critical bug. It will stop aggregate DB history in a state files. DB will grow and may slightly slow-down - and removing this flag in future will not fix this effect (db size will not greatly reduce).",
	}
	SnapSkipStateSnapshotDownloadFlag = cli.BoolFlag{
		Name:  "snap.skip-state-snapshot-download",
		Usage: "Skip state download and start from genesis block",
		Value: false,
	}
	SnapP2PManifestFlag = cli.BoolFlag{
		Name:  "snap.p2p-manifest",
		Usage: "Discover snapshot manifest (chain.toml) from P2P peers via ENR instead of using centralized preverified.toml",
	}
	SnapDownloadToBlockFlag = cli.Uint64Flag{
		Name:    "snap.download.to.block",
		Usage:   "Download snapshots up to the given block number (exclusive). Disabled by default. Useful for testing and shadow forks.",
		Aliases: []string{"shadow.fork.block"},
	}
	TorrentVerbosityFlag = cli.IntFlag{
		Name:  "torrent.verbosity",
		Value: 1,
		Usage: "0=silent, 1=error, 2=warn, 3=info, 4=debug, 5=detail (must set --verbosity to equal or higher level)",
	}
	TorrentDownloadRateFlag = cli.StringFlag{
		Name: "torrent.download.rate",
		// Default for 3.1. Try not drain the whole swarm by default.
		Value: "512mb",
		Usage: "Bytes per second, example: 32mb. Set Inf for no limit. Shared with webseeds unless that rate is set separately.",
	}
	// Decided to not provide a default to keep things simpler (so it shares whatever
	// TorrentDownloadRateFlag is set to).
	TorrentWebseedDownloadRateFlag = cli.StringFlag{
		Name:  "torrent.webseed.download.rate",
		Usage: "Bytes per second for webseeds, example: 32mb. Set Inf for no limit. If not set, rate limit is shared with torrent.download.rate",
	}
	TorrentUploadRateFlag = cli.StringFlag{
		Name: "torrent.upload.rate",
		// Agreed in meeting to leave it quite a bit higher than 3.0 unless it becomes a problem.
		Value: "16mb",
		Usage: "Bytes per second, example: 32mb. Set Inf for no limit.",
	}
	// Deprecated (v3.0): This flag no longer has any effect and will be removed in a future release.
	// The downloader now manages concurrent downloads automatically based on available resources.
	// Previously controlled the number of files to download in parallel, but this is now handled
	// internally by the BitTorrent client's resource management.
	TorrentDownloadSlotsFlag = cli.IntFlag{
		Name:   "torrent.download.slots",
		Value:  32, // Keep default for backward compatibility
		Usage:  "(DEPRECATED: No longer has any effect) Amount of files to download in parallel.",
		Hidden: true,
	}
	// TODO: Currently unused.
	TorrentStaticPeersFlag = cli.StringFlag{
		Name:   "torrent.staticpeers",
		Usage:  "Comma separated host:port to connect to",
		Value:  "",
		Hidden: true,
	}
	TorrentDisableTrackers = cli.BoolFlag{
		Name:  "torrent.trackers.disable",
		Usage: "Disable conventional BitTorrent trackers",
	}
	NoDownloaderFlag = cli.BoolFlag{
		Name:  "no-downloader",
		Usage: "Disables downloader component",
	}
	DownloaderVerifyFlag = cli.BoolFlag{
		Name:  "downloader.verify",
		Usage: "Verify snapshots on startup. It will not report problems found, but re-download broken pieces.",
	}
	DisableIPV6 = cli.BoolFlag{
		Name:  "downloader.disable.ipv6",
		Usage: "Turns off ipv6 for the downloader",
		Value: false,
	}

	DisableIPV4 = cli.BoolFlag{
		Name:  "downloader.disable.ipv4",
		Usage: "Turns off ipv4 for the downloader",
		Value: false,
	}
	TorrentPortFlag = cli.IntFlag{
		Name:  "torrent.port",
		Value: 42069,
		Usage: "Port to listen and serve BitTorrent protocol",
	}
	TorrentMaxPeersFlag = cli.IntFlag{
		Name:  "torrent.maxpeers",
		Value: 100,
		Usage: "Unused parameter (reserved for future use)",
	}
	TorrentConnsPerFileFlag = cli.IntFlag{
		Name:  "torrent.conns.perfile",
		Value: 10,
		Usage: "Number of connections per file",
	}
	DbPageSizeFlag = cli.StringFlag{
		Name:  "db.pagesize",
		Usage: "DB is split to 'pages' of fixed size. Can't change DB creation. Must be power of 2 and '256b <= pagesize <= 64kb'. Default: equal to OperationSystem's pageSize. Bigger pageSize causing: 1. More writes to disk during commit 2. Smaller b-tree high 3. Less fragmentation 4. Less overhead on 'free-pages list' maintenance (a bit faster Put/Commit) 5. If expecting DB-size > 8Tb then set pageSize >= 8Kb",
		Value: ethconfig.DefaultChainDBPageSize.String(),
	}
	DbSizeLimitFlag = cli.StringFlag{
		Name:  "db.size.limit",
		Usage: "Runtime limit of chaindata db size (can change at any time)",
		Value: (1 * datasize.TB).String(),
	}
	DbWriteMapFlag = cli.BoolFlag{
		Name:  "db.writemap",
		Usage: "Enable WRITE_MAP feature for fast database writes and fast commit times",
		Value: true,
	}

	HealthCheckFlag = cli.BoolFlag{
		Name:  "healthcheck",
		Usage: "Enable grpc health check",
	}

	WebSeedsFlag = cli.StringFlag{
		Name:  "webseed",
		Usage: "Comma-separated URL's, holding metadata about network-support infrastructure (like S3 buckets with snapshots, bootnodes, etc...)",
		Value: "",
	}

	HeimdallURLFlag = cli.StringFlag{
		Name:  "bor.heimdall",
		Usage: "URL of Heimdall service",
		Value: "http://localhost:1317",
	}

	// WithoutHeimdallFlag no heimdall (for testing purpose)
	WithoutHeimdallFlag = cli.BoolFlag{
		Name:  "bor.withoutheimdall",
		Usage: "Run without Heimdall service (for testing purposes)",
	}

	BorBlockPeriodFlag = cli.BoolFlag{
		Name:  "bor.period",
		Usage: "Override the bor block period (for testing purposes)",
	}

	BorBlockSizeFlag = cli.BoolFlag{
		Name:  "bor.minblocksize",
		Usage: "Ignore the bor block period and wait for 'blocksize' transactions (for testing purposes)",
	}

	AAFlag = cli.BoolFlag{
		Name:  "aa",
		Usage: "Enable AA transactions",
		Value: false,
	}

	ConfigFlag = cli.StringFlag{
		Name:  "config",
		Usage: "Sets erigon flags from YAML/TOML file",
		Value: "",
	}

	CaplinDiscoveryAddrFlag = cli.StringFlag{
		Name:  "caplin.discovery.addr",
		Usage: "Address for Caplin DISCV5 protocol",
		Value: "0.0.0.0",
	}
	CaplinDiscoveryPortFlag = cli.Uint64Flag{
		Name:  "caplin.discovery.port",
		Usage: "Port for Caplin DISCV5 protocol",
		Value: 4000,
	}
	CaplinDiscoveryTCPPortFlag = cli.Uint64Flag{
		Name:  "caplin.discovery.tcpport",
		Usage: "TCP Port for Caplin DISCV5 protocol",
		Value: 4001,
	}
	CaplinEnableUPNPlag = cli.BoolFlag{
		Name:  "caplin.enable-upnp",
		Usage: "Enable NAT porting for Caplin",
		Value: false,
	}
	CaplinNATFlag = cli.StringFlag{
		Name: "caplin.nat",
		Usage: `NAT port mapping for Caplin P2P. Sets the external IP advertised in the discv5 ENR and libp2p
		multiaddrs while the socket still binds to --caplin.discovery.addr (typically 0.0.0.0).
		Required when running inside Docker or behind NAT to allow incoming peer connections.
		         ""               Default — no NAT, use bind address as-is
		         "extip:1.2.3.4"  Explicit public IP (recommended for VPS/Docker with static IP)
		         "stun"           Detect public IP via STUN (default server: stun.l.google.com:19302)
		         "stun:<host>"    Detect public IP via STUN using a custom server
		         "upnp"           Use UPnP to discover external IP and map ports (home routers)
		         "pmp"            Use NAT-PMP with auto-detected gateway
		         "pmp:192.168.0.1" Use NAT-PMP with explicit gateway`,
		Value: "",
	}
	CaplinMaxInboundTrafficPerPeerFlag = cli.StringFlag{
		Name:  "caplin.max-inbound-traffic-per-peer",
		Usage: "Max inbound traffic per second per peer",
		Value: "1MB",
	}
	CaplinMaxOutboundTrafficPerPeerFlag = cli.StringFlag{
		Name:  "caplin.max-outbound-traffic-per-peer",
		Usage: "Max outbound traffic per second per peer",
		Value: "1MB",
	}
	CaplinAdaptableTrafficRequirementsFlag = cli.BoolFlag{
		Name:  "caplin.adaptable-maximum-traffic-requirements",
		Usage: "Make the node adaptable to the maximum traffic requirement based on how many validators are being ran",
		Value: true,
	}
	CaplinCheckpointSyncUrlFlag = cli.StringSliceFlag{
		Name:  "caplin.checkpoint-sync-url",
		Usage: "checkpoint sync endpoint",
		Value: cli.NewStringSlice(),
	}
	CaplinSubscribeAllTopicsFlag = cli.BoolFlag{
		Name:  "caplin.subscribe-all-topics",
		Usage: "Subscribe to all gossip topics",
		Value: false,
	}
	CaplinMevRelayUrl = cli.StringFlag{
		Name:  "caplin.mev-relay-url",
		Usage: "MEV relay endpoint. Caplin runs in builder mode if this is set",
		Value: "",
	}
	CaplinValidatorMonitorFlag = cli.BoolFlag{
		Name:  "caplin.validator-monitor",
		Usage: "Enable caplin validator monitoring metrics",
		Value: false,
	}
	CaplinMaxPeerCount = cli.Uint64Flag{
		Name:  "caplin.max-peer-count",
		Usage: "Max number of peers to connect",
		Value: 128,
	}
	CaplinUseEngineApiFlag = cli.BoolFlag{
		Name:  "caplin.use-engine-api",
		Usage: "Use engine API for internal Caplin. useful for testing and if CL network is degraded",
		Value: false,
	}
	SentinelAddrFlag = cli.StringFlag{
		Name:  "sentinel.addr",
		Usage: "Address for sentinel",
		Value: "localhost",
	}
	SentinelPortFlag = cli.Uint64Flag{
		Name:  "sentinel.port",
		Usage: "Port for sentinel",
		Value: 7777,
	}
	SentinelBootnodes = cli.StringSliceFlag{
		Name:  "sentinel.bootnodes",
		Usage: "Comma separated enode URLs for P2P discovery bootstrap",
		Value: cli.NewStringSlice(),
	}
	SentinelStaticPeers = cli.StringSliceFlag{
		Name:  "sentinel.staticpeers",
		Usage: "connect to comma-separated Consensus static peers",
		Value: cli.NewStringSlice(),
	}

	OtsSearchMaxCapFlag = cli.Uint64Flag{
		Name:  "ots.search.max.pagesize",
		Usage: "Max allowed page size for search methods",
		Value: 25,
	}

	BeaconAPIFlag = cli.StringSliceFlag{
		Name:  "beacon.api",
		Usage: "Enable beacon API (available endpoints: beacon, builder, config, debug, events, node, validator, lighthouse)",
	}
	BeaconApiProtocolFlag = cli.StringFlag{
		Name:  "beacon.api.protocol",
		Usage: "Protocol for beacon API",
		Value: "tcp",
	}
	BeaconApiReadTimeoutFlag = cli.Uint64Flag{
		Name:  "beacon.api.read.timeout",
		Usage: "Sets the seconds for a read time out in the beacon api",
		Value: 5,
	}
	BeaconApiWriteTimeoutFlag = cli.Uint64Flag{
		Name:  "beacon.api.write.timeout",
		Usage: "Sets the seconds for a write time out in the beacon api",
		Value: 31536000,
	}
	BeaconApiIdleTimeoutFlag = cli.Uint64Flag{
		Name:  "beacon.api.idle.timeout",
		Usage: "Sets the seconds for a write time out in the beacon api",
		Value: 25,
	}
	BeaconApiAddrFlag = cli.StringFlag{
		Name:  "beacon.api.addr",
		Usage: "sets the host to listen for beacon api requests",
		Value: "localhost",
	}
	BeaconApiPortFlag = cli.UintFlag{
		Name:  "beacon.api.port",
		Usage: "sets the port to listen for beacon api requests",
		Value: 5555,
	}
	RPCSlowFlag = cli.DurationFlag{
		Name:  "rpc.slow",
		Usage: "Print in logs RPC requests slower than given threshold: 100ms, 1s, 1m. Excluded methods: " + strings.Join(rpccfg.SlowLogBlackList, ","),
		Value: 0,
	}
	CaplinArchiveBlocksFlag = cli.BoolFlag{
		Name:  "caplin.blocks-archive",
		Usage: "sets whether backfilling is enabled for caplin",
		Value: false,
	}
	CaplinArchiveStatesFlag = cli.BoolFlag{
		Name:  "caplin.states-archive",
		Usage: "enables archival node for historical states in caplin (it will enable block archival as well)",
		Value: false,
	}
	CaplinArchiveBlobsFlag = cli.BoolFlag{
		Name:  "caplin.blobs-archive",
		Usage: "sets whether backfilling is enabled for caplin",
		Value: false,
	}
	CaplinImmediateBlobBackfillFlag = cli.BoolFlag{
		Name:  "caplin.blobs-immediate-backfill",
		Usage: "sets whether caplin should immediately backfill blobs (4096 epochs)",
		Value: false,
	}
	CaplinDisableBlobPruningFlag = cli.BoolFlag{
		Name:  "caplin.blobs-no-pruning",
		Usage: "disable blob pruning in caplin",
		Value: false,
	}
	CaplinColumnKeepSlotsFlag = cli.Uint64Flag{
		Name:  "caplin.columns-keep-slots",
		Usage: "number of slots to retain PeerDAS data column sidecars (default: MIN_EPOCHS_FOR_DATA_COLUMN_SIDECARS_REQUESTS * SLOTS_PER_EPOCH = 131072, ~18 days); increase for DA oracle or rollup nodes that need longer column history",
		Value: 131072,
	}
	CaplinDisableCheckpointSyncFlag = cli.BoolFlag{
		Name:  "caplin.checkpoint-sync.disable",
		Usage: "disable checkpoint sync in caplin",
		Value: false,
	}

	CaplinEnableSnapshotGeneration = cli.BoolFlag{
		Name:  "caplin.snapgen",
		Usage: "enables snapshot generation in caplin",
		Value: false,
	}
	BeaconApiAllowCredentialsFlag = cli.BoolFlag{
		Name:  "beacon.api.cors.allow-credentials",
		Usage: "set the cors' allow credentials",
		Value: false,
	}
	BeaconApiAllowMethodsFlag = cli.StringSliceFlag{
		Name:  "beacon.api.cors.allow-methods",
		Usage: "set the cors' allow methods",
		Value: cli.NewStringSlice("GET", "POST", "PUT", "DELETE", "OPTIONS"),
	}
	BeaconApiAllowOriginsFlag = cli.StringSliceFlag{
		Name:  "beacon.api.cors.allow-origins",
		Usage: "set the cors' allow origins",
		Value: cli.NewStringSlice(),
	}
	CaplinCustomConfigFlag = cli.StringFlag{
		Name:  "caplin.custom-config",
		Usage: "set the custom config for caplin",
		Value: "",
	}
	CaplinCustomGenesisFlag = cli.StringFlag{
		Name:  "caplin.custom-genesis",
		Usage: "set the custom genesis for caplin",
		Value: "",
	}
	ChaosMonkeyFlag = cli.BoolFlag{
		Name:  "chaos.monkey",
		Usage: "Enable 'chaos monkey' to generate spontaneous network/consensus/etc failures. Use ONLY for testing",
		Value: false,
	}
	ShutterEnabledFlag = cli.BoolFlag{
		Name:  "shutter",
		Usage: "Enable the Shutter encrypted transactions mempool (defaults to false)",
	}
	ShutterP2pBootstrapNodesFlag = cli.StringSliceFlag{
		Name:  "shutter.p2p.bootstrap.nodes",
		Usage: "Use to override the default p2p bootstrap nodes (defaults to using the values in the embedded config)",
	}
	ShutterP2pListenPortFlag = cli.UintFlag{
		Name:  "shutter.p2p.listen.port",
		Usage: "Use to override the default p2p listen port (defaults to 23102)",
	}
	PolygonPosSingleSlotFinalityFlag = cli.BoolFlag{
		Name:  "polygon.pos.ssf",
		Usage: "Enabling Polygon PoS Single Slot Finality",
	}
	PolygonPosSingleSlotFinalityBlockAtFlag = cli.Int64Flag{
		Name:  "polygon.pos.ssf.block",
		Usage: "Enabling Polygon PoS Single Slot Finality since block",
	}
	PolygonPosWitProtocolFlag = cli.BoolFlag{
		Name:  "polygon.wit-protocol",
		Usage: "Enable WIT protocol for stateless witness data exchange (auto-enabled for Bor chains)",
	}
	ExperimentalConcurrentCommitmentFlag = cli.BoolFlag{
		Name:  "experimental.concurrent-commitment",
		Usage: "EXPERIMENTAL: enables concurrent trie for commitment",
		Value: false,
	}
	GDBMeFlag = cli.BoolFlag{
		Name:  "gdbme",
		Usage: "restart erigon under gdb for debug purposes",
		Value: false,
	}
	KeepExecutionProofsFlag = cli.BoolFlag{
		Name:    "prune.include-commitment-history",
		Usage:   "Enables blazing fast eth_getProof for executed block",
		Aliases: []string{"experimental.commitment-history", "prune.experimental.include-commitment-history"},
	}
	AlwaysGenerateChangesetsFlag = cli.BoolFlag{
		Name:  "experimental.always-generate-changesets",
		Usage: "Allows to override changesets generation logic",
	}
	FcuTimeoutFlag = cli.DurationFlag{
		Name:  "fcu.timeout",
		Usage: "FCU timeout before it switches to being process async (use 0 to disable)",
		Value: ethconfig.Defaults.FcuTimeout,
	}
	FcuBackgroundPruneFlag = cli.BoolFlag{
		Name:  "fcu.background.prune",
		Usage: "Enables background pruning post fcu",
		Value: ethconfig.Defaults.FcuBackgroundPrune,
	}
	FcuBackgroundCommitFlag = cli.BoolFlag{
		Name:  "fcu.background.commit",
		Usage: "Enables background flush and commit",
		Value: ethconfig.Defaults.FcuBackgroundCommit,
	}
	MCPDisableFlag = cli.BoolFlag{
		Name:  "mcp.disable",
		Usage: "Disables the embedded MCP server",
		Value: false,
	}
	MCPAddrFlag = cli.StringFlag{
		Name:  "mcp.addr",
		Usage: "Address for MCP RPC server",
		Value: "127.0.0.1",
	}
	MCPPortFlag = cli.UintFlag{
		Name:  "mcp.port",
		Usage: "Port for MCP RPC server",
		Value: 8553,
	}
	ErigondbDomainStepsInFrozenFileFlag = cli.StringFlag{
		Name:  "erigondb.domain.steps-in-frozen-file",
		Usage: `Override erigondb.toml "steps_in_frozen_file" for the domain merge cap only (history/inverted-index merges are unaffected). Pass a positive integer to set an explicit cap, or "Inf" to leave the domain merge unbounded. Default: unset, meaning the domain uses the same cap as determined by erigondb.toml.`,
	}
	ExecBatchedIOFlag = cli.BoolFlag{
		Name:  "exec.batched-io",
		Usage: "Enable BAL-driven I/O and write-dependency optimisations: (1) read-ahead pre-warms the DB page cache with account/code/storage reads before block execution (READ_AHEAD=true), and (2) the parallel executor pre-populates the version map from BAL hints (IGNORE_BAL=false). Disable for cold-read or non-BAL scheduling performance measurements.",
		Value: true,
	}
	ExecStateCacheFlag = cli.BoolFlag{
		Name:  "exec.state-cache",
		Usage: "Enable the executor domain-shared read cache (equivalent to USE_STATE_CACHE=true). Disable for cold-read performance measurements.",
		Value: true,
	}
	ExecWorkersFlag = cli.IntFlag{
		Name:  "exec.workers",
		Usage: "Parallel executor worker count (equivalent to EXEC3_WORKERS). Default: half the number of CPU cores, other half reserved for snapshots build/merge/prune.",
		Value: runtime.NumCPU() / 2,
	}
	ExecSerialFlag = cli.BoolFlag{
		Name:  "exec.serial",
		Usage: "Force serial execution by clamping the parallel executor to a single worker. Wins over --exec.workers and EXEC3_WORKERS — use to disable parallelism for diagnostics or like-for-like baseline comparisons.",
		Value: false,
	}
	ExecNoMergeFlag = cli.BoolFlag{
		Name:  "exec.no-merge",
		Usage: "Disable state-aggregator file merges for Domain / History / Inverted-Index (equivalent to NO_MERGE=true). Diagnostic / perf-comparison use only.",
		Value: false,
	}
	ExecNoPruneFlag = cli.BoolFlag{
		Name:  "exec.no-prune",
		Usage: "Disable state-aggregator pruning of historical steps (equivalent to NO_PRUNE=true). Diagnostic / perf-comparison use only.",
		Value: false,
	}
)

var MetricFlags = []cli.Flag{&MetricsEnabledFlag, &MetricsHTTPFlag, &MetricsPortFlag}

var devnetEtherbase = common.HexToAddress("67b1d87101671b127f5f8714789c7192f7ad340e")

// setNodeKey loads a node key from command line flags if provided,
// otherwise it tries to load it from datadir,
// otherwise it generates a new key in datadir.
func setNodeKey(ctx *cli.Context, cfg *p2p.Config, datadir string) {
	file := ctx.String(NodeKeyFileFlag.Name)
	hex := ctx.String(NodeKeyHexFlag.Name)

	config := p2p.NodeKeyConfig{}
	key, err := config.LoadOrParseOrGenerateAndSave(file, hex, datadir)
	if err != nil {
		Fatalf("%v", err)
	}
	cfg.PrivateKey = key
}

// setNodeUserIdent creates the user identifier from CLI flags.
func setNodeUserIdent(ctx *cli.Context, cfg *nodecfg.Config) {
	if identity := ctx.String(IdentityFlag.Name); len(identity) > 0 {
		cfg.UserIdent = identity
	}
}
func setNodeUserIdentCobra(f *pflag.FlagSet, cfg *nodecfg.Config) {
	if identity := f.String(IdentityFlag.Name, IdentityFlag.Value, IdentityFlag.Usage); identity != nil && len(*identity) > 0 {
		cfg.UserIdent = *identity
	}
}

func setBootstrapNodes(ctx *cli.Context, cfg *p2p.Config) {
	// If already set, don't apply defaults.
	if cfg.BootstrapNodes != nil {
		return
	}

	nodes, err := getBootnodesFromContext(ctx)
	if err != nil {
		Fatalf("Option %s: %v", BootnodesFlag.Name, err)
	}

	cfg.BootstrapNodes = nodes
}

func setBootstrapNodesV5(ctx *cli.Context, cfg *p2p.Config) {
	// If already set, don't apply defaults.
	if cfg.BootstrapNodesV5 != nil {
		return
	}

	nodes, err := getBootnodesFromContext(ctx)
	if err != nil {
		Fatalf("Option %s: %v", BootnodesFlag.Name, err)
	}

	cfg.BootstrapNodesV5 = nodes
}

// resolveChainName returns the effective chain name from --chain and --networkid.
// It is used for bootnodes, DNS discovery URLs, static peers, and the
// chain-derived configuration in SetEthConfig (snapshot chain name,
// chain-specific branches, etc.).
//
// It mirrors go-ethereum's behavior: when --networkid is explicitly set to a
// non-mainnet value and --chain is not, the "mainnet" default on --chain
// should not bleed into chain-derived config. If the networkid maps to a known
// chain, that name is returned; otherwise an empty string is returned,
// yielding no defaults.
func resolveChainName(ctx *cli.Context) string {
	chain := ctx.String(ChainFlag.Name)
	if !ctx.IsSet(NetworkIdFlag.Name) || ctx.IsSet(ChainFlag.Name) {
		return chain
	}
	networkID := ctx.Uint64(NetworkIdFlag.Name)
	if networkID == 1 {
		return chain
	}
	if chainName, ok := chainspec.NetworkNameByID[networkID]; ok {
		return chainName
	}
	return ""
}

// getBootnodesFromContext resolves bootstrap nodes from the CLI context. An explicitly
// set --bootnodes flag (even if empty) overrides chain defaults, matching go-ethereum's
// behavior and allowing callers to run discovery with no bootstrap peers.
func getBootnodesFromContext(ctx *cli.Context) ([]*enode.Node, error) {
	if ctx.IsSet(BootnodesFlag.Name) {
		return enode.ParseNodesFromURLs(common.CliString2Array(ctx.String(BootnodesFlag.Name)))
	}
	return GetBootnodesFromFlags("", resolveChainName(ctx))
}

// GetBootnodesFromFlags makes a list of bootnodes from command line flags.
// If urlsStr is given, it is used and parsed as a comma-separated list of enode:// urls,
// otherwise a list of preconfigured bootnodes of the specified chain is returned.
func GetBootnodesFromFlags(urlsStr, chain string) ([]*enode.Node, error) {
	var urls []string
	if urlsStr != "" {
		urls = common.CliString2Array(urlsStr)
	} else {
		spec, _ := chainspec.ChainSpecByName(chain)
		if !spec.IsEmpty() {
			urls = spec.Bootnodes
		}
	}
	return enode.ParseNodesFromURLs(urls)
}

func setStaticPeers(ctx *cli.Context, cfg *p2p.Config) {
	var urls []string
	if ctx.IsSet(StaticPeersFlag.Name) {
		urls = common.CliString2Array(ctx.String(StaticPeersFlag.Name))
	} else {
		urls = chainspec.StaticPeerURLsOfChain(resolveChainName(ctx))
	}

	nodes, err := enode.ParseNodesFromURLs(urls)
	if err != nil {
		Fatalf("Option %s: %v", StaticPeersFlag.Name, err)
	}

	cfg.StaticNodes = nodes
}

func setTrustedPeers(ctx *cli.Context, cfg *p2p.Config) {
	if !ctx.IsSet(TrustedPeersFlag.Name) {
		return
	}

	urls := common.CliString2Array(ctx.String(TrustedPeersFlag.Name))
	trustedNodes, err := enode.ParseNodesFromURLs(urls)
	if err != nil {
		Fatalf("Option %s: %v", TrustedPeersFlag.Name, err)
	}

	cfg.TrustedNodes = append(cfg.TrustedNodes, trustedNodes...)
}

// NewP2PConfig
//   - doesn't setup bootnodes - they will set when genesisHash will know
func NewP2PConfig(
	nodiscover bool,
	dirs datadir.Dirs,
	netRestrict string,
	natSetting string,
	maxPeers int,
	maxPendPeers int,
	nodeName string,
	staticPeers []string,
	trustedPeers []string,
	port uint,
	protocol uint,
	allowedPorts []uint,
	metricsEnabled, witProtocol bool,
) (*p2p.Config, error) {
	var enodeDBPath string
	switch protocol {
	case direct.ETH68:
		enodeDBPath = filepath.Join(dirs.Nodes, "eth68")
	case direct.ETH69:
		enodeDBPath = filepath.Join(dirs.Nodes, "eth69")
	case direct.ETH70:
		enodeDBPath = filepath.Join(dirs.Nodes, "eth70")
	default:
		return nil, fmt.Errorf("unknown protocol: %v", protocol)
	}

	serverKey, err := nodeKey(dirs.DataDir)
	if err != nil {
		return nil, err
	}

	cfg := &p2p.Config{
		ListenAddr:        fmt.Sprintf(":%d", port),
		MaxPeers:          maxPeers,
		MaxPendingPeers:   maxPendPeers,
		NAT:               nat.Any(),
		NoDiscovery:       nodiscover,
		PrivateKey:        serverKey,
		Name:              nodeName,
		NodeDatabase:      enodeDBPath,
		AllowedPorts:      allowedPorts,
		TmpDir:            dirs.Tmp,
		MetricsEnabled:    metricsEnabled,
		EnableWitProtocol: witProtocol,
	}
	if netRestrict != "" {
		cfg.NetRestrict = new(netutil.Netlist)
		cfg.NetRestrict.Add(netRestrict)
	}
	if staticPeers != nil {
		staticNodes, err := enode.ParseNodesFromURLs(staticPeers)
		if err != nil {
			return nil, fmt.Errorf("bad option %s: %w", StaticPeersFlag.Name, err)
		}
		cfg.StaticNodes = staticNodes
	}
	if trustedPeers != nil {
		trustedNodes, err := enode.ParseNodesFromURLs(trustedPeers)
		if err != nil {
			return nil, fmt.Errorf("bad option %s: %w", TrustedPeersFlag.Name, err)
		}
		cfg.TrustedNodes = trustedNodes
	}
	natif, err := nat.Parse(natSetting)
	if err != nil {
		return nil, fmt.Errorf("invalid nat option %s: %w", natSetting, err)
	}
	cfg.NAT = natif
	cfg.NATSpec = natSetting
	return cfg, nil
}

// nodeKey loads a node key from datadir if it exists,
// otherwise it generates a new key in datadir.
func nodeKey(datadir string) (*ecdsa.PrivateKey, error) {
	config := p2p.NodeKeyConfig{}
	keyfile := config.DefaultPath(datadir)
	return config.LoadOrGenerateAndSave(keyfile)
}

// setListenAddress creates a TCP listening address string from set command
// line flags.
func setListenAddress(ctx *cli.Context, cfg *p2p.Config) {
	if ctx.IsSet(ListenPortFlag.Name) {
		cfg.ListenAddr = fmt.Sprintf(":%d", ctx.Int(ListenPortFlag.Name))
	}
	if ctx.IsSet(P2pProtocolVersionFlag.Name) {
		cfg.ProtocolVersion = ctx.UintSlice(P2pProtocolVersionFlag.Name)
	}
	if ctx.IsSet(SentryAddrFlag.Name) {
		cfg.SentryAddr = common.CliString2Array(ctx.String(SentryAddrFlag.Name))
	}
	// TODO cli lib doesn't store defaults for UintSlice properly so we have to get value directly
	cfg.AllowedPorts = P2pProtocolAllowedPorts.Value.Value()
	if ctx.IsSet(P2pProtocolAllowedPorts.Name) {
		cfg.AllowedPorts = ctx.UintSlice(P2pProtocolAllowedPorts.Name)
	}

	if ctx.IsSet(ListenPortFlag.Name) {
		// add non-default port to allowed port list
		lp := ctx.Int(ListenPortFlag.Name)
		found := false
		for _, p := range cfg.AllowedPorts {
			if int(p) == lp {
				found = true
				break
			}
		}
		if !found {
			cfg.AllowedPorts = append([]uint{uint(lp)}, cfg.AllowedPorts...)
		}
	}
}

// setNAT creates a port mapper from command line flags.
func setNAT(ctx *cli.Context, cfg *p2p.Config) {
	if ctx.IsSet(NATFlag.Name) {
		natSetting := ctx.String(NATFlag.Name)
		natif, err := nat.Parse(natSetting)
		if err != nil {
			Fatalf("Option %s: %v", NATFlag.Name, err)
		}
		cfg.NAT = natif
		cfg.NATSpec = natSetting
	}
}

// setEtherbase retrieves the etherbase from the directly specified
// command line flags.
func setEtherbase(ctx *cli.Context, cfg *ethconfig.Config) {
	var etherbase string
	if ctx.IsSet(MinerEtherbaseFlag.Name) {
		etherbase = ctx.String(MinerEtherbaseFlag.Name)
		if etherbase != "" {
			cfg.Builder.Etherbase = common.HexToAddress(etherbase)
		}
	}

	if chainName := ctx.String(ChainFlag.Name); chainName == networkname.Dev || chainName == networkname.BorDevnet {
		if etherbase == "" {
			cfg.Builder.Etherbase = devnetEtherbase
		}
	}
}

func SetP2PConfig(ctx *cli.Context, cfg *p2p.Config, nodeName, datadir string, logger log.Logger) {
	cfg.Name = nodeName
	setNodeKey(ctx, cfg, datadir)
	setNAT(ctx, cfg)
	setListenAddress(ctx, cfg)
	setBootstrapNodes(ctx, cfg)
	setBootstrapNodesV5(ctx, cfg)
	setStaticPeers(ctx, cfg)
	setTrustedPeers(ctx, cfg)

	if ctx.IsSet(MaxPeersFlag.Name) {
		cfg.MaxPeers = ctx.Int(MaxPeersFlag.Name)
	}

	if ctx.IsSet(MaxPendingPeersFlag.Name) {
		cfg.MaxPendingPeers = ctx.Int(MaxPendingPeersFlag.Name)
	}

	setBoolIfSet := func(set *bool, flag *cli.BoolFlag) {
		if ctx.IsSet(flag.Name) {
			*set = ctx.Bool(flag.Name)
		}
	}

	CheckExclusive(ctx, &DiscoveryV4Flag, &NoDiscoverFlag)
	CheckExclusive(ctx, &DiscoveryV5Flag, &NoDiscoverFlag)
	setBoolIfSet(&cfg.NoDiscovery, &NoDiscoverFlag)
	setBoolIfSet(&cfg.DiscoveryV4, &DiscoveryV4Flag)
	setBoolIfSet(&cfg.DiscoveryV5, &DiscoveryV5Flag)
	setBoolIfSet(&cfg.MetricsEnabled, &MetricsEnabledFlag)
	setBoolIfSet(&cfg.EnableWitProtocol, &PolygonPosWitProtocolFlag)

	logger.Info("Maximum peer count", "total", cfg.MaxPeers)

	if netrestrict := ctx.String(NetrestrictFlag.Name); netrestrict != "" {
		list, err := netutil.ParseNetlist(netrestrict)
		if err != nil {
			Fatalf("Option %q: %v", NetrestrictFlag.Name, err)
		}
		cfg.NetRestrict = list
	}

	if ctx.String(ChainFlag.Name) == networkname.Dev {
		// --dev mode can't use p2p networking.
		//cfg.MaxPeers = 0 // It can have peers otherwise local sync is not possible
		if !ctx.IsSet(ListenPortFlag.Name) {
			cfg.ListenAddr = ":0"
		}
		cfg.NoDiscovery = true
		cfg.DiscoveryV4 = false
		cfg.DiscoveryV5 = false
		logger.Info("Development chain flags set", "--nodiscover", cfg.NoDiscovery, "--v5disc", cfg.DiscoveryV5, "--port", cfg.ListenAddr)
	}
}

// SetNodeConfig applies node-related command line flags to the config.
func SetNodeConfig(ctx *cli.Context, cfg *nodecfg.Config, logger log.Logger) error {
	if err := setDataDir(ctx, cfg); err != nil {
		return err
	}
	setNodeUserIdent(ctx, cfg)
	SetP2PConfig(ctx, &cfg.P2P, cfg.NodeName(), cfg.Dirs.DataDir, logger)

	cfg.SentryLogPeerInfo = ctx.IsSet(SentryLogPeerInfoFlag.Name)
	return nil
}

func SetNodeConfigCobra(cmd *cobra.Command, cfg *nodecfg.Config) {
	flags := cmd.Flags()
	//SetP2PConfig(ctx, &cfg.P2P)
	setNodeUserIdentCobra(flags, cfg)
	setDataDirCobra(flags, cfg)
}

func setDataDir(ctx *cli.Context, cfg *nodecfg.Config) error {
	if ctx.IsSet(DataDirFlag.Name) {
		cfg.Dirs = datadir.New(ctx.String(DataDirFlag.Name))
	} else {
		cfg.Dirs = datadir.New(paths.DataDirForNetwork(paths.DefaultDataDir(), ctx.String(ChainFlag.Name)))
	}

	cfg.Dirs.Log = logging.LogDirPath(ctx)

	cfg.MdbxPageSize = flags.DBPageSizeFlagUnmarshal(ctx, DbPageSizeFlag.Name, DbPageSizeFlag.Usage)
	if err := cfg.MdbxDBSizeLimit.UnmarshalText([]byte(ctx.String(DbSizeLimitFlag.Name))); err != nil {
		return fmt.Errorf("failed to parse --%s: %w", DbSizeLimitFlag.Name, err)
	}
	cfg.MdbxWriteMap = ctx.Bool(DbWriteMapFlag.Name)
	szLimit := cfg.MdbxDBSizeLimit.Bytes()
	if szLimit%256 != 0 || szLimit < 256 {
		return fmt.Errorf("invalid --%s: %s=%d, see: %s", DbSizeLimitFlag.Name, ctx.String(DbSizeLimitFlag.Name),
			szLimit, DbSizeLimitFlag.Usage)
	}

	if err := cfg.Dirs.RenameOldVersions(false); err != nil {
		return fmt.Errorf("failed to rename old versions: %w", err)
	}

	return nil
}

func setDataDirCobra(f *pflag.FlagSet, cfg *nodecfg.Config) {
	dirname, err := f.GetString(DataDirFlag.Name)
	if err != nil {
		panic(err)
	}
	chain, err := f.GetString(ChainFlag.Name)
	if err != nil {
		panic(err)
	}
	if dirname != "" {
		cfg.Dirs = datadir.New(dirname)
	} else {
		cfg.Dirs = datadir.New(paths.DataDirForNetwork(paths.DefaultDataDir(), chain))
	}
}

func setGPO(ctx *cli.Context, cfg *gaspricecfg.Config) {
	if ctx.IsSet(GpoBlocksFlag.Name) {
		cfg.Blocks = ctx.Int(GpoBlocksFlag.Name)
	}
	if ctx.IsSet(GpoPercentileFlag.Name) {
		cfg.Percentile = ctx.Int(GpoPercentileFlag.Name)
	}
	if ctx.IsSet(GpoMaxGasPriceFlag.Name) {
		cfg.MaxPrice = uint256.NewInt(ctx.Uint64(GpoMaxGasPriceFlag.Name))
	}
}

func setTxPool(ctx *cli.Context, dbDir string, fullCfg *ethconfig.Config) {
	cfg := txpoolcfg.DefaultConfig
	if ctx.IsSet(TxPoolDisableFlag.Name) || TxPoolDisableFlag.Value {
		cfg.Disable = true
	}
	if ctx.IsSet(TxPoolPriceLimitFlag.Name) {
		cfg.MinFeeCap = ctx.Uint64(TxPoolPriceLimitFlag.Name)
	}
	if ctx.IsSet(TxPoolPriceBumpFlag.Name) {
		cfg.PriceBump = ctx.Uint64(TxPoolPriceBumpFlag.Name)
	}
	if ctx.IsSet(TxPoolBlobPriceBumpFlag.Name) {
		cfg.BlobPriceBump = ctx.Uint64(TxPoolBlobPriceBumpFlag.Name)
	}
	if ctx.IsSet(TxPoolAccountSlotsFlag.Name) {
		cfg.AccountSlots = ctx.Uint64(TxPoolAccountSlotsFlag.Name)
	}
	if ctx.IsSet(TxPoolBlobSlotsFlag.Name) {
		cfg.BlobSlots = ctx.Uint64(TxPoolBlobSlotsFlag.Name)
	}
	if ctx.IsSet(TxPoolTotalBlobPoolLimit.Name) {
		cfg.TotalBlobPoolLimit = ctx.Uint64(TxPoolTotalBlobPoolLimit.Name)
	}
	if ctx.IsSet(TxPoolGlobalSlotsFlag.Name) {
		cfg.PendingSubPoolLimit = ctx.Int(TxPoolGlobalSlotsFlag.Name)
	}
	if ctx.IsSet(TxPoolGlobalQueueFlag.Name) {
		cfg.QueuedSubPoolLimit = ctx.Int(TxPoolGlobalQueueFlag.Name)
	}
	if ctx.IsSet(TxPoolGlobalBaseFeeSlotsFlag.Name) {
		cfg.BaseFeeSubPoolLimit = ctx.Int(TxPoolGlobalBaseFeeSlotsFlag.Name)
	}
	if ctx.IsSet(TxPoolTraceSendersFlag.Name) {
		// Parse the command separated flag
		senderHexes := common.CliString2Array(ctx.String(TxPoolTraceSendersFlag.Name))
		cfg.TracedSenders = make([]string, len(senderHexes))
		for i, senderHex := range senderHexes {
			sender := common.HexToAddress(senderHex)
			cfg.TracedSenders[i] = string(sender[:])
		}
	}
	if ctx.IsSet(DbWriteMapFlag.Name) {
		cfg.MdbxWriteMap = ctx.Bool(DbWriteMapFlag.Name)
	}
	if ctx.IsSet(TxPoolGossipDisableFlag.Name) {
		cfg.NoGossip = ctx.Bool(TxPoolGossipDisableFlag.Name)
	}
	cfg.AllowAA = ctx.Bool(AAFlag.Name)
	cfg.LogEvery = 3 * time.Minute
	cfg.CommitEvery = common.RandomizeDuration(ctx.Duration(TxPoolCommitEveryFlag.Name))
	if ctx.IsSet(TxPoolQueuedDormancyFlag.Name) {
		cfg.QueuedDormancyDuration = ctx.Duration(TxPoolQueuedDormancyFlag.Name)
	}
	cfg.DBDir = dbDir
	fullCfg.TxPool = cfg
}

func setShutter(ctx *cli.Context, chainName string, nodeConfig *nodecfg.Config, ethConfig *ethconfig.Config) {
	if enabled := ctx.Bool(ShutterEnabledFlag.Name); !enabled {
		return
	}

	config := shuttercfg.ConfigByChainName(chainName)
	config.PrivateKey = nodeConfig.P2P.PrivateKey
	// check for cli overrides
	if ctx.IsSet(ShutterP2pBootstrapNodesFlag.Name) {
		config.BootstrapNodes = ctx.StringSlice(ShutterP2pBootstrapNodesFlag.Name)
	}
	if ctx.IsSet(ShutterP2pListenPortFlag.Name) {
		config.ListenPort = ctx.Uint64(ShutterP2pListenPortFlag.Name)
	}

	ethConfig.Shutter = config
}

func setEthash(ctx *cli.Context, datadir string, cfg *ethconfig.Config) {
	if ctx.IsSet(EthashDatasetDirFlag.Name) {
		cfg.Ethash.DatasetDir = ctx.String(EthashDatasetDirFlag.Name)
	} else {
		cfg.Ethash.DatasetDir = filepath.Join(datadir, "ethash-dags")
	}
	if ctx.IsSet(EthashCachesInMemoryFlag.Name) {
		cfg.Ethash.CachesInMem = ctx.Int(EthashCachesInMemoryFlag.Name)
	}
	if ctx.IsSet(EthashCachesLockMmapFlag.Name) {
		cfg.Ethash.CachesLockMmap = ctx.Bool(EthashCachesLockMmapFlag.Name)
	}
	if ctx.IsSet(FakePoWFlag.Name) {
		cfg.Ethash.PowMode = ethashcfg.ModeFake
	}
	if ctx.IsSet(EthashDatasetsLockMmapFlag.Name) {
		cfg.Ethash.DatasetsLockMmap = ctx.Bool(EthashDatasetsLockMmapFlag.Name)
	}
}

func SetupMinerCobra(cmd *cobra.Command, cfg *buildercfg.BuilderConfig) {
	flags := cmd.Flags()
	var err error
	extraDataStr, err := flags.GetString(MinerExtraDataFlag.Name)
	if err != nil {
		panic(err)
	}
	cfg.ExtraData = []byte(extraDataStr)
	if flags.Changed(MinerGasLimitFlag.Name) {
		gasLimit, err := flags.GetUint64(MinerGasLimitFlag.Name)
		if err != nil {
			panic(err)
		}
		cfg.GasLimit = &gasLimit
	}

	// Extract the current etherbase, new flag overriding legacy one
	var etherbase string
	etherbase, err = flags.GetString(MinerEtherbaseFlag.Name)
	if err != nil {
		panic(err)
	}

	// Convert the etherbase into an address and configure it
	if etherbase == "" {
		Fatalf("No etherbase configured")
	}
	cfg.Etherbase = common.HexToAddress(etherbase)
}

func setBorConfig(ctx *cli.Context, cfg *ethconfig.Config, nodeConfig *nodecfg.Config, logger log.Logger) {
	cfg.HeimdallURL = ctx.String(HeimdallURLFlag.Name)
	cfg.WithoutHeimdall = ctx.Bool(WithoutHeimdallFlag.Name)

	heimdall.RecordWayPoints(true)

	spec, _ := chainspec.ChainSpecByName(ctx.String(ChainFlag.Name))
	if !spec.IsEmpty() && spec.Config.Bor != nil && !ctx.IsSet(MaxPeersFlag.Name) { // IsBor?
		// override default max devp2p peers for polygon as per
		// https://forum.polygon.technology/t/introducing-our-new-dns-discovery-for-polygon-pos-faster-smarter-more-connected/19871
		// which encourages high peer count
		nodeConfig.P2P.MaxPeers = 100
		logger.Info("Maximum peer count default sanitizing for bor", "total", nodeConfig.P2P.MaxPeers)
	}

	cfg.PolygonPosSingleSlotFinality = ctx.Bool(PolygonPosSingleSlotFinalityFlag.Name)
	cfg.PolygonPosSingleSlotFinalityBlockAt = ctx.Uint64(PolygonPosSingleSlotFinalityBlockAtFlag.Name)
}

func setBuilder(ctx *cli.Context, cfg *buildercfg.BuilderConfig) {
	cfg.EnabledPOS = !ctx.IsSet(ProposingDisableFlag.Name)

	if ctx.IsSet(MinerExtraDataFlag.Name) {
		cfg.ExtraData = []byte(ctx.String(MinerExtraDataFlag.Name))
	} else if len(version.GitCommit) > 0 {
		cfg.ExtraData = []byte(ctx.App.Name + "-" + version.VersionWithCommit(version.GitCommit))
	} else {
		cfg.ExtraData = []byte(ctx.App.Name + "-" + ctx.App.Version)
	}
	maxExtra := min(int(params.MaximumExtraDataSize), types.ExtraVanityLength)
	if len(cfg.ExtraData) > maxExtra {
		cfg.ExtraData = cfg.ExtraData[:maxExtra]
	}

	if ctx.IsSet(MinerGasLimitFlag.Name) {
		if gasLimit := ctx.Uint64(MinerGasLimitFlag.Name); gasLimit != 0 {
			cfg.GasLimit = &gasLimit
		}
	}

	if ctx.IsSet(BuilderMaxBlobsFlag.Name) {
		maxBlobs := ctx.Uint64(BuilderMaxBlobsFlag.Name)
		cfg.MaxBlobsPerBlock = &maxBlobs
	}
}

func setWhitelist(ctx *cli.Context, cfg *ethconfig.Config) {
	whitelist := ctx.String(WhitelistFlag.Name)
	if whitelist == "" {
		return
	}
	cfg.Whitelist = make(map[uint64]common.Hash)
	for _, entry := range common.CliString2Array(whitelist) {
		parts := strings.Split(entry, "=")
		if len(parts) != 2 {
			Fatalf("Invalid whitelist entry: %s", entry)
		}
		number, err := strconv.ParseUint(parts[0], 0, 64)
		if err != nil {
			Fatalf("Invalid whitelist block number %s: %v", parts[0], err)
		}
		var hash common.Hash
		if err = hash.UnmarshalText([]byte(parts[1])); err != nil {
			Fatalf("Invalid whitelist hash %s: %v", parts[1], err)
		}
		cfg.Whitelist[number] = hash
	}
}

func setBeaconAPI(ctx *cli.Context, cfg *ethconfig.Config) error {
	cfg.CaplinConfig.EnableEngineAPI = ctx.Bool(CaplinUseEngineApiFlag.Name)

	if cfg.CaplinConfig.EnableEngineAPI && ctx.IsSet(BeaconAPIFlag.Name) {
		log.Warn("Beacon API flag is set, but engine API is enabled. Beacon API is automatically disabled.")
		return nil
	}

	allowed := ctx.StringSlice(BeaconAPIFlag.Name)
	if err := cfg.CaplinConfig.BeaconAPIRouter.UnwrapEndpointsList(allowed); err != nil {
		return err
	}

	cfg.CaplinConfig.BeaconAPIRouter.Protocol = ctx.String(BeaconApiProtocolFlag.Name)
	cfg.CaplinConfig.BeaconAPIRouter.Address = fmt.Sprintf("%s:%d", ctx.String(BeaconApiAddrFlag.Name), ctx.Int(BeaconApiPortFlag.Name))
	cfg.CaplinConfig.BeaconAPIRouter.ReadTimeTimeout = time.Duration(ctx.Uint64(BeaconApiReadTimeoutFlag.Name)) * time.Second
	cfg.CaplinConfig.BeaconAPIRouter.WriteTimeout = time.Duration(ctx.Uint64(BeaconApiWriteTimeoutFlag.Name)) * time.Second
	cfg.CaplinConfig.BeaconAPIRouter.IdleTimeout = time.Duration(ctx.Uint64(BeaconApiIdleTimeoutFlag.Name)) * time.Second
	cfg.CaplinConfig.BeaconAPIRouter.AllowedMethods = ctx.StringSlice(BeaconApiAllowMethodsFlag.Name)
	cfg.CaplinConfig.BeaconAPIRouter.AllowedOrigins = ctx.StringSlice(BeaconApiAllowOriginsFlag.Name)
	cfg.CaplinConfig.BeaconAPIRouter.AllowCredentials = ctx.Bool(BeaconApiAllowCredentialsFlag.Name)
	return nil
}

func setCaplin(ctx *cli.Context, cfg *ethconfig.Config) {
	cfg.CaplinConfig.EnableEngineAPI = ctx.Bool(CaplinUseEngineApiFlag.Name)

	// Caplin's block's backfilling is enabled if any of the following flags are set
	if !cfg.CaplinConfig.EnableEngineAPI {
		cfg.CaplinConfig.ArchiveBlocks = ctx.Bool(CaplinArchiveBlocksFlag.Name) || ctx.Bool(CaplinArchiveStatesFlag.Name) || ctx.Bool(CaplinArchiveBlobsFlag.Name)
		cfg.CaplinConfig.ArchiveBlobs = ctx.Bool(CaplinArchiveBlobsFlag.Name)
		cfg.CaplinConfig.BlobPruningDisabled = ctx.Bool(CaplinDisableBlobPruningFlag.Name)
		cfg.CaplinConfig.ArchiveStates = ctx.Bool(CaplinArchiveStatesFlag.Name)
	} else {
		if ctx.IsSet(CaplinArchiveBlocksFlag.Name) {
			log.Warn("Caplin's block backfilling is disabled when engine API is enabled")
		}
		if ctx.IsSet(CaplinArchiveStatesFlag.Name) {
			log.Warn("Caplin's state backfilling is disabled when engine API is enabled")
		}
		if ctx.IsSet(CaplinArchiveBlobsFlag.Name) {
			log.Warn("Caplin's blob backfilling is disabled when engine API is enabled")
		}
		if ctx.IsSet(CaplinImmediateBlobBackfillFlag.Name) {
			log.Warn("Caplin's immediate blob backfilling is disabled when engine API is enabled")
		}
	}

	cfg.CaplinConfig.ImmediateBlobsBackfilling = ctx.Bool(CaplinImmediateBlobBackfillFlag.Name)
	cfg.CaplinConfig.SnapshotGenerationEnabled = ctx.Bool(CaplinEnableSnapshotGeneration.Name)
	cfg.CaplinConfig.DisabledCheckpointSync = ctx.Bool(CaplinDisableCheckpointSyncFlag.Name)
	cfg.CaplinConfig.ColumnKeepSlots = ctx.Uint64(CaplinColumnKeepSlotsFlag.Name)
	// bunch of extra stuff
	cfg.CaplinConfig.MevRelayUrl = ctx.String(CaplinMevRelayUrl.Name)
	cfg.CaplinConfig.EnableValidatorMonitor = ctx.Bool(CaplinValidatorMonitorFlag.Name)
	if checkpointUrls := ctx.StringSlice(CaplinCheckpointSyncUrlFlag.Name); len(checkpointUrls) > 0 {
		clparams.ConfigurableCheckpointsURLs = checkpointUrls
	}
	cfg.CaplinConfig.CustomConfigPath = ctx.String(CaplinCustomConfigFlag.Name)
	cfg.CaplinConfig.CustomGenesisStatePath = ctx.String(CaplinCustomGenesisFlag.Name)
}

// CheckExclusive verifies that only a single instance of the provided flags was
// set by the user. Each flag might optionally be followed by a string type to
// specialize it further.
func CheckExclusive(ctx *cli.Context, args ...any) {
	set := make([]string, 0, 1)
	for i := 0; i < len(args); i++ {
		// Make sure the next argument is a flag and skip if not set
		flag, ok := args[i].(cli.Flag)
		if !ok {
			panic(fmt.Sprintf("invalid argument, not cli.Flag type: %T", args[i]))
		}
		// Check if next arg extends current and expand its name if so
		name := flag.Names()[0]

		if i+1 < len(args) {
			switch option := args[i+1].(type) {
			case string:
				// Extended flag check, make sure value set doesn't conflict with passed in option
				if ctx.String(flag.Names()[0]) == option {
					name += "=" + option
					set = append(set, "--"+name)
				}
				// shift arguments and continue
				i++
				continue

			case cli.Flag:
			default:
				panic(fmt.Sprintf("invalid argument, not cli.Flag or string extension: %T", args[i+1]))
			}
		}
		// Mark the flag if it's set
		if ctx.IsSet(flag.Names()[0]) {
			set = append(set, "--"+name)
		}
	}
	if len(set) > 1 {
		Fatalf("Flags %v can't be used at the same time", strings.Join(set, ", "))
	}
}

// SetEthConfig applies eth-related command line flags to the config.
func SetEthConfig(ctx *cli.Context, nodeConfig *nodecfg.Config, cfg *ethconfig.Config, logger log.Logger) {
	if !ctx.Bool(MCPDisableFlag.Name) && ctx.String(MCPAddrFlag.Name) != "" {
		cfg.MCPAddress = fmt.Sprintf("%s:%d", ctx.String(MCPAddrFlag.Name), ctx.Uint(MCPPortFlag.Name))
	}

	cfg.CaplinConfig.CaplinDiscoveryAddr = ctx.String(CaplinDiscoveryAddrFlag.Name)
	cfg.CaplinConfig.CaplinDiscoveryPort = ctx.Uint64(CaplinDiscoveryPortFlag.Name)
	cfg.CaplinConfig.CaplinDiscoveryTCPPort = ctx.Uint64(CaplinDiscoveryTCPPortFlag.Name)
	if ctx.Bool(KeepExecutionProofsFlag.Name) {
		cfg.KeepExecutionProofs = true
	}

	if ctx.IsSet(AlwaysGenerateChangesetsFlag.Name) {
		cfg.AlwaysGenerateChangesets = ctx.Bool(AlwaysGenerateChangesetsFlag.Name)
	}
	cfg.CaplinConfig.EnableUPnP = ctx.Bool(CaplinEnableUPNPlag.Name)
	cfg.CaplinConfig.CaplinNAT = ctx.String(CaplinNATFlag.Name)
	var err error
	cfg.CaplinConfig.MaxInboundTrafficPerPeer, err = datasize.ParseString(ctx.String(CaplinMaxInboundTrafficPerPeerFlag.Name))
	if err != nil {
		Fatalf("Option %s: %v", CaplinMaxInboundTrafficPerPeerFlag.Name, err)
	}
	cfg.CaplinConfig.MaxOutboundTrafficPerPeer, err = datasize.ParseString(ctx.String(CaplinMaxOutboundTrafficPerPeerFlag.Name))
	if err != nil {
		Fatalf("Option %s: %v", CaplinMaxOutboundTrafficPerPeerFlag.Name, err)
	}
	cfg.CaplinConfig.AdptableTrafficRequirements = ctx.Bool(CaplinAdaptableTrafficRequirementsFlag.Name)

	cfg.CaplinConfig.SubscribeAllTopics = ctx.Bool(CaplinSubscribeAllTopicsFlag.Name)
	cfg.CaplinConfig.MaxPeerCount = ctx.Uint64(CaplinMaxPeerCount.Name)

	cfg.CaplinConfig.SentinelAddr = ctx.String(SentinelAddrFlag.Name)
	cfg.CaplinConfig.SentinelPort = ctx.Uint64(SentinelPortFlag.Name)
	cfg.CaplinConfig.BootstrapNodes = ctx.StringSlice(SentinelBootnodes.Name)
	cfg.CaplinConfig.StaticPeers = ctx.StringSlice(SentinelStaticPeers.Name)

	chain := resolveChainName(ctx)
	if ctx.IsSet(NetworkIdFlag.Name) {
		cfg.NetworkID = ctx.Uint64(NetworkIdFlag.Name)
	} else if chain != networkname.Dev && chain != networkname.BorDevnet {
		spec, err := chainspec.ChainSpecByName(chain)
		if err != nil {
			Fatalf("chain name is not recognized: %s", chain)
			return
		}
		// Use custom NetworkID from spec if set, otherwise use ChainID
		if spec.NetworkID != 0 {
			cfg.NetworkID = spec.NetworkID
		} else {
			cfg.NetworkID = spec.Config.ChainID.Uint64()
		}
	}

	cfg.Dirs = nodeConfig.Dirs
	cfg.Snapshot.KeepBlocks = ctx.Bool(SnapKeepBlocksFlag.Name)
	cfg.Snapshot.ProduceE2 = !ctx.Bool(SnapStopFlag.Name)
	cfg.Snapshot.ProduceE3 = !ctx.Bool(SnapStateStopFlag.Name)
	cfg.Snapshot.DisableDownloadE3 = ctx.Bool(SnapSkipStateSnapshotDownloadFlag.Name)
	cfg.Snapshot.NoDownloader = ctx.Bool(NoDownloaderFlag.Name)
	cfg.Snapshot.P2PManifest = ctx.Bool(SnapP2PManifestFlag.Name)
	cfg.Snapshot.DownloaderAddr = strings.TrimSpace(ctx.String(DownloaderAddrFlag.Name))
	cfg.Snapshot.ChainName = chain
	nodeConfig.Http.Snap = cfg.Snapshot

	setEtherbase(ctx, cfg)
	setGPO(ctx, &cfg.GPO)

	setTxPool(ctx, nodeConfig.Dirs.TxPool, cfg)
	setShutter(ctx, chain, nodeConfig, cfg)

	setEthash(ctx, nodeConfig.Dirs.DataDir, cfg)
	setBuilder(ctx, &cfg.Builder)
	setWhitelist(ctx, cfg)
	setBorConfig(ctx, cfg, nodeConfig, logger)
	if err := setBeaconAPI(ctx, cfg); err != nil {
		log.Error("Failed to set beacon API", "err", err)
	}
	setCaplin(ctx, cfg)

	cfg.AllowAA = ctx.Bool(AAFlag.Name)
	cfg.Ethstats = ctx.String(EthStatsURLFlag.Name)

	if ctx.Bool(ExperimentalConcurrentCommitmentFlag.Name) {
		cfg.ExperimentalConcurrentCommitment = true
	}

	cfg.FcuTimeout = ctx.Duration(FcuTimeoutFlag.Name)
	cfg.FcuBackgroundPrune = ctx.Bool(FcuBackgroundPruneFlag.Name)
	cfg.FcuBackgroundCommit = ctx.Bool(FcuBackgroundCommitFlag.Name)

	// Executor performance toggles. When the user explicitly sets the CLI
	// flag, it overrides the env-var default that dbg read at package init.
	// Otherwise env vars (IGNORE_BAL, USE_STATE_CACHE, EXEC3_WORKERS,
	// NO_MERGE, NO_PRUNE) remain the source of truth.
	if ctx.IsSet(ExecBatchedIOFlag.Name) {
		// --exec.batched-io toggles two BAL-driven optimisations together:
		// read-ahead pre-warming (ReadAhead) and version-map pre-population
		// (IgnoreBAL, inverted). Flipped in lockstep so perf comparisons
		// test "all BAL I/O off" vs "all BAL I/O on".
		v := ctx.Bool(ExecBatchedIOFlag.Name)
		dbg.SetReadAhead(v)
		dbg.SetIgnoreBAL(!v)
	}
	if ctx.IsSet(ExecStateCacheFlag.Name) {
		dbg.SetUseStateCache(ctx.Bool(ExecStateCacheFlag.Name))
	}
	if ctx.IsSet(ExecWorkersFlag.Name) {
		n := ctx.Int(ExecWorkersFlag.Name)
		dbg.SetExec3Workers(n)
		cfg.ExecWorkerCount = n
	}
	// --exec.serial wins over --exec.workers / EXEC3_WORKERS: clamp to 1.
	if ctx.IsSet(ExecSerialFlag.Name) && ctx.Bool(ExecSerialFlag.Name) {
		dbg.SetExec3Workers(1)
		cfg.ExecWorkerCount = 1
	}
	if ctx.IsSet(ExecNoMergeFlag.Name) {
		dbg.SetNoMerge(ctx.Bool(ExecNoMergeFlag.Name))
	}
	if ctx.IsSet(ExecNoPruneFlag.Name) {
		dbg.SetNoPrune(ctx.Bool(ExecNoPruneFlag.Name))
	}
	if ctx.IsSet(RPCGlobalGasCapFlag.Name) {
		cfg.RPCGasCap = ctx.Uint64(RPCGlobalGasCapFlag.Name)
	}
	if cfg.RPCGasCap != 0 {
		logger.Info("Set global gas cap", "cap", cfg.RPCGasCap)
	} else {
		logger.Info("Global gas cap disabled")
	}
	if ctx.IsSet(RPCGlobalTxFeeCapFlag.Name) {
		cfg.RPCTxFeeCap = ctx.Float64(RPCGlobalTxFeeCapFlag.Name)
	}
	if ctx.IsSet(NoDiscoverFlag.Name) {
		cfg.EthDiscoveryURLs = []string{}
	} else if ctx.IsSet(DNSDiscoveryFlag.Name) {
		urls := ctx.String(DNSDiscoveryFlag.Name)
		if urls == "" {
			cfg.EthDiscoveryURLs = []string{}
		} else {
			cfg.EthDiscoveryURLs = common.CliString2Array(urls)
		}
	}

	// Override any default configs for hard coded networks.
	switch chain {
	default:
		spec, err := chainspec.ChainSpecByName(chain)
		if err != nil {
			Fatalf("ChainDB name is not recognized: %s %s", chain, err)
			return
		}
		cfg.Genesis = spec.Genesis
		SetDNSDiscoveryDefaults(cfg, spec)
	case "":
		if cfg.NetworkID == 1 {
			SetDNSDiscoveryDefaults(cfg, chainspec.Mainnet)
		}
	case networkname.Dev:
		seed := ctx.String(DevValidatorSeedFlag.Name)
		validatorCount := ctx.Int(DevValidatorCountFlag.Name)
		if validatorCount == 0 {
			validatorCount = 64
		}

		// Derive the signer key for the dev account.
		signerKey, signerAddr, err := devgenesis.DeriveSignerKey(seed)
		if err != nil {
			Fatalf("Failed to derive dev signer key: %v", err)
		}
		_ = signerKey // available for future use (e.g., auto-funding txs)
		logger.Info("Using PoS dev mode",
			"seed", seed,
			"validators", validatorCount,
			"signer", signerAddr.Hex(),
		)

		// Build PoS EL genesis (TTD=0, post-merge from genesis).
		cfg.Genesis = chainspec.DeveloperGenesisBlock()
		// Ensure the derived signer address is pre-funded.
		if cfg.Genesis.Alloc == nil {
			cfg.Genesis.Alloc = make(types.GenesisAlloc)
		}
		if _, ok := cfg.Genesis.Alloc[signerAddr]; !ok {
			cfg.Genesis.Alloc[signerAddr] = types.GenesisAccount{
				Balance: big.NewInt(0).Mul(big.NewInt(1000), big.NewInt(common.Ether)),
			}
		}
		cfg.Genesis.Config.TerminalTotalDifficulty = big.NewInt(0)
		cfg.Genesis.Config.TerminalTotalDifficultyPassed = true
		zero := uint64(0)
		cfg.Genesis.Config.ShanghaiTime = &zero
		cfg.Genesis.Config.CancunTime = &zero
		cfg.Genesis.Config.PragueTime = nil // Prague may need more config; leave disabled

		// Configure embedded Caplin + dev validator.
		cfg.InternalCL = true
		cfg.CaplinConfig.DevValidatorSeed = seed
		cfg.CaplinConfig.DevValidatorCount = validatorCount
		// Enable Beacon API for dev mode.
		cfg.CaplinConfig.BeaconAPIRouter.Active = true
		if cfg.CaplinConfig.BeaconAPIRouter.Address == "" {
			cfg.CaplinConfig.BeaconAPIRouter.Address = "127.0.0.1:5555"
		}

		// Build beacon genesis state and write to temp file for Caplin.
		beaconCfg := clparams.MainnetBeaconConfig
		clparams.ApplyMinimalPreset(&beaconCfg)
		// Enable all forks from genesis (PoS from block 0).
		beaconCfg.AltairForkEpoch = 0
		beaconCfg.BellatrixForkEpoch = 0
		beaconCfg.CapellaForkEpoch = 0
		beaconCfg.DenebForkEpoch = 0
		beaconCfg.ElectraForkEpoch = 0
		beaconCfg.FuluForkEpoch = 0
		slotTime := uint64(ctx.Int(DevSlotTimeFlag.Name))
		if slotTime < 2 {
			slotTime = 2
		}
		beaconCfg.SecondsPerSlot = slotTime
		beaconCfg.InitializeForkSchedule()
		genesisTime := uint64(time.Now().Unix())
		// Compute the EL genesis block hash so the beacon state's Eth1Data
		// matches the actual chain genesis.
		elGenesisBlock, _, err := genesiswrite.GenesisToBlock(nil, cfg.Genesis, cfg.Dirs, logger)
		if err != nil {
			Fatalf("Failed to compute dev EL genesis hash: %v", err)
		}
		elGenesisHash := elGenesisBlock.Hash()
		beaconState, _, err := devgenesis.BuildGenesisState(seed, validatorCount, &beaconCfg, genesisTime, elGenesisHash)
		if err != nil {
			Fatalf("Failed to build dev beacon genesis: %v", err)
		}
		// Write beacon config and genesis state to temp files.
		tmpDir := filepath.Join(cfg.Dirs.DataDir, "dev-beacon")
		if err := os.MkdirAll(tmpDir, 0755); err != nil {
			Fatalf("Failed to create dev beacon dir: %v", err)
		}
		stateSSZ, err := beaconState.EncodeSSZ(nil)
		if err != nil {
			Fatalf("Failed to encode dev genesis state: %v", err)
		}
		genesisStatePath := filepath.Join(tmpDir, "genesis.ssz")
		if err := os.WriteFile(genesisStatePath, stateSSZ, 0644); err != nil {
			Fatalf("Failed to write dev genesis state: %v", err)
		}

		// Write beacon config YAML with all forks enabled from genesis.
		// All known fork epochs are listed explicitly so that Caplin's
		// CustomConfig (which falls back to minimal preset defaults for
		// missing fields) activates every fork at epoch 0.
		configPath := filepath.Join(tmpDir, "config.yaml")
		configYAML := fmt.Sprintf(
			"PRESET_BASE: minimal\n"+
				"MIN_GENESIS_TIME: %d\n"+
				"SECONDS_PER_SLOT: %d\n"+
				"ALTAIR_FORK_EPOCH: 0\n"+
				"BELLATRIX_FORK_EPOCH: 0\n"+
				"CAPELLA_FORK_EPOCH: 0\n"+
				"DENEB_FORK_EPOCH: 0\n"+
				"ELECTRA_FORK_EPOCH: 0\n"+
				"FULU_FORK_EPOCH: 0\n"+
				"TERMINAL_TOTAL_DIFFICULTY: 0\n",
			genesisTime, beaconCfg.SecondsPerSlot)
		if err := os.WriteFile(configPath, []byte(configYAML), 0644); err != nil {
			Fatalf("Failed to write dev beacon config: %v", err)
		}

		cfg.CaplinConfig.CustomConfigPath = configPath
		cfg.CaplinConfig.CustomGenesisStatePath = genesisStatePath
	}

	if ctx.IsSet(OverrideOsakaFlag.Name) {
		v := ctx.Uint64(OverrideOsakaFlag.Name)
		cfg.OverrideOsakaTime = &v
	}
	if ctx.IsSet(OverrideAmsterdamFlag.Name) {
		v := ctx.Uint64(OverrideAmsterdamFlag.Name)
		cfg.OverrideAmsterdamTime = &v
	}
	cfg.KeepStoredChainConfig = ctx.Bool(KeepStoredChainConfigFlag.Name)

	if clparams.EmbeddedSupported(cfg.NetworkID) || cfg.CaplinConfig.IsDevnet() {
		cfg.InternalCL = !ctx.Bool(ExternalConsensusFlag.Name)
	}

	if ctx.IsSet(TrustedSetupFile.Name) {
		libkzg.SetTrustedSetupFilePath(ctx.String(TrustedSetupFile.Name))
	}

	// Do this after chain config as there are chain type registration
	// dependencies for know config which need to be set-up
	if cfg.Snapshot.DownloaderAddr == "" {
		lvl, err := downloadercfg.Int2LogLevel(ctx.Int(TorrentVerbosityFlag.Name))
		if err != nil {
			panic(err)
		}
		version := "erigon: " + version.VersionWithCommit(version.GitCommit)
		var webseedsList []string
		if ctx.IsSet(WebSeedsFlag.Name) {
			// Unfortunately we don't take webseed URL here in the native format.
			webseedsList = common.CliString2Array(ctx.String(WebSeedsFlag.Name))
		} else {
			if known, ok := snapcfg.GetEmbeddedWebseeds(chain); ok {
				webseedsList = append(webseedsList, known...)
			}
		}
		cfg.Downloader, err = downloadercfg.New(
			ctx.Context,
			cfg.Dirs,
			version,
			lvl,
			ctx.Int(TorrentPortFlag.Name),
			ctx.Int(TorrentConnsPerFileFlag.Name),
			webseedsList,
			chain,
			ctx.Bool(DbWriteMapFlag.Name),
			downloadercfg.NewCfgOpts{
				DisableTrackers:          boolFlagOpt(ctx, &TorrentDisableTrackers),
				Verify:                   DownloaderVerifyFlag.Get(ctx),
				DownloadRateLimit:        MustGetStringFlagDownloaderRateLimit(ctx.String(TorrentDownloadRateFlag.Name)),
				UploadRateLimit:          MustGetStringFlagDownloaderRateLimit(ctx.String(TorrentUploadRateFlag.Name)),
				WebseedDownloadRateLimit: MustGetStringFlagDownloaderRateLimit(ctx.String(TorrentWebseedDownloadRateFlag.Name)),
			},
		)
		if err != nil {
			panic(err)
		}
		downloadernat.DoNat(nodeConfig.P2P.NAT, cfg.Downloader.ClientConfig, logger)
	}

	if ctx.IsSet(ErigondbDomainStepsInFrozenFileFlag.Name) {
		s := ctx.String(ErigondbDomainStepsInFrozenFileFlag.Name)
		var v uint64
		if strings.EqualFold(s, "inf") {
			v = config3.UnboundedDomainMerge
		} else {
			parsed, err := strconv.ParseUint(s, 10, 64)
			if err != nil {
				Fatalf("invalid --%s value %q: must be a positive integer or \"Inf\"", ErigondbDomainStepsInFrozenFileFlag.Name, s)
			}
			if parsed == 0 {
				Fatalf("invalid --%s value %q: must be a positive integer or \"Inf\"", ErigondbDomainStepsInFrozenFileFlag.Name, s)
			}
			v = parsed
		}
		cfg.ErigondbDomainStepsInFrozenFile = &v
	}
}

// Convenience type for optional flag value representing a rate limit that should print nicely for
// humans too.
type RateLimitFlagValue g.Option[rate.Limit]

// Converts the parsed rate limit to the type expected by the Downloader torrent configuration.
func (me RateLimitFlagValue) TorrentRateLimit() g.Option[rate.Limit] {
	return g.Option[rate.Limit](me)
}

func GetStringFlagRateLimit(value string) (_ RateLimitFlagValue, err error) {
	switch value {
	case "":
		return
	case "Inf":
		return RateLimitFlagValue(g.Some(rate.Inf)), nil
	}
	var size datasize.ByteSize
	err = size.UnmarshalText([]byte(value))
	if err != nil {
		return
	}
	return RateLimitFlagValue(g.Some(rate.Limit(size))), nil
}

// Takes a string value from a flag, in a human readable byte rate format, and converts it to a
// Downloader rate limit option value. Panics on parse errors per the old package behaviour.
func MustGetStringFlagDownloaderRateLimit(value string) (_ g.Option[rate.Limit]) {
	hiho, err := GetStringFlagRateLimit(value)
	panicif.Err(err)
	return hiho.TorrentRateLimit()
}

// Converts flag value to an Option for packages that abstract over flag handling.
func boolFlagOpt(ctx *cli.Context, flag *cli.BoolFlag) g.Option[bool] {
	if ctx.IsSet(flag.Name) {
		return g.Some(ctx.Bool(flag.Name))
	}
	return g.None[bool]()
}

// SetDNSDiscoveryDefaults configures DNS discovery with the given URL if
// no URLs are set.
func SetDNSDiscoveryDefaults(cfg *ethconfig.Config, spec chainspec.Spec) {
	if cfg.EthDiscoveryURLs != nil {
		return // already set through flags/config
	}
	if url := spec.DNSNetwork; url != "" {
		cfg.EthDiscoveryURLs = []string{url}
	}
}

func SplitTagsFlag(tagsFlag string) map[string]string {
	tags := common.CliString2Array(tagsFlag)
	tagsMap := map[string]string{}

	for _, t := range tags {
		if t != "" {
			kv := strings.Split(t, "=")

			if len(kv) == 2 {
				tagsMap[kv[0]] = kv[1]
			}
		}
	}

	return tagsMap
}

func CobraFlags(cmd *cobra.Command, urfaveCliFlagsLists ...[]cli.Flag) {
	flags := cmd.PersistentFlags()
	for _, urfaveCliFlags := range urfaveCliFlagsLists {
		for _, flag := range urfaveCliFlags {
			switch f := flag.(type) {
			case *cli.IntFlag:
				flags.Int(f.Name, f.Value, f.Usage)
			case *cli.UintFlag:
				flags.Uint(f.Name, f.Value, f.Usage)
			case *cli.StringFlag:
				flags.StringVar(&f.Value, f.Name, f.Value, f.Usage)
			case *cli.StringSliceFlag:
				var val []string
				if f.Value != nil {
					val = f.Value.Value()
				}
				flags.StringSlice(f.Name, val, f.Usage)
			case *cli.BoolFlag:
				flags.Bool(f.Name, false, f.Usage)
			default:
				panic(fmt.Errorf("unexpected type: %T", flag))
			}
		}
	}
}