package actions
  
  import (
  	"fmt"
  	"github.com/gin-gonic/gin"
  	"net/http"
  	"pro2d/components/db"

  	"pro2d/components/etcd"

  	"pro2d/conf"
  	"pro2d/models"
  	"pro2d/protos/pb"
  	"pro2d/utils"
  	"reflect"
  	"strings"
  )
  
  type HttpAction struct {
  	version string
  	port []string

  	EtcdClient *etcd.EtcdClient

  }
  
  func NewHttpAction(version string, port ...string) *HttpAction {
  	return &HttpAction{version: version, port: port}
  }
  
  func Pong (c *gin.Context) {
  	c.JSON(200, gin.H{
  		"message": "pong",
  	})
  }
  
  func HandlerFuncObj(tvl, obj reflect.Value) gin.HandlerFunc {
  	apiFun := func(c *gin.Context) interface{} { return c }
  	return func(c *gin.Context) {
  		tvl.Call([]reflect.Value{obj, reflect.ValueOf(apiFun(c))})
  	}
  }
  
  func GetRoutePath(objName, objFunc string) string  {
  	return strings.ToLower(objName + "/" + objFunc)
  }
  
  func PubRsp(c *gin.Context, code int, data interface{}) {
  	c.JSON(http.StatusOK, gin.H{"code": code, "data": data})
  }
  
  func (h *HttpAction) Register(c *gin.Context) {
  	var register pb.Register
  	if err := c.ShouldBindJSON(&register); err != nil {
  		PubRsp(c, -1, err.Error())
  		return
  	}
  
  	account := models.NewAccount(register.Phone)
  	if err := account.Load(); err == nil {
  		PubRsp(c, -2, "account exist: " + register.Phone)
  		return
  	}
  
  	account.Uid = conf.SnowFlack.NextValStr()
  	account.Password = utils.Md5V(register.Password)
  	if _, err := account.Create(); err != nil{
  		PubRsp(c, -3, "account register err: " + err.Error())
  		return
  	}
  	account.Password = register.Password
  	PubRsp(c, 0, account.Account)
  }
  
  func (h *HttpAction) Login(c *gin.Context) {
  	var login pb.Account
  	if err := c.ShouldBindJSON(&login); err != nil {
  		PubRsp(c, -1, err.Error())
  		return
  	}
  	account := models.NewAccount(login.Phone)
  	if err := account.Load(); err != nil {
  		PubRsp(c, -2, err.Error())
  		return
  	}
  
  	if utils.Md5V(login.Password) != account.Password {
  		PubRsp(c, -3, "password error")
  		return
  	}
  

  	var gs []*pb.ServiceInfo

  	for k, v := range h.EtcdClient.GetByPrefix(conf.GlobalConf.GameConf.Name) {

  		gs = append(gs, &pb.ServiceInfo{
  			Id:      k,
  			Name:    conf.GlobalConf.GameConf.Name,
  			Address: v,
  		})
  	}
  	rsp := &pb.LoginRsp{
  		Uid:         account.Uid,
  		GameService: gs,
  	}
  	PubRsp(c, 0, rsp)

  }
  
  func (h *HttpAction) Start() error {
  	//mongo 初始化
  	db.MongoDatabase = db.MongoClient.Database(conf.GlobalConf.AccountConf.DBName)
  	models.InitAccountServerModels()
  
  	//Etcd 初始化

  	h.EtcdClient = etcd.NewEtcdClient(conf.GlobalConf.Etcd)
  	h.EtcdClient.PutWithLeasePrefix(conf.GlobalConf.AccountConf.Name, conf.GlobalConf.AccountConf.ID, fmt.Sprintf("%s:%d", conf.GlobalConf.AccountConf.IP, conf.GlobalConf.AccountConf.Port), 5)

  
  	//gin初始化
  	r := gin.Default()
  	r.GET("/ping", Pong)
  	typ := reflect.TypeOf(h)
  	val := reflect.ValueOf(h)
  	//t := reflect.Indirect(val).Type()
  	//objectName := t.Name()
  
  	numOfMethod := val.NumMethod()
  	for i := 0; i < numOfMethod; i++ {
  		method := typ.Method(i)
  		r.GET(GetRoutePath(h.version, method.Name), HandlerFuncObj(method.Func, val))
  		r.POST(GetRoutePath(h.version, method.Name), HandlerFuncObj(method.Func, val))
  	}
  	return r.Run(h.port...) // listen and serve on 0.0.0.0:8080 (for windows "localhost:8080")
  }