Skip to content

Commit

Permalink
Rename responses
Browse files Browse the repository at this point in the history
  • Loading branch information
chipshort committed Nov 21, 2023
1 parent 02ba90c commit b9f9624
Showing 1 changed file with 20 additions and 20 deletions.
40 changes: 20 additions & 20 deletions ibc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,8 +108,8 @@ func TestIBCHandshake(t *testing.T) {
i, _, err := vm.Instantiate(checksum, env, info, toBytes(t, init_msg), store, *goapi, querier, gasMeter1, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
assert.NotNil(t, i.Ok)
ires := i.Ok
require.Equal(t, 0, len(ires.Messages))
iResponse := i.Ok
require.Equal(t, 0, len(iResponse.Messages))

// channel open
gasMeter2 := api.NewMockGasMeter(TESTING_GAS_LIMIT)
Expand All @@ -119,8 +119,8 @@ func TestIBCHandshake(t *testing.T) {
o, _, err := vm.IBCChannelOpen(checksum, env, openMsg, store, *goapi, querier, gasMeter2, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
require.NotNil(t, o.Ok)
ores := o.Ok
require.Equal(t, &types.IBC3ChannelOpenResponse{Version: "ibc-reflect-v1"}, ores)
oResponse := o.Ok
require.Equal(t, &types.IBC3ChannelOpenResponse{Version: "ibc-reflect-v1"}, oResponse)

// channel connect
gasMeter3 := api.NewMockGasMeter(TESTING_GAS_LIMIT)
Expand All @@ -131,8 +131,8 @@ func TestIBCHandshake(t *testing.T) {
conn, _, err := vm.IBCChannelConnect(checksum, env, connectMsg, store, *goapi, querier, gasMeter2, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
require.NotNil(t, conn.Ok)
res := conn.Ok
require.Equal(t, 1, len(res.Messages))
connResponse := conn.Ok
require.Equal(t, 1, len(connResponse.Messages))

// check for the expected custom event
expected_events := []types.Event{{
Expand All @@ -142,10 +142,10 @@ func TestIBCHandshake(t *testing.T) {
Value: "connect",
}},
}}
require.Equal(t, expected_events, res.Events)
require.Equal(t, expected_events, connResponse.Events)

// make sure it read the balance properly and we got 250 atoms
dispatch := res.Messages[0].Msg
dispatch := connResponse.Messages[0].Msg
require.NotNil(t, dispatch.Wasm, "%#v", dispatch)
require.NotNil(t, dispatch.Wasm.Instantiate, "%#v", dispatch)
init := dispatch.Wasm.Instantiate
Expand Down Expand Up @@ -188,8 +188,8 @@ func TestIBCPacketDispatch(t *testing.T) {
o, _, err := vm.IBCChannelOpen(checksum, env, openMsg, store, *goapi, querier, gasMeter2, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
require.NotNil(t, o.Ok)
ores := o.Ok
require.Equal(t, &types.IBC3ChannelOpenResponse{Version: "ibc-reflect-v1"}, ores)
oResponse := o.Ok
require.Equal(t, &types.IBC3ChannelOpenResponse{Version: "ibc-reflect-v1"}, oResponse)

// channel connect
gasMeter3 := api.NewMockGasMeter(TESTING_GAS_LIMIT)
Expand All @@ -199,9 +199,9 @@ func TestIBCPacketDispatch(t *testing.T) {
conn, _, err := vm.IBCChannelConnect(checksum, env, connectMsg, store, *goapi, querier, gasMeter3, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
require.NotNil(t, conn.Ok)
res := conn.Ok
require.Equal(t, 1, len(res.Messages))
id := res.Messages[0].ID
connResponse := conn.Ok
require.Equal(t, 1, len(connResponse.Messages))
id := connResponse.Messages[0].ID

// mock reflect init callback (to store address)
gasMeter4 := api.NewMockGasMeter(TESTING_GAS_LIMIT)
Expand Down Expand Up @@ -233,9 +233,9 @@ func TestIBCPacketDispatch(t *testing.T) {
q, _, err := vm.Query(checksum, env, toBytes(t, queryMsg), store, *goapi, querier, gasMeter4, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
require.NotNil(t, q.Ok)
qres := q.Ok
qResponse := q.Ok
var accounts ListAccountsResponse
err = json.Unmarshal(qres, &accounts)
err = json.Unmarshal(qResponse, &accounts)
require.NoError(t, err)
require.Equal(t, 1, len(accounts.Accounts))
require.Equal(t, CHANNEL_ID, accounts.Accounts[0].ChannelID)
Expand All @@ -258,11 +258,11 @@ func TestIBCPacketDispatch(t *testing.T) {
pr, _, err := vm.IBCPacketReceive(checksum, env, msg, store, *goapi, querier, gasMeter5, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
assert.NotNil(t, pr.Ok)
pres := pr.Ok
prResponse := pr.Ok

// assert app-level success
var ack AcknowledgeDispatch
err = json.Unmarshal(pres.Acknowledgement, &ack)
err = json.Unmarshal(prResponse.Acknowledgement, &ack)
require.NoError(t, err)
require.Empty(t, ack.Err)

Expand All @@ -271,10 +271,10 @@ func TestIBCPacketDispatch(t *testing.T) {
pr2, _, err := vm.IBCPacketReceive(checksum, env, msg2, store, *goapi, querier, gasMeter5, TESTING_GAS_LIMIT, deserCost)
require.NoError(t, err)
assert.NotNil(t, pr.Ok)
pres2 := pr2.Ok
prResponse2 := pr2.Ok
// assert app-level failure
var ack2 AcknowledgeDispatch
err = json.Unmarshal(pres2.Acknowledgement, &ack2)
err = json.Unmarshal(prResponse2.Acknowledgement, &ack2)
require.NoError(t, err)
require.Equal(t, "invalid packet: cosmwasm_std::addresses::Addr not found", ack2.Err)

Expand All @@ -286,7 +286,7 @@ func TestIBCPacketDispatch(t *testing.T) {
Value: "receive",
}},
}}
require.Equal(t, expected_events, pres2.Events)
require.Equal(t, expected_events, prResponse2.Events)
}

func TestAnalyzeCode(t *testing.T) {
Expand Down

0 comments on commit b9f9624

Please sign in to comment.