add highest voted height

proto/babylon/btcstaking/v1/btcstaking.proto

@@ -36,6 +36,9 @@ message FinalityProvider {
     uint32 slashed_btc_height = 7;
     // jailed defines whether the finality provider is jailed
     bool jailed = 8;
+    // highest_voted_height is the highest height for which the
+    // finality provider has voted
+    uint32 highest_voted_height = 9;
 }
 
 // FinalityProviderWithMeta wraps the FinalityProvider with metadata.
@@ -57,6 +60,9 @@ message FinalityProviderWithMeta {
     uint32 slashed_btc_height = 5;
     // jailed defines whether the finality provider is detected jailed
     bool jailed = 6;
+    // highest_voted_height is the highest height for which the
+    // finality provider has voted
+    uint32 highest_voted_height = 7;
 }
 
 // BTCDelegation defines a BTC delegation

proto/babylon/btcstaking/v1/query.proto

@@ -270,4 +270,7 @@ message FinalityProviderResponse {
   uint64 height = 8;
   // jailed defines whether the finality provider is jailed
   bool jailed = 9;
+  // highest_voted_height is the highest height for which the
+  // finality provider has voted
+  uint32 highest_voted_height = 10;
 }

proto/babylon/finality/v1/query.proto

@@ -163,6 +163,9 @@ message ActiveFinalityProvidersAtHeightResponse {
   uint32 slashed_btc_height = 5;
   // jailed defines whether the finality provider is detected jailed
   bool jailed = 6;
+  // highest_voted_height is the highest height for which the
+  // finality provider has voted
+  uint32 highest_voted_height = 7;
 }
 
 // QueryActiveFinalityProvidersAtHeightResponse is the response type for the

x/btcstaking/keeper/finality_providers.go

@@ -53,6 +53,17 @@ func (k Keeper) setFinalityProvider(ctx context.Context, fp *types.FinalityProvi
 	store.Set(fp.BtcPk.MustMarshal(), fpBytes)
 }
 
+// UpdateFinalityProvider update the given finality provider to KVStore
+func (k Keeper) UpdateFinalityProvider(ctx context.Context, fp *types.FinalityProvider) error {
+	if !k.HasFinalityProvider(ctx, fp.BtcPk.MustMarshal()) {
+		return types.ErrFpNotFound
+	}
+
+	k.setFinalityProvider(ctx, fp)
+
+	return nil
+}
+
 // HasFinalityProvider checks if the finality provider exists
 func (k Keeper) HasFinalityProvider(ctx context.Context, fpBTCPK []byte) bool {
 	store := k.finalityProviderStore(ctx)

x/btcstaking/keeper/grpc_query_test.go

@@ -107,6 +107,9 @@ func FuzzFinalityProvider(f *testing.F) {
 			require.NoError(t, err)
 
 			AddFinalityProvider(t, ctx, *keeper, fp)
+			fp.HighestVotedHeight = uint32(datagen.RandomInt(r, 1000) + 1)
+			err = keeper.UpdateFinalityProvider(ctx, fp)
+			require.NoError(t, err)
 			fpsMap[fp.BtcPk.MarshalHex()] = fp
 		}
 
@@ -129,6 +132,7 @@ func FuzzFinalityProvider(f *testing.F) {
 			// check keys from map matches those in returned response
 			require.Equal(t, v.BtcPk.MarshalHex(), resp.FinalityProvider.BtcPk.MarshalHex())
 			require.Equal(t, v.Addr, resp.FinalityProvider.Addr)
+			require.Equal(t, v.HighestVotedHeight, resp.FinalityProvider.HighestVotedHeight)
 		}
 
 		// check some random non-existing guy

x/btcstaking/types/query.go

@@ -81,5 +81,6 @@ func NewFinalityProviderResponse(f *FinalityProvider, bbnBlockHeight uint64) *Fi
 		SlashedBtcHeight:     f.SlashedBtcHeight,
 		Jailed:               f.Jailed,
 		Height:               bbnBlockHeight,
+		HighestVotedHeight:   f.HighestVotedHeight,
 	}
 }

x/finality/keeper/grpc_query.go

@@ -90,6 +90,7 @@ func (k Keeper) ActiveFinalityProvidersAtHeight(ctx context.Context, req *types.
 				VotingPower:          votingPower,
 				SlashedBabylonHeight: finalityProvider.SlashedBabylonHeight,
 				SlashedBtcHeight:     finalityProvider.SlashedBtcHeight,
+				HighestVotedHeight:   finalityProvider.HighestVotedHeight,
 			}
 			finalityProvidersWithMeta = append(finalityProvidersWithMeta, &finalityProviderWithMeta)
 		}
@@ -420,6 +421,7 @@ func convertToActiveFinalityProvidersAtHeightResponse(finalityProvidersWithMeta
 			SlashedBabylonHeight: fpWithMeta.SlashedBabylonHeight,
 			SlashedBtcHeight:     fpWithMeta.SlashedBtcHeight,
 			Jailed:               fpWithMeta.Jailed,
+			HighestVotedHeight:   fpWithMeta.HighestVotedHeight,
 		})
 	}
 	return activeFinalityProvidersAtHeightResponse

x/finality/keeper/msg_server.go

@@ -172,6 +172,15 @@ func (ms msgServer) AddFinalitySig(goCtx context.Context, req *types.MsgAddFinal
 	// this signature is good, add vote to DB
 	ms.SetSig(ctx, req.BlockHeight, fpPK, req.FinalitySig)
 
+	// update `HighestVotedHeight` if needed
+	if fp.HighestVotedHeight < uint32(req.BlockHeight) {
+		fp.HighestVotedHeight = uint32(req.BlockHeight)
+		err := ms.BTCStakingKeeper.UpdateFinalityProvider(ctx, fp)
+		if err != nil {
+			return nil, fmt.Errorf("failed to update the finality provider: %w", err)
+		}
+	}
+
 	// if this finality provider has signed the canonical block before,
 	// slash it via extracting its secret key, and emit an event
 	if ms.HasEvidence(ctx, req.FpBtcPk, req.BlockHeight) {

x/finality/keeper/msg_server_test.go

@@ -112,6 +112,7 @@ func FuzzAddFinalitySig(f *testing.F) {
 		defer ctrl.Finish()
 
 		bsKeeper := types.NewMockBTCStakingKeeper(ctrl)
+		bsKeeper.EXPECT().UpdateFinalityProvider(gomock.Any(), gomock.Any()).Return(nil).AnyTimes()
 		cKeeper := types.NewMockCheckpointingKeeper(ctrl)
 		iKeeper := types.NewMockIncentiveKeeper(ctrl)
 		iKeeper.EXPECT().IndexRefundableMsg(gomock.Any(), gomock.Any()).AnyTimes()
@@ -310,6 +311,7 @@ func TestVoteForConflictingHashShouldRetrieveEvidenceAndSlash(t *testing.T) {
 	ctrl := gomock.NewController(t)
 	defer ctrl.Finish()
 	bsKeeper := types.NewMockBTCStakingKeeper(ctrl)
+	bsKeeper.EXPECT().UpdateFinalityProvider(gomock.Any(), gomock.Any()).Return(nil).AnyTimes()
 	cKeeper := types.NewMockCheckpointingKeeper(ctrl)
 	iKeeper := types.NewMockIncentiveKeeper(ctrl)
 	iKeeper.EXPECT().IndexRefundableMsg(gomock.Any(), gomock.Any()).AnyTimes()
@@ -381,6 +383,7 @@ func TestDoNotPanicOnNilProof(t *testing.T) {
 	defer ctrl.Finish()
 
 	bsKeeper := types.NewMockBTCStakingKeeper(ctrl)
+	bsKeeper.EXPECT().UpdateFinalityProvider(gomock.Any(), gomock.Any()).Return(nil).AnyTimes()
 	cKeeper := types.NewMockCheckpointingKeeper(ctrl)
 	iKeeper := types.NewMockIncentiveKeeper(ctrl)
 	iKeeper.EXPECT().IndexRefundableMsg(gomock.Any(), gomock.Any()).AnyTimes()

x/finality/types/expected_keepers.go

@@ -3,9 +3,10 @@ package types
 import (
 	"context"
 
+	sdk "github.com/cosmos/cosmos-sdk/types"
+
 	bstypes "github.com/babylonlabs-io/babylon/x/btcstaking/types"
 	etypes "github.com/babylonlabs-io/babylon/x/epoching/types"
-	sdk "github.com/cosmos/cosmos-sdk/types"
 )
 
 type BTCStakingKeeper interface {
@@ -20,6 +21,7 @@ type BTCStakingKeeper interface {
 	ClearPowerDistUpdateEvents(ctx context.Context, btcHeight uint32)
 	JailFinalityProvider(ctx context.Context, fpBTCPK []byte) error
 	UnjailFinalityProvider(ctx context.Context, fpBTCPK []byte) error
+	UpdateFinalityProvider(ctx context.Context, fp *bstypes.FinalityProvider) error
 }
 
 type CheckpointingKeeper interface {