ICS 03 Implementation

client/flags/flags.go

@@ -54,6 +54,7 @@ const (
  FlagRPCWriteTimeout = "write-timeout"
  FlagOutputDocument = "output-document" // inspired by wget -O
  FlagSkipConfirmation = "yes"
+ FlagProve = "prove"
 )
 
 // LineBreak can be included in a command list to provide a blank line

x/ibc/03-connection/alias.go

@@ -0,0 +1,102 @@
+package connection
+
+// nolint
+// autogenerated code using github.com/rigelrozanski/multitool
+// aliases generated for the following subdirectories:
+// ALIASGEN: github.com/cosmos/cosmos-sdk/x/ibc/03-connection/keeper
+// ALIASGEN: github.com/cosmos/cosmos-sdk/x/ibc/03-connection/types
+
+import (
+ "github.com/cosmos/cosmos-sdk/x/ibc/03-connection/keeper"
+ "github.com/cosmos/cosmos-sdk/x/ibc/03-connection/types"
+)
+
+const (
+ NONE = types.NONE
+ INIT = types.INIT
+ TRYOPEN = types.TRYOPEN
+ OPEN = types.OPEN
+ StateNone = types.StateNone
+ StateInit = types.StateInit
+ StateTryOpen = types.StateTryOpen
+ StateOpen = types.StateOpen
+ DefaultCodespace = types.DefaultCodespace
+ CodeConnectionExists = types.CodeConnectionExists
+ CodeConnectionNotFound = types.CodeConnectionNotFound
+ CodeClientConnectionPathsNotFound = types.CodeClientConnectionPathsNotFound
+ CodeConnectionPath = types.CodeConnectionPath
+ CodeInvalidCounterpartyConnection = types.CodeInvalidCounterpartyConnection
+ CodeInvalidVersion = types.CodeInvalidVersion
+ CodeInvalidHeight = types.CodeInvalidHeight
+ CodeInvalidConnectionState = types.CodeInvalidConnectionState
+ CodeInvalidProof = types.CodeInvalidProof
+ CodeInvalidCounterparty = types.CodeInvalidCounterparty
+ AttributeKeyConnectionID = types.AttributeKeyConnectionID
+ AttributeKeyCounterpartyClientID = types.AttributeKeyCounterpartyClientID
+ SubModuleName = types.SubModuleName
+ StoreKey = types.StoreKey
+ RouterKey = types.RouterKey
+ QuerierRoute = types.QuerierRoute
+ QueryConnection = types.QueryConnection
+ QueryClientConnections = types.QueryClientConnections
+)
+
+var (
+ // functions aliases
+ NewKeeper = keeper.NewKeeper
+ QuerierConnection = keeper.QuerierConnection
+ QuerierClientConnections = keeper.QuerierClientConnections
+ RegisterCodec = types.RegisterCodec
+ NewConnectionEnd = types.NewConnectionEnd
+ NewCounterparty = types.NewCounterparty
+ StateFromString = types.StateFromString
+ ErrConnectionExists = types.ErrConnectionExists
+ ErrConnectionNotFound = types.ErrConnectionNotFound
+ ErrClientConnectionPathsNotFound = types.ErrClientConnectionPathsNotFound
+ ErrConnectionPath = types.ErrConnectionPath
+ ErrInvalidCounterpartyConnection = types.ErrInvalidCounterpartyConnection
+ ErrInvalidVersion = types.ErrInvalidVersion
+ ErrInvalidHeight = types.ErrInvalidHeight
+ ErrInvalidConnectionState = types.ErrInvalidConnectionState
+ ErrInvalidConnectionProof = types.ErrInvalidConnectionProof
+ ErrInvalidCounterparty = types.ErrInvalidCounterparty
+ ConnectionPath = types.ConnectionPath
+ ClientConnectionsPath = types.ClientConnectionsPath
+ KeyConnection = types.KeyConnection
+ KeyClientConnections = types.KeyClientConnections
+ NewMsgConnectionOpenInit = types.NewMsgConnectionOpenInit
+ NewMsgConnectionOpenTry = types.NewMsgConnectionOpenTry
+ NewMsgConnectionOpenAck = types.NewMsgConnectionOpenAck
+ NewMsgConnectionOpenConfirm = types.NewMsgConnectionOpenConfirm
+ NewConnectionResponse = types.NewConnectionResponse
+ NewQueryConnectionParams = types.NewQueryConnectionParams
+ NewClientConnectionsResponse = types.NewClientConnectionsResponse
+ NewQueryClientConnectionsParams = types.NewQueryClientConnectionsParams
+ GetCompatibleVersions = types.GetCompatibleVersions
+ LatestVersion = types.LatestVersion
+ PickVersion = types.PickVersion
+
+ // variable aliases
+ SubModuleCdc = types.SubModuleCdc
+ EventTypeConnectionOpenInit = types.EventTypeConnectionOpenInit
+ EventTypeConnectionOpenTry = types.EventTypeConnectionOpenTry
+ EventTypeConnectionOpenAck = types.EventTypeConnectionOpenAck
+ EventTypeConnectionOpenConfirm = types.EventTypeConnectionOpenConfirm
+ AttributeValueCategory = types.AttributeValueCategory
+)
+
+type (
+ Keeper = keeper.Keeper
+ ConnectionEnd = types.ConnectionEnd
+ Counterparty = types.Counterparty
+ State = types.State
+ ClientKeeper = types.ClientKeeper
+ MsgConnectionOpenInit = types.MsgConnectionOpenInit
+ MsgConnectionOpenTry = types.MsgConnectionOpenTry
+ MsgConnectionOpenAck = types.MsgConnectionOpenAck
+ MsgConnectionOpenConfirm = types.MsgConnectionOpenConfirm
+ ConnectionResponse = types.ConnectionResponse
+ QueryConnectionParams = types.QueryConnectionParams
+ ClientConnectionsResponse = types.ClientConnectionsResponse
+ QueryClientConnectionsParams = types.QueryClientConnectionsParams
+)

x/ibc/03-connection/client/cli/query.go

@@ -0,0 +1,130 @@
+package cli
+
+import (
+ "fmt"
+ "strings"
+
+ "github.com/spf13/cobra"
+ "github.com/spf13/viper"
+
+ abci "github.com/tendermint/tendermint/abci/types"
+
+ "github.com/cosmos/cosmos-sdk/client"
+ "github.com/cosmos/cosmos-sdk/client/context"
+ "github.com/cosmos/cosmos-sdk/client/flags"
+ "github.com/cosmos/cosmos-sdk/codec"
+ "github.com/cosmos/cosmos-sdk/version"
+ "github.com/cosmos/cosmos-sdk/x/ibc/03-connection/types"
+)
+
+// GetQueryCmd returns the query commands for IBC connections
+func GetQueryCmd(queryRoute string, cdc *codec.Codec) *cobra.Command {
+ ics03ConnectionQueryCmd := &cobra.Command{
+ Use: "connection",
+ Short: "IBC connection query subcommands",
+ DisableFlagParsing: true,
+ SuggestionsMinimumDistance: 2,
+ }
+
+ ics03ConnectionQueryCmd.AddCommand(client.GetCommands(
+ GetCmdQueryConnection(queryRoute, cdc),
+ )...)
+ return ics03ConnectionQueryCmd
+}
+
+// GetCmdQueryConnection defines the command to query a connection end
+func GetCmdQueryConnection(queryRoute string, cdc *codec.Codec) *cobra.Command {
+ cmd := &cobra.Command{
+ Use: "end [connection-id]",
+ Short: "Query stored connection end",
+ Long: strings.TrimSpace(fmt.Sprintf(`Query stored connection end
+ 
+Example:
+$ %s query ibc connection end [connection-id]
+ `, version.ClientName),
+ ),
+ Args: cobra.ExactArgs(1),
+ RunE: func(cmd *cobra.Command, args []string) error {
+ cliCtx := context.NewCLIContext().WithCodec(cdc)
+ connectionID := args[0]
+
+ bz, err := cdc.MarshalJSON(types.NewQueryConnectionParams(connectionID))
+ if err != nil {
+ return err
+ }
+
+ req := abci.RequestQuery{
+ Path: fmt.Sprintf("custom/%s/%s", queryRoute, types.QueryConnection),
+ Data: bz,
+ Prove: viper.GetBool(flags.FlagProve),
+ }
+
+ res, err := cliCtx.QueryABCI(req)
+ if err != nil {
+ return err
+ }
+
+ var connection types.ConnectionEnd
+ if err := cdc.UnmarshalJSON(res.Value, &connection); err != nil {
+ return err
+ }
+
+ if res.Proof == nil {
+ return cliCtx.PrintOutput(connection)
+ }
+
+ connRes := types.NewConnectionResponse(connectionID, connection, res.Proof, res.Height)
+ return cliCtx.PrintOutput(connRes)
+ },
+ }
+ cmd.Flags().Bool(flags.FlagProve, true, "show proofs for the query results")
+
+ return cmd
+}
+
+// GetCmdQueryClientConnections defines the command to query a client connections
+func GetCmdQueryClientConnections(queryRoute string, cdc *codec.Codec) *cobra.Command {
+ return &cobra.Command{
+ Use: "client [client-id]",
+ Short: "Query stored client connection paths",
+ Long: strings.TrimSpace(fmt.Sprintf(`Query stored client connection paths
+ 
+Example:
+$ %s query ibc connection client [client-id]
+ `, version.ClientName),
+ ),
+ Args: cobra.ExactArgs(1),
+ RunE: func(cmd *cobra.Command, args []string) error {
+ cliCtx := context.NewCLIContext().WithCodec(cdc)
+ clientID := args[0]
+
+ bz, err := cdc.MarshalJSON(types.NewQueryClientConnectionsParams(clientID))
+ if err != nil {
+ return err
+ }
+
+ req := abci.RequestQuery{
+ Path: fmt.Sprintf("custom/%s/%s", queryRoute, types.QueryClientConnections),
+ Data: bz,
+ Prove: viper.GetBool(flags.FlagProve),
+ }
+
+ res, err := cliCtx.QueryABCI(req)
+ if err != nil {
+ return err
+ }
+
+ var connectionPaths []string
+ if err := cdc.UnmarshalJSON(res.Value, &connectionPaths); err != nil {
+ return err
+ }
+
+ if res.Proof == nil {
+ return cliCtx.PrintOutput(connectionPaths)
+ }
+
+ connPathsRes := types.NewClientConnectionsResponse(clientID, connectionPaths, res.Proof, res.Height)
+ return cliCtx.PrintOutput(connPathsRes)
+ },
+ }
+}