feat: add flush on nonce error

node/pkg/chain/helper/helper.go

@@ -218,3 +218,7 @@ func (t *ChainHelper) SubmitDirect(ctx context.Context, contractAddress, functio
 
 	return utils.SubmitRawTx(ctx, t.client, tx)
 }
+
+func (t *ChainHelper) FlushNoncePool(ctx context.Context) error {
+	return t.noncemanager.Refill(ctx, t.wallet)
+}

node/pkg/chain/noncemanagerv2/noncemanagerv2.go

@@ -47,6 +47,12 @@ func (m *NonceManagerV2) GetNonce(ctx context.Context, address string) (uint64,
 	return nonce, nil
 }
 
+func (m *NonceManagerV2) Refill(ctx context.Context, address string) error {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+	return m.unsafeRefill(ctx, address)
+}
+
 func (m *NonceManagerV2) unsafeRefill(ctx context.Context, address string) error {
 	currentNonce, err := utils.GetNonceFromPk(ctx, address, m.client)
 	if err != nil {

node/pkg/reporter/reporter.go

@@ -7,6 +7,7 @@ import (
 	"sync"
 	"time"
 
+	"bisonai.com/miko/node/pkg/chain/utils"
 	errorSentinel "bisonai.com/miko/node/pkg/error"
 
 	"github.com/rs/zerolog/log"
@@ -145,12 +146,18 @@ func (r *Reporter) report(ctx context.Context, pairs map[string]SubmissionData)
 	wg.Wait()
 	close(errorsChan)
 
+	isNonceErrorIncluded := false
+
 	for err := range errorsChan {
 		tmp := []error{}
 		tmp = append(tmp, err)
 		if len(tmp) > 0 {
 			return mergeErrors(tmp)
 		}
+
+		if utils.IsNonceError(err) {
+			isNonceErrorIncluded = true
+		}
 	}
 
 	for i, pair := range submittedPairs {
@@ -159,6 +166,10 @@ func (r *Reporter) report(ctx context.Context, pairs map[string]SubmissionData)
 
 	log.Debug().Str("Player", "Reporter").Msgf("reporting done for reporter with interval: %v", r.SubmissionInterval)
 
+	if isNonceErrorIncluded {
+		return r.KaiaHelper.FlushNoncePool(ctx)
+	}
+
 	return nil
 }