check the error in event manager

cosmos · Jan 30, 2025 · 327b41a · 327b41a
1 parent 6c23a79
commit 327b41a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/modules/core/keeper/msg_server.go b/modules/core/keeper/msg_server.go
@@ -3,6 +3,7 @@ package keeper
 import (
 	"context"
 	"errors"
+	"fmt"
 
 	"cosmossdk.io/core/event"
 	errorsmod "cosmossdk.io/errors"
@@ -421,7 +422,9 @@ func (k *Keeper) RecvPacket(ctx context.Context, msg *channeltypes.MsgRecvPacket
 						Value: attr.Value,
 					})
 				}
-				k.EventService.EventManager(ctx).EmitKV(e.Type, attrs...)
+				if err := k.EventService.EventManager(ctx).EmitKV(e.Type, attrs...); err != nil {
+					return nil, fmt.Errorf("failed to emit error events in RecvPacket: %w", err)
+				}
 			}
 		}
 	}