transaction object

subnet/deploy_subnet.go

@@ -44,10 +44,10 @@ func createSubnetTx(subnet Subnet, wallet primary.Wallet) (*txs.Tx, error) {
 
 // createBlockchainTx creates uncommitted createBlockchain transaction
 func createBlockchainTx(subnet Subnet, wallet primary.Wallet, network avalanche.Network, keyChain avalanche.Keychain) (*txs.Tx, error) {
-	wallet, err := loadCacheWallet(network, keyChain, wallet, subnet.SubnetID, subnet.TransferSubnetOwnershipTxID)
-	if err != nil {
-		return nil, err
-	}
+	//wallet, err := loadCacheWallet(network, keyChain, wallet, subnet.SubnetID, subnet.TransferSubnetOwnershipTxID)
+	//if err != nil {
+	//	return nil, err
+	//}
 	fxIDs := make([]ids.ID, 0)
 	options := getMultisigTxOptions(keyChain.Keychain, subnet.SubnetAuthKeys)
 	// create tx

transaction/transaction.go

@@ -0,0 +1,52 @@
+// Copyright (C) 2024, Ava Labs, Inc. All rights reserved.
+// See the file LICENSE for licensing terms.
+
+package transaction
+
+import (
+	"fmt"
+	"github.com/ava-labs/avalanchego/ids"
+	"github.com/ava-labs/avalanchego/vms/platformvm/txs"
+	"github.com/ava-labs/avalanchego/wallet/subnet/primary"
+	"github.com/ava-labs/avalanchego/wallet/subnet/primary/common"
+	"time"
+)
+
+func Commit(
+	wallet primary.Wallet,
+	tx *txs.Tx,
+	waitForTxAcceptance bool,
+) (ids.ID, error) {
+	const (
+		repeats             = 3
+		sleepBetweenRepeats = 2 * time.Second
+	)
+	var issueTxErr error
+	//wallet, err := d.loadCacheWallet()
+	//if err != nil {
+	//	return ids.Empty, err
+	//}
+	for i := 0; i < repeats; i++ {
+		ctx, cancel := utils.GetAPILargeContext()
+		defer cancel()
+		options := []common.Option{common.WithContext(ctx)}
+		if !waitForTxAcceptance {
+			options = append(options, common.WithAssumeDecided())
+		}
+		issueTxErr = wallet.P().IssueTx(tx, options...)
+		if issueTxErr == nil {
+			break
+		}
+		if ctx.Err() != nil {
+			issueTxErr = fmt.Errorf("timeout issuing/verifying tx with ID %s: %w", tx.ID(), issueTxErr)
+		} else {
+			issueTxErr = fmt.Errorf("error issuing tx with ID %s: %w", tx.ID(), issueTxErr)
+		}
+		ux.Logger.RedXToUser("%s", issueTxErr)
+		time.Sleep(sleepBetweenRepeats)
+	}
+	if issueTxErr != nil {
+		d.cleanCacheWallet()
+	}
+	return tx.ID(), issueTxErr
+}