-
Notifications
You must be signed in to change notification settings - Fork 662
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
MsgTransfer For Eureka #7957
base: main
Are you sure you want to change the base?
MsgTransfer For Eureka #7957
Conversation
// ClientKeeper defines the expected IBC client keeper | ||
type ClientKeeper interface { | ||
GetClientConsensusState(ctx sdk.Context, clientID string) (connection ibcexported.ConsensusState, found bool) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nonsensical method not used
_, isIBCV2 = k.clientKeeperV2.GetClientCounterparty(ctx, msg.SourceChannel) | ||
if !isIBCV2 { | ||
var found bool | ||
channel, found = k.channelKeeper.GetChannel(ctx, msg.SourcePort, msg.SourceChannel) | ||
if !found { | ||
return nil, errorsmod.Wrapf(channeltypes.ErrChannelNotFound, "port ID (%s) channel ID (%s)", msg.SourcePort, msg.SourceChannel) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i could choose to not have clientKeeperV2 in transfer keeper and just send the channelID from the msg directly to chanKeeperV2 and have it error if counterparty doesn't exist. But then we get a counterparty not found error over the channel not found error
if isIBCV2 { | ||
encoding := msg.Encoding | ||
if encoding == "" { | ||
encoding = types.EncodingJSON |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
default to JSON since that is expected ics20-v1 behaviour
sender.String(), payload, | ||
) | ||
|
||
res, err := k.channelKeeperV2.SendPacket(ctx, msg) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
SendPacket will call transfer module's OnSendPacket
@@ -61,6 +61,27 @@ func NewMsgTransfer( | |||
} | |||
} | |||
|
|||
// NewMsgTransferWithEncoding creates a new MsgTransfer instance | |||
// with the provided encoding | |||
func NewMsgTransferWithEncoding( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Allow users to pass in custom encoding
@@ -289,6 +290,15 @@ func (suite *TransferTestSuite) TestOnAckPacket() { | |||
suite.Require().True(ok) | |||
originalCoin := sdk.NewCoin(tc.sourceDenomToTransfer, amount) | |||
|
|||
msg := types.NewMsgTransferWithEncoding( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Use the transfer endpoint rather than channelKeeper.SendPacket
ics4Wrapper porttypes.ICS4Wrapper | ||
channelKeeper types.ChannelKeeper | ||
channelKeeperV2 types.ChannelKeeperV2 | ||
clientKeeperV2 types.ClientKeeperV2 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I could remove this if desired
I reviewed this yesterday, and came to the conclusion that I want to have a more indepth disucssion on how we do this one, because I am not too comfortable with the flag paths needed to make this work. |
refactored to have most of the logic pulled out in 2 different fns. If its still not desirable, we can revisit the approach |
Not sure why there's so much proto-gen diffs |
|
Description
closes: #7958
Before we can merge this PR, please make sure that all the following items have been
checked off. If any of the checklist items are not applicable, please leave them but
write a little note why.
docs/
).godoc
comments.Files changed
in the GitHub PR explorer.SonarCloud Report
in the comment section below once CI passes.