package service

import (
	"basic.com/syncdb.git"
	"basic.com/valib/logger.git"
	"basic.com/valib/serf.git/client"
	"basic.com/valib/serf.git/cmd/serf/command/agent"
	"context"
	"github.com/mitchellh/cli"
	"vamicro/config"
	"vamicro/extend/util"
)

//serf daemon进程，集群中只有主节点才会启动，非主节点处于停止状态。
func Start(ctx context.Context) error {
	clusterId := ""
	password := config.ClusterSet.PwdPre+"123456"
	var addrs []string

	conf := syncdb.DefaultConfig()
	conf.RPCAddr = "0.0.0.0"
	conf.RPCPort = 7474
	conf.BindAddr = "0.0.0.0:30290"
	conf.Ctx = ctx
	agent, err := syncdb.Init(clusterId, password, config.Server.AnalyServerId, addrs, "./serf-daemon.json", conf)
	if err != nil {
		return err
	}
	agent.RegisterHandleEventFunc(HandleSerfEvent)
	logger.Debug("agent:", agent, "err:", err)
	return nil
}

func TestSerfRPC() {
	shutdownCh := make(chan struct{})
	doneCh := make(chan struct{})
	defer func() {
		close(shutdownCh)
		<-doneCh
	}()

	ui := new(cli.MockUi)
	c := &agent.Command{
		ShutdownCh: shutdownCh,
		Ui: ui,
	}

	ip, _, _ := util.GetLocalIP(config.Server.NetworkAdapter)
	rpcAddr := ip + ":7373"
	args := []string {
		"-bind", ip,
		"-rpc-addr", rpcAddr,
	}

	go func() {
		code := c.Run(args)
		if code != 0 {
			logger.Debug("run serf Command code:", code)
		}
		close(doneCh)
	}()
	rpcClient, err := client.NewRPCClient(rpcAddr)
	if err != nil {
		logger.Debug("client.NewRPCClient err:", err)
		return
	}
	members, err := rpcClient.Members()
	if err != nil {
		logger.Debug("rpc members err:", err)
	}
	logger.Debug("len(members):", len(members))
	param := client.QueryParam{
		FilterNodes: []string{},
		Name: "",
		Payload: []byte(""),
	}
	rpcClient.Query(&param)
}