refactor(authn): use simple sync query for authn

there is no need to route the authn queries through the buffer worker

apps/emqx_authn/src/simple_authn/emqx_authn_http.erl

@@ -192,7 +192,7 @@ authenticate(
     } = State
 ) ->
     Request = generate_request(Credential, State),
-    Response = emqx_resource:query(ResourceId, {Method, Request, RequestTimeout}),
+    Response = emqx_resource:simple_sync_query(ResourceId, {Method, Request, RequestTimeout}),
     ?TRACE_AUTHN_PROVIDER("http_response", #{
         request => request_for_log(Credential, State),
         response => response_for_log(Response),

apps/emqx_authn/src/simple_authn/emqx_authn_jwt.erl

@@ -187,7 +187,7 @@ update(
     #{use_jwks := true} = Config,
     #{jwk_resource := ResourceId} = State
 ) ->
-    case emqx_resource:query(ResourceId, {update, connector_opts(Config)}) of
+    case emqx_resource:simple_sync_query(ResourceId, {update, connector_opts(Config)}) of
         ok ->
             case maps:get(verify_claims, Config, undefined) of
                 undefined ->
@@ -229,7 +229,7 @@ authenticate(
         from := From
     }
 ) ->
-    case emqx_resource:query(ResourceId, get_jwks) of
+    case emqx_resource:simple_sync_query(ResourceId, get_jwks) of
         {error, Reason} ->
             ?TRACE_AUTHN_PROVIDER(error, "get_jwks_failed", #{
                 resource => ResourceId,

apps/emqx_authn/src/simple_authn/emqx_authn_mongodb.erl

@@ -167,7 +167,7 @@ authenticate(
     } = State
 ) ->
     Filter = emqx_authn_utils:render_deep(FilterTemplate, Credential),
-    case emqx_resource:query(ResourceId, {find_one, Collection, Filter, #{}}) of
+    case emqx_resource:simple_sync_query(ResourceId, {find_one, Collection, Filter, #{}}) of
         {ok, undefined} ->
             ignore;
         {error, Reason} ->

apps/emqx_authn/src/simple_authn/emqx_authn_mysql.erl

@@ -118,7 +118,9 @@ authenticate(
     }
 ) ->
     Params = emqx_authn_utils:render_sql_params(TmplToken, Credential),
-    case emqx_resource:query(ResourceId, {prepared_query, ?PREPARE_KEY, Params, Timeout}) of
+    case
+        emqx_resource:simple_sync_query(ResourceId, {prepared_query, ?PREPARE_KEY, Params, Timeout})
+    of
         {ok, _Columns, []} ->
             ignore;
         {ok, Columns, [Row | _]} ->

apps/emqx_authn/src/simple_authn/emqx_authn_pgsql.erl

@@ -120,7 +120,7 @@ authenticate(
     }
 ) ->
     Params = emqx_authn_utils:render_sql_params(PlaceHolders, Credential),
-    case emqx_resource:query(ResourceId, {prepared_query, ResourceId, Params}) of
+    case emqx_resource:simple_sync_query(ResourceId, {prepared_query, ResourceId, Params}) of
         {ok, _Columns, []} ->
             ignore;
         {ok, Columns, [Row | _]} ->

apps/emqx_authn/src/simple_authn/emqx_authn_redis.erl

@@ -139,7 +139,7 @@ authenticate(
 ) ->
     NKey = emqx_authn_utils:render_str(KeyTemplate, Credential),
     Command = [CommandName, NKey | Fields],
-    case emqx_resource:query(ResourceId, {cmd, Command}) of
+    case emqx_resource:simple_sync_query(ResourceId, {cmd, Command}) of
         {ok, []} ->
             ignore;
         {ok, Values} ->

apps/emqx_authn/test/emqx_authn_mysql_SUITE.erl

@@ -516,13 +516,13 @@ init_seeds() ->
     ).
 
 q(Sql) ->
-    emqx_resource:query(
+    emqx_resource:simple_sync_query(
         ?MYSQL_RESOURCE,
         {sql, Sql}
     ).
 
 q(Sql, Params) ->
-    emqx_resource:query(
+    emqx_resource:simple_sync_query(
         ?MYSQL_RESOURCE,
         {sql, Sql, Params}
     ).

apps/emqx_authn/test/emqx_authn_pgsql_SUITE.erl

@@ -594,13 +594,13 @@ create_user(Values) ->
     ok.
 
 q(Sql) ->
-    emqx_resource:query(
+    emqx_resource:simple_sync_query(
         ?PGSQL_RESOURCE,
         {query, Sql}
     ).
 
 q(Sql, Params) ->
-    emqx_resource:query(
+    emqx_resource:simple_sync_query(
         ?PGSQL_RESOURCE,
         {query, Sql, Params}
     ).

apps/emqx_authn/test/emqx_authn_redis_SUITE.erl

@@ -588,7 +588,7 @@ init_seeds() ->
     ).
 
 q(Command) ->
-    emqx_resource:query(
+    emqx_resource:simple_sync_query(
         ?REDIS_RESOURCE,
         {cmd, Command}
     ).