fix: continue replacing other messages when a message is not found in…

… mpool (#14)
strahe · Jun 5, 2024 · eabffa1 · eabffa1
1 parent bfa2e47
commit eabffa1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/service.go b/service.go
@@ -890,8 +890,10 @@ func (s *Service) replaceMessage(ctx context.Context, id uint, mss *api.MessageS
 		}
 	}
 
+	// If the message is not found in the mpool, skip it and continue with the next one
 	if found == nil {
-		return fmt.Errorf("no pending message found from %s with nonce %d", cm.From, cm.Nonce)
+		sLog.Warn("message not found in mpool, skipping")
+		return nil
 	}
 	msg := found.Message