package guildgve_test

import (
	"fmt"
	"go_dreamfactory/comm"
	"go_dreamfactory/lego"
	"go_dreamfactory/lego/base/rpcx"
	"go_dreamfactory/lego/core"
	"go_dreamfactory/lego/sys/log"
	"go_dreamfactory/modules/chat"
	"go_dreamfactory/services"
	"go_dreamfactory/sys/db"
	"os"
	"testing"
	"time"

	"github.com/go-redis/redis/v8"
)

func newService(ops ...rpcx.Option) core.IService {
	s := new(TestService)
	s.Configure(ops...)
	return s
}

// 梦工厂基础服务对象
type TestService struct {
	services.ServiceBase
}

// 初始化相关系统
func (this *TestService) InitSys() {
	this.ServiceBase.InitSys()
	if err := db.OnInit(this.GetSettings().Sys["db"], db.SetServiceId(this.GetTag())); err != nil {
		panic(fmt.Sprintf("init sys.db err: %s", err.Error()))
	} else {
		log.Infof("init sys.db success!")
	}
}

var service core.IService
var s_gateComp comm.ISC_GateRouteComp = services.NewGateRouteComp()
var module = new(chat.Chat)

// 测试环境下初始化db和cache 系统
func TestMain(m *testing.M) {
	service = newService(
		rpcx.SetConfPath("../../bin/conf/dfli_worker0.yaml"),
		rpcx.SetVersion("1.0.0.0"),
	)
	service.OnInstallComp( //装备组件
		s_gateComp, //此服务需要接受用户的消息 需要装备网关组件
	)
	go func() {
		lego.Run(service) //运行模块

	}()
	time.Sleep(time.Second * 3)
	defer os.Exit(m.Run())
}

func Test_Module(t *testing.T) {
	var (
		key     string
		score   float64
		menbers *redis.Z
		conn    *db.DBConn
		err     error
	)
	key = "guildgvebattlerank:3"
	score = 1
	menbers = &redis.Z{Score: (score), Member: "member"}
	conn, err = db.Local()
	if err = conn.Redis.ZAdd(key, menbers); err != nil {
		log.Errorln(err)
	}
}