// Copyright 2019 The Go Cloud Development Kit Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package awsdynamodb

import (
	"reflect"
	"testing"

	dynattr "github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue"
	dyn2Types "github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
	"github.com/google/go-cmp/cmp"
	"github.com/google/go-cmp/cmp/cmpopts"
	"gocloud.dev/docstore/driver"
	"gocloud.dev/docstore/drivertest"
)

var compareIgnoreAttributeUnexported = cmpopts.IgnoreUnexported(
	dyn2Types.AttributeValueMemberB{},
	dyn2Types.AttributeValueMemberBOOL{},
	dyn2Types.AttributeValueMemberBS{},
	dyn2Types.AttributeValueMemberL{},
	dyn2Types.AttributeValueMemberM{},
	dyn2Types.AttributeValueMemberN{},
	dyn2Types.AttributeValueMemberNS{},
	dyn2Types.AttributeValueMemberNULL{},
	dyn2Types.AttributeValueMemberS{},
	dyn2Types.AttributeValueMemberSS{},
)

func TestEncodeValue(t *testing.T) {
	avn := func(s string) dyn2Types.AttributeValue { return &dyn2Types.AttributeValueMemberN{Value: s} }
	avl := func(avs ...dyn2Types.AttributeValue) dyn2Types.AttributeValue {
		return &dyn2Types.AttributeValueMemberL{Value: avs}
	}

	var seven int32 = 7
	var nullptr *int

	for _, test := range []struct {
		in   any
		want dyn2Types.AttributeValue
	}{
		// null
		{nil, nullValue},
		{nullptr, nullValue},
		// number
		{0, avn("0")},
		{uint64(999), avn("999")},
		{3.5, avn("3.5")},
		{seven, avn("7")},
		{&seven, avn("7")},
		// string
		{"", nullValue},
		{"x", &dyn2Types.AttributeValueMemberS{Value: "x"}},
		{"abc123", &dyn2Types.AttributeValueMemberS{Value: "abc123"}},
		{"abc 123", &dyn2Types.AttributeValueMemberS{Value: "abc 123"}},
		// bool
		{true, &dyn2Types.AttributeValueMemberBOOL{Value: true}},
		{false, &dyn2Types.AttributeValueMemberBOOL{Value: false}},
		// list
		{[]int(nil), nullValue},
		{[]int{}, &dyn2Types.AttributeValueMemberL{Value: []dyn2Types.AttributeValue{}}},
		{[]int{1, 2}, avl(avn("1"), avn("2"))},
		{[...]int{1, 2}, avl(avn("1"), avn("2"))},
		{[]any{nil, false}, avl(nullValue, &dyn2Types.AttributeValueMemberBOOL{Value: false})},
		// map
		{map[string]int(nil), nullValue},
		{map[string]int{}, &dyn2Types.AttributeValueMemberM{Value: map[string]dyn2Types.AttributeValue{}}},
		{
			map[string]int{"a": 1, "b": 2},
			&dyn2Types.AttributeValueMemberM{Value: map[string]dyn2Types.AttributeValue{
				"a": avn("1"),
				"b": avn("2"),
			}},
		},
	} {
		var e encoder
		if err := driver.Encode(reflect.ValueOf(test.in), &e); err != nil {
			t.Fatal(err)
		}
		got := e.av
		if !cmp.Equal(got, test.want, compareIgnoreAttributeUnexported) {
			t.Errorf("%#v: got %#v, want %#v", test.in, got, test.want)
		}
	}
}

func TestDecodeValue(t *testing.T) {
	avn := func(s string) dyn2Types.AttributeValue { return &dyn2Types.AttributeValueMemberN{Value: s} }
	avl := func(vals ...dyn2Types.AttributeValue) dyn2Types.AttributeValue {
		return &dyn2Types.AttributeValueMemberL{Value: vals}
	}

	for _, test := range []struct {
		in   dyn2Types.AttributeValue
		want any
	}{
		// null
		// {nullValue, nil}, // cant reflect new, how best to test?
		// bool
		{&dyn2Types.AttributeValueMemberBOOL{Value: false}, false},
		{&dyn2Types.AttributeValueMemberBOOL{Value: true}, true},
		// string
		{&dyn2Types.AttributeValueMemberS{Value: "x"}, "x"},
		// int64
		{avn("7"), int64(7)},
		{avn("-7"), int64(-7)},
		{avn("0"), int64(0)},
		// uint64
		{avn("7"), uint64(7)},
		{avn("0"), uint64(0)},
		// float64
		{avn("7"), float64(7)},
		{avn("0"), float64(0)},
		{avn("3.1415"), float64(3.1415)},
		// []byte
		{&dyn2Types.AttributeValueMemberB{Value: []byte(`123`)}, []byte(`123`)},
		// List
		{avl(avn("12"), avn("37")), []int64{12, 37}},
		{avl(avn("12"), avn("37")), []uint64{12, 37}},
		{avl(avn("12.8"), avn("37.1")), []float64{12.8, 37.1}},
		// Map
		{
			&dyn2Types.AttributeValueMemberM{Value: map[string]dyn2Types.AttributeValue{}},
			map[string]int{},
		},
		{
			&dyn2Types.AttributeValueMemberM{Value: map[string]dyn2Types.AttributeValue{"a": avn("1"), "b": avn("2")}},
			map[string]int{"a": 1, "b": 2},
		},
	} {
		var (
			target = reflect.New(reflect.TypeOf(test.want))
		)

		dec := decoder{av: test.in}
		if err := driver.Decode(target.Elem(), dec); err != nil {
			t.Errorf(" error decoding value %#v, got error: %#v", test.in, err)
			continue
		}

		if !cmp.Equal(target.Elem().Interface(), test.want, compareIgnoreAttributeUnexported) {
			t.Errorf(" %#v: got %#v, want %#v", test.in, target.Elem().Interface(), test.want)
		}
	}
}

func TestDecodeErrorOnUnsupported(t *testing.T) {
	for _, tc := range []struct {
		in  dyn2Types.AttributeValue
		out any
	}{
		{&dyn2Types.AttributeValueMemberSS{Value: []string{"foo", "bar"}}, []string{}},
		{&dyn2Types.AttributeValueMemberNS{Value: []string{"1.1", "-2.2", "3.3"}}, []float64{}},
		{&dyn2Types.AttributeValueMemberBS{Value: [][]byte{{4}, {5}, {6}}}, [][]byte{}},
	} {
		d := decoder{av: tc.in}
		if err := driver.Decode(reflect.ValueOf(tc.out), &d); err == nil {
			t.Error("got nil error, want unsupported error")
		}
	}
}

type codecTester struct{}

func (ct *codecTester) UnsupportedTypes() []drivertest.UnsupportedType {
	return []drivertest.UnsupportedType{drivertest.BinarySet}
}

func (ct *codecTester) NativeEncode(obj any) (any, error) {
	return dynattr.Marshal(obj)
}

func (ct *codecTester) NativeDecode(value, dest any) error {
	return dynattr.Unmarshal(value.(dyn2Types.AttributeValue), dest)
}

func (ct *codecTester) DocstoreEncode(obj any) (any, error) {
	return encodeDoc(drivertest.MustDocument(obj))
}

func (ct *codecTester) DocstoreDecode(value, dest any) error {
	return decodeDoc(value.(dyn2Types.AttributeValue), drivertest.MustDocument(dest))
}