go/stellar/seqno.go - master - githubmirror/client

go/stellar/seqno.go
82 строки3 KB
zoom-ua
enable gosec (#28775)
08 янв 2026, 19:26
08 янв 2026, 19:265670f73
package stellar

import (
	"sync"

	"github.com/keybase/client/go/libkb"
	"github.com/keybase/client/go/protocol/stellar1"
	"github.com/stellar/go/xdr"
)

// SeqnoProvider implements build.SequenceProvider.  It can be
// used for several transactions in a row.
type SeqnoProvider struct {
	mctx        libkb.MetaContext
	walletState *WalletState
	refresh     sync.Once
}

// NewSeqnoProvider creates a SeqnoProvider.  It also returns an `unlock` function
// that must be called after the operation(s) that used this seqno provider have
// been submitted.
//
// The idea here is to fix a race where multiple calls to send payments will
// make a SeqnoProvider and while they will consume seqnos in order, they are
// not guaranteed to be submitted in order.  In particular, the `dust storm`
// function in the bot has a tendency to expose the race.
func NewSeqnoProvider(mctx libkb.MetaContext, walletState *WalletState) (seqnoProvider *SeqnoProvider, unlock func()) {
	walletState.SeqnoLock()
	return &SeqnoProvider{
		mctx:        mctx,
		walletState: walletState,
	}, walletState.SeqnoUnlock
}

// SequenceForAccount implements build.SequenceProvider.
func (s *SeqnoProvider) SequenceForAccount(aid string) (xdr.SequenceNumber, error) {
	s.refresh.Do(func() {
		err := s.walletState.ForceSeqnoRefresh(s.mctx, stellar1.AccountID(aid))
		if err != nil {
			s.mctx.Debug("SeqnoProvider ws.ForceSeqnoRefresh error: %s", err)
		}
	})
	seqno, err := s.walletState.AccountSeqnoAndBump(s.mctx.Ctx(), stellar1.AccountID(aid))
	if err != nil {
		s.mctx.Debug("SeqnoProvider AccountSeqnoAndBump error: %s", err)
		return 0, err
	}

	s.mctx.Debug("SeqnoProvider.SequenceForAccount(%s) -> %d", aid, seqno)
	return xdr.SequenceNumber(seqno), nil //nolint:gosec // G115: Stellar sequence number is positive and bounded, safe to convert
}

// ClaimSeqnoProvider is a build.SequenceProvider for relay claims.  It should only
// be used for relay claims.
//
// It only uses the network and skips any of the work in WalletState to keep track
// of in-use seqnos for multiple concurrent payments.
//
// It also returns an `unlock` function that must be called after the operation
// that used this seqno provider has been submitted.
type ClaimSeqnoProvider struct {
	mctx        libkb.MetaContext
	walletState *WalletState
}

// NewClaimSeqnoProvider creates a ClaimSeqnoProvider for use in relay claims.
func NewClaimSeqnoProvider(mctx libkb.MetaContext, walletState *WalletState) (seqnoProvider *ClaimSeqnoProvider, unlock func()) {
	walletState.SeqnoLock()
	return &ClaimSeqnoProvider{
		mctx:        mctx,
		walletState: walletState,
	}, walletState.SeqnoUnlock
}

// SequenceForAccount implements build.SequenceProvider.
func (s *ClaimSeqnoProvider) SequenceForAccount(aid string) (xdr.SequenceNumber, error) {
	seqno, err := s.walletState.Remoter.AccountSeqno(s.mctx.Ctx(), stellar1.AccountID(aid))
	if err != nil {
		return 0, err
	}
	return xdr.SequenceNumber(seqno), nil //nolint:gosec // G115: Stellar sequence number is positive and bounded, safe to convert
}