package etcd

import (
	"context"
	"fmt"
	"go.etcd.io/etcd/api/v3/mvccpb"
	clientv3 "go.etcd.io/etcd/client/v3"
	"pro2d/common"
	"pro2d/common/logger"
	"testing"
)

func TestEtcdClient_GetByPrefix(t *testing.T) {
	err := NewEtcdClient(common.GlobalConf.Etcd)
	if err != nil {
		logger.Error(err)
		return
	}
	gameInfo := GEtcdClient().GetByPrefix(common.GlobalConf.AccountConf.Name)
	for k, v := range gameInfo {
		logger.Debug("game info key:  %v val: %v", k, v)
	}

	rch := GEtcdClient().etcd.Watch(context.Background(), fmt.Sprintf("/%s/", common.GlobalConf.AccountConf.Name), clientv3.WithPrefix())
	go func() {
		for wresp := range rch {
			for _, ev := range wresp.Events {
				switch ev.Type {
				case mvccpb.PUT: //修改或者新增
					logger.Debug("account put key:  %s val: %s", ev.Kv.Key, ev.Kv.Value)
				case mvccpb.DELETE: //删除
					logger.Debug("account delete key:  %s val: %s", ev.Kv.Key, ev.Kv.Value)
				}
			}
		}
	}()

	game := GEtcdClient().etcd.Watch(context.Background(), fmt.Sprintf("/%s/", common.GlobalConf.GameConf.Name), clientv3.WithPrefix())
	for wresp := range game {
		for _, ev := range wresp.Events {
			switch ev.Type {
			case mvccpb.PUT: //修改或者新增
				logger.Debug("game put key:  %s val: %s", ev.Kv.Key, ev.Kv.Value)
			case mvccpb.DELETE: //删除
				logger.Debug("game delete key:  %s val: %s", ev.Kv.Key, ev.Kv.Value)
			}
		}
	}

}