relayersetup.go

package conformance

import (
	"context"
	"fmt"
	"testing"

	interchaintest "github.com/Moonyongjung/interchaintest/v4"
	"github.com/Moonyongjung/interchaintest/v4/ibc"
	"github.com/Moonyongjung/interchaintest/v4/testreporter"
	"github.com/Moonyongjung/interchaintest/v4/testutil"
	conntypes "github.com/cosmos/ibc-go/v4/modules/core/03-connection/types"
	"github.com/stretchr/testify/require"
	"golang.org/x/sync/errgroup"
)

// TestRelayerSetup contains a series of subtests that configure a relayer step-by-step.
func TestRelayerSetup(t *testing.T, ctx context.Context, cf interchaintest.ChainFactory, rf interchaintest.RelayerFactory, rep *testreporter.Reporter) {
	rep.TrackTest(t)

	client, network := interchaintest.DockerSetup(t)

	req := require.New(rep.TestifyT(t))
	chains, err := cf.Chains(t.Name())
	req.NoError(err, "failed to get chains")

	if len(chains) != 2 {
		panic(fmt.Errorf("expected 2 chains, got %d", len(chains)))
	}

	c0, c1 := chains[0], chains[1]

	r := rf.Build(t, client, network)

	const pathName = "p"
	ic := interchaintest.NewInterchain().
		AddChain(c0).
		AddChain(c1).
		AddRelayer(r, "r").
		AddLink(interchaintest.InterchainLink{
			// We are adding a link here so that the interchain object creates appropriate relayer wallets,
			// but we call ic.Build with SkipPathCreation=true, so the link won't be created.
			Chain1:  c0,
			Chain2:  c1,
			Relayer: r,

			Path: pathName,
		})

	eRep := rep.RelayerExecReporter(t)

	req.NoError(ic.Build(ctx, eRep, interchaintest.InterchainBuildOptions{
		TestName:  t.Name(),
		Client:    client,
		NetworkID: network,

		// Create relayer keys and wallets but don't create links,
		// since that is what we are about to test.
		SkipPathCreation: true,
	}))
	defer ic.Close()

	// Now handle each creation step as a subtest in sequence.
	// After each subtest, check t.Failed, which will be true if a subtest failed,
	// to conditionally stop execution before the following subtest.

	t.Run("generate path", func(t *testing.T) {
		rep.TrackTest(t)
		req := require.New(rep.TestifyT(t))

		req.NoError(r.GeneratePath(ctx, rep.RelayerExecReporter(t), c0.Config().ChainID, c1.Config().ChainID, pathName))
	})
	if t.Failed() {
		return
	}

	t.Run("create clients", func(t *testing.T) {
		rep.TrackTest(t)
		req := require.New(rep.TestifyT(t))

		req.NoError(r.CreateClients(ctx, rep.RelayerExecReporter(t), pathName, ibc.DefaultClientOpts()))
	})
	if t.Failed() {
		return
	}

	// The client isn't created immediately -- wait for two blocks to ensure the clients are ready.
	req.NoError(testutil.WaitForBlocks(ctx, 2, c0, c1))

	t.Run("create connections", func(t *testing.T) {
		rep.TrackTest(t)
		req := require.New(rep.TestifyT(t))

		eRep := rep.RelayerExecReporter(t)
		req.NoError(r.CreateConnections(ctx, eRep, pathName))

		// Assert against the singly created connections individually.
		conns0, err := r.GetConnections(ctx, eRep, c0.Config().ChainID)
		req.NoError(err)

		req.Len(conns0, 1)
		conn0 := conns0[0]
		req.NotEmpty(conn0.ID)
		req.NotEmpty(conn0.ClientID)
		req.Subset([]string{conntypes.OPEN.String(), "Open"}, []string{conn0.State})

		conns1, err := r.GetConnections(ctx, eRep, c1.Config().ChainID)
		req.NoError(err)

		req.Len(conns1, 1)
		conn1 := conns1[0]
		req.NotEmpty(conn1.ID)
		req.NotEmpty(conn1.ClientID)
		req.Subset([]string{conntypes.OPEN.String(), "Open"}, []string{conn1.State})

		// Now validate counterparties.
		req.Equal(conn0.Counterparty.ClientId, conn1.ClientID)
		req.Equal(conn0.Counterparty.ConnectionId, conn1.ID)
		req.Equal(conn1.Counterparty.ClientId, conn0.ClientID)
		req.Equal(conn1.Counterparty.ConnectionId, conn0.ID)
	})
	if t.Failed() {
		return
	}

	t.Run("create channel", func(t *testing.T) {
		rep.TrackTest(t)
		req := require.New(rep.TestifyT(t))

		eRep := rep.RelayerExecReporter(t)
		req.NoError(r.CreateChannel(ctx, eRep, pathName, ibc.CreateChannelOptions{
			SourcePortName: "transfer",
			DestPortName:   "transfer",
			Order:          ibc.Unordered,
			Version:        "ics20-1",
		}))

		// Now validate that the channels correctly report as created.
		// GetChannels takes around two seconds with rly,
		// so getting the channels concurrently is a measurable speedup.
		eg, egCtx := errgroup.WithContext(ctx)
		var channels0, channels1 []ibc.ChannelOutput
		eg.Go(func() error {
			var err error
			channels0, err = r.GetChannels(egCtx, eRep, c0.Config().ChainID)
			return err
		})
		eg.Go(func() error {
			var err error
			channels1, err = r.GetChannels(egCtx, eRep, c1.Config().ChainID)
			return err
		})
		req.NoError(eg.Wait(), "failure retrieving channels")

		req.Len(channels0, 1)
		ch0 := channels0[0]

		req.Len(channels1, 1)
		ch1 := channels1[0]

		// Piecemeal assertions against each channel.
		// Not asserting against ConnectionHops or ChannelID.
		req.Subset([]string{"STATE_OPEN", "Open"}, []string{ch0.State})
		req.Subset([]string{"ORDER_UNORDERED", "Unordered"}, []string{ch0.Ordering})
		req.Equal(ch0.Counterparty, ibc.ChannelCounterparty{PortID: "transfer", ChannelID: ch1.ChannelID})
		req.Equal(ch0.Version, "ics20-1")
		req.Equal(ch0.PortID, "transfer")

		req.Subset([]string{"STATE_OPEN", "Open"}, []string{ch1.State})
		req.Subset([]string{"ORDER_UNORDERED", "Unordered"}, []string{ch1.Ordering})
		req.Equal(ch1.Counterparty, ibc.ChannelCounterparty{PortID: "transfer", ChannelID: ch0.ChannelID})
		req.Equal(ch1.Version, "ics20-1")
		req.Equal(ch1.PortID, "transfer")
	})
}