feat(sequencers): v4 migration for proposer

app/upgrades/v4/upgrade.go

@@ -125,17 +125,18 @@ func migrateRollapps(ctx sdk.Context, rollappkeeper *rollappkeeper.Keeper) error
 }
 
 func migrateSequencers(ctx sdk.Context, sequencerkeeper sequencerkeeper.Keeper) {
-	// FIXME: handle migration (https://github.com/dymensionxyz/dymension/issues/1026)
-
 	list := sequencerkeeper.GetAllSequencers(ctx)
 	for _, oldSequencer := range list {
 		newSequencer := ConvertOldSequencerToNew(oldSequencer)
 		sequencerkeeper.SetSequencer(ctx, newSequencer)
+
+		if oldSequencer.Proposer {
+			sequencerkeeper.SetProposer(ctx, oldSequencer.RollappId, oldSequencer.Address)
+		}
 	}
 }
 
 func ConvertOldRollappToNew(oldRollapp rollapptypes.Rollapp) rollapptypes.Rollapp {
-	bech32Prefix := oldRollapp.RollappId[:5]
 	return rollapptypes.Rollapp{
 		RollappId:        oldRollapp.RollappId,
 		Owner:            oldRollapp.Owner,
@@ -144,7 +145,7 @@ func ConvertOldRollappToNew(oldRollapp rollapptypes.Rollapp) rollapptypes.Rollap
 		Frozen:           oldRollapp.Frozen,
 		RegisteredDenoms: oldRollapp.RegisteredDenoms,
 		// TODO: regarding missing data - https://github.com/dymensionxyz/dymension/issues/986
-		Bech32Prefix:    bech32Prefix,                                        // placeholder data
+		Bech32Prefix:    oldRollapp.RollappId[:5],                            // placeholder data
 		GenesisChecksum: string(crypto.Sha256([]byte(oldRollapp.RollappId))), // placeholder data
 		VmType:          rollapptypes.Rollapp_EVM,                            // placeholder data
 		Metadata: &rollapptypes.RollappMetadata{
@@ -155,6 +156,8 @@ func ConvertOldRollappToNew(oldRollapp rollapptypes.Rollapp) rollapptypes.Rollap
 			Telegram:         "",
 			X:                "",
 		},
+		InitialSequencer: "*",
+		Sealed:           true,
 	}
 }
 

app/upgrades/v4/upgrade_test.go

@@ -186,10 +186,9 @@ func (s *UpgradeTestSuite) validateRollappsMigration(numRoll int) error {
 }
 
 func (s *UpgradeTestSuite) validateSequencersMigration(numSeq int) error {
-	// FIXME: test proposer migration (https://github.com/dymensionxyz/dymension/issues/1026)
-
-	expectSequencers := make([]sequencertypes.Sequencer, numSeq)
-	for i, sequencer := range s.seedSequencers(numSeq) {
+	testSeqs := s.seedSequencers(numSeq)
+	expectSequencers := make([]sequencertypes.Sequencer, len(testSeqs))
+	for i, sequencer := range testSeqs {
 		expectSequencers[i] = v4.ConvertOldSequencerToNew(sequencer)
 	}
 	sequencers := s.App.SequencerKeeper.GetAllSequencers(s.Ctx)
@@ -215,6 +214,13 @@ func (s *UpgradeTestSuite) validateSequencersMigration(numSeq int) error {
 
 		s.Require().JSONEq(string(seq), string(nSeq))
 	}
+
+	// check proposer
+	for _, rollapp := range s.App.RollappKeeper.GetAllRollapps(s.Ctx) {
+		_, found := s.App.SequencerKeeper.GetProposer(s.Ctx, rollapp.RollappId)
+		s.Assert().True(found)
+	}
+
 	return nil
 }
 
@@ -246,24 +252,30 @@ func (s *UpgradeTestSuite) seedAndStoreSequencers(numRollapps int) {
 	}
 }
 
-func (s *UpgradeTestSuite) seedSequencers(numSeq int) []sequencertypes.Sequencer {
-	sequencers := make([]sequencertypes.Sequencer, numSeq)
-	for i := 0; i < numSeq; i++ {
+func (s *UpgradeTestSuite) seedSequencers(numRollapps int) []sequencertypes.Sequencer {
+	numSeqPerRollapp := numRollapps
+	sequencers := make([]sequencertypes.Sequencer, 0, numSeqPerRollapp*numRollapps)
+	for i := 0; i < numRollapps; i++ {
 		rollappID := rollappIDFromIdx(i)
-		pk := ed25519.GenPrivKeyFromSecret([]byte(rollappID)).PubKey()
-		pkAny, _ := codectypes.NewAnyWithValue(pk)
-		sequencer := sequencertypes.Sequencer{
-			Address:      sdk.AccAddress(pk.Address()).String(),
-			DymintPubKey: pkAny,
-			RollappId:    rollappID,
-			Metadata: sequencertypes.SequencerMetadata{
-				Moniker: fmt.Sprintf("sequencer-%d", i),
-				Details: fmt.Sprintf("Additional details about the sequencer-%d", i),
-			},
-			Status: sequencertypes.Bonded,
-			Tokens: sdk.NewCoins(sdk.NewInt64Coin("dym", 100)),
+
+		for j := 0; j < numSeqPerRollapp; j++ {
+			uuid := fmt.Sprintf("sequencer-%d-%d", i, j)
+			pk := ed25519.GenPrivKeyFromSecret([]byte(uuid)).PubKey()
+			pkAny, _ := codectypes.NewAnyWithValue(pk)
+			sequencer := sequencertypes.Sequencer{
+				Address:      sdk.AccAddress(pk.Address()).String(),
+				DymintPubKey: pkAny,
+				RollappId:    rollappID,
+				Metadata: sequencertypes.SequencerMetadata{
+					Moniker: uuid,
+					Details: fmt.Sprintf("Additional details about the %s", uuid),
+				},
+				Status:   sequencertypes.Bonded,
+				Tokens:   sdk.NewCoins(sdk.NewInt64Coin("dym", 100)),
+				Proposer: j == 0, // first sequencer is proposer
+			}
+			sequencers = append(sequencers, sequencer)
 		}
-		sequencers[i] = sequencer
 	}
 	return sequencers
 }

proto/dymensionxyz/dymension/sequencer/sequencer.proto

@@ -26,9 +26,9 @@ message Sequencer {
   SequencerMetadata metadata = 4 [(gogoproto.nullable) = false];
   // jailed defined whether the sequencer has been jailed from bonded status or not.
   bool jailed = 5;
-
-  reserved 6;
-
+  
+  bool proposer = 6 [deprecated = true];
+  
   // status is the sequencer status (bonded/unbonding/unbonded).
   OperatingStatus status = 7;
   // tokens define the delegated tokens (incl. self-delegation).