chore(data-proxy): emit events on TXs and endblock changes

Part-of: #316

x/data-proxy/keeper/abci.go

@@ -1,9 +1,13 @@
 package keeper
 
 import (
+	"encoding/hex"
+
 	"cosmossdk.io/collections"
 
 	sdk "github.com/cosmos/cosmos-sdk/types"
+
+	"github.com/sedaprotocol/seda-chain/x/data-proxy/types"
 )
 
 func (k *Keeper) EndBlock(ctx sdk.Context) (err error) {
@@ -48,7 +52,10 @@ func (k *Keeper) ProcessFeeUpdates(ctx sdk.Context) error {
 			return err
 		}
 
-		// TODO emit events
+		pubKeyHex := hex.EncodeToString(pubkey)
+		ctx.EventManager().EmitEvent(sdk.NewEvent(types.EventTypeFeeUpdate,
+			sdk.NewAttribute(types.AttributePubKey, pubKeyHex),
+			sdk.NewAttribute(types.AttributeFee, proxyConfig.Fee.String())))
 	}
 	return nil
 }

x/data-proxy/keeper/msg_server.go

@@ -92,6 +92,8 @@ func (m msgServer) RegisterDataProxy(goCtx context.Context, msg *types.MsgRegist
 		return nil, err
 	}
 
+	emitProxyConfigEvent(ctx, types.EventTypeRegisterProxy, msg.PubKey, &proxyConfig)
+
 	return &types.MsgRegisterDataProxyResponse{}, nil
 }
 
@@ -131,6 +133,8 @@ func (m msgServer) EditDataProxy(goCtx context.Context, msg *types.MsgEditDataPr
 			return nil, err
 		}
 
+		emitProxyConfigEvent(ctx, types.EventTypeEditProxy, msg.PubKey, &proxyConfig)
+
 		return &types.MsgEditDataProxyResponse{}, nil
 	}
 
@@ -156,11 +160,32 @@ func (m msgServer) EditDataProxy(goCtx context.Context, msg *types.MsgEditDataPr
 		return nil, err
 	}
 
+	emitProxyConfigEvent(ctx, types.EventTypeEditProxy, msg.PubKey, &proxyConfig)
+
 	return &types.MsgEditDataProxyResponse{
 		FeeUpdateHeight: updateHeight,
 	}, nil
 }
 
+func emitProxyConfigEvent(ctx sdk.Context, eventType string, pubKey string, proxyConfig *types.ProxyConfig) {
+	event := sdk.NewEvent(eventType,
+		sdk.NewAttribute(types.AttributePubKey, pubKey),
+		sdk.NewAttribute(types.AttributePayoutAddress, proxyConfig.PayoutAddress),
+		sdk.NewAttribute(types.AttributeFee, proxyConfig.Fee.String()),
+		sdk.NewAttribute(types.AttributeMemo, proxyConfig.Memo),
+		sdk.NewAttribute(types.AttributeAdminAddress, proxyConfig.AdminAddress),
+	)
+
+	if proxyConfig.FeeUpdate != nil {
+		event.AppendAttributes(
+			sdk.NewAttribute(types.AttributeNewFee, proxyConfig.FeeUpdate.String()),
+			sdk.NewAttribute(types.AttributeNewFeeHeight, fmt.Sprintf("%d", proxyConfig.FeeUpdate.UpdateHeight)),
+		)
+	}
+
+	ctx.EventManager().EmitEvent(event)
+}
+
 func (m msgServer) TransferAdmin(goCtx context.Context, msg *types.MsgTransferAdmin) (*types.MsgTransferAdminResponse, error) {
 	ctx := sdk.UnwrapSDKContext(goCtx)
 
@@ -192,6 +217,11 @@ func (m msgServer) TransferAdmin(goCtx context.Context, msg *types.MsgTransferAd
 		return nil, err
 	}
 
+	ctx.EventManager().EmitEvent(sdk.NewEvent(types.EventTypeTransferAdmin,
+		sdk.NewAttribute(types.AttributePubKey, msg.PubKey),
+		sdk.NewAttribute(types.AttributeAdminAddress, proxyConfig.AdminAddress),
+	))
+
 	return &types.MsgTransferAdminResponse{}, nil
 }
 

x/data-proxy/types/events.go

@@ -1,5 +1,16 @@
 package types
 
 const (
-	EventTypeRegisterProxy = "register_proxy"
+	EventTypeRegisterProxy = "register_data_proxy"
+	EventTypeEditProxy     = "edit_data_proxy"
+	EventTypeFeeUpdate     = "fee_update"
+	EventTypeTransferAdmin = "transfer_admin"
+
+	AttributePubKey        = "pub_key"
+	AttributePayoutAddress = "payout_address"
+	AttributeFee           = "fee"
+	AttributeMemo          = "memo"
+	AttributeAdminAddress  = "admin_address"
+	AttributeNewFee        = "new_fee"
+	AttributeNewFeeHeight  = "new_fee_height"
 )