txm

type AccountStore struct {
	// contains filtered or unexported fields
}

type Config struct {
	BroadcastChanSize        uint          // Size of the broadcast queue
	ConfirmPollSecs          uint          // Interval to poll for transaction confirmations
	SendRetryDelay           time.Duration // Delay between send retry attempts
	MaxSendRetryAttempts     uint          // Max retries before giving up broadcasting
	TxExpirationMins         uint          // Time (in minutes) after which an unconfirmed transaction is considered expired
	StickyNodeContextEnabled bool          // Whether to use sticky context (single node per lifecycle)
}

type FinalizedTx struct {
	ReceivedMessage tracetracking.ReceivedMessage
	ExitCode        tvm.ExitCode
	TraceSucceeded  bool
}

type Request struct {
	Mode            uint8           // Send mode for TON message
	FromWallet      wallet.Wallet   // Source wallet address
	ContractAddress address.Address // Destination contract or wallet address
	Body            *cell.Cell      // Encoded message body (method + params)
	Amount          tlb.Coins       // Amount in nanotons
	Bounce          bool            // Bounce on error (TON message flag)
	StateInit       *cell.Cell      // Optional: contract deploy init
}

type Tx struct {
	Mode            uint8                         // send mode bitmask, controls how the TON message is processed
	From            address.Address               // wallet used to send the message
	To              address.Address               // destination address
	Amount          tlb.Coins                     // amount to send
	Body            *cell.Cell                    // optional body to attach
	StateInit       *cell.Cell                    // optional, for deploying new contracts
	Bounceable      bool                          // whether the destination is bounceable
	CreatedAt       time.Time                     // when the tx was first enqueued
	Expiration      time.Time                     // expiration timestamp based on TTL
	ReceivedMessage tracetracking.ReceivedMessage // received message
}

type TxManager interface {
	services.Service

	Enqueue(request Request) error
	GetTransactionStatus(ctx context.Context, lt uint64) (commontypes.TransactionStatus, tvm.ExitCode, tlb.Coins, error)
	GetClient() tracetracking.SignedAPIClient
	InflightCount() (int, int)
}

type TxStore struct {
	// contains filtered or unexported fields
}

type Txm struct {
	Logger   logger.Logger
	Keystore loop.Keystore
	Config   Config

	Client        tracetracking.SignedAPIClient
	BroadcastChan chan *Tx
	AccountStore  *AccountStore
	Starter       commonutils.StartStopOnce
	Done          sync.WaitGroup
	Stop          chan struct{}
}

type UnconfirmedTx struct {
	LT           uint64
	ExpirationMs uint64
	Tx           *Tx
}