fix(manager): gossip any pending blocks not gossiped before (in case of restart or crash)

block/block.go

@@ -1,10 +1,12 @@
 package block
 
 import (
+	"context"
 	"fmt"
 
 	errorsmod "cosmossdk.io/errors"
 
+	"github.com/dymensionxyz/dymint/p2p"
 	"github.com/dymensionxyz/dymint/types"
 )
 
@@ -48,6 +50,16 @@ func (m *Manager) applyBlock(block *types.Block, commit *types.Commit, blockMeta
 			return fmt.Errorf("save block: %w", err)
 		}
 
+		gossipedBlock := p2p.BlockData{Block: *block, Commit: *commit}
+		gossipedBlockBytes, err := gossipedBlock.MarshalBinary()
+		if err != nil {
+			return fmt.Errorf("marshal binary: %w: %w", err, ErrNonRecoverable)
+		}
+		err = m.P2PClient.SaveBlock(context.TODO(), block.Header.Height, gossipedBlockBytes)
+		if err != nil {
+			m.logger.Error("Adding  block to blocksync store.", "err", err, "height", gossipedBlock.Block.Header.Height)
+		}
+
 		responses, err := m.Executor.ExecuteBlock(m.State, block)
 		if err != nil {
 			return fmt.Errorf("execute block: %w", err)

go.mod

@@ -69,7 +69,7 @@ require (
 	github.com/cometbft/cometbft v0.37.2
 	github.com/cometbft/cometbft-db v0.11.0 // indirect
 	github.com/cosmos/cosmos-proto v1.0.0-beta.3
-	github.com/cosmos/gogoproto v1.5.0 // indirect
+	github.com/cosmos/gogoproto v1.5.0
 	github.com/creachadair/taskgroup v0.3.2 // indirect
 	github.com/deckarep/golang-set v1.8.0 // indirect
 	github.com/decred/base58 v1.0.4 // indirect

p2p/client.go

@@ -519,6 +519,11 @@ func (c *Client) blockGossipReceived(ctx context.Context, block []byte) {
 		c.logger.Error("Publishing event.", "err", err)
 	}
 	if c.conf.BlockSyncEnabled {
+		_, err := c.store.LoadBlockCid(gossipedBlock.Block.Header.Height)
+		// skip block already added to blocksync
+		if err == nil {
+			return
+		}
 		err = c.SaveBlock(ctx, gossipedBlock.Block.Header.Height, block)
 		if err != nil {
 			c.logger.Error("Adding  block to blocksync store.", "err", err, "height", gossipedBlock.Block.Header.Height)

proto/types/dymint/state.proto

@@ -44,7 +44,7 @@ message State {
 
   SequencerSet sequencerSet         = 18 [(gogoproto.nullable) = false];
   RollappConsensusParams consensus_params = 19 [(gogoproto.nullable) = false];
-
+  
 }
 
 //rollapp params defined in genesis and updated via gov proposal