emit event for btc bridge dkg

Author: keithsue

x/btcbridge/keeper/msg_server.go

@@ -5,6 +5,7 @@ import (
 	"context"
 	"encoding/hex"
 	"fmt"
+	"strings"
 
 	"github.com/btcsuite/btcd/btcutil/psbt"
 
@@ -295,9 +296,15 @@ func (m msgServer) InitiateDKG(goCtx context.Context, msg *types.MsgInitiateDKG)
 	}
 
 	// Emit events
-	m.EmitEvent(ctx, msg.Authority,
-		sdk.NewAttribute("id", fmt.Sprintf("%d", req.Id)),
-		sdk.NewAttribute("expiration", req.Expiration.String()),
+	ctx.EventManager().EmitEvent(
+		sdk.NewEvent(
+			types.EventTypeInitiateDKG,
+			sdk.NewAttribute(types.AttributeKeyId, fmt.Sprintf("%d", req.Id)),
+			sdk.NewAttribute(types.AttributeKeyParticipants, strings.Join(types.GetParticipantPubKeys(req.Participants), types.AttributeValueSeparator)),
+			sdk.NewAttribute(types.AttributeKeyThreshold, fmt.Sprintf("%d", req.Threshold)),
+			sdk.NewAttribute(types.AttributeKeyBatchSize, fmt.Sprintf("%d", len(req.VaultTypes))),
+			sdk.NewAttribute(types.AttributeKeyExpirationTime, req.Expiration.String()),
+		),
 	)
 
 	return &types.MsgInitiateDKGResponse{}, nil

x/btcbridge/types/events.go

@@ -2,9 +2,16 @@ package types
 
 // BtcBridge module event types and attribute keys
 const (
+	EventTypeInitiateDKG     = "initiate_dkg"
 	EventTypeInitiateSigning = "initiate_signing"
 
-	AttributeKeyId        = "id"
+	AttributeKeyId = "id"
+
+	AttributeKeyParticipants   = "participants"
+	AttributeKeyThreshold      = "threshold"
+	AttributeKeyBatchSize      = "batch_size"
+	AttributeKeyExpirationTime = "expiration_time"
+
 	AttributeKeySigners   = "signers"
 	AttributeKeySigHashes = "sig_hashes"
 )

x/btcbridge/types/tss.go

@@ -33,6 +33,17 @@ func ParticipantExists(participants []*DKGParticipant, consAddress string) bool
 	return false
 }
 
+// GetParticipantPubKeys gets consensus pub keys of all participants
+func GetParticipantPubKeys(participants []*DKGParticipant) []string {
+	pubKeys := []string{}
+
+	for _, p := range participants {
+		pubKeys = append(pubKeys, p.ConsensusPubkey)
+	}
+
+	return pubKeys
+}
+
 // CheckDKGCompletionRequests checks if the vaults of all the DKG completion requests are same
 func CheckDKGCompletionRequests(requests []*DKGCompletionRequest) bool {
 	if len(requests) == 0 {