-
Notifications
You must be signed in to change notification settings - Fork 8
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Browse files
Browse the repository at this point in the history
* add icq module * lint * add interface * . * uncomment test --------- Co-authored-by: themandalore <[email protected]> (cherry picked from commit cefdcfe) Co-authored-by: akrem <[email protected]>
- Loading branch information
1 parent
9287a48
commit 10ad9a7
Showing
7 changed files
with
287 additions
and
20 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,232 @@ | ||
| package e2e_test | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/hex" | ||
| "encoding/json" | ||
| "fmt" | ||
| "testing" | ||
|
|
||
| "github.com/strangelove-ventures/interchaintest/v8" | ||
| "github.com/strangelove-ventures/interchaintest/v8/chain/cosmos" | ||
| "github.com/strangelove-ventures/interchaintest/v8/ibc" | ||
| "github.com/strangelove-ventures/interchaintest/v8/relayer" | ||
| "github.com/strangelove-ventures/interchaintest/v8/testreporter" | ||
| "github.com/strangelove-ventures/interchaintest/v8/testutil" | ||
| "github.com/stretchr/testify/require" | ||
| "github.com/tellor-io/layer/e2e" | ||
| "github.com/tellor-io/layer/utils" | ||
| "go.uber.org/zap/zaptest" | ||
|
|
||
| "cosmossdk.io/math" | ||
|
|
||
| "github.com/cosmos/cosmos-sdk/crypto/keyring" | ||
| sdk "github.com/cosmos/cosmos-sdk/types" | ||
| ) | ||
|
|
||
| func TestIbcInterchainQuery(t *testing.T) { | ||
| if testing.Short() { | ||
| t.Skip("skipping in short mode") | ||
| } | ||
|
|
||
| cosmos.SetSDKConfig("tellor") | ||
|
|
||
| rep := testreporter.NewNopReporter() | ||
| eRep := rep.RelayerExecReporter(t) | ||
|
|
||
| ctx := context.Background() | ||
|
|
||
| client, network := interchaintest.DockerSetup(t) | ||
|
|
||
| modifyGenesis := []cosmos.GenesisKV{ | ||
| cosmos.NewGenesisKV("app_state.dispute.params.team_address", sdk.MustAccAddressFromBech32("tellor14ncp4jg0d087l54pwnp8p036s0dc580xy4gavf").Bytes()), | ||
| cosmos.NewGenesisKV("consensus.params.abci.vote_extensions_enable_height", "1"), | ||
| cosmos.NewGenesisKV("app_state.gov.params.voting_period", "15s"), | ||
| cosmos.NewGenesisKV("app_state.gov.params.max_deposit_period", "10s"), | ||
| cosmos.NewGenesisKV("app_state.gov.params.min_deposit.0.denom", "loya"), | ||
| cosmos.NewGenesisKV("app_state.gov.params.min_deposit.0.amount", "1"), | ||
| cosmos.NewGenesisKV("app_state.globalfee.params.minimum_gas_prices.0.amount", "0.0"), | ||
| } | ||
| nv := 1 | ||
| nf := 0 | ||
| cf := interchaintest.NewBuiltinChainFactory(zaptest.NewLogger(t), []*interchaintest.ChainSpec{ | ||
| { | ||
| NumValidators: &nv, | ||
| NumFullNodes: &nf, | ||
| ChainConfig: ibc.ChainConfig{ | ||
| Type: "cosmos", | ||
| Name: "layer", | ||
| ChainID: "layer", | ||
| Bin: "layerd", | ||
| Denom: "loya", | ||
| Bech32Prefix: "tellor", | ||
| CoinType: "118", | ||
| GasPrices: "0.0loya", | ||
| GasAdjustment: 1.1, | ||
| TrustingPeriod: "504h", | ||
| NoHostMount: false, | ||
| Images: []ibc.DockerImage{ | ||
| { | ||
| Repository: "ghcr.io/akremstudy/layer-icq", // source code ibc branch | ||
| Version: "latest", | ||
| UidGid: "1025:1025", | ||
| }, | ||
| }, | ||
| EncodingConfig: e2e.LayerEncoding(), | ||
| ModifyGenesis: cosmos.ModifyGenesis(modifyGenesis), | ||
| AdditionalStartArgs: []string{"--key-name", "validator", "--price-daemon-enabled=false"}, | ||
| }, | ||
| }, | ||
| { | ||
| NumValidators: &nv, | ||
| NumFullNodes: &nf, | ||
| ChainConfig: ibc.ChainConfig{ | ||
| Type: "cosmos", | ||
| Name: "layer", | ||
| ChainID: "layer-receiver", | ||
| Bin: "layerd", | ||
| Denom: "loya", | ||
| Bech32Prefix: "tellor", | ||
| CoinType: "118", | ||
| GasPrices: "0.0loya", | ||
| GasAdjustment: 1.1, | ||
| TrustingPeriod: "504h", | ||
| NoHostMount: false, | ||
| Images: []ibc.DockerImage{ | ||
| { | ||
| Repository: "layer", | ||
| Version: "local", | ||
| UidGid: "1025:1025", | ||
| }, | ||
| }, | ||
| EncodingConfig: e2e.LayerEncoding(), | ||
| ModifyGenesis: cosmos.ModifyGenesis(modifyGenesis), | ||
| AdditionalStartArgs: []string{"--key-name", "validator", "--price-daemon-enabled=false"}, | ||
| }, | ||
| }, | ||
| }) | ||
|
|
||
| chains, err := cf.Chains(t.Name()) | ||
| require.NoError(t, err) | ||
|
|
||
| layer1, layer2 := chains[0].(*cosmos.CosmosChain), chains[1].(*cosmos.CosmosChain) | ||
|
|
||
| r := interchaintest.NewBuiltinRelayerFactory( | ||
| ibc.CosmosRly, | ||
| zaptest.NewLogger(t), | ||
| relayer.StartupFlags("-b", "100"), | ||
| ).Build(t, client, network) | ||
|
|
||
| const pathName = "layer1-layer2" | ||
| const relayerName = "relayer" | ||
|
|
||
| ic := interchaintest.NewInterchain(). | ||
| AddChain(layer1). | ||
| AddChain(layer2). | ||
| AddRelayer(r, relayerName). | ||
| AddLink(interchaintest.InterchainLink{ | ||
| Chain1: layer1, | ||
| Chain2: layer2, | ||
| Relayer: r, | ||
| Path: pathName, | ||
| CreateClientOpts: ibc.CreateClientOptions{}, | ||
| CreateChannelOpts: ibc.CreateChannelOptions{ | ||
| SourcePortName: "oracle", | ||
| DestPortName: "icqhost", | ||
| Order: ibc.Unordered, | ||
| Version: "icq-1", | ||
| }, | ||
| }) | ||
|
|
||
| require.NoError(t, ic.Build(ctx, eRep, interchaintest.InterchainBuildOptions{ | ||
| TestName: t.Name(), | ||
| Client: client, | ||
| NetworkID: network, | ||
|
|
||
| SkipPathCreation: false, | ||
| })) | ||
|
|
||
| t.Cleanup(func() { | ||
| _ = ic.Close() | ||
| }) | ||
|
|
||
| layer2validator := layer2.Validators[0] | ||
|
|
||
| valAddress, err := layer2validator.AccountKeyBech32(ctx, "validator") | ||
| require.NoError(t, err) | ||
|
|
||
| // create reporter | ||
| _, err = layer2.GetNode().ExecTx(ctx, "validator", "reporter", "create-reporter", math.NewUint(0).String(), math.NewUint(1_000_000).String(), "--keyring-dir", layer2.HomeDir()) | ||
| require.NoError(t, err) | ||
|
|
||
| // tip query | ||
| _, err = layer2validator.ExecTx(ctx, "validator", "oracle", "tip", valAddress, qData, "1000000loya", "--keyring-dir", layer2.HomeDir()) | ||
| require.NoError(t, err) | ||
|
|
||
| // submit value | ||
| _, err = layer2validator.ExecTx(ctx, "validator", "oracle", "submit-value", valAddress, qData, value, "--keyring-dir", layer2.HomeDir()) | ||
| require.NoError(t, err) | ||
|
|
||
| // Query for the recently created channel-id. | ||
| channels, err := r.GetChannels(ctx, eRep, layer1.Config().ChainID) | ||
| require.NoError(t, err) | ||
|
|
||
| // Start the relayer and set the cleanup function. | ||
| err = r.StartRelayer(ctx, eRep, pathName) | ||
| require.NoError(t, err) | ||
|
|
||
| t.Cleanup(func() { | ||
| err := r.StopRelayer(ctx, eRep) | ||
| if err != nil { | ||
| t.Logf("an error occurred while stopping the relayer: %s", err) | ||
| } | ||
| }) | ||
|
|
||
| err = testutil.WaitForBlocks(ctx, 5, layer1, layer2) | ||
| require.NoError(t, err) | ||
|
|
||
| chanID := channels[0].Counterparty.ChannelID | ||
| require.NotEmpty(t, chanID) | ||
|
|
||
| // get aggreate report | ||
| qidbz, err := utils.QueryIDFromDataString(qData) | ||
| require.NoError(t, err) | ||
|
|
||
| cmd := []string{ | ||
| "layerd", "tx", "oracle", "send-query-get-current-aggregated-report", chanID, hex.EncodeToString(qidbz), | ||
| "--node", layer1.GetRPCAddress(), | ||
| "--home", layer1.HomeDir(), | ||
| "--chain-id", layer1.Config().ChainID, | ||
| "--from", "validator", | ||
| "--gas", "1000000", | ||
| "--fees", "1000000loya", | ||
| "--keyring-dir", layer1.HomeDir(), | ||
| "--keyring-backend", keyring.BackendTest, | ||
| "-y", | ||
| } | ||
|
|
||
| // Execute interchain query | ||
| stdout, _, err := layer1.Exec(ctx, cmd, nil) | ||
| require.NoError(t, err) | ||
| fmt.Println(string(stdout)) | ||
|
|
||
| err = testutil.WaitForBlocks(ctx, 10, layer1, layer2) | ||
| require.NoError(t, err) | ||
| cmd = []string{ | ||
| "layerd", "query", "oracle", "query-state", "--sequence", "1", | ||
| "--node", layer1.GetRPCAddress(), | ||
| "--home", layer1.HomeDir(), | ||
| "--chain-id", layer1.Config().ChainID, | ||
| "--output", "json", | ||
| } | ||
|
|
||
| response, _, err := layer1.Exec(ctx, cmd, nil) | ||
| fmt.Println(string(response), "response") | ||
| require.NoError(t, err) | ||
| // Validate response | ||
| var aggReport AggregateReport | ||
| err = json.Unmarshal(response, &aggReport) | ||
| require.NoError(t, err) | ||
| fmt.Println("Aggregate report: ", aggReport) | ||
| require.Equal(t, aggReport.Aggregate.AggregateReporter, valAddress) | ||
| } |
Oops, something went wrong.