package bhomedbapi

import (
	"basic.com/valib/bhshmq.git/proto/source/bhome_msg"
	"errors"
	"fmt"
	"strconv"
)

type Client interface {
	//GET
	DoGetRequest(url string, params map[string]string, headers map[string]string) ([]byte, error)
	//POST
	DoPostRequest(url string, contentType string, body map[string]interface{}, params map[string]string, headers map[string]string) ([]byte, error)
	//PUT
	DoPutRequest(url string, contentType string, body map[string]interface{}, headers map[string]string) ([]byte, error)
	//DELETE
	DoDeleteRequest(url string, contentType string, body map[string]interface{}, headers map[string]string) ([]byte, error)
}

var BASIC_URL            = "http://127.0.0.1:8001"

var DEFAULT_IP			 = "127.0.0.1"
var DEFAULT_PORT         = 8001

const (
	DATA_URL_PREFIX      = "/data/api-v"
	CONTENT_TYPE_FORM    = "application/x-www-form-urlencoded"
	CONTENT_TYPE_MULFORM = "multipart/form-data"
	CONTENT_TYPE_JSON    = "application/json"
)

var logPrint = func(i ...interface{}) {
	fmt.Println(i...)
}
//初始化dbserver的地址和端口
func Init(ip string,port int){
	BASIC_URL = "http://"+ ip + ":" + strconv.Itoa(port)
}

func InitLog(fn func(i ...interface{})) {
	if fn != nil {
		logPrint = fn
	}
}

var getNetNode = func(topic string) []bhome_msg.BHAddress{
	return nil
}

func InitGetNetNode(fn func(name string)[]bhome_msg.BHAddress) {
	if fn != nil {
		getNetNode = fn
	}
}

var busReq = func(req *bhome_msg.MsgRequestTopic,dest []bhome_msg.BHAddress) ([]byte, error) {
	return nil, errors.New("please init InitDoReq first")
}

func InitDoReq(fn func(*bhome_msg.MsgRequestTopic, []bhome_msg.BHAddress) ([]byte, error)) {
	if fn != nil {
		busReq = fn
	}
}

func url2Topic(serviceName string, url string) string {
	return url
}