chore(psk): fix bugs

apps/emqx/test/props/prop_emqx_psk.erl

@@ -33,7 +33,7 @@ prop_lookup() ->
     ?ALL({ClientPSKID, UserState},
          {client_pskid(), user_state()},
          begin
-             case emqx_psk:lookup(psk, ClientPSKID, UserState) of
+             case emqx_tls_psk:lookup(psk, ClientPSKID, UserState) of
                  {ok, _Result} -> true;
                  error -> true;
                  _Other -> false

apps/emqx_psk/src/emqx_psk.erl

@@ -106,11 +106,11 @@ stop() ->
 %%--------------------------------------------------------------------
 
 init(_Opts) ->
-    case is_enable() of
+    case get_config(enable) of
         true -> load();
         false -> ok
     end,
-    case init_file() of
+    case get_config(init_file) of
         undefined -> ok;
         BootFile -> import_psks(BootFile)
     end,
@@ -142,13 +142,11 @@ code_change(_OldVsn, State, _Extra) ->
 %% Internal functions
 %%------------------------------------------------------------------------------
 
-is_enable() ->
+get_config(enable) ->
-    emqx_config:get([psk, enable]).
+    emqx_config:get([psk, enable]);
-
+get_config(init_file) ->
-init_file() ->
+    emqx_config:get([psk, init_file], undefined);
-    emqx_config:get([psk, init_file], undefined).
+get_config(separator) ->
-
-separator() ->
     emqx_config:get([psk, separator], ?DEFAULT_DELIMITER).
 
 import_psks(SrcFile) ->
@@ -156,10 +154,10 @@ import_psks(SrcFile) ->
         {error, Reason} ->
             {error, Reason};
         {ok, Io} ->
-            case Result = import_psks(Io, separator()) of
+            case Result = import_psks(Io, get_config(separator)) of
                 ok -> ignore;
                 {error, Reason} ->
-                    ?LOG("Failed to import psk from ~s due to ~p", [SrcFile, Reason])
+                    ?LOG(warning, "Failed to import psk from ~s due to ~p", [SrcFile, Reason])
             end,
             _ = file:close(Io),
             Result