package service

import (
	"encoding/json"
	"strings"
	"vamicro/config"

	"basic.com/valib/bhomeclient.git"
	"basic.com/valib/bhomedbapi.git"
	"basic.com/valib/go-aiot.git/aiotProto/aiot"
	"basic.com/valib/logger.git"
	"gitee.com/LearingIt/goTypeTrans/trans"
)

const (
	Token = "Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjQ3NDUwMjU5MjMsInVzZXIiOiJ7XCJpZFwiOlwiZTZjY2QzNmQtNGYxNi00NmZjLTg4ZDUtMDczNjU4NjZkMjA1XCIsXCJwZXJtaXNzaW9uc1wiOltcInByb2R1Y3RNYW5nZTpwdWJsaXNoXCIsXCJjb2RlTWFuZ2U6dmlld1wiLFwiZGV2aWNlTWFuYWdlOmFkZFwiLFwiYWRtaW5NYW5hZ2VcIixcIm9yZGVyTWFuZ2VcIixcImRldmljZU1hbmFnZTp2aWV3XCIsXCJwcm9kdWN0TWFuZ2U6YWRkXCIsXCJhZG1pbk1hbmFnZTp2aWV3XCIsXCJjb2RlTWFuZ2U6YWRkXCIsXCJwcm9kdWN0TWFuZ2U6b2ZmU2FsZVwiLFwib3JkZXJNYW5nZTpjYW5jZWxcIixcInByb2R1Y3RDZW50ZXI6ZG93bmxvYWRcIixcInByb2R1Y3RDZW50ZXI6YnV5XCIsXCJwcm9kdWN0TWFuZ2U6dmlld1wiLFwiYXBpXCIsXCJob21lXCIsXCJvcmRlck1hbmdlOnBheVwiLFwiYWRtaW5NYW5hZ2U6YWRkXCIsXCJvcmRlck1hbmdlOmRvd25sb2FkXCIsXCJwcm9kdWN0Q2VudGVyXCIsXCJkZXZpY2VNYW5hZ2U6dW5iaW5kXCIsXCJvcmRlck1hbmdlOnZpZXdcIixcImFkbWluTWFuYWdlOmVkaXRcIixcImRldmljZU1hbmFnZVwiLFwidmlwTWFuYWdlOmFkZFwiLFwidmlwTWFuYWdlOnZpZXdcIixcInByb2R1Y3RDZW50ZXI6dmlld1wiLFwidmlwTWFuYWdlOmVkaXRcIixcInZpcE1hbmFnZVwiLFwicHJvZHVjdE1hbmdlOmVkaXRcIixcImNvZGVNYW5nZVwiLFwicHJvZHVjdE1hbmdlXCJdLFwidXNlcm5hbWVcIjpcImJhc2ljXCJ9In0.vwjAFkWuEyadRLvIOGK8LFE3MjpY3SQ7j6AlTXnQDG8"
)

// string转interface
func stringParams2paramsBody(params map[string]string) map[string]interface{} {
	paramsBody := make(map[string]interface{})
	for k, v := range params {
		paramsBody[k] = v
	}
	return paramsBody
}

// interface转string
func interfaceParams2paramsBody(params map[string]interface{}) map[string]string {
	paramsBody := make(map[string]string)
	for k, v := range params {
		paramsBody[k] = trans.Any2String(v)
	}
	return paramsBody
}

// 封装统一请求方法
func DoBusReq(topic string, nodeId string, method aiot.RequestMethod, contentType aiot.RequestContentType, params map[string]interface{}) ([]byte, error) {
	var err error
	var data []byte
	logger.Debug("DoBusReq...", topic, nodeId, method, contentType, GetContentTypeString(contentType), params)
	switch method {
	case aiot.RequestMethod_Get:
		// 发送get请求
		return DoGetToBus(nodeId, topic, interfaceParams2paramsBody(params))
	case aiot.RequestMethod_Post:
		// post请求
		return DoPostToBus(nodeId, topic, GetContentTypeString(contentType), params)
	case aiot.RequestMethod_Put:
		// put
		return DoPutToBus(nodeId, topic, GetContentTypeString(contentType), params)
	case aiot.RequestMethod_Delete:
		// delete
		return DoDeleteToBus(nodeId, topic, GetContentTypeString(contentType), params)
	}
	return data, err
}

// 获取节点IP
func GetNodeIp(nodeId string) (string, error) {
	client := bhomedbapi.NewClient(bhomedbapi.WithNodes(nil))
	params := map[string]interface{}{
		"node_id": nodeId,
	}
	node, err := client.DoPostRequest("/data/api-v/cluster/findIpByNode", bhomedbapi.CONTENT_TYPE_JSON, params, nil, nil)
	if err != nil {
		logger.Error("Fail to execute GetNodeIp", err)
		return "", err
	}

	var ret bhomeclient.Reply
	err = json.Unmarshal(node, &ret)
	if err != nil {
		return "", err
	}
	ip := trans.Any2String(ret.Data)
	if ip != "" && strings.Index(ip, ":") > 0 {
		return ip[0:strings.Index(ip, ":")], nil
	}
	return ip, nil
}

// bus-get请求
func DoGetToBus(nodeId string, url string, params map[string]string) ([]byte, error) {
	ip, _ := GetNodeIp(nodeId)
	header := map[string]string{
		"Authorization": Token,
	}
	client := bhomedbapi.NewClient(bhomedbapi.WithIp(ip), bhomedbapi.WithDevId(nodeId), bhomedbapi.WithTopic(url))
	if client == nil || nodeId != config.Server.AnalyServerId {
		logger.Warn("client is nil. return from bus to http")
		client = bhomedbapi.HttpClient{}
		url = "http://" + ip + ":8888/" + strings.Trim(url, "/")
	}
	return client.DoGetRequest(url, params, header)
}

// bus-post请求
func DoPostToBus(nodeId string, url string, contentType string, params map[string]interface{}) ([]byte, error) {
	ip, _ := GetNodeIp(nodeId)
	header := map[string]string{
		"Authorization": Token,
	}
	client := bhomedbapi.NewClient(bhomedbapi.WithIp(ip), bhomedbapi.WithDevId(nodeId), bhomedbapi.WithTopic(url))
	if client == nil || nodeId != config.Server.AnalyServerId {
		logger.Warn("client is nil. return from bus to http")
		client = bhomedbapi.HttpClient{}
		url = "http://" + ip + ":8888/" + strings.Trim(url, "/")
	}
	return client.DoPostRequest(url, contentType, params, nil, header)
}

// bus-put请求
func DoPutToBus(nodeId string, url string, contentType string, params map[string]interface{}) ([]byte, error) {
	ip, _ := GetNodeIp(nodeId)
	header := map[string]string{
		"Authorization": Token,
	}
	client := bhomedbapi.NewClient(bhomedbapi.WithIp(ip), bhomedbapi.WithDevId(nodeId), bhomedbapi.WithTopic(url))
	if client == nil || nodeId != config.Server.AnalyServerId {
		logger.Warn("client is nil. return from bus to http")
		client = bhomedbapi.HttpClient{}
		url = "http://" + ip + ":8888/" + strings.Trim(url, "/")
	}
	return client.DoPutRequest(url, contentType, params, header)
}

// bus-delete请求
func DoDeleteToBus(nodeId string, url string, contentType string, params map[string]interface{}) ([]byte, error) {
	ip, _ := GetNodeIp(nodeId)
	header := map[string]string{
		"Authorization": Token,
	}
	client := bhomedbapi.NewClient(bhomedbapi.WithIp(ip), bhomedbapi.WithDevId(nodeId), bhomedbapi.WithTopic(url))
	if client == nil || nodeId != config.Server.AnalyServerId {
		logger.Warn("client is nil. return from bus to http")
		client = bhomedbapi.HttpClient{}
		url = "http://" + ip + ":8888/" + strings.Trim(url, "/")
	}
	return client.DoDeleteRequest(url, contentType, params, header)
}