test: add wasm light client test

Author: wllmshao

tests/e2e/data/wasm_dummy_light_client.go

@@ -17,6 +17,7 @@ var (
 	runRateLimitTest              = true
 	runTxExtensionsTest           = true
 	runCWTest                     = true
+	runWasmLightClientTest        = true
 )
 
 func (s *IntegrationTestSuite) TestRestInterfaces() {
@@ -139,3 +140,11 @@ func (s *IntegrationTestSuite) TestCW() {
 	}
 	s.testCWCounter()
 }
+
+func (s *IntegrationTestSuite) TestWasmLightClient() {
+	if !runWasmLightClientTest {
+		s.T().Skip()
+	}
+	s.testStoreWasmLightClient()
+	s.testCreateWasmLightClient()
+}

tests/e2e/e2e_test.go

@@ -0,0 +1,105 @@
+package e2e
+
+import (
+	"context"
+	"fmt"
+	"path/filepath"
+	"strconv"
+	"time"
+
+	"github.com/cosmos/gaia/v23/tests/e2e/data"
+)
+
+const (
+	proposalStoreWasmLightClientFilename  = "proposal_store_wasm_light_client.json"
+	wasmLightClientStateFilename          = "wasm_light_client_state.json"
+	wasmLightClientConsensusStateFilename = "wasm_light_client_consensus_state.json"
+)
+
+func (s *IntegrationTestSuite) testStoreWasmLightClient() {
+	chainEndpoint := fmt.Sprintf("http://%s", s.valResources[s.chainA.id][0].GetHostPort("1317/tcp"))
+
+	validatorA := s.chainA.validators[0]
+	validatorAAddr, _ := validatorA.keyInfo.GetAddress()
+
+	s.writeStoreWasmLightClientProposal(s.chainA)
+	proposalCounter++
+	submitGovFlags := []string{configFile(proposalStoreWasmLightClientFilename)}
+	depositGovFlags := []string{strconv.Itoa(proposalCounter), depositAmount.String()}
+	voteGovFlags := []string{strconv.Itoa(proposalCounter), "yes"}
+
+	s.T().Logf("Proposal number: %d", proposalCounter)
+	s.T().Logf("Submitting, deposit and vote Gov Proposal: Store wasm light client code")
+	s.submitGovProposal(chainEndpoint, validatorAAddr.String(), proposalCounter, "ibc.lightclients.wasm.v1.MsgStoreCode", submitGovFlags, depositGovFlags, voteGovFlags, "vote")
+
+	s.Require().Eventually(
+		func() bool {
+			s.T().Logf("After StoreWasmLightClient proposal")
+
+			res, err := queryIbcWasmChecksums(chainEndpoint)
+			s.Require().NoError(err)
+			s.Require().NotNil(res)
+			s.Require().Equal(len(res), 1)
+
+			return true
+		},
+		15*time.Second,
+		5*time.Second,
+	)
+}
+
+func (s *IntegrationTestSuite) testCreateWasmLightClient() {
+	ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
+	defer cancel()
+
+	s.writeClientAndConsensusState(s.chainA)
+
+	cmd := []string{
+		gaiadBinary,
+		txCommand,
+		"ibc",
+		"client",
+		"create",
+		wasmLightClientStateFilename,
+		wasmLightClientConsensusStateFilename,
+	}
+
+	s.T().Logf("Creating wasm light client on chain %s", s.chainA.id)
+	s.executeGaiaTxCommand(ctx, s.chainA, cmd, 0, s.defaultExecValidation(s.chainA, 0))
+	s.T().Log("successfully created wasm light client")
+}
+
+func (s *IntegrationTestSuite) writeStoreWasmLightClientProposal(c *chain) {
+	template := `
+	{
+		"messages": [
+			{
+			"@type": "/ibc.lightclients.wasm.v1.MsgStoreCode",
+			"signer": "%s",
+			"wasm_byte_code": "%s"
+			}
+		],
+		"metadata": "AQ==",
+		"deposit": "100uatom",
+		"title": "Store wasm light client code",
+		"summary": "e2e-test storing wasm light client code"
+	   }`
+	propMsgBody := fmt.Sprintf(template,
+		govAuthority,
+		data.WasmDummyLightClient,
+	)
+
+	err := writeFile(filepath.Join(c.validators[0].configDir(), "config", proposalStoreWasmLightClientFilename), []byte(propMsgBody))
+	s.Require().NoError(err)
+}
+
+func (s *IntegrationTestSuite) writeClientAndConsensusState(c *chain) {
+	clientState := `{"@type":"/ibc.lightclients.wasm.v1.ClientState","data":"ZG9lc250IG1hdHRlcg==","checksum":"O45STPnbLLar4DtFwDx0dE6tuXQW5XTKPHpbjaugun4=","latest_height":{"revision_number":"0","revision_height":"7795583"}}`
+	consensusState := `{"@type":"/ibc.lightclients.wasm.v1.ConsensusState","data":"ZG9lc250IG1hdHRlcg=="}`
+
+	err := writeFile(filepath.Join(c.validators[0].configDir(), "config", wasmLightClientStateFilename), []byte(clientState))
+	s.Require().NoError(err)
+
+	err = writeFile(filepath.Join(c.validators[0].configDir(), "config", wasmLightClientConsensusStateFilename), []byte(consensusState))
+	s.Require().NoError(err)
+}

tests/e2e/e2e_wasm_light_client_test.go

@@ -8,6 +8,7 @@ import (
 	"strings"
 
 	ratelimittypes "github.com/cosmos/ibc-apps/modules/rate-limiting/v10/types"
+	wasmclienttypes "github.com/cosmos/ibc-go/modules/light-clients/08-wasm/types"
 	icacontrollertypes "github.com/cosmos/ibc-go/v10/modules/apps/27-interchain-accounts/controller/types"
 	providertypes "github.com/cosmos/interchain-security/v7/x/ccv/provider/types"
 
@@ -403,3 +404,17 @@ func queryWasmSmartContractState(endpoint, address, msg string) ([]byte, error)
 
 	return response.Data, nil
 }
+
+func queryIbcWasmChecksums(endpoint string) ([]string, error) {
+	body, err := httpGet(fmt.Sprintf("%s/ibc/lightclients/wasm/v1/checksums", endpoint))
+	if err != nil {
+		return nil, fmt.Errorf("failed to execute HTTP request: %w", err)
+	}
+
+	var response wasmclienttypes.QueryChecksumsResponse
+	if err = cdc.UnmarshalJSON(body, &response); err != nil {
+		return nil, err
+	}
+
+	return response.Checksums, nil
+}