add it at load pending tx too

initia-labs · Nov 5, 2024 · 8db5cef · 8db5cef
1 parent 6a23951
commit 8db5cef
Showing 1 changed file with 12 additions and 5 deletions.
diff --git a/node/broadcaster/broadcaster.go b/node/broadcaster/broadcaster.go
@@ -187,11 +187,18 @@ func (b *Broadcaster) prepareBroadcaster(ctx context.Context, lastBlockTime time
 			}
 
 			if txInfo.Save {
-				b.pendingProcessedMsgs = append(b.pendingProcessedMsgs, btypes.ProcessedMsgs{
-					Msgs:      msgs,
-					Timestamp: time.Now().UnixNano(),
-					Save:      txInfo.Save,
-				})
+				for i := 0; i < len(msgs); i += 5 {
+					end := i + 5
+					if end > len(msgs) {
+						end = len(msgs)
+					}
+
+					b.pendingProcessedMsgs = append(b.pendingProcessedMsgs, btypes.ProcessedMsgs{
+						Msgs:      msgs[i:end],
+						Timestamp: time.Now().UnixNano(),
+						Save:      true,
+					})
+				}
 			}
 
 			b.logger.Debug("pending tx", zap.Int("index", i), zap.String("tx", txInfo.String()))