Merge pull request #1326 from kaleido-io/reject

Perform nextpin calculations for both confirmed and rejected messages
hyperledger · May 31, 2023 · 26f0245 · 26f0245
2 parents 04ed0e2 + 23f1792
commit 26f0245
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/internal/events/aggregator.go b/internal/events/aggregator.go
@@ -481,7 +481,7 @@ func (ag *aggregator) processMessage(ctx context.Context, manifest *core.BatchMa
 	default:
 		// Check the pin signer is valid for the message
 		action, err = ag.checkOnchainConsistency(ctx, msg, pin)
-		if action != core.ActionConfirm {
+		if action == core.ActionWait || action == core.ActionRetry {
 			break
 		}
 
@@ -524,8 +524,10 @@ func (ag *aggregator) processMessage(ctx context.Context, manifest *core.BatchMa
 			}
 		}
 
-		l.Debugf("Attempt dispatch msg=%s broadcastContexts=%v privatePins=%v", msg.Header.ID, unmaskedContexts, msg.Pins)
-		action, correlator, err = ag.readyForDispatch(ctx, msg, data, manifest.TX.ID, state, pin)
+		if action == core.ActionConfirm {
+			l.Debugf("Attempt dispatch msg=%s broadcastContexts=%v privatePins=%v", msg.Header.ID, unmaskedContexts, msg.Pins)
+			action, correlator, err = ag.readyForDispatch(ctx, msg, data, manifest.TX.ID, state, pin)
+		}
 	}
 
 	if action == core.ActionRetry {