feat(manager): create sequencer events populate sequencers list

block/manager.go

@@ -194,6 +194,7 @@
 	/* ----------------------------- sequencer mode ----------------------------- */
 	// Subscribe to batch events, to update last submitted height in case batch confirmation was lost. This could happen if the sequencer crash/restarted just after submitting a batch to the settlement and by the time we query the last batch, this batch wasn't accepted yet.
 	go uevent.MustSubscribe(ctx, m.Pubsub, "updateSubmittedHeightLoop", settlement.EventQueryNewSettlementBatchAccepted, m.UpdateLastSubmittedHeight, m.logger)
+	go uevent.MustSubscribe(ctx, m.Pubsub, "newBondedSequencer", settlement.EventQueryNewBondedSequencer, m.UpdateSequencerSet, m.logger)
 
 	// Sequencer must wait till DA is synced to start submitting blobs
 	<-m.DAClient.Synced()

block/sequencers.go

@@ -8,6 +8,7 @@ import (
 
 	"github.com/dymensionxyz/dymint/settlement"
 	"github.com/dymensionxyz/dymint/types"
+	"github.com/tendermint/tendermint/libs/pubsub"
 )
 
 func (m *Manager) MonitorSequencerRotation(ctx context.Context, rotateC chan string) error {
@@ -179,3 +180,27 @@ func (m *Manager) UpdateProposer() error {
 	m.State.Sequencers.SetProposer(m.SLClient.GetProposer())
 	return nil
 }
+
+// UpdateLastSubmittedHeight will update last height submitted height upon events.
+// This may be necessary in case we crashed/restarted before getting response for our submission to the settlement layer.
+func (m *Manager) UpdateSequencerSet(event pubsub.Message) {
+	eventData, ok := event.Data().(*settlement.EventDataNewBondedSequencer)
+	if !ok {
+		m.logger.Error("onReceivedBatch", "err", "wrong event data received")
+		return
+	}
+
+	if m.State.Sequencers.GetByAddress(eventData.SeqAddr) != nil {
+		m.logger.Debug("Sequencer not added from new bonded sequencer event because already in the list.")
+		return
+	}
+
+	newSequencer, err := m.SLClient.GetSequencerByAddress(eventData.SeqAddr)
+	if err != nil {
+		m.logger.Error("Unable to add new sequencer from event. err:%w", err)
+		return
+	}
+	sequencers := m.State.Sequencers.Sequencers
+	sequencers = append(sequencers, newSequencer)
+	m.State.Sequencers.SetSequencers(sequencers)
+}

settlement/dymension/dymension.go

@@ -318,6 +318,46 @@ func (c *Client) GetProposer() *types.Sequencer {
 	return &seqs[index]
 }
 
+// GetSequencerByAddress returns a sequencer by its address.
+func (c *Client) GetSequencerByAddress(address string) (types.Sequencer, error) {
+	var res *sequencertypes.QueryGetSequencerResponse
+	req := &sequencertypes.QueryGetSequencerRequest{
+		SequencerAddress: address,
+	}
+
+	err := c.RunWithRetry(func() error {
+		var err error
+		res, err = c.sequencerQueryClient.Sequencer(c.ctx, req)
+		if err == nil {
+			return nil
+		}
+
+		if status.Code(err) == codes.NotFound {
+			return retry.Unrecoverable(errors.Join(gerrc.ErrNotFound, err))
+		}
+		return err
+	})
+
+	if err != nil {
+		return types.Sequencer{}, err
+	}
+
+	var pubKey cryptotypes.PubKey
+	err = c.protoCodec.UnpackAny(res.Sequencer.DymintPubKey, &pubKey)
+	if err != nil {
+		return types.Sequencer{}, err
+	}
+
+	tmPubKey, err := cryptocodec.ToTmPubKeyInterface(pubKey)
+	if err != nil {
+		return types.Sequencer{}, err
+	}
+
+	sequencer := *types.NewSequencer(tmPubKey, res.Sequencer.Address)
+
+	return sequencer, nil
+}
+
 // GetAllSequencers returns all sequencers of the given rollapp.
 func (c *Client) GetAllSequencers() ([]types.Sequencer, error) {
 	var res *sequencertypes.QueryGetSequencersByRollappResponse

settlement/grpc/grpc.go

@@ -228,6 +228,11 @@ func (c *Client) GetProposer() *types.Sequencer {
 	return types.NewSequencer(tmPubKey, pubKey.Address().String())
 }
 
+// GetSequencerByAddress returns all sequencer information by its address. Not implemented since it will not be used in grpc SL
+func (c *Client) GetSequencerByAddress(address string) (types.Sequencer, error) {
+	return types.Sequencer{}, nil
+}
+
 // GetAllSequencers implements settlement.ClientI.
 func (c *Client) GetAllSequencers() ([]types.Sequencer, error) {
 	return c.GetBondedSequencers()

settlement/local/local.go

@@ -206,6 +206,11 @@ func (c *Client) GetProposer() *types.Sequencer {
 	return types.NewSequencer(tmPubKey, pubKey.Address().String())
 }
 
+// GetSequencerByAddress returns all sequencer information by its address. Not implemented since it will not be used in mock SL
+func (c *Client) GetSequencerByAddress(address string) (types.Sequencer, error) {
+	return types.Sequencer{}, nil
+}
+
 // GetAllSequencers implements settlement.ClientI.
 func (c *Client) GetAllSequencers() ([]types.Sequencer, error) {
 	return c.GetBondedSequencers()

settlement/settlement.go

@@ -73,7 +73,8 @@ type ClientI interface {
 	GetLatestBatch() (*ResultRetrieveBatch, error)
 	// GetBatchAtIndex returns the batch at the given index.
 	GetBatchAtIndex(index uint64) (*ResultRetrieveBatch, error)
-
+	// GetSequencerByAddress returns all sequencer information by its address.
+	GetSequencerByAddress(address string) (types.Sequencer, error)
 	// GetAllSequencers returns all sequencers for this rollapp (bonded and not bonded).
 	GetAllSequencers() ([]types.Sequencer, error)
 	// GetBondedSequencers returns the list of the bonded sequencers for this rollapp.