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

chore: sync changes in emqx_relup from ee to ce

This commit is contained in:
Zaiming (Stone) Shi 2022-12-28 14:28:50 +01:00
parent f033b1389e
commit 614d740f71
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/emqx_relup.erl
View File

@ -31,12 +31,14 @@
post_release_upgrade(FromRelVsn, _) -> post_release_upgrade(FromRelVsn, _) ->
{_, CurrRelVsn} = ?EMQX_RELEASE, {_, CurrRelVsn} = ?EMQX_RELEASE,
?INFO("emqx has been upgraded from ~s to ~s!", [FromRelVsn, CurrRelVsn]), ?INFO("emqx has been upgraded from ~s to ~s!", [FromRelVsn, CurrRelVsn]),
maybe_refresh_jwt_module(FromRelVsn),
reload_components(). reload_components().
%% What to do after downgraded to an old release vsn. %% What to do after downgraded to an old release vsn.
post_release_downgrade(ToRelVsn, _) -> post_release_downgrade(ToRelVsn, _) ->
{_, CurrRelVsn} = ?EMQX_RELEASE, {_, CurrRelVsn} = ?EMQX_RELEASE,
?INFO("emqx has been downgraded from ~s to ~s!", [CurrRelVsn, ToRelVsn]), ?INFO("emqx has been downgraded from ~s to ~s!", [CurrRelVsn, ToRelVsn]),
maybe_refresh_jwt_module(ToRelVsn),
reload_components(). reload_components().
-ifdef(EMQX_ENTERPRISE). -ifdef(EMQX_ENTERPRISE).
@ -73,3 +75,21 @@ load_plugins() ->
true -> emqx_plugins:force_load(); true -> emqx_plugins:force_load();
false -> emqx_plugins:load() false -> emqx_plugins:load()
end. end.
-ifdef(EMQX_ENTERPRISE).
maybe_refresh_jwt_module(Release) when Release =:= "4.4.0"
orelse Release =:= "4.4.1"
orelse Release =:= "4.4.2"
orelse Release =:= "4.4.3" ->
_ = emqx:unhook('client.authenticate', fun emqx_auth_jwt:check/3),
_ = emqx:unhook('client.authenticate', fun emqx_auth_jwt:check_auth/3),
emqx_modules:refresh_module(jwt_authentication);
maybe_refresh_jwt_module(_) ->
ok.
-else.
maybe_refresh_jwt_module(_) ->
ok.
-endif.