package raft

import (
	"time"

	cached "gitee.com/prestonTao/libp2parea/cache/cachedata"
	"gitee.com/prestonTao/utils"
)

func init() {
	go func() {
		ticker := time.NewTicker(5 * time.Second)
		defer ticker.Stop()
		for {
			<-ticker.C
			RD.Team.Range(func(k, v interface{}) bool {
				team, ok := v.(RaftTeam)
				if !ok {
					return false
				}
				if team.Role.Role == Leader {
					syncData(team.TeamId)
				}
				return true
			})
		}
	}()
}

// 初始化cachedata
func bindCacheData() {
	cached.Register()
}

// 同步数据
func syncData(teamid *utils.Multihash) {
	cached.SyncDataToQuarterLogicIds(teamid)
}

// 增加数据
func Add(key, value []byte) {
	cachedata := cached.BuildCacheData(key, value)
	//cachedata.AddOwnId(nodeStore.NodeSelf.IdInfo.Id)
	//保存数据
	cached.Save(cachedata)
	teamid := BuildHash(key)
	//广播出去
	go cached.SyncDataToQuarterLogicIds(teamid)
	FirstTeam(teamid)
}

// 修改数据
func Update(key, value []byte) {
	cachedata := cached.BuildCacheData(key, value)
	//保存数据
	cached.Save(cachedata)
	teamid := BuildHash(key)
	//广播出去
	go cached.SyncDataToQuarterLogicIds(teamid)
}

// 删除数据
func Del(key []byte) {
	teamid := BuildHash(key)
	cachedata := cached.GetCacheDataByHash(teamid)
	if cachedata == nil {
		return
	}
	cachedata.Del = true
	//广播出去
	go cached.SyncCacheDataToQuarterLogicIds(cachedata)
	cached.Del(key)
}