fix: generalize archway module as wasm

.gitignore

@@ -20,7 +20,7 @@ dist/
 .release-env
 
 **/log*.txt
-**/debug_archway_msg_data.json
+**/debug_wasm_msg_data.json
 
 # Don't commit the vendor directory if anyone runs 'go mod vendor'.
 /vendor

cmd/config.go

@@ -30,10 +30,10 @@
 	"time"
 
 	"github.com/cosmos/relayer/v2/relayer"
-	archway "github.com/cosmos/relayer/v2/relayer/chains/archway"
 	"github.com/cosmos/relayer/v2/relayer/chains/cosmos"
 	"github.com/cosmos/relayer/v2/relayer/chains/icon"
 	"github.com/cosmos/relayer/v2/relayer/chains/penumbra"
+	wasm "github.com/cosmos/relayer/v2/relayer/chains/wasm"
 	"github.com/cosmos/relayer/v2/relayer/provider"
 	"github.com/spf13/cobra"
 	"go.uber.org/zap"
@@ -378,7 +378,7 @@
 	customTypes := map[string]reflect.Type{
 		"cosmos":   reflect.TypeOf(cosmos.CosmosProviderConfig{}),
 		"icon":     reflect.TypeOf(icon.IconProviderConfig{}),
-		"archway":  reflect.TypeOf(archway.ArchwayProviderConfig{}),
+		"wasm":     reflect.TypeOf(wasm.WasmProviderConfig{}),
 		"penumbra": reflect.TypeOf(penumbra.PenumbraProviderConfig{}),
 	}
 	val, err := UnmarshalJSONProviderConfig(data, customTypes)
@@ -434,8 +434,8 @@
 		iw.Value = new(cosmos.CosmosProviderConfig)
 	case "icon":
 		iw.Value = new(icon.IconProviderConfig)
-	case "archway":
-		iw.Value = new(archway.ArchwayProviderConfig)
+	case "wasm":
+		iw.Value = new(wasm.WasmProviderConfig)
 	case "penumbra":
 		iw.Value = new(penumbra.PenumbraProviderConfig)
 	default:

examples/demo/configs/chains/ibc-archway.json → examples/demo/configs/chains/ibc-wasm.json

@@ -1,12 +1,12 @@
 {
-  "type": "archway",
+  "type": "wasm",
   "value": {
     "key": "default",
-    "chain-id": "constantine-2",
+    "chain-id": "test-1",
     "rpc-addr": "https://rpc.constantine-2.archway.tech:443",
-    "key-directory":"/Users/viveksharmapoudel/.relayer/keys/archway",
+    "key-directory":"/Users/viveksharmapoudel/.relayer/keys/test-1",
     "grpc-addr": "",
-    "account-prefix": "archway",
+    "account-prefix": "neutron",
     "keyring-backend": "test",
     "gas-adjustment": 1.5,
     "gas-prices": "0.02uconst",

go.mod

@@ -208,7 +208,6 @@ require (
 replace (
 	github.com/ChainSafe/go-schnorrkel => github.com/ChainSafe/go-schnorrkel v0.0.0-20200405005733-88cbf1b4c40d
 	github.com/CosmWasm/wasmd => github.com/cosmwasm/wasmd v0.40.0-rc.1.0.20230424144037-55647a1fd1f9
-	// github.com/CosmWasm/wasmd => github.com/archway-network/archway-wasmd v0.29.2-archway
 	github.com/gogo/protobuf => github.com/regen-network/protobuf v1.3.3-alpha.regen.1
 	github.com/icon-project/IBC-Integration => github.com/icon-project/ibc-integration v0.0.0-20230619065023-ddc96101b9b1
 )

relayer/chains/archway/accounts.go → relayer/chains/wasm/accounts.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 import (
 	"context"
@@ -13,19 +13,19 @@
 	"google.golang.org/grpc/metadata"
 )
 
-var _ client.AccountRetriever = &ArchwayProvider{}
+var _ client.AccountRetriever = &WasmProvider{}
 
 // GetAccount queries for an account given an address and a block height. An
 // error is returned if the query or decoding fails.
-func (cc *ArchwayProvider) GetAccount(clientCtx client.Context, addr sdk.AccAddress) (client.Account, error) {
+func (cc *WasmProvider) GetAccount(clientCtx client.Context, addr sdk.AccAddress) (client.Account, error) {
 	account, _, err := cc.GetAccountWithHeight(clientCtx, addr)
 	return account, err
 }
 
 // GetAccountWithHeight queries for an account given an address. Returns the
 // height of the query with the account. An error is returned if the query
 // or decoding fails.
-func (cc *ArchwayProvider) GetAccountWithHeight(clientCtx client.Context, addr sdk.AccAddress) (client.Account, int64, error) {
+func (cc *WasmProvider) GetAccountWithHeight(clientCtx client.Context, addr sdk.AccAddress) (client.Account, int64, error) {
 	var header metadata.MD
 	address, err := cc.EncodeBech32AccAddr(addr)
 	if err != nil {
@@ -57,7 +57,7 @@
 }
 
 // EnsureExists returns an error if no account exists for the given address else nil.
-func (cc *ArchwayProvider) EnsureExists(clientCtx client.Context, addr sdk.AccAddress) error {
+func (cc *WasmProvider) EnsureExists(clientCtx client.Context, addr sdk.AccAddress) error {
 	if _, err := cc.GetAccount(clientCtx, addr); err != nil {
 		return err
 	}
@@ -66,7 +66,7 @@
 
 // GetAccountNumberSequence returns sequence and account number for the given address.
 // It returns an error if the account couldn't be retrieved from the state.
-func (cc *ArchwayProvider) GetAccountNumberSequence(clientCtx client.Context, addr sdk.AccAddress) (uint64, uint64, error) {
+func (cc *WasmProvider) GetAccountNumberSequence(clientCtx client.Context, addr sdk.AccAddress) (uint64, uint64, error) {
 	acc, err := cc.GetAccount(clientCtx, addr)
 	if err != nil {
 		return 0, 0, err

relayer/chains/archway/archway_chain_processor.go → relayer/chains/wasm/archway_chain_processor.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 import (
 	"context"
@@ -20,10 +20,10 @@
 	"golang.org/x/sync/errgroup"
 )
 
-type ArchwayChainProcessor struct {
+type WasmChainProcessor struct {
 	log *zap.Logger
 
-	chainProvider *ArchwayProvider
+	chainProvider *WasmProvider
 
 	pathProcessors processor.PathProcessors
 
@@ -55,8 +55,8 @@
 	parsedGasPrices *sdk.DecCoins
 }
 
-func NewArchwayChainProcessor(log *zap.Logger, provider *ArchwayProvider, metrics *processor.PrometheusMetrics) *ArchwayChainProcessor {
-	return &ArchwayChainProcessor{
+func NewWasmChainProcessor(log *zap.Logger, provider *WasmProvider, metrics *processor.PrometheusMetrics) *WasmChainProcessor {
+	return &WasmChainProcessor{
 		log:                  log.With(zap.String("chain_name", provider.ChainName()), zap.String("chain_id", provider.ChainId())),
 		chainProvider:        provider,
 		latestClientState:    make(latestClientState),
@@ -82,7 +82,7 @@
 // latestClientState is a map of clientID to the latest clientInfo for that client.
 type latestClientState map[string]provider.ClientState
 
-func (l latestClientState) update(ctx context.Context, clientInfo clientInfo, ccp *ArchwayChainProcessor) {
+func (l latestClientState) update(ctx context.Context, clientInfo clientInfo, ccp *WasmChainProcessor) {
 	existingClientInfo, ok := l[clientInfo.clientID]
 	var trustingPeriod time.Duration
 	if ok {
@@ -112,19 +112,19 @@
 }
 
 // Provider returns the ChainProvider, which provides the methods for querying, assembling IBC messages, and sending transactions.
-func (ccp *ArchwayChainProcessor) Provider() provider.ChainProvider {
+func (ccp *WasmChainProcessor) Provider() provider.ChainProvider {
 	return ccp.chainProvider
 }
 
 // Set the PathProcessors that this ChainProcessor should publish relevant IBC events to.
 // ChainProcessors need reference to their PathProcessors and vice-versa, handled by EventProcessorBuilder.Build().
-func (ccp *ArchwayChainProcessor) SetPathProcessors(pathProcessors processor.PathProcessors) {
+func (ccp *WasmChainProcessor) SetPathProcessors(pathProcessors processor.PathProcessors) {
 	ccp.pathProcessors = pathProcessors
 }
 
 // latestHeightWithRetry will query for the latest height, retrying in case of failure.
 // It will delay by latestHeightQueryRetryDelay between attempts, up to latestHeightQueryRetries.
-func (ccp *ArchwayChainProcessor) latestHeightWithRetry(ctx context.Context) (latestHeight int64, err error) {
+func (ccp *WasmChainProcessor) latestHeightWithRetry(ctx context.Context) (latestHeight int64, err error) {
 	return latestHeight, retry.Do(func() error {
 		latestHeightQueryCtx, cancelLatestHeightQueryCtx := context.WithTimeout(ctx, queryTimeout)
 		defer cancelLatestHeightQueryCtx()
@@ -143,7 +143,7 @@
 
 // nodeStatusWithRetry will query for the latest node status, retrying in case of failure.
 // It will delay by latestHeightQueryRetryDelay between attempts, up to latestHeightQueryRetries.
-func (ccp *ArchwayChainProcessor) nodeStatusWithRetry(ctx context.Context) (status *ctypes.ResultStatus, err error) {
+func (ccp *WasmChainProcessor) nodeStatusWithRetry(ctx context.Context) (status *ctypes.ResultStatus, err error) {
 	return status, retry.Do(func() error {
 		latestHeightQueryCtx, cancelLatestHeightQueryCtx := context.WithTimeout(ctx, queryTimeout)
 		defer cancelLatestHeightQueryCtx()
@@ -162,7 +162,7 @@
 
 // clientState will return the most recent client state if client messages
 // have already been observed for the clientID, otherwise it will query for it.
-func (ccp *ArchwayChainProcessor) clientState(ctx context.Context, clientID string) (provider.ClientState, error) {
+func (ccp *WasmChainProcessor) clientState(ctx context.Context, clientID string) (provider.ClientState, error) {
 	if state, ok := ccp.latestClientState[clientID]; ok && state.TrustingPeriod > 0 {
 		return state, nil
 	}
@@ -191,7 +191,7 @@
 // Run starts the query loop for the chain which will gather applicable ibc messages and push events out to the relevant PathProcessors.
 // The initialBlockHistory parameter determines how many historical blocks should be fetched and processed before continuing with current blocks.
 // ChainProcessors should obey the context and return upon context cancellation.
-func (ccp *ArchwayChainProcessor) Run(ctx context.Context, initialBlockHistory uint64) error {
+func (ccp *WasmChainProcessor) Run(ctx context.Context, initialBlockHistory uint64) error {
 	// this will be used for persistence across query cycle loop executions
 	persistence := queryCyclePersistence{
 		minQueryLoopDuration:      defaultMinQueryLoopDuration,
@@ -257,7 +257,7 @@
 }
 
 // initializeConnectionState will bootstrap the connectionStateCache with the open connection state.
-func (ccp *ArchwayChainProcessor) initializeConnectionState(ctx context.Context) error {
+func (ccp *WasmChainProcessor) initializeConnectionState(ctx context.Context) error {
 	ctx, cancel := context.WithTimeout(ctx, queryTimeout)
 	defer cancel()
 	connections, err := ccp.chainProvider.QueryConnections(ctx)
@@ -277,7 +277,7 @@
 }
 
 // initializeChannelState will bootstrap the channelStateCache with the open channel state.
-func (ccp *ArchwayChainProcessor) initializeChannelState(ctx context.Context) error {
+func (ccp *WasmChainProcessor) initializeChannelState(ctx context.Context) error {
 	ctx, cancel := context.WithTimeout(ctx, queryTimeout)
 	defer cancel()
 	channels, err := ccp.chainProvider.QueryChannels(ctx)
@@ -304,10 +304,10 @@
 	return nil
 }
 
-func (ccp *ArchwayChainProcessor) queryCycle(ctx context.Context, persistence *queryCyclePersistence) error {
+func (ccp *WasmChainProcessor) queryCycle(ctx context.Context, persistence *queryCyclePersistence) error {
 	status, err := ccp.nodeStatusWithRetry(ctx)
 	if err != nil {
-		// don't want to cause ArchwayChainProcessor to quit here, can retry again next cycle.
+		// don't want to cause WasmChainProcessor to quit here, can retry again next cycle.
 		ccp.log.Error(
 			"Failed to query node status after max attempts",
 			zap.Uint("attempts", latestHeightQueryRetries),
@@ -349,7 +349,7 @@
 
 	ppChanged := false
 
-	var latestHeader ArchwayIBCHeader
+	var latestHeader WasmIBCHeader
 
 	newLatestQueriedBlock := persistence.latestQueriedBlock
 
@@ -379,7 +379,7 @@
 			break
 		}
 
-		latestHeader = ibcHeader.(ArchwayIBCHeader)
+		latestHeader = ibcHeader.(WasmIBCHeader)
 
 		heightUint64 := uint64(i)
 
@@ -451,7 +451,7 @@
 	return nil
 }
 
-func (ccp *ArchwayChainProcessor) CollectMetrics(ctx context.Context, persistence *queryCyclePersistence) {
+func (ccp *WasmChainProcessor) CollectMetrics(ctx context.Context, persistence *queryCyclePersistence) {
 	ccp.CurrentBlockHeight(ctx, persistence)
 
 	// Wait a while before updating the balance
@@ -461,11 +461,11 @@
 	}
 }
 
-func (ccp *ArchwayChainProcessor) CurrentBlockHeight(ctx context.Context, persistence *queryCyclePersistence) {
+func (ccp *WasmChainProcessor) CurrentBlockHeight(ctx context.Context, persistence *queryCyclePersistence) {
 	ccp.metrics.SetLatestHeight(ccp.chainProvider.ChainId(), persistence.latestHeight)
 }
 
-// func (ccp *ArchwayChainProcessor) CurrentRelayerBalance(ctx context.Context) {
+// func (ccp *WasmChainProcessor) CurrentRelayerBalance(ctx context.Context) {
 // 	// memoize the current gas prices to only show metrics for "interesting" denoms
 // 	if ccp.parsedGasPrices == nil {
 // 		gp, err := sdk.ParseDecCoins(ccp.chainProvider.PCfg.GasPrices)

relayer/chains/archway/archway_prefix.go → relayer/chains/wasm/archway_prefix.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 import (
 	"sync"
@@ -13,10 +13,10 @@ import (
 var sdkConfigMutex sync.Mutex
 
 // Based on cosmos bech32_hack.go
-// SetSDKContext sets the SDK config to the proper bech32 prefixes for archway.
+// SetSDKContext sets the SDK config to the proper bech32 prefixes for wasm.
 // Don't use this unless you know what you're doing.
 // TODO: :dagger: :knife: :chainsaw: remove this function
-func (ap *ArchwayProvider) SetSDKContext() {
+func (ap *WasmProvider) SetSDKContext() {
 	sdkConfigMutex.Lock()
 	cfg := sdk.GetConfig()
 	cfg.SetBech32PrefixForAccount(ap.PCfg.AccountPrefix, app.Bech32PrefixAccPub)

relayer/chains/archway/codec.go → relayer/chains/wasm/codec.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 import (
 	"github.com/CosmWasm/wasmd/x/wasm"
@@ -10,14 +10,14 @@ import (
 	"github.com/cosmos/cosmos-sdk/x/auth"
 	"github.com/cosmos/cosmos-sdk/x/auth/tx"
 	ibc "github.com/cosmos/ibc-go/v7/modules/core"
-	archway_module "github.com/cosmos/relayer/v2/relayer/chains/archway/module"
 	icon_module "github.com/cosmos/relayer/v2/relayer/chains/icon/module"
+	wasm_module "github.com/cosmos/relayer/v2/relayer/chains/wasm/module"
 )
 
 var ModuleBasics = []module.AppModuleBasic{
 	auth.AppModuleBasic{},
 	ibc.AppModuleBasic{},
-	archway_module.AppModuleBasic{},
+	wasm_module.AppModuleBasic{},
 	wasm.AppModuleBasic{},
 	icon_module.AppModuleBasic{},
 }

relayer/chains/archway/consts.go → relayer/chains/wasm/consts.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 const (
 	// External methods

relayer/chains/archway/event_parser.go → relayer/chains/wasm/event_parser.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 import (
 	"encoding/base64"
@@ -36,7 +36,7 @@ type ibcMessageInfo interface {
 	MarshalLogObject(enc zapcore.ObjectEncoder) error
 }
 
-// func (ccp *ArchwayChainProcessor) ibcMessagesFromBlockEvents(
+// func (ccp *WasmChainProcessor) ibcMessagesFromBlockEvents(
 // 	beginBlockEvents, endBlockEvents []abci.Event,
 // 	height uint64, base64Encoded bool,
 // ) (res []ibcMessage) {

relayer/chains/archway/event_parser_test.go → relayer/chains/wasm/event_parser_test.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 import (
 	"testing"

relayer/chains/archway/grpc_query.go → relayer/chains/wasm/grpc_query.go

@@ -1,4 +1,4 @@
-package archway
+package wasm
 
 import (
 	"context"
@@ -25,12 +25,12 @@
 	"github.com/cosmos/cosmos-sdk/types/tx"
 )
 
-var _ gogogrpc.ClientConn = &ArchwayProvider{}
+var _ gogogrpc.ClientConn = &WasmProvider{}
 
 var protoCodec = encoding.GetCodec(proto.Name)
 
 // Invoke implements the grpc ClientConn.Invoke method
-func (ap *ArchwayProvider) Invoke(ctx context.Context, method string, req, reply interface{}, opts ...grpc.CallOption) (err error) {
+func (ap *WasmProvider) Invoke(ctx context.Context, method string, req, reply interface{}, opts ...grpc.CallOption) (err error) {
 	// Two things can happen here:
 	// 1. either we're broadcasting a Tx, in which call we call Tendermint's broadcast endpoint directly,
 	// 2. or we are querying for state, in which case we call ABCI's Querier.
@@ -86,15 +86,15 @@
 }
 
 // NewStream implements the grpc ClientConn.NewStream method
-func (ap *ArchwayProvider) NewStream(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error) {
+func (ap *WasmProvider) NewStream(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error) {
 	return nil, fmt.Errorf("streaming rpc not supported")
 }
 
 // RunGRPCQuery runs a gRPC query from the clientCtx, given all necessary
 // arguments for the gRPC method, and returns the ABCI response. It is used
 // to factorize code between client (Invoke) and server (RegisterGRPCServer)
 // gRPC handlers.
-func (ap *ArchwayProvider) RunGRPCQuery(ctx context.Context, method string, req interface{}, md metadata.MD) (abci.ResponseQuery, metadata.MD, error) {
+func (ap *WasmProvider) RunGRPCQuery(ctx context.Context, method string, req interface{}, md metadata.MD) (abci.ResponseQuery, metadata.MD, error) {
 	reqBz, err := protoCodec.Marshal(req)
 	if err != nil {
 		return abci.ResponseQuery{}, nil, err
@@ -147,7 +147,7 @@
 
 // TxServiceBroadcast is a helper function to broadcast a Tx with the correct gRPC types
 // from the tx service. Calls `clientCtx.BroadcastTx` under the hood.
-func (ap *ArchwayProvider) TxServiceBroadcast(ctx context.Context, req *tx.BroadcastTxRequest) (*tx.BroadcastTxResponse, error) {
+func (ap *WasmProvider) TxServiceBroadcast(ctx context.Context, req *tx.BroadcastTxRequest) (*tx.BroadcastTxResponse, error) {
 	if req == nil || req.TxBytes == nil {
 		return nil, status.Error(codes.InvalidArgument, "invalid empty tx")
 	}
@@ -163,7 +163,7 @@
 	if ap.PCfg.BlockTimeout != "" {
 		blockTimeout, err = time.ParseDuration(ap.PCfg.BlockTimeout)
 		if err != nil {
-			// Did you call Validate() method on ArchwayProviderConfig struct
+			// Did you call Validate() method on WasmProviderConfig struct
 			// before coming here?
 			return nil, err
 		}