e6f51498b6
* Upgrade to IBC v4.2.0 with interchain-accounts v0.2.4 * Fix linter issues * Test version handshake * Add more ibc e2e scenarios * Add fee middleware to wasm * Get ibc app version from middleware
83 lines
2.4 KiB
Go
83 lines
2.4 KiB
Go
package wasm
|
|
|
|
import (
|
|
"testing"
|
|
|
|
wasmvmtypes "github.com/CosmWasm/wasmvm/types"
|
|
clienttypes "github.com/cosmos/ibc-go/v4/modules/core/02-client/types"
|
|
channeltypes "github.com/cosmos/ibc-go/v4/modules/core/04-channel/types"
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
func TestMapToWasmVMIBCPacket(t *testing.T) {
|
|
var myTimestamp uint64 = 1
|
|
specs := map[string]struct {
|
|
src channeltypes.Packet
|
|
exp wasmvmtypes.IBCPacket
|
|
}{
|
|
"with height timeout": {
|
|
src: IBCPacketFixture(),
|
|
exp: wasmvmtypes.IBCPacket{
|
|
Data: []byte("myData"),
|
|
Src: wasmvmtypes.IBCEndpoint{PortID: "srcPort", ChannelID: "channel-1"},
|
|
Dest: wasmvmtypes.IBCEndpoint{PortID: "destPort", ChannelID: "channel-2"},
|
|
Sequence: 1,
|
|
Timeout: wasmvmtypes.IBCTimeout{Block: &wasmvmtypes.IBCTimeoutBlock{Height: 1, Revision: 2}},
|
|
},
|
|
},
|
|
"with time timeout": {
|
|
src: IBCPacketFixture(func(p *channeltypes.Packet) {
|
|
p.TimeoutTimestamp = myTimestamp
|
|
p.TimeoutHeight = clienttypes.Height{}
|
|
}),
|
|
exp: wasmvmtypes.IBCPacket{
|
|
Data: []byte("myData"),
|
|
Src: wasmvmtypes.IBCEndpoint{PortID: "srcPort", ChannelID: "channel-1"},
|
|
Dest: wasmvmtypes.IBCEndpoint{PortID: "destPort", ChannelID: "channel-2"},
|
|
Sequence: 1,
|
|
Timeout: wasmvmtypes.IBCTimeout{Timestamp: myTimestamp},
|
|
},
|
|
}, "with time and height timeout": {
|
|
src: IBCPacketFixture(func(p *channeltypes.Packet) {
|
|
p.TimeoutTimestamp = myTimestamp
|
|
}),
|
|
exp: wasmvmtypes.IBCPacket{
|
|
Data: []byte("myData"),
|
|
Src: wasmvmtypes.IBCEndpoint{PortID: "srcPort", ChannelID: "channel-1"},
|
|
Dest: wasmvmtypes.IBCEndpoint{PortID: "destPort", ChannelID: "channel-2"},
|
|
Sequence: 1,
|
|
Timeout: wasmvmtypes.IBCTimeout{
|
|
Block: &wasmvmtypes.IBCTimeoutBlock{Height: 1, Revision: 2},
|
|
Timestamp: myTimestamp,
|
|
},
|
|
},
|
|
},
|
|
}
|
|
for name, spec := range specs {
|
|
t.Run(name, func(t *testing.T) {
|
|
got := newIBCPacket(spec.src)
|
|
assert.Equal(t, spec.exp, got)
|
|
})
|
|
}
|
|
}
|
|
|
|
func IBCPacketFixture(mutators ...func(p *channeltypes.Packet)) channeltypes.Packet {
|
|
r := channeltypes.Packet{
|
|
Sequence: 1,
|
|
SourcePort: "srcPort",
|
|
SourceChannel: "channel-1",
|
|
DestinationPort: "destPort",
|
|
DestinationChannel: "channel-2",
|
|
Data: []byte("myData"),
|
|
TimeoutHeight: clienttypes.Height{
|
|
RevisionHeight: 1,
|
|
RevisionNumber: 2,
|
|
},
|
|
TimeoutTimestamp: 0,
|
|
}
|
|
for _, m := range mutators {
|
|
m(&r)
|
|
}
|
|
return r
|
|
}
|