package etcd
  
  import (
  	"context"
  	"fmt"
  	"go.etcd.io/etcd/api/v3/mvccpb"
  	clientv3 "go.etcd.io/etcd/client/v3"
  	"pro2d/conf"

  	"pro2d/utils/logger"

  	"testing"
  )
  
  func TestEtcdClient_GetByPrefix(t *testing.T) {

  	etcd, err := NewEtcdClient(conf.GlobalConf.Etcd)
  	if err != nil {
  		logger.Error(err)
  		return
  	}

  	gameInfo := etcd.GetByPrefix(conf.GlobalConf.AccountConf.Name)
  	for k, v := range gameInfo {

  		logger.Debug("game info key:  %v val: %v", k, v)

  	}
  
  	rch := etcd.etcd.Watch(context.Background(), fmt.Sprintf("/%s/", conf.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 := etcd.etcd.Watch(context.Background(), fmt.Sprintf("/%s/", conf.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)

  			}
  		}
  	}
  
  }