From f92fa17a7de5db02a9978e2b8e66058c65e2bfa5 Mon Sep 17 00:00:00 2001
From: PumpkinSeed <qwer.kocka@gmail.com>
Date: Wed, 10 Dec 2025 12:56:21 +0100
Subject: [PATCH] Fix the too long bufio.stream

---
 internal/catcher/catcher.go | 33 ++++++++++++++++++++-------------
 1 file changed, 20 insertions(+), 13 deletions(-)

diff --git a/internal/catcher/catcher.go b/internal/catcher/catcher.go
index 7e8f048..5980019 100644
--- a/internal/catcher/catcher.go
+++ b/internal/catcher/catcher.go
@@ -5,6 +5,7 @@ import (
 	"context"
 	"io"
 	"log/slog"
+	"strings"
 
 	"github.com/DLC-link/cantcost/internal/env"
 	slogcontext "github.com/PumpkinSeed/slog-context"
@@ -34,22 +35,28 @@ func Stream(ctx context.Context, lineHandler func(context.Context, string) error
 	}
 	defer stream.Close()
 
-	scanner := bufio.NewScanner(stream)
-	for scanner.Scan() {
-		line := scanner.Text()
-		if err := lineHandler(ctx, line); err != nil {
-			slog.ErrorContext(ctx, "Error handling log line", slog.Any("error", err))
-			continue
+	r := bufio.NewReader(stream)
+
+	for {
+		line, err := r.ReadString('\n') // keeps reading until newline
+		if len(line) > 0 {
+			// trim trailing newline(s) to match Scanner behavior
+			line = strings.TrimRight(line, "\r\n")
+			if err2 := lineHandler(ctx, line); err2 != nil {
+				slog.ErrorContext(ctx, "Error handling log line", slog.Any("error", err2))
+			}
 		}
-	}
 
-	if err := scanner.Err(); err != nil && err != io.EOF {
-		slog.ErrorContext(ctx, "Error reading log stream", slog.Any("error", err))
-		return err
+		if err != nil {
+			if err == io.EOF {
+				// if your log stream is truly "follow", EOF usually means stream ended
+				slog.InfoContext(ctx, "Log stream ended")
+				return nil
+			}
+			slog.ErrorContext(ctx, "Error reading log stream", slog.Any("error", err))
+			return err
+		}
 	}
-
-	slog.InfoContext(ctx, "Log stream ended")
-	return nil
 }
 
 func getKubernetesClient(ctx context.Context) (*kubernetes.Clientset, error) {