gravitl/netmaker
1
1
Fork 0
mirror of https://github.com/gravitl/netmaker.git synced 2025-10-09 13:26:52 +08:00
Code Issues Projects Releases Packages Wiki Activity

change emqx apis to support v5.0.09

Browse source
This commit is contained in:
Abhishek Kondur 2023-04-04 15:43:06 +04:00
parent a3684b2c0b
commit 2bc5cb238f
3 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
compose/docker-compose-emqx.yml
View file

@ -65,7 +65,7 @@ services:
- dnsconfig:/root/dnsconfig - dnsconfig:/root/dnsconfig
mq: mq:
container_name: mq container_name: mq
image: emqx/emqx:5.0.17 image: emqx/emqx:5.0.09
restart: unless-stopped restart: unless-stopped
environment: environment:
EMQX_NAME: "emqx" EMQX_NAME: "emqx"

2
compose/docker-compose.ee.yml
View file

@ -68,7 +68,7 @@ services:
- dnsconfig:/root/dnsconfig - dnsconfig:/root/dnsconfig
mq: mq:
container_name: mq container_name: mq
image: emqx/emqx:5.0.17 image: emqx/emqx:5.0.09
restart: unless-stopped restart: unless-stopped
environment: environment:
EMQX_NAME: "emqx" EMQX_NAME: "emqx"

8
mq/emqx.go
View file

@ -205,7 +205,7 @@ func GetUserACL(username string) (*aclObject, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
req, err := http.NewRequest(http.MethodGet, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/rules/users/"+username, nil) req, err := http.NewRequest(http.MethodGet, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/username/"+username, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -241,7 +241,7 @@ func CreateDefaultDenyRule() error {
if err != nil { if err != nil {
return err return err
} }
req, err := http.NewRequest(http.MethodPost, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/rules/all", bytes.NewReader(payload)) req, err := http.NewRequest(http.MethodPost, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/all", bytes.NewReader(payload))
if err != nil { if err != nil {
return err return err
} }
@ -301,7 +301,7 @@ func CreateHostACL(hostID, serverName string) error {
if err != nil { if err != nil {
return err return err
} }
req, err := http.NewRequest(http.MethodPut, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/rules/users/"+hostID, bytes.NewReader(payload)) req, err := http.NewRequest(http.MethodPut, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/username/"+hostID, bytes.NewReader(payload))
if err != nil { if err != nil {
return err return err
} }
@ -369,7 +369,7 @@ func AppendNodeUpdateACL(hostID, nodeNetwork, nodeID, serverName string) error {
if err != nil { if err != nil {
return err return err
} }
req, err := http.NewRequest(http.MethodPut, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/rules/users/"+hostID, bytes.NewReader(payload)) req, err := http.NewRequest(http.MethodPut, servercfg.GetEmqxRestEndpoint()+"/api/v5/authorization/sources/built_in_database/username/"+hostID, bytes.NewReader(payload))
if err != nil { if err != nil {
return err return err
} }