createClient WIP

examples/ibc/client_creation_test.go

@@ -0,0 +1,146 @@
+package ibc_test
+
+import (
+	"context"
+	"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/relayer/rly"
+	"github.com/strangelove-ventures/interchaintest/v8/testreporter"
+	"github.com/stretchr/testify/require"
+	"go.uber.org/zap/zaptest"
+)
+
+var (
+	numVals      = 1
+	numFullNodes = 0
+)
+
+type relayerImp struct {
+	name           string
+	relayer        ibc.RelayerImplementation
+	relayerVersion string
+}
+
+func TestCreatClient(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping in short mode")
+	}
+
+	t.Parallel()
+
+	var tests = []relayerImp{
+		{
+			name:           "Cosmos Relayer",
+			relayer:        ibc.CosmosRly,
+			relayerVersion: "v2.5.0",
+		},
+		//TODO: Get hermes working and uncomment:
+
+		// {
+		// 	name:           "Hermes",
+		// 	relayer:        ibc.Hermes,
+		// 	relayerVersion: "v1.7.1",
+		// },
+	}
+
+	for _, tt := range tests {
+		tt := tt
+		testname := tt.name
+		t.Run(testname, func(t *testing.T) {
+			t.Parallel()
+
+			ctx := context.Background()
+
+			chainSpec := []*interchaintest.ChainSpec{
+				{
+					Name:      "ibc-go-simd",
+					ChainName: "chain1",
+					Version:   "v8.0.0",
+
+					NumValidators: &numVals,
+					NumFullNodes:  &numFullNodes,
+				},
+				{
+					Name:      "ibc-go-simd",
+					ChainName: "chain2",
+					Version:   "v8.0.0",
+
+					NumValidators: &numVals,
+					NumFullNodes:  &numFullNodes,
+				},
+			}
+
+			chains := interchaintest.CreateChainsWithChainSpecs(t, chainSpec)
+
+			client, network := interchaintest.DockerSetup(t)
+
+			chain, counterpartyChain := chains[0].(*cosmos.CosmosChain), chains[1].(*cosmos.CosmosChain)
+
+			rf := interchaintest.NewBuiltinRelayerFactory(
+				tt.relayer,
+				zaptest.NewLogger(t),
+				relayer.CustomDockerImage(
+					rly.DefaultContainerImage,
+					tt.relayerVersion,
+					rly.RlyDefaultUidGid,
+				),
+			)
+
+			r := rf.Build(t, client, network)
+
+			pathName := "ibc-path"
+
+			ic := interchaintest.NewInterchain().
+				AddChain(chain).
+				AddChain(counterpartyChain).
+				AddRelayer(r, "relayer").
+				AddLink(interchaintest.InterchainLink{
+					Chain1:  chain,
+					Chain2:  counterpartyChain,
+					Relayer: r,
+					Path:    pathName,
+				})
+
+			rep := testreporter.NewNopReporter()
+
+			require.NoError(t, ic.Build(ctx, rep.RelayerExecReporter(t), interchaintest.InterchainBuildOptions{
+				TestName:         t.Name(),
+				Client:           client,
+				NetworkID:        network,
+				SkipPathCreation: true,
+			}))
+			t.Cleanup(func() {
+				_ = ic.Close()
+			})
+
+			eRep := rep.RelayerExecReporter(t)
+
+			result := r.Exec(ctx, eRep, []string{"rly", "config", "show", "--home", "/home/relayer"}, []string{})
+
+			fmt.Println("RESULT: ", string(result.Stdout))
+
+			//TODO: need a way to get chain name from relayer config!!
+			require.NoError(t,
+				r.CreateClient(ctx, eRep,
+					chain.Config().Name,             // Does not work
+					counterpartyChain.Config().Name, // Does not work
+					pathName, ibc.CreateClientOptions{},
+				),
+			)
+
+			clientInfo, err := r.GetClients(ctx, eRep, chain.Config().ChainID)
+			require.NoError(t, err)
+
+			// TODO: ensure client exists
+			fmt.Println(clientInfo)
+
+		})
+
+	}
+
+}

ibc/relayer.go

@@ -77,6 +77,11 @@ type Relayer interface {
 	// on src that tracks the state of dst, and a light client on dst that tracks the state of src.
 	CreateClients(ctx context.Context, rep RelayerExecReporter, pathName string, opts CreateClientOptions) error
 
+	// CreateClient performs the client handshake steps necessary for creating a light client
+	// on src that tracks the state of dst.
+	// Unlike CreateClients, this only creates the client on the destination chain
+	CreateClient(ctx context.Context, rep RelayerExecReporter, srcChainName, dstChainName, pathName string, opts CreateClientOptions) error
+
 	// CreateConnections performs the connection handshake steps necessary for creating a connection
 	// between the src and dst chains.
 	CreateConnections(ctx context.Context, rep RelayerExecReporter, pathName string) error

relayer/docker.go

@@ -228,6 +228,12 @@ func (r *DockerRelayer) CreateClients(ctx context.Context, rep ibc.RelayerExecRe
 	return res.Err
 }
 
+func (r *DockerRelayer) CreateClient(ctx context.Context, rep ibc.RelayerExecReporter, srcChainName, dstChainName, pathName string, opts ibc.CreateClientOptions) error {
+	cmd := r.c.CreateClient(srcChainName, dstChainName, pathName, opts, r.HomeDir())
+	res := r.Exec(ctx, rep, cmd, nil)
+	return res.Err
+}
+
 func (r *DockerRelayer) CreateConnections(ctx context.Context, rep ibc.RelayerExecReporter, pathName string) error {
 	cmd := r.c.CreateConnections(pathName, r.HomeDir())
 	res := r.Exec(ctx, rep, cmd, nil)
@@ -554,6 +560,7 @@ type RelayerCommander interface {
 	AddKey(chainID, keyName, coinType, signingAlgorithm, homeDir string) []string
 	CreateChannel(pathName string, opts ibc.CreateChannelOptions, homeDir string) []string
 	CreateClients(pathName string, opts ibc.CreateClientOptions, homeDir string) []string
+	CreateClient(srcChainName, dstChainName, pathName string, opts ibc.CreateClientOptions, homeDir string) []string
 	CreateConnections(pathName, homeDir string) []string
 	Flush(pathName, channelID, homeDir string) []string
 	GeneratePath(srcChainID, dstChainID, pathName, homeDir string) []string

relayer/hermes/hermes_commander.go

@@ -185,6 +185,10 @@ func (c commander) CreateClients(pathName string, opts ibc.CreateClientOptions,
 	panic("create clients implemented in hermes relayer not the commander")
 }
 
+func (c commander) CreateClient(srcChain, dstChainName, pathName string, opts ibc.CreateClientOptions, homeDir string) []string {
+	panic("create client implemented in hermes relayer not the commander")
+}
+
 func (c commander) CreateConnections(pathName string, homeDir string) []string {
 	panic("create connections implemented in hermes relayer not the commander")
 }

relayer/hermes/hermes_relayer.go

@@ -204,6 +204,11 @@ func (r *Relayer) CreateClients(ctx context.Context, rep ibc.RelayerExecReporter
 	return res.Err
 }
 
+// TODO: Implement this
+func (r *Relayer) CreateClient(ctx context.Context, rep ibc.RelayerExecReporter, srcChainName, dstChainName, pathName string, opts ibc.CreateClientOptions) error {
+	panic("implement me")
+}
+
 // RestoreKey restores a key from a mnemonic. In hermes, you must provide a file containing the mnemonic. We need
 // to copy the contents of the mnemonic into a file on disk and then reference the newly created file.
 func (r *Relayer) RestoreKey(ctx context.Context, rep ibc.RelayerExecReporter, cfg ibc.ChainConfig, keyName, mnemonic string) error {

relayer/hyperspace/hyperspace_commander.go

@@ -101,6 +101,11 @@ func (c *hyperspaceCommander) CreateClients(pathName string, opts ibc.CreateClie
 	}
 }
 
+// TODO: Implement if available in hyperspace relayer
+func (hyperspaceCommander) CreateClient(srcChainName, dstChainName, pathName string, opts ibc.CreateClientOptions, homeDir string) []string {
+	panic("[CreateClient] Not Implemented")
+}
+
 func (c *hyperspaceCommander) CreateConnections(pathName, homeDir string) []string {
 	fmt.Println("[hyperspace] CreateConnections", pathName, homeDir)
 	_, ok := c.paths[pathName]

relayer/rly/cosmos_relayer.go

@@ -63,7 +63,7 @@ type CosmosRelayerChainConfig struct {
 
 const (
 	DefaultContainerImage   = "ghcr.io/cosmos/relayer"
-	DefaultContainerVersion = "v2.4.1"
+	DefaultContainerVersion = "v2.5.0"
 )
 
 // Capabilities returns the set of capabilities of the Cosmos relayer.
@@ -165,9 +165,8 @@ func (commander) CreateClients(pathName string, opts ibc.CreateClientOptions, ho
 	return cmd
 }
 
-// passing a value of 0 for customeClientTrustingPeriod will use default
-func (commander) CreateClient(pathName, homeDir string, opts ibc.CreateClientOptions) []string {
-	cmd := []string{"rly", "tx", "client", pathName, "--home", homeDir}
+func (commander) CreateClient(srcChainName, dstChainName, pathName string, opts ibc.CreateClientOptions, homeDir string) []string {
+	cmd := []string{"rly", "tx", "client", srcChainName, dstChainName, pathName, "--home", homeDir}
 
 	clientOptions := createClientOptsHelper(opts)
 	cmd = append(cmd, clientOptions...)