package list

import (
	"net/url"
	"os"
	"testing"

	"github.com/stretchr/testify/assert"
	"github.com/yaoapp/gou/model"
	"github.com/yaoapp/gou/process"
	"github.com/yaoapp/gou/session"
	"github.com/yaoapp/kun/any"
	"github.com/yaoapp/yao/config"
	"github.com/yaoapp/yao/test"
)

func TestProcessSetting(t *testing.T) {
	test.Prepare(t, config.Conf)
	defer test.Clean()

	load(t)
	clear(t)
	testData(t)
	args := []interface{}{"category"}
	res, err := process.New("yao.list.Setting", args...).Exec()
	if err != nil {
		t.Fatal(err)
	}
	data := any.Of(res).MapStr().Dot()
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("父类")+".edit.props.xProps/remote", data.Get("fields.list.父类.edit.props.xProps.remote.api"))
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("名称")+".edit.props/on%3Achange", data.Get("hooks.onChange.名称.api"))
	assert.Equal(t, "开发者自定义", data.Get("hooks.onChange.名称.params.extra"))
}

func TestProcessXgen(t *testing.T) {
	test.Prepare(t, config.Conf)
	defer test.Clean()

	load(t)
	clear(t)
	testData(t)
	args := []interface{}{"category"}
	res, err := process.New("yao.list.Xgen", args...).Exec()
	if err != nil {
		t.Fatal(err)
	}
	data := any.Of(res).MapStr().Dot()
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("父类")+".edit.props.xProps/remote", data.Get("fields.list.父类.edit.props.xProps.remote.api"))
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("名称")+".edit.props/on%3Achange", data.Get("hooks.onChange.名称.api"))
	assert.Equal(t, "开发者自定义", data.Get("hooks.onChange.名称.params.extra"))
}

func TestProcessXgenWithPermissions(t *testing.T) {
	test.Prepare(t, config.Conf)
	defer test.Clean()

	load(t)
	clear(t)
	testData(t)

	session.Global().Set("__permissions", map[string]interface{}{
		"lists.category": []string{
			"a189b2bf0dd9b29f6628b386e501397f", // fields.list.库存预警
		},
	})

	args := []interface{}{"category"}
	res, err := process.New("yao.list.Xgen", args...).Exec()
	if err != nil {
		t.Fatal(err)
	}
	data := any.Of(res).MapStr().Dot()
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("父类")+".edit.props.xProps/remote", data.Get("fields.list.父类.edit.props.xProps.remote.api"))
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("名称")+".edit.props/on%3Achange", data.Get("hooks.onChange.名称.api"))
	assert.Equal(t, "开发者自定义", data.Get("hooks.onChange.名称.params.extra"))
	assert.False(t, data.Has("fields.list.库存预警"))

	session.Global().Set("__permissions", nil)
	res, err = process.New("yao.list.Xgen", args...).Exec()
	if err != nil {
		t.Fatal(err)
	}
	data = any.Of(res).MapStr().Dot()
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("父类")+".edit.props.xProps/remote", data.Get("fields.list.父类.edit.props.xProps.remote.api"))
	assert.Equal(t, "/api/__yao/list/category/component/fields.list."+url.QueryEscape("名称")+".edit.props/on%3Achange", data.Get("hooks.onChange.名称.api"))
	assert.Equal(t, "开发者自定义", data.Get("hooks.onChange.名称.params.extra"))
	assert.True(t, data.Has("fields.list.库存预警"))

}

func load(t *testing.T) {
	prepare(t)
	err := Load(config.Conf)
	if err != nil {
		t.Fatal(err)
	}
}

func testData(t *testing.T) {
	category := model.Select("category")
	err := category.Insert(
		[]string{"name", "stock", "status", "rank"},
		[][]interface{}{
			{"机器人", 100, "启用", 1},
			{"运输车", 80, "启用", 2},
			{"货柜", 100, "停用", 3},
		},
	)
	if err != nil {
		t.Fatal(err)
	}
}

func tempFile(t *testing.T) string {
	file, err := os.CreateTemp("", "unit-test")
	if err != nil {
		t.Fatal(err)
	}
	defer file.Close()

	_, err = file.Write([]byte("HELLO"))
	if err != nil {
		t.Fatal(err)
	}

	return file.Name()
}

func clear(t *testing.T) {
	for _, m := range model.Models {
		err := m.DropTable()
		if err != nil {
			t.Fatal(err)
		}
		err = m.Migrate(true)
		if err != nil {
			t.Fatal(err)
		}
	}
}