add SyncDevToManager

liuxiaolong

2021-05-10 30bbec0a251cb33a01f2693b6da3c92bd5802d50

 client.go

@@ -1,7 +1,8 @@
package bhomedbapi

import (
   "basic.com/valib/bhomebus.git"
   "basic.com/valib/bhshmq.git/proto/source/bhome_msg"
   "errors"
   "fmt"
   "strconv"
)
@@ -43,16 +44,26 @@
   }
}

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

func InitGetNetNode(fn func(name string)[]bhomebus.NetNode) {
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 serviceName+"_"+url
   return url
}