test/dgiot
1
0
Fork 0
mirror of https://gitee.com/dgiiot/dgiot.git synced 2024-12-02 12:18:30 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: device acl

Browse Source
This commit is contained in:
jhonliu 2022-05-07 20:08:22 +08:00
parent 4f4ccd5047
commit 8a5723f1c4
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/dgiot_dlink/src/proctol/dgiot_mqtt_acl.erl
View File

@ -17,14 +17,9 @@
-module(dgiot_mqtt_acl).
%% ACL Callbacks
-export([
check_acl/5
, description/0
, check_device_acl/3
]).
-export([check_acl/5, description/0, check_device_acl/3]).
check_acl(ClientInfo, PubSub, <<"$dg/", _/binary>> = Topic, _NoMatchAction, _Params) ->
io:format("~s ~p Topic: ~p _NoMatchAction ~p ~n", [?FILE, ?LINE, Topic, _NoMatchAction]),
_Username = maps:get(username, ClientInfo, undefined),
case do_check(ClientInfo, PubSub, Topic) of
allow ->
@ -71,7 +66,7 @@ do_check(#{clientid := Token, username := UserId} = _ClientInfo, publish, <<"$dg
end;
%% 用户订阅 "$dg/user/deviceid/#"
do_check(#{clientid := Token, username := UserId} = _ClientInfo, subscribe, <<"$dg/user/", DeviceID:10/binary, "/", Rest/binary>> = _Topic)
do_check(#{clientid := Token, username := UserId} = _ClientInfo, subscribe, <<"$dg/user/", DeviceID:10/binary, "/", _Rest/binary>> = _Topic)
when UserId =/= undefined ->
%% io:format("~s ~p Topic: ~p~n", [?FILE, ?LINE, _Topic]),
%% 此时的ClientID为 Token