nit fixes

Author: dhaidashenko

pkg/logpoller/log_poller.go

@@ -1221,6 +1221,7 @@ func (e *reorgError) Error() string {
 }
 
 func (lp *logPoller) getUnfinalizedLogs(ctx context.Context, currentBlock *evmtypes.Head, latest, safe, finalized int64, isReplay bool) ([]Block, []Log, error) {
+	const maxUnfinalizedBlocks = 2000
 	var logs []Log
 	var blocks []Block
 	for {
@@ -1245,6 +1246,11 @@ func (lp *logPoller) getUnfinalizedLogs(ctx context.Context, currentBlock *evmty
 			return blocks, logs, nil
 		}
 
+		if len(blocks) >= maxUnfinalizedBlocks {
+			lp.lggr.Warnw("Too many unfinalized blocks, stopping log retrieval to avoid OOM", "currentBlockNumber", currentBlock.Number, "latestBlockNumber", latest)
+			return blocks, logs, nil
+		}
+
 		nextBlock, err := lp.headerByNumber(ctx, currentBlock.Number+1)
 		if err != nil {
 			lp.lggr.Warnw("Unable to get next block header, retrying on next poll", "err", err, "block", currentBlock.Number)

pkg/logpoller/orm.go

@@ -586,8 +586,7 @@ func (o *DSORM) insertLogsWithinTx(ctx context.Context, logs []Log, tx sqlutil.D
 	return batchInsert(ctx, tx, q, logs, 4000)
 }
 
-func batchInsert[T any](ctx context.Context, ds sqlutil.DataSource, query string, objs []T, batchSize int) error {
-	batchInsertSize := 4000
+func batchInsert[T any](ctx context.Context, ds sqlutil.DataSource, query string, objs []T, batchInsertSize int) error {
 	for i := 0; i < len(objs); i += batchInsertSize {
 		start, end := i, i+batchInsertSize
 		if end > len(objs) {