fix: filter contract address wasm

cmd/root.go

@@ -178,7 +178,7 @@
 	*lumberjack.Logger
 }
 
 func (lumberjackSink) Sync() error { return nil }
 
 func newRootLogger(format string, debug bool) (*zap.Logger, error) {
 	config := zap.NewProductionEncoderConfig()
@@ -187,18 +187,18 @@
 	}
 	config.LevelKey = "lvl"
 
 	ll := lumberjack.Logger{
 		Filename:   path.Join(defaultHome, "relay.log"),
-		MaxSize:    50, //MB
+		MaxSize:    10, //MB
 		MaxBackups: 30,
 		MaxAge:     28, //days
-		Compress:   true,
+		Compress:   false,
 	}
 	zap.RegisterSink("lumberjack", func(*url.URL) (zap.Sink, error) {
 		return lumberjackSink{
 			Logger: &ll,
 		}, nil
 	})
 
 	var enc zapcore.Encoder
 	switch format {
@@ -217,13 +217,13 @@
 		level = zap.DebugLevel
 	}
 
 	w := zapcore.AddSync(&ll)
 
 	core := zapcore.NewTee(
 		zapcore.NewCore(enc, w, level),
 		zapcore.NewCore(enc, os.Stderr, level),
 	)
 
 	return zap.New(core), nil
 }
 

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

@@ -14,7 +14,7 @@
     "timeout": "20s",
     "output-format": "json",
     "sign-mode": "direct",
-    "ibc-handler-address":"--",
+    "ibc-handler-address":"neutron1fde8lfydxgwg6p7xe9ugx5a6ysj37zfvn9m9z5rxt4mqvdcneczsczq2a4",
     "broadcast-mode": "batch",
     "block-timeout": "",
     "start-height":0,

relayer/chains/icon/query.go

@@ -8,6 +8,7 @@
 	"strings"
 	"time"
 
+	"cosmossdk.io/math"
 	"github.com/avast/retry-go/v4"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	"github.com/cosmos/gogoproto/proto"
@@ -81,12 +82,12 @@
 
 // required for cosmos only
 func (icp *IconProvider) QueryTx(ctx context.Context, hashHex string) (*provider.RelayerTxResponse, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 // required for cosmos only
 func (icp *IconProvider) QueryTxs(ctx context.Context, page, limit int, events []string) ([]*provider.RelayerTxResponse, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryLatestHeight(ctx context.Context) (int64, error) {
@@ -125,11 +126,11 @@
 }
 
 func (icp *IconProvider) QuerySendPacket(ctx context.Context, srcChanID, srcPortID string, sequence uint64) (provider.PacketInfo, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryRecvPacket(ctx context.Context, dstChanID, dstPortID string, sequence uint64) (provider.PacketInfo, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryBalance(ctx context.Context, keyName string) (sdk.Coins, error) {
@@ -143,7 +144,17 @@
 
 // implementing is not required
 func (icp *IconProvider) QueryBalanceWithAddress(ctx context.Context, addr string) (sdk.Coins, error) {
-	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
+	param := types.AddressParam{
+		Address: types.Address(addr),
+	}
+	balance, err := icp.client.GetBalance(&param)
+	if err != nil {
+		return nil, err
+	}
+	return sdk.Coins{sdk.Coin{
+		Denom:  "ICX",
+		Amount: math.NewInt(balance.Int64()),
+	}}, nil
 }
 
 func (icp *IconProvider) QueryUnbondingPeriod(context.Context) (time.Duration, error) {
@@ -282,15 +293,15 @@
 }
 
 func (icp *IconProvider) QueryUpgradedClient(ctx context.Context, height int64) (*clienttypes.QueryClientStateResponse, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryUpgradedConsState(ctx context.Context, height int64) (*clienttypes.QueryConsensusStateResponse, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryConsensusState(ctx context.Context, height int64) (ibcexported.ConsensusState, int64, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 // query all the clients of the chain
@@ -413,7 +424,7 @@
 			continue
 		}
 		// Only return open conenctions
 		if conn.State == conntypes.OPEN {
 			identifiedConn := conntypes.IdentifiedConnection{
 				Id:           connectionId,
 				ClientId:     conn.ClientId,
@@ -465,7 +476,7 @@
 }
 
 func (icp *IconProvider) QueryConnectionsUsingClient(ctx context.Context, height int64, clientid string) (*conntypes.QueryConnectionsResponse, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 func (icp *IconProvider) GenerateConnHandshakeProof(ctx context.Context, height int64, clientId, connId string) (ibcexported.ClientState,
 	[]byte, []byte, []byte,
@@ -560,7 +571,7 @@
 )
 
 func (icp *IconProvider) QueryChannelClient(ctx context.Context, height int64, channelid, portid string) (*clienttypes.IdentifiedClientState, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 // is not needed currently for the operation
@@ -623,7 +634,7 @@
 			}
 
 			// check if the channel is open
 			if channel.State == chantypes.OPEN {
 				identifiedChannel := chantypes.IdentifiedChannel{
 					State:          channel.State,
 					Ordering:       channel.Ordering,
@@ -643,19 +654,19 @@
 
 // required to flush packets
 func (icp *IconProvider) QueryPacketCommitments(ctx context.Context, height uint64, channelid, portid string) (commitments *chantypes.QueryPacketCommitmentsResponse, err error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryPacketAcknowledgements(ctx context.Context, height uint64, channelid, portid string) (acknowledgements []*chantypes.PacketState, err error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryUnreceivedPackets(ctx context.Context, height uint64, channelid, portid string, seqs []uint64) ([]uint64, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryUnreceivedAcknowledgements(ctx context.Context, height uint64, channelid, portid string, seqs []uint64) ([]uint64, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryNextSeqRecv(ctx context.Context, height int64, channelid, portid string) (recvRes *chantypes.QueryNextSequenceReceiveResponse, err error) {
@@ -780,12 +791,12 @@
 // ics 20 - transfer
 // not required for icon
 func (icp *IconProvider) QueryDenomTrace(ctx context.Context, denom string) (*transfertypes.DenomTrace, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 // not required for icon
 func (icp *IconProvider) QueryDenomTraces(ctx context.Context, offset, limit uint64, height int64) ([]transfertypes.DenomTrace, error) {
 	panic(fmt.Sprintf("%s%s", icp.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (icp *IconProvider) QueryIconProof(ctx context.Context, height int64, keyHash []byte) ([]byte, error) {

relayer/chains/wasm/event_parser.go

@@ -106,6 +106,10 @@
 		return nil
 	}
 
+	if !eventFromIBCContractAddress(event.Attributes[0], contractAddress) {
+		return nil
+	}
+
 	eventType := findEventType(event.Type)
 	attrs := event.Attributes[1:]
 	switch eventType {

relayer/chains/wasm/query.go

@@ -39,7 +39,7 @@
 	NOT_IMPLEMENTED = " :: Not implemented for WASM"
 )
 
 func (ap *WasmProvider) QueryTx(ctx context.Context, hashHex string) (*provider.RelayerTxResponse, error) {
 	hash, err := hex.DecodeString(hashHex)
 	if err != nil {
 		return nil, err
@@ -61,7 +61,7 @@
 	}, nil
 
 }
 func (ap *WasmProvider) QueryTxs(ctx context.Context, page, limit int, events []string) ([]*provider.RelayerTxResponse, error) {
 	if len(events) == 0 {
 		return nil, errors.New("must declare at least one event to search")
 	}
@@ -115,7 +115,7 @@
 	return events
 }
 
 func (ap *WasmProvider) QueryLatestHeight(ctx context.Context) (int64, error) {
 
 	stat, err := ap.RPCClient.Status(ctx)
 	if err != nil {
@@ -127,7 +127,7 @@
 }
 
 // QueryIBCHeader returns the IBC compatible block header at a specific height.
 func (ap *WasmProvider) QueryIBCHeader(ctx context.Context, h int64) (provider.IBCHeader, error) {
 	if h == 0 {
 		return nil, fmt.Errorf("No header at height 0")
 	}
@@ -136,31 +136,31 @@
 		return nil, err
 	}
 
 	return NewWasmIBCHeaderFromLightBlock(lightBlock), nil
 }
 
 func (ap *WasmProvider) QueryLightBlock(ctx context.Context, h int64) (provider.IBCHeader, *tmtypes.LightBlock, error) {
 	if h == 0 {
 		return nil, nil, fmt.Errorf("No header at height 0")
 	}
 	lightBlock, err := ap.LightProvider.LightBlock(ctx, h)
 	if err != nil {
 		return nil, nil, err
 	}
 
 	return NewWasmIBCHeaderFromLightBlock(lightBlock), lightBlock, nil
 }
 
 // query packet info for sequence
 func (ap *WasmProvider) QuerySendPacket(ctx context.Context, srcChanID, srcPortID string, sequence uint64) (provider.PacketInfo, error) {
 	return provider.PacketInfo{}, fmt.Errorf("Not implemented for Wasm")
 }
 func (ap *WasmProvider) QueryRecvPacket(ctx context.Context, dstChanID, dstPortID string, sequence uint64) (provider.PacketInfo, error) {
 	return provider.PacketInfo{}, fmt.Errorf("Not implemented for Wasm")
 }
 
 // bank
 func (ap *WasmProvider) QueryBalance(ctx context.Context, keyName string) (sdk.Coins, error) {
 	addr, err := ap.ShowAddress(keyName)
 	if err != nil {
 		return nil, err
@@ -169,7 +169,7 @@
 	return ap.QueryBalanceWithAddress(ctx, addr)
 }
 
 func (ap *WasmProvider) QueryBalanceWithAddress(ctx context.Context, address string) (sdk.Coins, error) {
 	qc := bankTypes.NewQueryClient(ap)
 	p := DefaultPageRequest()
 	coins := sdk.Coins{}
@@ -205,13 +205,13 @@
 }
 
 // staking
 func (ap *WasmProvider) QueryUnbondingPeriod(context.Context) (time.Duration, error) {
 	// move to provider, panic
 	return 0, nil
 }
 
 // ics 02 - client
 func (ap *WasmProvider) QueryClientState(ctx context.Context, height int64, clientid string) (ibcexported.ClientState, error) {
 	clientStateRes, err := ap.QueryClientStateResponse(ctx, height, clientid)
 	if err != nil {
 		return nil, err
@@ -225,7 +225,7 @@
 }
 
 // TODO: Check revision number
 func (ap *WasmProvider) QueryClientStateResponse(ctx context.Context, height int64, srcClientId string) (*clienttypes.QueryClientStateResponse, error) {
 
 	clS, err := ap.QueryClientStateContract(ctx, srcClientId)
 	if err != nil {
@@ -237,7 +237,7 @@
 	}
 
 	storageKey := getStorageKeyFromPath(common.GetClientStateCommitmentKey(srcClientId))
 	proof, err := ap.QueryWasmProof(ctx, storageKey, height)
 	if err != nil {
 		return nil, err
 	}
@@ -249,7 +249,7 @@
 	}, nil
 }
 
 func (ap *WasmProvider) QueryClientStateContract(ctx context.Context, clientId string) (*icon.ClientState, error) {
 	clientStateParam, err := types.NewClientState(clientId).Bytes()
 	if err != nil {
 		return nil, err
@@ -275,7 +275,7 @@
 	return iconClientState, nil
 }
 
 func (ap *WasmProvider) QueryConnectionContract(ctx context.Context, connId string) (*conntypes.ConnectionEnd, error) {
 	connStateParam, err := types.NewConnection(connId).Bytes()
 	if err != nil {
 		return nil, err
@@ -294,7 +294,7 @@
 	return &connS, nil
 }
 
 func (ap *WasmProvider) QueryChannelContract(ctx context.Context, portId, channelId string) (*chantypes.Channel, error) {
 	channelStateParam, err := types.NewChannel(portId, channelId).Bytes()
 	if err != nil {
 		return nil, err
@@ -312,7 +312,7 @@
 	return &channelS, nil
 }
 
 func (ap *WasmProvider) QueryClientConsensusState(ctx context.Context, chainHeight int64, clientid string, clientHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error) {
 	consensusStateParam, err := types.NewConsensusState(clientid, uint64(chainHeight)).Bytes()
 	consensusState, err := ap.QueryIBCHandlerContractProcessed(ctx, consensusStateParam)
 	if err != nil {
@@ -332,7 +332,7 @@
 	return clienttypes.NewQueryConsensusStateResponse(anyConsensusState, nil, clienttypes.NewHeight(0, uint64(chainHeight))), nil
 }
 
 func (ap *WasmProvider) QueryIBCHandlerContract(ctx context.Context, param wasmtypes.RawContractMessage) (*wasmtypes.QuerySmartContractStateResponse, error) {
 
 	return ap.QueryClient.SmartContractState(ctx, &wasmtypes.QuerySmartContractStateRequest{
 		Address:   ap.PCfg.IbcHandlerAddress,
@@ -340,7 +340,7 @@
 	})
 }
 
 func (ap *WasmProvider) QueryIBCHandlerContractProcessed(ctx context.Context, param wasmtypes.RawContractMessage) ([]byte, error) {
 	res, err := ap.QueryIBCHandlerContract(ctx, param)
 	if err != nil {
 		return nil, err
@@ -348,15 +348,15 @@
 	return ProcessContractResponse(res)
 }
 
 func (ap *WasmProvider) QueryUpgradedClient(ctx context.Context, height int64) (*clienttypes.QueryClientStateResponse, error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) QueryUpgradedConsState(ctx context.Context, height int64) (*clienttypes.QueryConsensusStateResponse, error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) QueryConsensusState(ctx context.Context, height int64) (ibcexported.ConsensusState, int64, error) {
 
 	commit, err := ap.RPCClient.Commit(ctx, &height)
 	if err != nil {
@@ -381,7 +381,7 @@
 	return state, height, nil
 }
 
 func (ap *WasmProvider) getAllPorts(ctx context.Context) ([]string, error) {
 	param, err := types.NewGetAllPorts().Bytes()
 	if err != nil {
 		return make([]string, 0), err
@@ -399,7 +399,7 @@
 	return ports, nil
 }
 
 func (ap *WasmProvider) getNextSequence(ctx context.Context, methodName string) (int, error) {
 	switch methodName {
 	case MethodGetNextClientSequence:
 		param, err := types.NewNextClientSequence().Bytes()
@@ -441,7 +441,7 @@
 	}
 }
 
 func (ap *WasmProvider) QueryClients(ctx context.Context) (clienttypes.IdentifiedClientStates, error) {
 
 	seq, err := ap.getNextSequence(ctx, MethodGetNextClientSequence)
 	if err != nil {
@@ -466,7 +466,7 @@
 }
 
 // ics 03 - connection
 func (ap *WasmProvider) QueryConnection(ctx context.Context, height int64, connectionid string) (*conntypes.QueryConnectionResponse, error) {
 	connectionStateParams, err := types.NewConnection(connectionid).Bytes()
 	if err != nil {
 		return nil, err
@@ -484,12 +484,12 @@
 	}
 
 	storageKey := getStorageKeyFromPath(common.GetConnectionCommitmentKey(connectionid))
 	connProof, err := ap.QueryWasmProof(ctx, storageKey, height)
 
 	return conntypes.NewQueryConnectionResponse(conn, connProof, clienttypes.NewHeight(0, uint64(height))), nil
 }
 
 func (ap *WasmProvider) QueryWasmProof(ctx context.Context, storageKey []byte, height int64) ([]byte, error) {
 	ibcAddr, err := sdk.AccAddressFromBech32(ap.PCfg.IbcHandlerAddress)
 	if err != nil {
 		return nil, err
@@ -533,7 +533,7 @@
 
 }
 
 func (ap *WasmProvider) QueryConnections(ctx context.Context) (conns []*conntypes.IdentifiedConnection, err error) {
 
 	seq, err := ap.getNextSequence(ctx, MethodGetNextConnectionSequence)
 	if err != nil {
@@ -552,7 +552,7 @@
 		}
 
 		// Only return open conenctions
 		if conn.State == conntypes.OPEN {
 			identifiedConn := conntypes.IdentifiedConnection{
 				Id:           connectionId,
 				ClientId:     conn.ClientId,
@@ -568,8 +568,8 @@
 	return conns, nil
 }
 
 func (ap *WasmProvider) QueryConnectionsUsingClient(ctx context.Context, height int64, clientid string) (*conntypes.QueryConnectionsResponse, error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) GenerateConnHandshakeProof(ctx context.Context, height int64, clientId, connId string) (clientState ibcexported.ClientState,
@@ -588,14 +588,14 @@
 	}
 
 	connStorageKey := getStorageKeyFromPath(common.GetConnectionCommitmentKey(connId))
 	proofConnBytes, err := ap.QueryWasmProof(ctx, connStorageKey, height)
 	if err != nil {
 		return nil, nil, nil, nil, nil, err
 
 	}
 
 	consStorageKey := getStorageKeyFromPath(common.GetConsensusStateCommitmentKey(clientId, big.NewInt(0), big.NewInt(height)))
 	proofConsensusBytes, err := ap.QueryWasmProof(ctx, consStorageKey, height)
 	if err != nil {
 		return nil, nil, nil, nil, nil, err
 	}
@@ -603,7 +603,7 @@
 }
 
 // ics 04 - channel
 func (ap *WasmProvider) QueryChannel(ctx context.Context, height int64, channelid, portid string) (chanRes *chantypes.QueryChannelResponse, err error) {
 	channelParams, err := types.NewChannel(portid, channelid).Bytes()
 	if err != nil {
 		return nil, err
@@ -624,16 +624,16 @@
 	}
 
 	storageKey := getStorageKeyFromPath(common.GetChannelCommitmentKey(portid, channelid))
 	proof, err := ap.QueryWasmProof(ctx, storageKey, height)
 
 	return chantypes.NewQueryChannelResponse(channelS, proof, clienttypes.NewHeight(0, uint64(height))), nil
 }
 
 func (ap *WasmProvider) QueryChannelClient(ctx context.Context, height int64, channelid, portid string) (*clienttypes.IdentifiedClientState, error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) QueryConnectionChannels(ctx context.Context, height int64, connectionid string) ([]*chantypes.IdentifiedChannel, error) {
 	allChannel, err := ap.QueryChannels(ctx)
 	if err != nil {
 		return nil, fmt.Errorf("error querying Channels %v", err)
@@ -647,7 +647,7 @@
 	return identifiedChannels, nil
 }
 
 func (ap *WasmProvider) QueryChannels(ctx context.Context) ([]*chantypes.IdentifiedChannel, error) {
 	nextSeq, err := ap.getNextSequence(ctx, MethodGetNextChannelSequence)
 	if err != nil {
 		return nil, err
@@ -671,7 +671,7 @@
 			}
 
 			// check if the channel is open
 			if channel.State == chantypes.OPEN {
 				identifiedChannel := chantypes.IdentifiedChannel{
 					State:          channel.State,
 					Ordering:       channel.Ordering,
@@ -689,23 +689,23 @@
 	return channels, nil
 }
 
 func (ap *WasmProvider) QueryPacketCommitments(ctx context.Context, height uint64, channelid, portid string) (commitments *chantypes.QueryPacketCommitmentsResponse, err error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) QueryPacketAcknowledgements(ctx context.Context, height uint64, channelid, portid string) (acknowledgements []*chantypes.PacketState, err error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) QueryUnreceivedPackets(ctx context.Context, height uint64, channelid, portid string, seqs []uint64) ([]uint64, error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) QueryUnreceivedAcknowledgements(ctx context.Context, height uint64, channelid, portid string, seqs []uint64) ([]uint64, error) {
 	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
 }
 
 func (ap *WasmProvider) QueryNextSeqRecv(ctx context.Context, height int64, channelid, portid string) (recvRes *chantypes.QueryNextSequenceReceiveResponse, err error) {
 	nextSeqRecvParams, err := types.NewNextSequenceReceive(portid, channelid).Bytes()
 	if err != nil {
 		return nil, err
@@ -715,7 +715,7 @@
 		return nil, err
 	}
 
 	proof, err := ap.QueryWasmProof(ctx, common.MustHexStrToBytes(STORAGEKEY__NextSequenceReceive), height)
 	if err != nil {
 		return nil, err
 	}
@@ -727,7 +727,7 @@
 	}, nil
 }
 
 func (ap *WasmProvider) QueryPacketCommitment(ctx context.Context, height int64, channelid, portid string, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error) {
 	pktCommitmentParams, err := types.NewPacketCommitment(portid, channelid, seq).Bytes()
 	if err != nil {
 		return nil, err
@@ -737,7 +737,7 @@
 		return nil, err
 	}
 	storageKey := getStorageKeyFromPath(common.GetPacketCommitmentKey(portid, channelid, big.NewInt(int64(seq))))
 	proof, err := ap.QueryWasmProof(ctx, storageKey, height)
 
 	if err != nil {
 		return nil, err
@@ -750,7 +750,7 @@
 
 }
 
 func (ap *WasmProvider) QueryPacketAcknowledgement(ctx context.Context, height int64, channelid, portid string, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error) {
 	pktAcknowledgementParams, err := types.NewPacketAcknowledgementCommitment(portid, channelid, seq).Bytes()
 	if err != nil {
 		return nil, err
@@ -760,7 +760,7 @@
 		return nil, err
 	}
 	storageKey := getStorageKeyFromPath(common.GetPacketAcknowledgementCommitmentKey(portid, channelid, big.NewInt(int64(seq))))
 	proof, err := ap.QueryWasmProof(ctx, storageKey, height)
 
 	return &chantypes.QueryPacketAcknowledgementResponse{
 		Acknowledgement: pktAcknowledgement.Data.Bytes(),
@@ -769,11 +769,11 @@
 	}, nil
 }
 
 func (ap *WasmProvider) QueryPacketReceipt(ctx context.Context, height int64, channelid, portid string, seq uint64) (recRes *chantypes.QueryPacketReceiptResponse, err error) {
 
 	// getting proof from commitment map in contract
 	storageKey := getStorageKeyFromPath(common.GetPacketReceiptCommitmentKey(portid, channelid, big.NewInt(int64(seq))))
 	proof, err := ap.QueryWasmProof(ctx, storageKey, height)
 	if err != nil {
 		return nil, err
 	}
@@ -795,7 +795,7 @@
 	}, nil
 }
 
 func (ap *WasmProvider) GetCommitmentPrefixFromContract(ctx context.Context) ([]byte, error) {
 
 	pktCommitmentParams, err := types.NewCommitmentPrefix().Bytes()
 	if err != nil {
@@ -806,9 +806,38 @@
 }
 
 // ics 20 - transfer
 func (ap *WasmProvider) QueryDenomTrace(ctx context.Context, denom string) (*transfertypes.DenomTrace, error) {
-	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
+	transfers, err := transfertypes.NewQueryClient(ap).DenomTrace(ctx,
+		&transfertypes.QueryDenomTraceRequest{
+			Hash: denom,
+		})
+	if err != nil {
+		return nil, err
+	}
+	return transfers.DenomTrace, nil
 }
 func (ap *WasmProvider) QueryDenomTraces(ctx context.Context, offset, limit uint64, height int64) ([]transfertypes.DenomTrace, error) {
-	panic(fmt.Sprintf("%s%s", ap.ChainName(), NOT_IMPLEMENTED))
+	qc := transfertypes.NewQueryClient(ap)
+	p := DefaultPageRequest()
+	transfers := []transfertypes.DenomTrace{}
+	for {
+		res, err := qc.DenomTraces(ctx,
+			&transfertypes.QueryDenomTracesRequest{
+				Pagination: p,
+			})
+
+		if err != nil || res == nil {
+			return nil, err
+		}
+
+		transfers = append(transfers, res.DenomTraces...)
+		next := res.GetPagination().GetNextKey()
+		if len(next) == 0 {
+			break
+		}
+
+		time.Sleep(PaginationDelay)
+		p.Key = next
+	}
+	return transfers, nil
 }

relayer/query.go

@@ -10,6 +10,7 @@
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	chantypes "github.com/cosmos/ibc-go/v7/modules/core/04-channel/types"
 	ibcexported "github.com/cosmos/ibc-go/v7/modules/core/exported"
+	"github.com/cosmos/relayer/v2/relayer/common"
 	"github.com/cosmos/relayer/v2/relayer/provider"
 	"go.uber.org/zap"
 	"golang.org/x/sync/errgroup"
@@ -234,7 +235,7 @@
 		return nil, err
 	}
 
-	if showDenoms {
+	if showDenoms || chain.ChainProvider.Type() == common.IconModule {
 		return coins, nil
 	}