NODE/GACCT: Don't reload invalid transfers (#3486)

2023-11-01 12:13:05 -05:00 · 2023-11-01 12:13:05 -05:00 · 398f57498d
parent 70ae80ac83
commit 398f57498d
1 changed files with 4 additions and 0 deletions
--- a/node/pkg/accountant/accountant.go
+++ b/node/pkg/accountant/accountant.go
@ -331,6 +331,10 @@ func (acct *Accountant) loadPendingTransfers() error {

 	for _, msg := range pendingTransfers {
 		msgId := msg.MessageIDString()
+		if !acct.IsMessageCoveredByAccountant(msg) {
+			acct.logger.Error("dropping reloaded pending transfer because it is not covered by the accountant", zap.String("msgID", msgId))
+			continue
+		}
 		acct.logger.Info("reloaded pending transfer", zap.String("msgID", msgId))

 		digest := msg.CreateDigest()