From 0b08cd654c75f11f63e164d403c7084322fc9106 Mon Sep 17 00:00:00 2001
From: KevRiver <kanggakky1214@gmail.com>
Date: Sat, 2 Nov 2024 18:23:44 +0900
Subject: [PATCH] add failing test for issue #66

---
 scanner_test.go | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

diff --git a/scanner_test.go b/scanner_test.go
index 99b82aaa..1d69201a 100644
--- a/scanner_test.go
+++ b/scanner_test.go
@@ -46,6 +46,22 @@ func TestScannerLongLine(t *testing.T) {
 	}
 }
 
+func TestLargePayload(t *testing.T) {
+
+	ctx := context.Background()
+	payload := `{"msg":` + strings.Repeat("a", 1024*1024) + `}` // more than 1mb long json payload
+	src := strings.NewReader(payload)
+
+	opts := DefaultOptions()
+	opts.timeNow = func() time.Time {
+		return time.Date(2024, 11, 1, 15, 40, 0, 0, time.UTC)
+	}
+
+	sink := bufsink.NewSizedBufferedSink(1024*1024, nil)
+	err := Scan(ctx, src, sink, opts)
+	require.NoError(t, err)
+}
+
 func pjson(m proto.Message) string {
 	o, err := protojson.Marshal(m)
 	if err != nil {