Enable execution only mode in nitro

changelog/bragaigor-nit-4241.md

@@ -0,0 +1,2 @@
+### Changed
+- enable execution and consensus only mode

cmd/chaininfo/chain_info.go

@@ -37,13 +37,15 @@ type ChainInfo struct {
 	RollupAddresses        *RollupAddresses    `json:"rollup"`
 }
 
-func GetChainConfig(chainId *big.Int, chainName string, genesisBlockNum uint64, l2ChainInfoFiles []string, l2ChainInfoJson string) (*params.ChainConfig, error) {
+func GetChainConfig(chainId *big.Int, chainName string, genesisBlockNum *uint64, l2ChainInfoFiles []string, l2ChainInfoJson string) (*params.ChainConfig, error) {
 	chainInfo, err := ProcessChainInfo(chainId.Uint64(), chainName, l2ChainInfoFiles, l2ChainInfoJson)
 	if err != nil {
 		return nil, err
 	}
 	if chainInfo.ChainConfig != nil {
-		chainInfo.ChainConfig.ArbitrumChainParams.GenesisBlockNum = genesisBlockNum
+		if genesisBlockNum != nil {
+			chainInfo.ChainConfig.ArbitrumChainParams.GenesisBlockNum = *genesisBlockNum
+		}
 		return chainInfo.ChainConfig, nil
 	}
 	if chainId.Uint64() != 0 {

cmd/nitro/config/config.go

@@ -143,6 +143,7 @@ func (c *NodeConfig) Validate() error {
 	if err := c.ParentChain.Validate(); err != nil {
 		return err
 	}
+
 	if err := c.Node.Validate(); err != nil {
 		return err
 	}
@@ -169,8 +170,10 @@ func (c *NodeConfig) Validate() error {
 		if c.Node.Sequencer || c.Node.BatchPoster.Enable {
 			return errors.New("sequencing and batch-posting are currently not supported when connecting to an execution client over RPC")
 		}
-	} else if c.Execution.ConsensusRPCClient.URL != "" {
-		return errors.New("consensus is connecting directly to execution but execution is connecting to consensus over an rpc- invalid case")
+	} else if c.Execution.RPCServer.Enable && c.Execution.ConsensusRPCClient.URL == "" {
+		return errors.New("communication over rpc is enabled on execution but consensus RPC client is not set")
+	} else if c.Node.RPCServer.Enable && c.Node.ExecutionRPCClient.URL == "" {
+		return errors.New("communication over rpc is enabled on consensus but execution RPC client is not set")
 	}
 	if err := c.BlocksReExecutor.Validate(); err != nil {
 		return err

cmd/nitro/init/init.go

@@ -776,7 +776,7 @@ func GetInit(config *config.NodeConfig, executionDB ethdb.Database) (statetransf
 			if err != nil {
 				return nil, nil, nil, err
 			}
-			chainConfig, err = chaininfo.GetChainConfig(new(big.Int).SetUint64(config.Chain.ID), config.Chain.Name, genesisBlockNr, config.Chain.InfoFiles, config.Chain.InfoJson)
+			chainConfig, err = chaininfo.GetChainConfig(new(big.Int).SetUint64(config.Chain.ID), config.Chain.Name, &genesisBlockNr, config.Chain.InfoFiles, config.Chain.InfoJson)
 			if err != nil {
 				return nil, nil, nil, err
 			}

cmd/replay/main.go

@@ -397,7 +397,7 @@ func main() {
 			}
 		} else {
 			log.Info("Falling back to hardcoded chain config.")
-			chainConfig, err = chaininfo.GetChainConfig(chainId, "", genesisBlockNum, []string{}, "")
+			chainConfig, err = chaininfo.GetChainConfig(chainId, "", &genesisBlockNum, []string{}, "")
 			if err != nil {
 				panic(err)
 			}
@@ -424,7 +424,8 @@ func main() {
 		chainConfig := initMessage.ChainConfig
 		if chainConfig == nil {
 			log.Info("No chain config in the init message. Falling back to hardcoded chain config.")
-			chainConfig, err = chaininfo.GetChainConfig(initMessage.ChainId, "", 0, []string{}, "")
+			genesisBlockNum := uint64(0)
+			chainConfig, err = chaininfo.GetChainConfig(initMessage.ChainId, "", &genesisBlockNum, []string{}, "")
 			if err != nil {
 				panic(err)
 			}

execution_consensus/init.go

@@ -23,16 +23,21 @@ func InitAndStartExecutionAndConsensusNodes(ctx context.Context, stack *node.Nod
 		return nil, fmt.Errorf("error starting geth stack: %w", err)
 	}
 	if execNode != nil {
+		// consensusNode may be nil; SetConsensusClient handles it via consensusRPCClient
 		execNode.SetConsensusClient(consensusNode)
 		if err := execNode.Start(ctx); err != nil {
 			return nil, fmt.Errorf("error starting exec node: %w", err)
 		}
 	}
-	if err := consensusNode.Start(ctx); err != nil {
-		return nil, fmt.Errorf("error starting consensus node: %w", err)
+	if consensusNode != nil {
+		if err := consensusNode.Start(ctx); err != nil {
+			return nil, fmt.Errorf("error starting consensus node: %w", err)
+		}
 	}
 	return func() {
-		consensusNode.StopAndWait()
+		if consensusNode != nil {
+			consensusNode.StopAndWait()
+		}
 		if execNode != nil {
 			execNode.StopAndWait()
 		}