修改url2Topic

liuxiaolong

2021-01-06 29b8db9bddbf63434f3cd62776d7c4d7e4cdc510

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package bhomedbapi
 
import (
    "basic.com/valib/bhomebus.git"
    "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) []bhomebus.NetNode{
    return nil
}
 
func InitGetNetNode(fn func(name string)[]bhomebus.NetNode) {
    if fn != nil {
        getNetNode = fn
    }
}
 
func url2Topic(serviceName string, url string) string {
    return serviceName+"_"+url
}