package test

import (
	"context"
	"log"
	"testing"
	"time"

	"app.yhyue.com/moapp/jy_docs/rpc/stdlib/stdlib"
	"app.yhyue.com/moapp/jy_docs/rpc/stdlib/stdlibclient"
	"github.com/tal-tech/go-zero/core/discov"
	"github.com/tal-tech/go-zero/zrpc"
)

func Test_DocOn(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
	req := &stdlib.DocChangeReq{Id: "123", Reason: 1, AppId: "app_id_123"}
	res, err := std.DocOn(ctx, req)
	log.Println("err ", err)
	if res.State == true {
		log.Println("req true")
	} else {
		log.Println("req false", res)
	}
}
func Test_DocOff(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
	req := &stdlib.DocChangeReq{Id: "123", Reason: 10, AppId: "app_id_123"}
	res, err := std.DocOff(ctx, req)
	log.Println("err ", err)
	if res.State == true {
		log.Println("req true")
	} else {
		log.Println("req false", res)
	}
	//log.Println("err ", err)
	//log.Println("req ", res)
}

func Test_DocActivity(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
	req := &stdlib.DocActivityReq{PageNum: 1, PageSize: 10, AppId: "app_id_123"}
	res, err := std.DocActivity(ctx, req)
	log.Println("err ", err)
	log.Println("req ", res)
}

func Test_DocStatistics(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
	req := &stdlib.DocStatisticsReq{DocId: "123", DocStatisticsType: 1, AppId: "app_id_123"}
	res, err := std.DocStatistics(ctx, req)
	log.Println("err ", err)
	log.Println("req ", res)
}

func Test_DocGetCheck(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
	req := &stdlib.DocGetCheckReq{DocId: "111", UserId: "123", AppId: "app_id_123"}
	res, err := std.DocGetCheck(ctx, req)
	log.Println("err ", err)
	log.Println("req ", res)
}

func Test_DocGetContent(t *testing.T) {
	ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
	std := stdlibclient.NewStdlib(zrpc.MustNewClient(zrpc.RpcClientConf{Etcd: discov.EtcdConf{Hosts: []string{"192.168.3.240:2379"}, Key: "jydocs.stdlib.rpc"}}))
	req := &stdlib.DocGetCheckReq{DocId: "111", UserId: "123", AppId: "app_id_123"}
	res, err := std.DocGetContent(ctx, req)
	log.Println("err ", err)
	log.Println("req ", res)
}