Fix acl bug in subscribe
This commit is contained in:
parent
7baa317d55
commit
f14a56eb17
|
@ -863,7 +863,7 @@ check_sub_acl(TopicFilters, #pstate{credentials = #{is_superuser := IsSuper}, en
|
||||||
check_sub_acl(TopicFilters, #pstate{credentials = Credentials}) ->
|
check_sub_acl(TopicFilters, #pstate{credentials = Credentials}) ->
|
||||||
lists:foldr(
|
lists:foldr(
|
||||||
fun({Topic, SubOpts}, {Ok, Acc}) ->
|
fun({Topic, SubOpts}, {Ok, Acc}) ->
|
||||||
case emqx_access_control:check_acl(Credentials, publish, Topic) of
|
case emqx_access_control:check_acl(Credentials, subscribe, Topic) of
|
||||||
allow -> {Ok, [{Topic, SubOpts}|Acc]};
|
allow -> {Ok, [{Topic, SubOpts}|Acc]};
|
||||||
deny ->
|
deny ->
|
||||||
{error, [{Topic, SubOpts#{rc := ?RC_NOT_AUTHORIZED}}|Acc]}
|
{error, [{Topic, SubOpts#{rc := ?RC_NOT_AUTHORIZED}}|Acc]}
|
||||||
|
|
Loading…
Reference in New Issue