Merge pull request #473 from distractedm1nd/lazy-initGenesisChunks

Move initGenesisChunks call into GetGenesisChunks

Author: tzdybal

node/node.go

@@ -215,10 +215,6 @@ func (n *Node) OnStart() error {
 	if err != nil {
 		return fmt.Errorf("error while starting data availability layer client: %w", err)
 	}
-	err = n.initGenesisChunks()
-	if err != nil {
-		return fmt.Errorf("error while creating chunks of the genesis document: %w", err)
-	}
 	if n.conf.Aggregator {
 		n.Logger.Info("working in aggregator mode", "block time", n.conf.BlockTime)
 		go n.blockManager.AggregationLoop(n.ctx)
@@ -236,8 +232,12 @@ func (n *Node) GetGenesis() *tmtypes.GenesisDoc {
 }
 
 // GetGenesisChunks returns chunked version of genesis.
-func (n *Node) GetGenesisChunks() []string {
-	return n.genChunks
+func (n *Node) GetGenesisChunks() ([]string, error) {
+	err := n.initGenesisChunks()
+	if err != nil {
+		return nil, err
+	}
+	return n.genChunks, err
 }
 
 // OnStop is a part of Service interface.

rpc/client/client.go

@@ -275,7 +275,10 @@ func (c *Client) Genesis(_ context.Context) (*ctypes.ResultGenesis, error) {
 
 // GenesisChunked returns given chunk of genesis.
 func (c *Client) GenesisChunked(context context.Context, id uint) (*ctypes.ResultGenesisChunk, error) {
-	genChunks := c.node.GetGenesisChunks()
+	genChunks, err := c.node.GetGenesisChunks()
+	if err != nil {
+		return nil, fmt.Errorf("error while creating chunks of the genesis document: %w", err)
+	}
 	if genChunks == nil {
 		return nil, fmt.Errorf("service configuration error, genesis chunks are not initialized")
 	}