mirror of
https://github.com/fhmq/hmq.git
synced 2026-05-06 07:35:32 +00:00
joy.zhou
39 lines
645 B
Go
39 lines
645 B
Go
/* Copyright (c) 2018, joy.zhou <chowyu08@gmail.com>
|
|
*/
|
|
package broker
|
|
|
|
import (
|
|
"strings"
|
|
|
|
"github.com/fhmq/hmq/plugins/authhttp"
|
|
)
|
|
|
|
const (
|
|
PUB = 1
|
|
SUB = 2
|
|
)
|
|
|
|
func (c *client) CheckTopicAuth(typ int, topic string) bool {
|
|
if strings.HasPrefix(topic, "$SYS/broker/connection/clients/") {
|
|
return true
|
|
}
|
|
|
|
if strings.HasPrefix(topic, "$queue/") {
|
|
topic = strings.TrimPrefix(topic, "$queue/")
|
|
}
|
|
|
|
if c.typ != CLIENT || !c.broker.pluginAuthHTTP {
|
|
return true
|
|
}
|
|
access := "sub"
|
|
switch typ {
|
|
case 1:
|
|
access = "2"
|
|
case 2:
|
|
access = "1"
|
|
}
|
|
username := string(c.info.username)
|
|
return authhttp.CheckACL(username, access, topic)
|
|
|
|
}
|