fix: query solana inbound signatures using max version0 to avoid erro…

…rs (#3246)

* fix all inbound solana signature query to avoid version0 error

* skip unsupported solana inbound tracker hash

zetaclient/chains/solana/observer/inbound_tracker.go

@@ -5,9 +5,9 @@ import (
 	"fmt"
 
 	"github.com/gagliardetto/solana-go"
-	"github.com/gagliardetto/solana-go/rpc"
 	"github.com/pkg/errors"
 
+	solanarpc "github.com/zeta-chain/node/zetaclient/chains/solana/rpc"
 	zctx "github.com/zeta-chain/node/zetaclient/context"
 	clienttypes "github.com/zeta-chain/node/zetaclient/types"
 )
@@ -61,10 +61,12 @@ func (ob *Observer) ProcessInboundTrackers(ctx context.Context) error {
 	// process inbound trackers
 	for _, tracker := range trackers {
 		signature := solana.MustSignatureFromBase58(tracker.TxHash)
-		txResult, err := ob.solClient.GetTransaction(ctx, signature, &rpc.GetTransactionOpts{
-			Commitment: rpc.CommitmentFinalized,
-		})
-		if err != nil {
+		txResult, err := solanarpc.GetTransaction(ctx, ob.solClient, signature)
+		switch {
+		case errors.Is(err, solanarpc.ErrUnsupportedTxVersion):
+			ob.Logger().Inbound.Warn().Stringer("tx.signature", signature).Msg("skip inbound tracker hash")
+			continue
+		case err != nil:
 			return errors.Wrapf(err, "error GetTransaction for chain %d sig %s", chainID, signature)
 		}
 

zetaclient/chains/solana/rpc/rpc.go

@@ -85,12 +85,8 @@ func GetSignaturesForAddressUntil(
 	var allSignatures []*rpc.TransactionSignature
 
 	// make sure that the 'untilSig' exists to prevent undefined behavior on GetSignaturesForAddressWithOpts
-	_, err := client.GetTransaction(
-		ctx,
-		untilSig,
-		&rpc.GetTransactionOpts{Commitment: rpc.CommitmentFinalized},
-	)
-	if err != nil {
+	_, err := GetTransaction(ctx, client, untilSig)
+	if err != nil && !errors.Is(err, ErrUnsupportedTxVersion) {
 		return nil, errors.Wrapf(err, "error GetTransaction for untilSig %s", untilSig)
 	}
 
@@ -137,6 +133,7 @@ func GetTransaction(
 	sig solana.Signature,
 ) (*rpc.GetTransactionResult, error) {
 	txResult, err := client.GetTransaction(ctx, sig, &rpc.GetTransactionOpts{
+		Commitment:                     rpc.CommitmentFinalized,
 		MaxSupportedTransactionVersion: &rpc.MaxSupportedTransactionVersion0,
 	})
 

zetaclient/chains/solana/rpc/rpc_live_test.go

@@ -7,8 +7,10 @@ import (
 	"github.com/gagliardetto/solana-go"
 	solanarpc "github.com/gagliardetto/solana-go/rpc"
 	"github.com/stretchr/testify/require"
+	"github.com/zeta-chain/node/pkg/chains"
 	"github.com/zeta-chain/node/zetaclient/chains/solana/rpc"
 	"github.com/zeta-chain/node/zetaclient/common"
+	"github.com/zeta-chain/node/zetaclient/testutils"
 )
 
 // Test_SolanaRPCLive is a phony test to run all live tests
@@ -20,6 +22,7 @@ func Test_SolanaRPCLive(t *testing.T) {
 	LiveTest_GetTransactionWithVersion(t)
 	LiveTest_GetFirstSignatureForAddress(t)
 	LiveTest_GetSignaturesForAddressUntil(t)
+	LiveTest_GetSignaturesForAddressUntil_Version0(t)
 	LiveTest_CheckRPCStatus(t)
 }
 
@@ -80,6 +83,22 @@ func LiveTest_GetSignaturesForAddressUntil(t *testing.T) {
 	}
 }
 
+func LiveTest_GetSignaturesForAddressUntil_Version0(t *testing.T) {
+	// create a Solana devnet RPC client
+	client := solanarpc.New(solanarpc.DevNet_RPC)
+
+	// program address and signature of version "0"
+	chain := chains.SolanaDevnet
+	address := solana.MustPublicKeyFromBase58(testutils.GatewayAddresses[chain.ChainId])
+	untilSig := solana.MustSignatureFromBase58(
+		"39fSgD2nteJCQRQP3ynqEcDMZAFSETCbfb61AUqLU6y7qbzSJL5rn2DHU2oM35zsf94Feb5C5QWd5L5UnncBsAay",
+	)
+
+	// should get all signatures for the address until a signature of version "0" successfully
+	_, err := rpc.GetSignaturesForAddressUntil(context.Background(), client, address, untilSig, 100)
+	require.NoError(t, err)
+}
+
 func LiveTest_CheckRPCStatus(t *testing.T) {
 	// create a Solana devnet RPC client
 	client := solanarpc.New(solanarpc.DevNet_RPC)