-
Notifications
You must be signed in to change notification settings - Fork 12
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
11 changed files
with
1,020 additions
and
11 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,148 @@ | ||
| package nonceHandlerV3 | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "sync" | ||
| "time" | ||
|
|
||
| "github.com/multiversx/mx-chain-core-go/core" | ||
| "github.com/multiversx/mx-chain-core-go/core/check" | ||
| "github.com/multiversx/mx-chain-core-go/data/transaction" | ||
|
|
||
| sdkCore "github.com/multiversx/mx-sdk-go/core" | ||
| "github.com/multiversx/mx-sdk-go/interactors" | ||
| "github.com/multiversx/mx-sdk-go/interactors/nonceHandlerV3/workers" | ||
| ) | ||
|
|
||
| // addressNonceHandler is the handler used for one address. It is able to handle the current | ||
| // nonce as max(current_stored_nonce, account_nonce). After each call of the getNonce function | ||
| // the current_stored_nonce is incremented. This will prevent "nonce too low in transaction" | ||
| // errors on the node interceptor. To prevent the "nonce too high in transaction" error, | ||
| // a retrial mechanism is implemented. This struct is able to store all sent transactions, | ||
| // having a function that sweeps the map in order to resend a transaction or remove them | ||
| // because they were executed. This struct is concurrent safe. | ||
| type addressNonceHandler struct { | ||
| mut sync.RWMutex | ||
| address sdkCore.AddressHandler | ||
| proxy interactors.Proxy | ||
| nonce int64 | ||
| gasPrice uint64 | ||
| transactionWorker *workers.TransactionWorker | ||
| cancelFunc func() | ||
| } | ||
|
|
||
| // NewAddressNonceHandlerV3 returns a new instance of a addressNonceHandler | ||
| func NewAddressNonceHandlerV3(proxy interactors.Proxy, address sdkCore.AddressHandler, intervalToSend time.Duration) (*addressNonceHandler, error) { | ||
| if check.IfNil(proxy) { | ||
| return nil, interactors.ErrNilProxy | ||
| } | ||
| if check.IfNil(address) { | ||
| return nil, interactors.ErrNilAddress | ||
| } | ||
|
|
||
| ctx, cancelFunc := context.WithCancel(context.Background()) | ||
|
|
||
| anh := &addressNonceHandler{ | ||
| mut: sync.RWMutex{}, | ||
| address: address, | ||
| nonce: -1, | ||
| proxy: proxy, | ||
| transactionWorker: workers.NewTransactionWorker(ctx, proxy, intervalToSend), | ||
| cancelFunc: cancelFunc, | ||
| } | ||
|
|
||
| return anh, nil | ||
| } | ||
|
|
||
| // ApplyNonceAndGasPrice will apply the computed nonce to the given FrontendTransaction | ||
| func (anh *addressNonceHandler) ApplyNonceAndGasPrice(ctx context.Context, txs ...*transaction.FrontendTransaction) error { | ||
| for _, tx := range txs { | ||
| nonce, err := anh.computeNonce(ctx) | ||
| if err != nil { | ||
| //anh.mut.Unlock() | ||
| return fmt.Errorf("failed to fetch nonce: %w", err) | ||
| } | ||
| tx.Nonce = uint64(nonce) | ||
|
|
||
| anh.applyGasPriceIfRequired(ctx, tx) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // SendTransaction will save and propagate a transaction to the network | ||
| func (anh *addressNonceHandler) SendTransaction(ctx context.Context, tx *transaction.FrontendTransaction) (string, error) { | ||
| ch := anh.transactionWorker.AddTransaction(tx) | ||
|
|
||
| select { | ||
| case response := <-ch: | ||
| anh.adaptNonceBasedOnResponse(response) | ||
|
|
||
| return response.TxHash, response.Error | ||
|
|
||
| case <-ctx.Done(): | ||
| return "", ctx.Err() | ||
| } | ||
| } | ||
|
|
||
| func (anh *addressNonceHandler) adaptNonceBasedOnResponse(response *workers.TransactionResponse) { | ||
| anh.mut.Lock() | ||
| defer anh.mut.Unlock() | ||
|
|
||
| // if the response did not contain any errors, increase the cached nonce. | ||
| if response.Error == nil { | ||
| anh.nonce++ | ||
| return | ||
| } | ||
| // we invalidate the cache if there was an error sending the transaction. | ||
| anh.nonce = -1 | ||
| } | ||
|
|
||
| // IsInterfaceNil returns true if there is no value under the interface | ||
| func (anh *addressNonceHandler) IsInterfaceNil() bool { | ||
| return anh == nil | ||
| } | ||
|
|
||
| // Close will cancel all related processes.. | ||
| func (anh *addressNonceHandler) Close() { | ||
| anh.cancelFunc() | ||
| } | ||
|
|
||
| func (anh *addressNonceHandler) applyGasPriceIfRequired(ctx context.Context, tx *transaction.FrontendTransaction) { | ||
| anh.mut.RLock() | ||
| gasPrice := anh.gasPrice | ||
| anh.mut.RUnlock() | ||
|
|
||
| if gasPrice == 0 { | ||
| networkConfig, err := anh.proxy.GetNetworkConfig(ctx) | ||
|
|
||
| if err != nil { | ||
| log.Error("%w: while fetching network config", err) | ||
| } | ||
|
|
||
| gasPrice = networkConfig.MinGasPrice | ||
| } | ||
| anh.mut.Lock() | ||
| defer anh.mut.Unlock() | ||
| anh.gasPrice = gasPrice | ||
| tx.GasPrice = core.MaxUint64(gasPrice, tx.GasPrice) | ||
| } | ||
|
|
||
| func (anh *addressNonceHandler) computeNonce(ctx context.Context) (int64, error) { | ||
| // if it is the first time applying nonces to this address, or if the cache was invalidated it will try to fetch | ||
| // the nonce from the chain. | ||
| anh.mut.Lock() | ||
| defer anh.mut.Unlock() | ||
|
|
||
| if anh.nonce == -1 { | ||
| account, err := anh.proxy.GetAccount(ctx, anh.address) | ||
| if err != nil { | ||
| return -1, fmt.Errorf("failed to fetch nonce: %w", err) | ||
| } | ||
| anh.nonce = int64(account.Nonce) | ||
| } else { | ||
| anh.nonce++ | ||
| } | ||
| return anh.nonce, nil | ||
| } |
Oops, something went wrong.