package service

import (
	"basic.com/pubsub/protomsg.git"
	"basic.com/valib/bhomeclient.git"
	"basic.com/valib/logger.git"
	"encoding/json"
	"time"
	"vamicro/extend/util"
	"vamicro/system-service/models"
)

//判断升级或者其他操作导致通道数量变化
func WatchAuthSetChange(bk bhomeclient.Broker) {
	for {
		var lc models.LocalConfig
		err := lc.Select()
		if err == nil {
			if !util.SysExpired && lc.RealMax != util.SysChCount && util.SysChCount != 0 {
				lc.RealMax = util.SysChCount
				lc.Update()

				pMsg := protomsg.DbChangeMessage{
					Table:  protomsg.TableChanged_T_Server,
					Action: protomsg.DbAction_Update,
				}
				pb, _ := json.Marshal(pMsg)
				bk.Publish(ProcName, pb)
			}
		}
		time.Sleep(time.Second * 10)
	}
}

func TestGetTopicNode(ms *bhomeclient.MicroNode) {
	for {
		nodes := ms.GetLocalNetNodeByTopic("/data/api-v/sysset/getDeviceInfo")
		for i := 0; i < len(nodes); i++ {
			logger.Debug("GetNetNodeByTopic nodes[", i, "]:", nodes[i])
		}
		time.Sleep(time.Second * 10)
	}
}