collab/hmq
3
0
Fork 0
mirror of https://github.com/fhmq/hmq.git synced 2026-05-06 07:35:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

change acl

Browse Source
This commit is contained in:
joy.zhou
2019-07-15 18:21:12 +08:00
parent e09891eea6
commit e945b35c91
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/authhttp/authhttp.go
+12 -7
View File
@@ -114,19 +114,24 @@ func CheckSuper(clientID, username, password string) bool {
//CheckACL check mqtt connect //CheckACL check mqtt connect
func CheckACL(username, access, topic string) bool { func CheckACL(username, access, topic string) bool {
req, err := http.NewRequest("GET", config.ACLURL, nil) data := url.Values{}
data.Add("username", username)
data.Add("topic", topic)
data.Add("access", access)
req, err := http.NewRequest("GET", config.ACLURL, strings.NewReader(data.Encode()))
if err != nil { if err != nil {
log.Error("get acl: ", zap.Error(err)) log.Error("get acl: ", zap.Error(err))
return false return false
} }
data := req.URL.Query() // data := req.URL.Query()
data.Add("username", username) // data.Add("username", username)
data.Add("topic", topic) // data.Add("topic", topic)
data.Add("access", access) // data.Add("access", access)
req.URL.RawQuery = data.Encode() // req.URL.RawQuery = data.Encode()
// log.Debugf("req is :%v", req) // fmt.Println("req:", req)
resp, err := httpClient.Do(req) resp, err := httpClient.Do(req)
if err != nil { if err != nil {
log.Error("request acl: ", zap.Error(err)) log.Error("request acl: ", zap.Error(err))