fix: remove duplication of events in queued epoch msgs (#714)

Author: RafilxTenfen

CHANGELOG.md

@@ -37,6 +37,13 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 
 ## Unreleased
 
+## v1.0.0-rc.6-hot-fix
+
+### Bug fixes
+
+- [#714](https://github.com/babylonlabs-io/babylon/pull/714) hot-fix: removed
+duplicated events `EventHandleQueuedMsg` at end of epoch for queued messages
+
 ## v1.0.0-rc6
 
 ### Improvements

x/epoching/abci.go

@@ -89,20 +89,20 @@ func EndBlocker(ctx context.Context, k keeper.Keeper) ([]abci.ValidatorUpdate, e
 		queuedMsgs := k.GetCurrentEpochMsgs(ctx)
 		// forward each msg in the msg queue to the right keeper
 		for _, msg := range queuedMsgs {
-			res, err := k.HandleQueuedMsg(ctx, msg)
+			_, errMsg := k.HandleQueuedMsg(ctx, msg)
 			// skip this failed msg and emit and event signalling it
 			// we do not panic here as some users may wrap an invalid message
 			// (e.g., self-delegate coins more than its balance, wrong coding of addresses, ...)
 			// honest validators will have consistent execution results on the queued messages
-			if err != nil {
+			if errMsg != nil {
 				// emit an event signalling the failed execution
 				err := sdkCtx.EventManager().EmitTypedEvent(
 					&types.EventHandleQueuedMsg{
 						EpochNumber: epoch.EpochNumber,
 						Height:      msg.BlockHeight,
 						TxId:        msg.TxId,
 						MsgId:       msg.MsgId,
-						Error:       err.Error(),
+						Error:       errMsg.Error(),
 					},
 				)
 				if err != nil {
@@ -111,21 +111,6 @@ func EndBlocker(ctx context.Context, k keeper.Keeper) ([]abci.ValidatorUpdate, e
 				// skip this failed msg
 				continue
 			}
-			// for each event, emit an wrapped event EventTypeHandleQueuedMsg, which attaches the original attributes plus the original event type, the epoch number, txid and msgid to the event here
-			for _, event := range res.Events {
-				err := sdkCtx.EventManager().EmitTypedEvent(
-					&types.EventHandleQueuedMsg{
-						OriginalEventType:  event.Type,
-						EpochNumber:        epoch.EpochNumber,
-						TxId:               msg.TxId,
-						MsgId:              msg.MsgId,
-						OriginalAttributes: event.Attributes,
-					},
-				)
-				if err != nil {
-					return nil, err
-				}
-			}
 		}
 
 		// update validator set