package discovery

import (
	"basic.com/pubsub/cache.git/shardmap"
	"basic.com/pubsub/protomsg.git"
	"basic.com/valib/logger.git"
	"errors"
	"github.com/gogo/protobuf/proto"
	"sdkCompare/config"
	"sdkCompare/util"
)

const (
	SERVER_KEY = "SERVERINFO"
)

var cMap *shardmap.ShardMap
var withBus bool

func SetBus(wb bool) error {
	withBus = wb
	if !withBus {
		serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter)
		if e != nil {
			return e
		}
		cMap = shardmap.New(uint8(32))
		cMap.Set(SERVER_KEY, protomsg.LocalConfig{
			AlarmIp:   serverIp,
			AlarmPort: 9200,
		})
	}
	return nil
}

func initCacheData(initChan chan bool) {

	initChan <- true
}

var newUpdateMsg = &protomsg.DbChangeMessage{}

func updateData(b []byte) {
	if err := proto.Unmarshal(b, newUpdateMsg); err != nil {
		logger.Debug("dbChangeMsg unmarshal err:", err)
		return
	}
	switch newUpdateMsg.Table {
	case protomsg.TableChanged_T_Server:
	default:
		logger.Debug("other updateData operation")

	}
}

func GetServerInfo() (conf protomsg.LocalConfig, err error) {
	config, b := cMap.Get(SERVER_KEY)
	if b {
		return config.(protomsg.LocalConfig), nil
	} else {
		return conf, errors.New("conf not found")
	}
}

// 判断一个数组是否包含另一个数组的所有元素
func arrayContains(list []string, arr []string) bool {
	c := 0
	if arr == nil || list == nil {
		return false
	}
	for _, s := range arr {
		for _, t := range list {
			if s == t {
				c++
				break
			}
		}
	}
	return c == len(arr)
}