Skip to content

Commit

Permalink
fix(callbacks): reordered EmitCallbackEvents parameters during usage
Browse files Browse the repository at this point in the history
  • Loading branch information
srdtrk committed Aug 14, 2023
1 parent ddac027 commit ae81073
Show file tree
Hide file tree
Showing 2 changed files with 23 additions and 20 deletions.
10 changes: 5 additions & 5 deletions modules/apps/callbacks/ibc_middleware.go
Original file line number Diff line number Diff line change
Expand Up @@ -107,7 +107,7 @@ func (im IBCMiddleware) SendPacket(
return 0, err
}

types.EmitCallbackEvent(ctx, sourceChannel, sourcePort, seq, types.CallbackTypeSendPacket, callbackData, nil)
types.EmitCallbackEvent(ctx, sourcePort, sourceChannel, seq, types.CallbackTypeSendPacket, callbackData, nil)
return seq, nil
}

Expand Down Expand Up @@ -144,7 +144,7 @@ func (im IBCMiddleware) OnAcknowledgementPacket(
// callback execution errors are not allowed to block the packet lifecycle, they are only used in event emissions
err = im.processCallback(ctx, types.CallbackTypeAcknowledgementPacket, callbackData, callbackExecutor)
types.EmitCallbackEvent(
ctx, packet.GetSourceChannel(), packet.GetSourcePort(), packet.GetSequence(),
ctx, packet.GetSourcePort(), packet.GetSourceChannel(), packet.GetSequence(),
types.CallbackTypeAcknowledgementPacket, callbackData, err,
)

Expand Down Expand Up @@ -176,7 +176,7 @@ func (im IBCMiddleware) OnTimeoutPacket(ctx sdk.Context, packet channeltypes.Pac
// callback execution errors are not allowed to block the packet lifecycle, they are only used in event emissions
err = im.processCallback(ctx, types.CallbackTypeTimeoutPacket, callbackData, callbackExecutor)
types.EmitCallbackEvent(
ctx, packet.GetSourceChannel(), packet.GetSourcePort(), packet.GetSequence(),
ctx, packet.GetSourcePort(), packet.GetSourceChannel(), packet.GetSequence(),
types.CallbackTypeTimeoutPacket, callbackData, err,
)

Expand Down Expand Up @@ -212,7 +212,7 @@ func (im IBCMiddleware) OnRecvPacket(ctx sdk.Context, packet channeltypes.Packet
// callback execution errors are not allowed to block the packet lifecycle, they are only used in event emissions
err = im.processCallback(ctx, types.CallbackTypeReceivePacket, callbackData, callbackExecutor)
types.EmitCallbackEvent(
ctx, packet.GetDestChannel(), packet.GetDestPort(), packet.GetSequence(),
ctx, packet.GetDestPort(), packet.GetDestChannel(), packet.GetSequence(),
types.CallbackTypeReceivePacket, callbackData, err,
)

Expand Down Expand Up @@ -250,7 +250,7 @@ func (im IBCMiddleware) WriteAcknowledgement(
// callback execution errors are not allowed to block the packet lifecycle, they are only used in event emissions
err = im.processCallback(ctx, types.CallbackTypeReceivePacket, callbackData, callbackExecutor)
types.EmitCallbackEvent(
ctx, packet.GetDestChannel(), packet.GetDestPort(), packet.GetSequence(),
ctx, packet.GetDestPort(), packet.GetDestChannel(), packet.GetSequence(),
types.CallbackTypeReceivePacket, callbackData, err,
)

Expand Down
33 changes: 18 additions & 15 deletions modules/apps/callbacks/types/events_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -184,21 +184,24 @@ func (s *CallbacksTypesTestSuite) TestEvents() {
}

for _, tc := range testCases {
newCtx := sdk.Context{}.WithEventManager(sdk.NewEventManager())
tc := tc
s.Run(tc.name, func() {
newCtx := sdk.Context{}.WithEventManager(sdk.NewEventManager())

switch tc.callbackType {
case types.CallbackTypeReceivePacket:
types.EmitCallbackEvent(
newCtx, tc.packet.GetDestChannel(), tc.packet.GetDestPort(),
tc.packet.GetSequence(), tc.callbackType, tc.callbackData, tc.callbackError,
)
default:
types.EmitCallbackEvent(
newCtx, tc.packet.GetSourceChannel(), tc.packet.GetSourcePort(),
tc.packet.GetSequence(), tc.callbackType, tc.callbackData, tc.callbackError,
)
}
events := newCtx.EventManager().Events().ToABCIEvents()
ibctesting.AssertEvents(&s.Suite, tc.expEvents, events)
switch tc.callbackType {
case types.CallbackTypeReceivePacket:
types.EmitCallbackEvent(
newCtx, tc.packet.GetDestPort(), tc.packet.GetDestChannel(),
tc.packet.GetSequence(), tc.callbackType, tc.callbackData, tc.callbackError,
)
default:
types.EmitCallbackEvent(
newCtx, tc.packet.GetSourcePort(), tc.packet.GetSourceChannel(),
tc.packet.GetSequence(), tc.callbackType, tc.callbackData, tc.callbackError,
)
}
events := newCtx.EventManager().Events().ToABCIEvents()
ibctesting.AssertEvents(&s.Suite, tc.expEvents, events)
})
}
}

0 comments on commit ae81073

Please sign in to comment.