trigger oracle participant liveness check

Author: keithsue

api/side/dlc/params.pulsar.go

@@ -15,4 +15,5 @@ message Params {
     repeated string allowed_oracle_participants = 4;
     uint32 oracle_participant_num = 5;
     uint32 oracle_participant_threshold = 6;
+    int64 oracle_participant_liveness_check_interval = 7;
 }

docs/static/openapi.yml

@@ -37,3 +37,8 @@ func (k Keeper) OracleParticipantNum(ctx sdk.Context) uint32 {
 func (k Keeper) OracleParticipantThreshold(ctx sdk.Context) uint32 {
 	return k.GetParams(ctx).OracleParticipantThreshold
 }
+
+// OracleParticipantLivenessCheckInterval gets the oracle participant liveness check interval
+func (k Keeper) OracleParticipantLivenessCheckInterval(ctx sdk.Context) int64 {
+	return k.GetParams(ctx).OracleParticipantLivenessCheckInterval
+}

proto/side/dlc/params.proto

@@ -12,7 +12,7 @@ import (
 // DKGCompletionReceivedHandler is callback handler when the DKG completion received by TSS
 func (k Keeper) DKGCompletionReceivedHandler(ctx sdk.Context, id uint64, ty string, intent int32, participant string) error {
 	switch ty {
-	case types.DKG_TYPE_NONCE:
+	case types.DKG_TYPE_NONCE, types.DKG_TYPE_LIVENESS_CHECK:
 		k.SetOracleParticipantLiveness(ctx, &types.OracleParticipantLiveness{
 			ConsensusPubkey: participant,
 			IsAlive:         true,
@@ -46,12 +46,14 @@ func (k Keeper) DKGCompletedHandler(ctx sdk.Context, id uint64, ty string, inten
 // DKGTimeoutHandler is callback handler when the DKG timed out in TSS
 func (k Keeper) DKGTimeoutHandler(ctx sdk.Context, id uint64, ty string, intent int32, absentParticipants []string) error {
 	switch ty {
-	case types.DKG_TYPE_NONCE:
+	case types.DKG_TYPE_NONCE, types.DKG_TYPE_LIVENESS_CHECK:
 		for _, participant := range absentParticipants {
-			k.SetOracleParticipantLiveness(ctx, &types.OracleParticipantLiveness{
-				ConsensusPubkey: participant,
-				IsAlive:         false,
-			})
+			if k.HasOracleParticipantLiveness(ctx, participant) {
+				liveness := k.GetOracleParticipantLiveness(ctx, participant)
+				liveness.IsAlive = false
+
+				k.SetOracleParticipantLiveness(ctx, liveness)
+			}
 		}
 	}
 
@@ -63,39 +65,28 @@ func (k Keeper) SigningCompletedHandler(ctx sdk.Context, sender string, id uint6
 	return k.HandleAttestation(ctx, sender, types.FromScopedId(scopedId), signatures[0])
 }
 
-// GetOracleParticipants gets oracle participants
+// GetOracleParticipants gets oracle participants randomly
 func (k Keeper) GetOracleParticipants(ctx sdk.Context) []string {
-	// get alive participants
-	aliveParticipants := k.GetAliveOracleParticipants(ctx)
-
-	// check the participant num
+	baseParticipants := k.OracleParticipantBaseSet(ctx)
 	participantNum := int(k.OracleParticipantNum(ctx))
-	if len(aliveParticipants) < participantNum {
-		return nil
-	}
 
-	if len(aliveParticipants) == participantNum {
-		return aliveParticipants
-	}
-
-	participants := []string{}
+	return k.SelectOracleParticipants(ctx, baseParticipants, participantNum)
+}
 
-	// select oracle participants randomly from the alive list based on the expected participant number
-	rand := rand.New(rand.NewSource(ctx.BlockTime().Unix()))
-	selectedIndices := rand.Perm(len(aliveParticipants))[0:participantNum]
-	for _, index := range selectedIndices {
-		participants = append(participants, aliveParticipants[index])
-	}
+// GetAliveOracleParticipants gets alive oracle participants randomly
+func (k Keeper) GetAliveOracleParticipants(ctx sdk.Context) []string {
+	aliveOracleParticipants := k.GetAllAliveOracleParticipants(ctx)
+	participantNum := int(k.OracleParticipantNum(ctx))
 
-	return participants
+	return k.SelectOracleParticipants(ctx, aliveOracleParticipants, participantNum)
 }
 
-// GetAliveOracleParticipants gets alive oracle participants
-func (k Keeper) GetAliveOracleParticipants(ctx sdk.Context) []string {
+// GetAllAliveOracleParticipants gets all alive oracle participants
+func (k Keeper) GetAllAliveOracleParticipants(ctx sdk.Context) []string {
 	// get base participants
 	baseParticipants := k.OracleParticipantBaseSet(ctx)
 
-	// get alive participants
+	// filter alive participants
 	aliveParticipants := []string{}
 	for _, participant := range baseParticipants {
 		if k.IsOracleParticipantAlive(ctx, participant) {
@@ -105,3 +96,24 @@ func (k Keeper) GetAliveOracleParticipants(ctx sdk.Context) []string {
 
 	return aliveParticipants
 }
+
+// SelectOracleParticipants selects oracle participants randomly from the base set based on the specified participant num
+func (k Keeper) SelectOracleParticipants(ctx sdk.Context, baseOracleParticipants []string, participantNum int) []string {
+	if len(baseOracleParticipants) < participantNum {
+		return nil
+	}
+
+	if len(baseOracleParticipants) == participantNum {
+		return baseOracleParticipants
+	}
+
+	selectedParticipants := []string{}
+
+	rand := rand.New(rand.NewSource(ctx.BlockTime().Unix()))
+	selectedIndices := rand.Perm(len(baseOracleParticipants))[0:participantNum]
+	for _, index := range selectedIndices {
+		selectedParticipants = append(selectedParticipants, baseOracleParticipants[index])
+	}
+
+	return selectedParticipants
+}