feat: refresh nonce on context deadline exceed

Bisonai · Dec 8, 2024 · 35b5093 · 35b5093
1 parent 620820b
commit 35b5093
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/node/pkg/reporter/reporter.go b/node/pkg/reporter/reporter.go
@@ -146,7 +146,7 @@ func (r *Reporter) report(ctx context.Context, pairs map[string]SubmissionData)
 	wg.Wait()
 	close(errorsChan)
 
-	isNonceErrorIncluded := false
+	shouldRefreshNonce := false
 
 	for err := range errorsChan {
 		tmp := []error{}
@@ -155,8 +155,8 @@ func (r *Reporter) report(ctx context.Context, pairs map[string]SubmissionData)
 			return mergeErrors(tmp)
 		}
 
-		if utils.IsNonceError(err) {
-			isNonceErrorIncluded = true
+		if utils.IsNonceError(err) || errors.Is(err, context.DeadlineExceeded) {
+			shouldRefreshNonce = true
 		}
 	}
 
@@ -166,7 +166,7 @@ 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 {
+	if shouldRefreshNonce {
 		return r.KaiaHelper.FlushNoncePool(ctx)
 	}