package cypher

import (
	//"fmt"
	"fmt"
	"testing"
	"time"

	. "git.wecise.com/wecise/odbserver/odb"
	"git.wecise.com/wecise/odbserver/odb/test"
	"gitee.com/wecisecode/util/logger"

	//"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

type CypherTests struct {
	Test *testing.T
	g    *Gutil
}

func CypherTest(t *testing.T) {

	g := test.TestG()

	t.Run("InitG", func(t *testing.T) {
		test := &CypherTests{Test: t, g: g}
		test.InitG()
	})

	t.Run("Class", func(t *testing.T) {
		test := &CypherTests{Test: t, g: g}
		test.Class()
	})

	t.Run("Data", func(t *testing.T) {
		test := &CypherTests{Test: t, g: g}
		test.Data()
	})

	time.Sleep(time.Duration(1) * time.Second)

	/*t.Run("Valid", func(t *testing.T) {
		test := &CypherTests{Test: t, g: g}
		test.Valid()
	})

	t.Run("Search", func(t *testing.T) {
		test := &CypherTests{Test: t, g: g}
		test.Search()
	})*/

	/*t.Run("Update", func(t *testing.T) {
		test := &CypherTests{Test: t, g: g}
		test.Update()
	})*/

}

func (t *CypherTests) InitG() {
	require.NotNil(t.Test, t.g)
}

func (t *CypherTests) Class() {

	_, _, err := t.g.Query(`
		create edge type if not exists ` + t.g.Keyspace + `.connect "connect"`)

	if err != nil {
		logger.Errorf("%v", err)
	}

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`
		create class if not exists /test/cypher (
		name		varchar,		
		keys(name)
	)with key=manu and nickname='cypher'`)

	if err != nil {
		logger.Errorf("%v", err)
	}

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`
		create class if not exists /test/cypher2 (

		name		varchar,		
		keys(name)
	)with key=manu and nickname='cypher2'`)

	if err != nil {
		logger.Errorf("%v", err)
	}

	require.Nil(t.Test, err, fmt.Sprint(err))
}

func (t *CypherTests) Data() {
	var err error
	_, _, err = t.g.Query(`insert into /test/cypher (id, name) values ("cypher:e1", "entity1" )`)

	if err != nil {
		logger.Errorf("%v", err)
	}
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/cypher2 (id, name) values ("cypher2:e2", "entity2" )`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	require.Nil(t.Test, err, fmt.Sprint(err))

	for i := 0; i < 200; i++ {
		_, _, err = t.g.Query(`create ("cypher:e1")-[:connect]->("cypher2:e2")`)
		if err != nil {
			logger.Errorf("%v", err)
		}
		require.Nil(t.Test, err, fmt.Sprint(err))
	}
}

/*func (t *CypherTests) Valid() {
}

func (t *CypherTests) Search() {
}
*/