feat: initial svm txbuilder

Author: Aman035

universalClient/chains/chains.go

@@ -274,7 +274,7 @@ func (c *Chains) addChain(ctx context.Context, cfg *uregistrytypes.ChainConfig)
 	case uregistrytypes.VmType_EVM:
 		client, err = evm.NewClient(cfg, chainDB, chainConfig, c.pushSigner, c.logger)
 	case uregistrytypes.VmType_SVM:
-		client, err = svm.NewClient(cfg, chainDB, chainConfig, c.pushSigner, c.logger)
+		client, err = svm.NewClient(cfg, chainDB, chainConfig, c.pushSigner, c.config.NodeHome, c.logger)
 	default:
 		return fmt.Errorf("unsupported VM type: %v", cfg.VmType)
 	}

universalClient/chains/svm/client.go

@@ -35,9 +35,11 @@ type Client struct {
 	eventProcessor *common.EventProcessor
 	eventConfirmer *EventConfirmer
 	gasOracle      *GasOracle
+	txBuilder      *TxBuilder
 
 	// Dependencies
 	pushSigner *pushsigner.Signer
+	nodeHome   string
 }
 
 // NewClient creates a new Solana chain client
@@ -46,6 +48,7 @@ func NewClient(
 	database *db.DB,
 	chainConfig *config.ChainSpecificConfig,
 	pushSigner *pushsigner.Signer,
+	nodeHome string,
 	logger zerolog.Logger,
 ) (*Client, error) {
 	if config == nil {
@@ -78,6 +81,7 @@ func NewClient(
 		chainConfig:    chainConfig,
 		database:       database,
 		pushSigner:     pushSigner,
+		nodeHome:       nodeHome,
 	}
 
 	// Initialize components that don't require RPC client
@@ -179,6 +183,14 @@ func (c *Client) GetConfig() *uregistrytypes.ChainConfig {
 	return c.registryConfig
 }
 
+// GetTxBuilder returns the OutboundTxBuilder for this chain
+func (c *Client) GetTxBuilder() (common.OutboundTxBuilder, error) {
+	if c.txBuilder == nil {
+		return nil, fmt.Errorf("txBuilder not available for chain %s (gateway not configured)", c.chainIDStr)
+	}
+	return c.txBuilder, nil
+}
+
 // initializeComponents creates all components that require the RPC client
 func (c *Client) initializeComponents() error {
 	// Create event listener if gateway is configured
@@ -235,6 +247,21 @@ func (c *Client) initializeComponents() error {
 		)
 	}
 
+	// Create txBuilder if gateway is configured
+	if c.registryConfig != nil && c.registryConfig.GatewayAddress != "" {
+		txBuilder, err := NewTxBuilder(
+			c.rpcClient,
+			c.chainIDStr,
+			c.registryConfig.GatewayAddress,
+			c.nodeHome,
+			c.logger,
+		)
+		if err != nil {
+			return fmt.Errorf("failed to create txBuilder: %w", err)
+		}
+		c.txBuilder = txBuilder
+	}
+
 	return nil
 }
 

universalClient/chains/svm/rpc_client.go

@@ -296,6 +296,23 @@ func (rc *RPCClient) BroadcastTransaction(ctx context.Context, tx *solana.Transa
 	return txHash, err
 }
 
+// GetAccountData fetches account data for a given public key
+func (rc *RPCClient) GetAccountData(ctx context.Context, pubkey solana.PublicKey) ([]byte, error) {
+	var accountData []byte
+	err := rc.executeWithFailover(ctx, "get_account_data", func(client *rpc.Client) error {
+		accountInfo, innerErr := client.GetAccountInfo(ctx, pubkey)
+		if innerErr != nil {
+			return innerErr
+		}
+		if accountInfo.Value == nil {
+			return fmt.Errorf("account not found: %s", pubkey.String())
+		}
+		accountData = accountInfo.Value.Data.GetBinary()
+		return nil
+	})
+	return accountData, err
+}
+
 // Close closes all RPC connections
 func (rc *RPCClient) Close() {
 	rc.mu.Lock()