yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(acl): deny all ACl when token expired

This commit is contained in:
Zaiming (Stone) Shi 2022-05-15 09:24:02 +02:00
parent d6178f8611
commit 655c2987f3
1 changed files with 22 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
apps/emqx_auth_jwt/src/emqx_auth_jwt.erl
View File

@ -72,14 +72,31 @@ check_acl(ClientInfo = #{jwt_claims := Claims},
Topic, Topic,
_NoMatchAction, _NoMatchAction,
#{acl_claim_name := AclClaimName}) -> #{acl_claim_name := AclClaimName}) ->
Deadline = erlang:system_time(second),
case Claims of case Claims of
#{AclClaimName := Acl, <<"exp">> := Exp} #{AclClaimName := Acl, <<"exp">> := Exp} ->
when is_integer(Exp) andalso Exp >= Deadline -> try is_expired(Exp) of
verify_acl(ClientInfo, Acl, PubSub, Topic); true ->
_ -> ignore ?DEBUG("acl_deny_due_to_jwt_expired", []),
deny;
false ->
verify_acl(ClientInfo, Acl, PubSub, Topic)
catch
_:_ ->
?DEBUG("acl_deny_due_to_invalid_jwt_exp", []),
deny
end;
_ ->
?DEBUG("no_acl_jwt_claim", []),
ignore
end. end.
is_expired(Exp) when is_binary(Exp) ->
ExpInt = binary_to_integer(Exp),
is_expired(ExpInt);
is_expired(Exp) ->
Now = erlang:system_time(second),
Now > Exp.
description() -> "Authentication with JWT". description() -> "Authentication with JWT".
%%------------------------------------------------------------------------------ %%------------------------------------------------------------------------------