...
1
2
3
4
5 package csv
6
7 import (
8 "bytes"
9 "reflect"
10 "slices"
11 "strings"
12 "testing"
13 )
14
15 func FuzzRoundtrip(f *testing.F) {
16 f.Fuzz(func(t *testing.T, in []byte) {
17 buf := new(bytes.Buffer)
18
19 t.Logf("input = %q", in)
20 for _, tt := range []Reader{
21 {Comma: ','},
22 {Comma: ';'},
23 {Comma: '\t'},
24 {Comma: ',', LazyQuotes: true},
25 {Comma: ',', TrimLeadingSpace: true},
26 {Comma: ',', Comment: '#'},
27 {Comma: ',', Comment: ';'},
28 } {
29 t.Logf("With options:")
30 t.Logf(" Comma = %q", tt.Comma)
31 t.Logf(" LazyQuotes = %t", tt.LazyQuotes)
32 t.Logf(" TrimLeadingSpace = %t", tt.TrimLeadingSpace)
33 t.Logf(" Comment = %q", tt.Comment)
34 r := NewReader(bytes.NewReader(in))
35 r.Comma = tt.Comma
36 r.Comment = tt.Comment
37 r.LazyQuotes = tt.LazyQuotes
38 r.TrimLeadingSpace = tt.TrimLeadingSpace
39
40 records, err := r.ReadAll()
41 if err != nil {
42 continue
43 }
44 t.Logf("first records = %#v", records)
45
46 buf.Reset()
47 w := NewWriter(buf)
48 w.Comma = tt.Comma
49 err = w.WriteAll(records)
50 if err != nil {
51 t.Logf("writer = %#v\n", w)
52 t.Logf("records = %v\n", records)
53 t.Fatal(err)
54 }
55 if tt.Comment != 0 {
56
57
58 continue
59 }
60 t.Logf("second input = %q", buf.Bytes())
61
62 r = NewReader(buf)
63 r.Comma = tt.Comma
64 r.Comment = tt.Comment
65 r.LazyQuotes = tt.LazyQuotes
66 r.TrimLeadingSpace = tt.TrimLeadingSpace
67 result, err := r.ReadAll()
68 if err != nil {
69 t.Logf("reader = %#v\n", r)
70 t.Logf("records = %v\n", records)
71 t.Fatal(err)
72 }
73
74
75 for _, record := range records {
76 for i, s := range record {
77 record[i] = strings.ReplaceAll(s, "\r\n", "\n")
78 }
79 }
80
81
82
83 records = slices.DeleteFunc(records, func(record []string) bool {
84 return len(record) == 1 && record[0] == ""
85 })
86
87 if len(records) == 0 {
88 records = nil
89 }
90
91 if !reflect.DeepEqual(records, result) {
92 t.Fatalf("first read got %#v, second got %#v", records, result)
93 }
94 }
95 })
96 }
97
View as plain text