Remove (now-unneeded) filtering in DefaultWasmVMContractResponseHandler.Handle
This commit is contained in:
@@ -1072,20 +1072,12 @@ func NewDefaultWasmVMContractResponseHandler(md msgDispatcher) *DefaultWasmVMCon
|
||||
|
||||
// Handle processes the data returned by a contract invocation.
|
||||
func (h DefaultWasmVMContractResponseHandler) Handle(ctx sdk.Context, contractAddr sdk.AccAddress, ibcPort string, messages []wasmvmtypes.SubMsg, origRspData []byte) ([]byte, error) {
|
||||
em := sdk.NewEventManager()
|
||||
result := origRspData
|
||||
switch rsp, err := h.md.DispatchSubmessages(ctx.WithEventManager(em), contractAddr, ibcPort, messages); {
|
||||
switch rsp, err := h.md.DispatchSubmessages(ctx, contractAddr, ibcPort, messages); {
|
||||
case err != nil:
|
||||
return nil, sdkerrors.Wrap(err, "submessages")
|
||||
case rsp != nil:
|
||||
result = rsp
|
||||
}
|
||||
// TODO: remove this - handled inside DispatchSubmessages
|
||||
// emit non message type events only
|
||||
for _, e := range em.Events() {
|
||||
if e.Type != sdk.EventTypeMessage {
|
||||
ctx.EventManager().EmitEvent(e)
|
||||
}
|
||||
}
|
||||
return result, nil
|
||||
}
|
||||
|
||||
@@ -1563,15 +1563,6 @@ func TestNewDefaultWasmVMContractResponseHandler(t *testing.T) {
|
||||
},
|
||||
expErr: true,
|
||||
},
|
||||
"message events filtered out": {
|
||||
setup: func(m *wasmtesting.MockMsgDispatcher) {
|
||||
m.DispatchSubmessagesFn = func(ctx sdk.Context, contractAddr sdk.AccAddress, ibcPort string, msgs []wasmvmtypes.SubMsg) ([]byte, error) {
|
||||
ctx.EventManager().EmitEvent(sdk.NewEvent(sdk.EventTypeMessage))
|
||||
return nil, nil
|
||||
}
|
||||
},
|
||||
expEvts: sdk.Events{},
|
||||
},
|
||||
"message emit non message events": {
|
||||
setup: func(m *wasmtesting.MockMsgDispatcher) {
|
||||
m.DispatchSubmessagesFn = func(ctx sdk.Context, contractAddr sdk.AccAddress, ibcPort string, msgs []wasmvmtypes.SubMsg) ([]byte, error) {
|
||||
|
||||
Reference in New Issue
Block a user