feat(abci): add a custom process proposal

cosmos/config/config.go

@@ -83,6 +83,11 @@ func readConfigFromAppOptsParser(parser AppOptionsParser) (*Config, error) {
 	conf := &Config{}
 
 	// Polar settings
+	if conf.Polar.IsMainnet, err =
+		parser.GetBool(flags.IsMainnet); err != nil {
+		return nil, err
+	}
+
 	if conf.Polar.RPCGasCap, err =
 		parser.GetUint64(flags.RPCGasCap); err != nil {
 		return nil, err

cosmos/config/flags/flags.go

@@ -22,6 +22,7 @@ package flags
 
 const (
 	// Polar Root.
+	IsMainnet     = "polaris.polar.is-mainnet"
 	RPCEvmTimeout = "polaris.polar.rpc-evm-timeout"
 	RPCTxFeeCap   = "polaris.polar.rpc-tx-fee-cap"
 	RPCGasCap     = "polaris.polar.rpc-gas-cap"

cosmos/config/template.go

@@ -29,6 +29,8 @@ const (
 # General Polaris settings
 [polaris]
 
+is-mainnet = "{{Polaris.Polar.IsMainnet}}
+
 [polaris.polar]
 # Gas cap for RPC requests
 rpc-gas-cap = "{{ .Polaris.Polar.RPCGasCap }}"

cosmos/x/evm/genesis_test.go

@@ -83,7 +83,7 @@ var _ = Describe("Genesis", func() {
 			cfg,
 		)
 		err = k.Setup(
-			core.NewChain(k.Host, params.DefaultChainConfig, beacon.NewFaker()),
+			core.NewChain(k.Host, params.DefaultChainConfig, beacon.NewFaker(), true),
 		)
 		Expect(err).ToNot(HaveOccurred())
 

eth/core/chain.go

@@ -102,6 +102,7 @@ type blockchain struct {
 	rmLogsFeed    event.Feed // currently never used
 	chainSideFeed event.Feed // currently never used
 	logger        log.Logger
+	isMainnet     bool
 }
 
 // =========================================================================
@@ -110,7 +111,7 @@ type blockchain struct {
 
 // NewChain creates and returns a `api.Chain` with the given EVM chain configuration and host.
 func NewChain(
-	host PolarisHostChain, config *params.ChainConfig, engine consensus.Engine,
+	host PolarisHostChain, config *params.ChainConfig, engine consensus.Engine, isMainnet bool,
 ) *blockchain { //nolint:revive // only used as `api.Chain`.
 	bc := &blockchain{
 		bp:             host.GetBlockPlugin(),
@@ -127,6 +128,7 @@ func NewChain(
 		scope:          event.SubscriptionScope{},
 		logger:         log.Root(),
 		engine:         engine,
+		isMainnet:      isMainnet,
 	}
 	bc.statedb = state.NewStateDB(bc.sp, bc.pp)
 	bc.processor = core.NewStateProcessor(bc.config, bc, bc.engine)

eth/core/chain_writer.go

@@ -56,7 +56,9 @@ func (bc *blockchain) InsertBlockAndSetHead(block *types.Block) error {
 	if block.NumberU64() > 1 { // TODO DIAGNOSE
 		if err := bc.validator.ValidateBody(block); err != nil {
 			log.Error("invalid block body", "err", err)
-			return err
+			if bc.isMainnet {
+				return err
+			}
 		}
 	}
 
@@ -70,7 +72,9 @@ func (bc *blockchain) InsertBlockAndSetHead(block *types.Block) error {
 	// ValidateState validates the statedb post block processing.
 	if err = bc.validator.ValidateState(block, bc.statedb, receipts, usedGas); err != nil {
 		log.Error("invalid state after processing block", "num", block.NumberU64(), "err", err)
-		return err
+		if bc.isMainnet {
+			return err
+		}
 	}
 
 	// We can just immediately finalize the block. It's okay in this context.

eth/polar/backend.go

@@ -114,7 +114,7 @@ func New(
 		config:     config,
 		host:       host,
 		engine:     engine,
-		blockchain: core.NewChain(host, &config.Chain, engine),
+		blockchain: core.NewChain(host, &config.Chain, engine, config.IsMainnet),
 	}
 
 	// Build the backend api object.

eth/polar/config.go

@@ -96,4 +96,7 @@ type Config struct {
 	// RPCTxFeeCap is the global transaction fee(price * gaslimit) cap for
 	// send-transaction variants. The unit is ether.
 	RPCTxFeeCap float64
+
+	// IsMainnet is used to enable extra safety checks for a live mainnet.
+	IsMainnet bool
 }