add avalanche support

chain/avalanche/clientc.go

@@ -0,0 +1,26 @@
+package avalanche
+
+import (
+	"context"
+
+	"github.com/strangelove-ventures/interchaintest/v7/ibc"
+)
+
+type CChainClient struct {
+}
+
+func NewCChainClient(rpcHost string, pk string) (ibc.AvalancheSubnetClient, error) {
+	return new(CChainClient), nil
+}
+
+func (cchain *CChainClient) SendFunds(ctx context.Context, keyName string, amount ibc.WalletAmount) error {
+	panic("not implemented")
+}
+
+func (cchain *CChainClient) Height(ctx context.Context) (uint64, error) {
+	panic("not implemented")
+}
+
+func (cchain *CChainClient) GetBalance(ctx context.Context, address string, denom string) (int64, error) {
+	panic("not implemented")
+}

chain/avalanche/clientp.go

@@ -0,0 +1,27 @@
+package avalanche
+
+import (
+	"context"
+
+	"github.com/strangelove-ventures/interchaintest/v7/ibc"
+)
+
+type PChainClient struct {
+}
+
+func NewPChainClient(rpcHost string, pk string) (ibc.AvalancheSubnetClient, error) {
+	return new(PChainClient), nil
+}
+
+func (pchain *PChainClient) SendFunds(ctx context.Context, keyName string, amount ibc.WalletAmount) error {
+	panic("not implemented")
+}
+
+func (pchain *PChainClient) Height(ctx context.Context) (uint64, error) {
+	//platformvm.NewClient(fmt.Sprintf("http://127.0.0.1:%s", n.RPCPort())).GetHeight(ctx)
+	panic("not implemented")
+}
+
+func (pchain *PChainClient) GetBalance(ctx context.Context, address string, denom string) (int64, error) {
+	panic("not implemented")
+}

chain/avalanche/clientx.go

@@ -0,0 +1,26 @@
+package avalanche
+
+import (
+	"context"
+
+	"github.com/strangelove-ventures/interchaintest/v7/ibc"
+)
+
+type XChainClient struct {
+}
+
+func NewXChainClient(rpcHost string, pk string) (ibc.AvalancheSubnetClient, error) {
+	return new(XChainClient), nil
+}
+
+func (xchain *XChainClient) SendFunds(ctx context.Context, keyName string, amount ibc.WalletAmount) error {
+	panic("not implemented")
+}
+
+func (xchain *XChainClient) Height(ctx context.Context) (uint64, error) {
+	panic("not implemented")
+}
+
+func (xchain *XChainClient) GetBalance(ctx context.Context, address string, denom string) (int64, error) {
+	panic("not implemented")
+}

chain/avalanche/lib/chain_id.go

@@ -0,0 +1,38 @@
+package lib
+
+import (
+	"errors"
+	"fmt"
+	"regexp"
+	"strconv"
+	"strings"
+)
+
+type ChainID struct {
+	Name   string
+	Number uint32
+}
+
+var (
+	FormatChainID = regexp.MustCompile(`^([a-zA-Z]+)-(\d+)$`)
+	ErrBadChainID = errors.New("networkID has bad format")
+)
+
+func (cid ChainID) String() string {
+	return fmt.Sprintf("%d", cid.Number)
+}
+
+func ParseChainID(str string) (*ChainID, error) {
+	if !FormatChainID.Match([]byte(str)) {
+		return nil, ErrBadChainID
+	}
+	raw := strings.Split(str, "-")
+	num, err := strconv.ParseUint(raw[1], 10, 0)
+	if err != nil {
+		return nil, ErrBadChainID
+	}
+	return &ChainID{
+		Name:   raw[0],
+		Number: uint32(num),
+	}, nil
+}

chain/avalanche/lib/network.go

@@ -0,0 +1,83 @@
+package lib
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"io"
+	"net"
+	"syscall"
+	"time"
+
+	"github.com/ava-labs/avalanchego/api/info"
+	"go.uber.org/zap"
+)
+
+func IsOpened(host string, port string) bool {
+	conn, err := net.DialTimeout("tcp", net.JoinHostPort(host, port), time.Second)
+	if err != nil {
+		return false
+	}
+
+	if conn != nil {
+		conn.Close()
+		return true
+	}
+
+	return false
+}
+
+func WaitPort(ctx context.Context, host, port string) error {
+	var err error
+	for done := false; !done && err == nil; {
+		select {
+		case <-ctx.Done():
+			err = fmt.Errorf("WaitPort(%s, %s) context closed", host, port)
+		default:
+			done = IsOpened(host, port)
+		}
+	}
+	return err
+}
+
+func WaitNode(ctx context.Context, host, port string, logger *zap.Logger) error {
+	err := WaitPort(ctx, host, port)
+	if err != nil {
+		return err
+	}
+
+	time.Sleep(10 * time.Second)
+
+	client := info.NewClient(fmt.Sprintf("http://%s:%s", host, port))
+	for done := false; !done && err == nil; {
+		select {
+		case <-ctx.Done():
+			return fmt.Errorf("context closed")
+		default:
+			xdone, xerr := client.IsBootstrapped(ctx, "X")
+			if errors.Is(xerr, io.EOF) || errors.Is(xerr, syscall.ECONNREFUSED) {
+				xerr = nil
+			}
+			pdone, perr := client.IsBootstrapped(ctx, "P")
+			if errors.Is(perr, io.EOF) || errors.Is(perr, syscall.ECONNREFUSED) {
+				perr = nil
+			}
+			cdone, cerr := client.IsBootstrapped(ctx, "C")
+			if errors.Is(cerr, io.EOF) || errors.Is(cerr, syscall.ECONNREFUSED) {
+				cerr = nil
+			}
+			logger.Info(
+				"bootstrap status",
+				zap.Boolp("x", &xdone),
+				zap.Boolp("p", &pdone),
+				zap.Boolp("c", &cdone),
+			)
+
+			done = xdone && pdone && cdone
+			err = errors.Join(xerr, perr, cerr)
+			time.Sleep(5 * time.Second)
+		}
+	}
+
+	return err
+}