decode_test.go

package fixedwidth

import (
	"bufio"
	"bytes"
	"encoding"
	"fmt"
	"io"
	"log"
	"reflect"
	"testing"
)

func ExampleUnmarshal() {
	// define the format
	var people []struct {
		ID        int     `fixed:"1,5"`
		FirstName string  `fixed:"6,15"`
		LastName  string  `fixed:"16,25"`
		Grade     float64 `fixed:"26,30"`
		Age       uint    `fixed:"31,33"`
		Alive     bool    `fixed:"34,39"`
		Github    bool    `fixed:"40,41"`
	}

	// define some fixed-with data to parse
	data := []byte("" +
		"1    Ian       Lopshire  99.50 20 false f" + "\n" +
		"2    John      Doe       89.50 21 true t" + "\n" +
		"3    Jane      Doe       79.50 22 false F" + "\n" +
		"4    Ann       Carraway  79.59 23 false T" + "\n")

	err := Unmarshal(data, &people)
	if err != nil {
		log.Fatal(err)
	}

	fmt.Printf("%+v\n", people[0])
	fmt.Printf("%+v\n", people[1])
	fmt.Printf("%+v\n", people[2])
	fmt.Printf("%+v\n", people[3])
	// Output:
	//{ID:1 FirstName:Ian LastName:Lopshire Grade:99.5 Age:20 Alive:false Github:false}
	//{ID:2 FirstName:John LastName:Doe Grade:89.5 Age:21 Alive:true Github:true}
	//{ID:3 FirstName:Jane LastName:Doe Grade:79.5 Age:22 Alive:false Github:false}
	//{ID:4 FirstName:Ann LastName:Carraway Grade:79.59 Age:23 Alive:false Github:true}
}

func TestUnmarshal(t *testing.T) {
	// allTypes contains a field with all current supported types.
	type allTypes struct {
		String          string          `fixed:"1,5"`
		Int             int             `fixed:"6,10"`
		Float           float64         `fixed:"11,15"`
		TextUnmarshaler EncodableString `fixed:"16,20"`
		Uint            uint            `fixed:"21,25"`
		LongBool        bool            `fixed:"26,31"`
		ShortBool       bool            `fixed:"32,33"`
	}
	for _, tt := range []struct {
		name      string
		rawValue  []byte
		target    interface{}
		expected  interface{}
		shouldErr bool
	}{
		{
			name:     "Slice Case (no trailing new line)",
			rawValue: []byte("foo  123  1.2  bar  12345 false f" + "\n" + "bar  321  2.1  foo  54321 true t some_other_log_here"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"foo", 123, 1.2, EncodableString{"bar", nil}, uint(12345), false, false},
				{"bar", 321, 2.1, EncodableString{"foo", nil}, uint(54321), true, true},
			},
			shouldErr: false,
		},
		{
			name:     "Slice Case (trailing new line)",
			rawValue: []byte("foo  123  1.2  bar  12345 false f" + "\n" + "bar  321  2.1  foo  54321 true t" + "\n"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"foo", 123, 1.2, EncodableString{"bar", nil}, uint(12345), false, false},
				{"bar", 321, 2.1, EncodableString{"foo", nil}, uint(54321), true, true},
			},
			shouldErr: false,
		},
		{
			name:     "Slice Case (blank line mid file)",
			rawValue: []byte("foo  123  1.2  bar  12345 false F" + "\n" + "\n" + "bar  321  2.1  foo  54321 true T" + "\n"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"foo", 123, 1.2, EncodableString{"bar", nil}, uint(12345), false, false},
				{"", 0, 0, EncodableString{"", nil}, uint(0), false, false},
				{"bar", 321, 2.1, EncodableString{"foo", nil}, uint(54321), true, true},
			},
			shouldErr: false,
		},
		{
			name:     "Slice Case (no trailing new line) with empty content",
			rawValue: []byte("foo  123  1.2  bar  12345 false  " + "\n" + "bar  321  2.1  foo  54321 true t some_other_log_here"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"foo", 123, 1.2, EncodableString{"bar", nil}, uint(12345), false, false},
				{"bar", 321, 2.1, EncodableString{"foo", nil}, uint(54321), true, true},
			},
			shouldErr: false,
		},
		{
			name:      "Basic Struct Case",
			rawValue:  []byte("foo  123  1.2  bar  12345 false f"),
			target:    &allTypes{},
			expected:  &allTypes{"foo", 123, 1.2, EncodableString{"bar", nil}, uint(12345), false, false},
			shouldErr: false,
		},
		{
			name:      "Unmarshal Error",
			rawValue:  []byte("foo  nan  ddd  bar  baz"),
			target:    &allTypes{},
			expected:  &allTypes{},
			shouldErr: true,
		},
		{
			name:      "Empty Line",
			rawValue:  []byte(""),
			target:    &allTypes{},
			expected:  &allTypes{},
			shouldErr: true,
		},
		{
			name:     "Empty with new line (struct)",
			rawValue: []byte("\n"),
			target: &allTypes{
				String: "hello",
			},
			expected:  &allTypes{},
			shouldErr: false,
		},
		{
			name:     "Empty with new line (slice)",
			rawValue: []byte("\n"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{},
			},
			shouldErr: false,
		},
		{
			name:      "Invalid Target",
			rawValue:  []byte("foo  123  1.2  bar  baz false"),
			target:    allTypes{},
			expected:  allTypes{},
			shouldErr: true,
		},
	} {
		t.Run(tt.name, func(t *testing.T) {
			err := Unmarshal(tt.rawValue, tt.target)
			if tt.shouldErr != (err != nil) {
				t.Errorf("Unmarshal() err want %v, have %v (%v)", tt.shouldErr, err != nil, err)
			}
			if !tt.shouldErr && !reflect.DeepEqual(tt.target, tt.expected) {
				t.Errorf("Unmarshal() want %+v, have %+v", tt.expected, tt.target)
			}

		})
	}

	t.Run("Field Length 1", func(t *testing.T) {
		var st = struct {
			F1 string `fixed:"1,1"`
		}{}

		err := Unmarshal([]byte("v"), &st)
		if err != nil {
			t.Errorf("Unmarshal() err %v", err)
		}

		if st.F1 != "v" {
			t.Errorf("Unmarshal() want %v, have %v", "v", st.F1)
		}
	})

	t.Run("Invalid Unmarshal Errors", func(t *testing.T) {
		for _, tt := range []struct {
			name      string
			v         interface{}
			shouldErr bool
		}{
			{"Invalid Unmarshal Nil", nil, true},
			{"Invalid Unmarshal Not Pointer 1", struct{}{}, true},
			{"Invalid Unmarshal Not Pointer 2", []struct{}{}, true},
			{"Valid Unmarshal slice", &[]struct{}{}, false},
			{"Valid Unmarshal struct", &struct{}{}, true},
		} {
			t.Run(tt.name, func(t *testing.T) {
				err := Unmarshal([]byte{}, tt.v)
				if tt.shouldErr != (err != nil) {
					t.Errorf("Unmarshal() err want %v, have %v (%v)", tt.shouldErr, err != nil, err)
				}
			})
		}
	})
}

func TestUnmarshal_format(t *testing.T) {
	type H struct {
		F1 string `fixed:"1,5,left"`
		F2 string `fixed:"6,10,left,#"`
		F3 string `fixed:"11,15,right"`
		F4 string `fixed:"16,20,right,#"`
		F5 string `fixed:"21,25,default"`
		F6 string `fixed:"26,30,default,#"`
	}

	for _, tt := range []struct {
		name      string
		rawValue  []byte
		target    interface{}
		expected  interface{}
		shouldErr bool
	}{
		{
			name:      "base case",
			rawValue:  []byte(`foo  ` + `bar##` + `  baz` + `##biz` + ` bor ` + `#box#`),
			target:    &[]H{},
			expected:  &[]H{{"foo", "bar", "baz", "biz", "bor", "box"}},
			shouldErr: false,
		},
		{
			name:      "keep spaces",
			rawValue:  []byte(`  foo` + `   ##` + `baz  ` + `##   ` + ` bor ` + `#####`),
			target:    &[]H{},
			expected:  &[]H{{"  foo", "   ", "baz  ", "   ", "bor", ""}},
			shouldErr: false,
		},
		{
			name:      "empty",
			rawValue:  []byte(`     ` + `#####` + `     ` + `#####` + `     ` + `#####`),
			target:    &[]H{},
			expected:  &[]H{{"", "", "", "", "", ""}},
			shouldErr: false,
		},
	} {
		t.Run(tt.name, func(t *testing.T) {
			err := Unmarshal(tt.rawValue, tt.target)
			if tt.shouldErr != (err != nil) {
				t.Errorf("Unmarshal() err want %v, have %v (%v)", tt.shouldErr, err != nil, err)
			}
			if !tt.shouldErr && !reflect.DeepEqual(tt.target, tt.expected) {
				t.Errorf("Unmarshal() want %+v, have %+v", tt.expected, tt.target)
			}
		})
	}
}

func TestNewValueSetter(t *testing.T) {
	for _, tt := range []struct {
		name      string
		raw       []byte
		expected  interface{}
		shouldErr bool
	}{
		{"invalid type", []byte("foo"), true, true},

		{"textUnmarshaler implementation", []byte("foo"), &EncodableString{"foo", nil}, false},
		{"textUnmarshaler implementation if addressed", []byte("foo"), EncodableString{"foo", nil}, false},
		{"textUnmarshaler implementation as interface", []byte("foo"), encoding.TextUnmarshaler(&EncodableString{"foo", nil}), false},
		{"textUnmarshaler implementation in interface", []byte("foo"), interface{}(&EncodableString{"foo", nil}), false},
		{"textUnmarshaler implementation if addressed in interface", []byte("foo"), interface{}(EncodableString{"foo", nil}), false},

		{"string", []byte("foo"), string("foo"), false},
		{"string empty", []byte(""), string(""), false},
		{"string interface", []byte("foo"), interface{}(string("foo")), false},
		{"string interface empty", []byte(""), interface{}(string("")), false},
		{"*string", []byte("foo"), stringp("foo"), false},
		{"*string empty", []byte(""), (*string)(nil), false},

		{"int", []byte("1"), int(1), false},
		{"int zero", []byte("0"), int(0), false},
		{"int empty", []byte(""), int(0), false},
		{"*int", []byte("1"), intp(1), false},
		{"*int zero", []byte("0"), intp(0), false},
		{"*int empty", []byte(""), (*int)(nil), false},
		{"int Invalid", []byte("foo"), int(0), true},

		{"float64", []byte("1.23"), float64(1.23), false},
		{"*float64", []byte("1.23"), float64p(1.23), false},
		{"*float64 zero", []byte("0"), float64p(0), false},
		{"*float64 empty", []byte(""), (*float64)(nil), false},
		{"float64 Invalid", []byte("foo"), float64(0), true},

		{"float32", []byte("1.23"), float32(1.23), false},
		{"float32 Invalid", []byte("foo"), float32(0), true},

		{"int8", []byte("1"), int8(1), false},
		{"int16", []byte("1"), int16(1), false},
		{"int32", []byte("1"), int32(1), false},
		{"int64", []byte("1"), int64(1), false},

		{"uint", []byte("1"), uint(1), false},
		{"uint zero", []byte("0"), uint(0), false},
		{"uint empty", []byte(""), uint(0), false},
		{"*uint", []byte("1"), uintp(1), false},
		{"*uint zero", []byte("0"), uintp(0), false},
		{"*uint empty", []byte(""), (*uint)(nil), false},
		{"uint Invalid", []byte("foo"), uint(0), true},
		{"uint Negative", []byte("-1"), uint(0), true},

		{"uint8", []byte("1"), uint8(1), false},
		{"uint16", []byte("1"), uint16(1), false},
		{"uint32", []byte("1"), uint32(1), false},
		{"uint64", []byte("1"), uint64(1), false},

		{"bool negative", []byte("false"), bool(false), false},
		{"bool positive", []byte("true"), bool(true), false},
		{"bool empty", []byte(""), bool(false), false},
		{"*bool positive", []byte("true"), boolp(true), false},
		{"*bool negative", []byte("0"), boolp(false), false},
		{"*bool empty", []byte(""), (*bool)(nil), false},
		{"bool Invalid", []byte("foo"), bool(true), true},
		{"short bool negative (lowercase)", []byte("f"), bool(false), false},
		{"short bool positive (lowercase)", []byte("t"), bool(true), false},
		{"short bool negative (uppercase)", []byte("F"), bool(false), false},
		{"short bool positive (uppercase)", []byte("T"), bool(true), false},
	} {
		t.Run(tt.name, func(t *testing.T) {
			// ensure we have an addressable target
			var i = reflect.Indirect(reflect.New(reflect.TypeOf(tt.expected)))

			err := newValueSetter(i.Type())(i, rawValue{data: string(tt.raw)})
			if tt.shouldErr != (err != nil) {
				t.Errorf("newValueSetter(%s)() err want %v, have %v (%v)", reflect.TypeOf(tt.expected).Name(), tt.shouldErr, err != nil, err.Error())
			}
			if !tt.shouldErr && !reflect.DeepEqual(tt.expected, i.Interface()) {
				t.Errorf("newValueSetter(%s)() want %s, have %s", reflect.TypeOf(tt.expected).Name(), tt.expected, i)
			}
		})
	}
}

func TestDecodeSetUseCodepointIndices(t *testing.T) {
	type S struct {
		A string `fixed:"1,5"`
		B string `fixed:"6,10"`
		C string `fixed:"11,15"`
	}

	for _, tt := range []struct {
		name     string
		raw      []byte
		expected S
	}{
		{
			name:     "All ASCII characters",
			raw:      []byte("ABCD EFGH IJKL \n"),
			expected: S{"ABCD", "EFGH", "IJKL"},
		},
		{
			name:     "Multi-byte characters",
			raw:      []byte("ABCD ☃☃   EFG  \n"),
			expected: S{"ABCD", "☃☃", "EFG"},
		},
		{
			name:     "Truncated with multi-byte characters",
			raw:      []byte("☃☃\n"),
			expected: S{"☃☃", "", ""},
		},
		{
			name:     "Multi-byte characters",
			raw:      []byte("PIÑA DEFGHIJKLM"),
			expected: S{"PIÑA", "DEFGH", "IJKLM"},
		},
	} {
		t.Run(tt.name, func(t *testing.T) {
			d := NewDecoder(bytes.NewReader(tt.raw))
			d.SetUseCodepointIndices(true)
			var s S
			err := d.Decode(&s)
			if err != nil {
				t.Errorf("Unexpected err: %v", err)
			}
			if !reflect.DeepEqual(tt.expected, s) {
				t.Errorf("Decode(%v) want %v, have %v", tt.raw, tt.expected, s)
			}
		})
	}

}

// Verify the behavior of Decoder.Decode at the end of a file. See
// https://github.com/ianlopshire/go-fixedwidth/issues/6 for more details.
func TestDecode_EOF(t *testing.T) {
	d := NewDecoder(bytes.NewReader([]byte("")))
	type S struct {
		Field1 string `fixed:"1,1"`
		Field2 string `fixed:"2,2"`
		Field3 string `fixed:"3,3"`
	}
	var s S
	err := d.Decode(&s)
	if err != io.EOF {
		t.Errorf("Decode should have returned an EOF error. Returned: %v", err)
	}

	d = NewDecoder(bytes.NewReader([]byte("ABC\n")))
	err = d.Decode(&s)
	if err != nil {
		t.Errorf("Unexpected error from decode")
	}
	if !reflect.DeepEqual(&s, &S{Field1: "A", Field2: "B", Field3: "C"}) {
		t.Errorf("Unexpected result from Decode: %#v", s)
	}
	err = d.Decode(&s)
	if err != io.EOF {
		t.Errorf("Decode should have returned an EOF error. Returned: %v", err)
	}
}

// Verify that lines longer than the bufio.Scanner buffer decode correctly. See
// https://github.com/ianlopshire/go-fixedwidth/issues/47.
func TestDecode_VeryLongLines(t *testing.T) {
	var s struct {
		Field1 string `fixed:"1,10"`
	}

	// Fill a line with bufio.MaxScanTokenSize charters.
	data := bytes.Repeat([]byte("a"), bufio.MaxScanTokenSize)

	d := NewDecoder(bytes.NewReader(data))
	if err := d.Decode(&s); err != ErrTooLong {
		t.Errorf("Decode should have returned ErrTooLong. Returned: %v", err)
	}
}

func TestNewRawValue(t *testing.T) {
	for _, tt := range []struct {
		name     string
		input    []byte
		expected []int
	}{
		{
			name:     "All ASCII",
			input:    []byte("ABC"),
			expected: []int(nil),
		},
		{
			name:     "All multi-byte",
			input:    []byte("☃☃☃"),
			expected: []int{0, 3, 6},
		},
		{
			name:     "Mixed",
			input:    []byte("abc☃☃☃123"),
			expected: []int{0, 1, 2, 3, 6, 9, 12, 13, 14},
		},
	} {
		t.Run(tt.name, func(t *testing.T) {
			result, err := newRawValue(string(tt.input), true)
			if err != nil {
				t.Errorf("newRawValue(%v, true): Unexpected error", tt.input)
			} else if !reflect.DeepEqual(tt.expected, result.codepointIndices) {
				t.Errorf("newRawValue(%v, true): Unexpected result, expected %v got %v", tt.input, tt.expected, result.codepointIndices)
			}
		})
	}
}

func TestLineSeparator(t *testing.T) {
	// allTypes contains a field with all current supported types.
	type allTypes struct {
		String          string          `fixed:"1,5"`
		Int             int             `fixed:"6,10"`
		Float           float64         `fixed:"11,15"`
		TextUnmarshaler EncodableString `fixed:"16,20"`
	}
	for _, tt := range []struct {
		name           string
		rawValue       []byte
		target         interface{}
		expected       interface{}
		shouldErr      bool
		lineTerminator []byte
	}{
		{
			name:     "LF line endings",
			rawValue: []byte("foo  123  1.2  bar" + "\n" + "bar  321  2.1  foo"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"foo", 123, 1.2, EncodableString{"bar", nil}},
				{"bar", 321, 2.1, EncodableString{"foo", nil}},
			},
			shouldErr:      false,
			lineTerminator: []byte{},
		},
		{
			name:     "LF line endings",
			rawValue: []byte("f\ro  123  1.2  bar" + "\n" + "bar  321  2.1  foo"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"f\ro", 123, 1.2, EncodableString{"bar", nil}},
				{"bar", 321, 2.1, EncodableString{"foo", nil}},
			},
			shouldErr:      false,
			lineTerminator: []byte("\n"),
		},
		{
			name:     "CRLF line endings",
			rawValue: []byte("f\no  123  1.2  bar" + "\r\n" + "bar  321  2.1  foo"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"f\no", 123, 1.2, EncodableString{"bar", nil}},
				{"bar", 321, 2.1, EncodableString{"foo", nil}},
			},
			shouldErr:      false,
			lineTerminator: []byte("\r\n"),
		},
		{
			name:     "CR line endings",
			rawValue: []byte("f\no  123  1.2  bar" + "\r" + "bar  321  2.1  foo"),
			target:   &[]allTypes{},
			expected: &[]allTypes{
				{"f\no", 123, 1.2, EncodableString{"bar", nil}},
				{"bar", 321, 2.1, EncodableString{"foo", nil}},
			},
			shouldErr:      false,
			lineTerminator: []byte("\r"),
		},
	} {
		t.Run(tt.name, func(t *testing.T) {
			dec := NewDecoder(bytes.NewReader(tt.rawValue))
			dec.SetLineTerminator(tt.lineTerminator)
			err := dec.Decode(tt.target)
			if tt.shouldErr != (err != nil) {
				t.Errorf("Unmarshal() err want %v, have %v (%v)", tt.shouldErr, err != nil, err)
			}
			if !tt.shouldErr && !reflect.DeepEqual(tt.target, tt.expected) {
				t.Errorf("Unmarshal() want %+v, have %+v", tt.expected, tt.target)
			}

		})
	}
}