From 6da1302acd502e010279f707943da96cee80eb50 Mon Sep 17 00:00:00 2001
From: JimMoen <LnJimMoen@outlook.com>
Date: Mon, 18 Apr 2022 11:48:35 +0800
Subject: [PATCH] feat: clean up all authz cache api

---
 apps/emqx_authz/src/emqx_authz_api_cache.erl  | 74 +++++++++++++++++++
 .../src/emqx_mgmt_api_clients.erl             |  8 +-
 2 files changed, 78 insertions(+), 4 deletions(-)
 create mode 100644 apps/emqx_authz/src/emqx_authz_api_cache.erl

diff --git a/apps/emqx_authz/src/emqx_authz_api_cache.erl b/apps/emqx_authz/src/emqx_authz_api_cache.erl
new file mode 100644
index 000000000..e6d3b941c
--- /dev/null
+++ b/apps/emqx_authz/src/emqx_authz_api_cache.erl
@@ -0,0 +1,74 @@
+%%--------------------------------------------------------------------
+%% Copyright (c) 2020-2022 EMQ Technologies Co., Ltd. All Rights Reserved.
+%%
+%% Licensed under the Apache License, Version 2.0 (the "License");
+%% you may not use this file except in compliance with the License.
+%% You may obtain a copy of the License at
+%%
+%%     http://www.apache.org/licenses/LICENSE-2.0
+%%
+%% Unless required by applicable law or agreed to in writing, software
+%% distributed under the License is distributed on an "AS IS" BASIS,
+%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+%% See the License for the specific language governing permissions and
+%% limitations under the License.
+%%--------------------------------------------------------------------
+
+-module(emqx_authz_api_cache).
+
+-behaviour(minirest_api).
+
+-export([
+    api_spec/0,
+    paths/0,
+    schema/1
+]).
+
+-export([
+    clean_cache/2
+]).
+
+-define(BAD_REQUEST, 'BAD_REQUEST').
+
+api_spec() ->
+    emqx_dashboard_swagger:spec(?MODULE, #{check_schema => true}).
+
+paths() ->
+    [
+        "/authorization/cache"
+    ].
+
+%%--------------------------------------------------------------------
+%% Schema for each URI
+%%--------------------------------------------------------------------
+
+schema("/authorization/cache") ->
+    #{
+        'operationId' => clean_cache,
+        delete =>
+            #{
+                description => <<"Clean all authorization cache in the cluster.">>,
+                responses =>
+                    #{
+                        204 => <<"No Content">>,
+                        400 => emqx_dashboard_swagger:error_codes([?BAD_REQUEST], <<"Bad Request">>)
+                    }
+            }
+    }.
+
+clean_cache(delete, _) ->
+    case emqx_mgmt:clean_authz_cache_all() of
+        ok ->
+            {204};
+        {error, Reason} ->
+            {400, #{
+                code => <<"BAD_REQUEST">>,
+                message => bin(Reason)
+            }}
+    end.
+
+%%--------------------------------------------------------------------
+%% Internal functions
+%%--------------------------------------------------------------------
+
+bin(Term) -> erlang:iolist_to_binary(io_lib:format("~p", [Term])).
diff --git a/apps/emqx_management/src/emqx_mgmt_api_clients.erl b/apps/emqx_management/src/emqx_mgmt_api_clients.erl
index d8c71e80c..36baf041f 100644
--- a/apps/emqx_management/src/emqx_mgmt_api_clients.erl
+++ b/apps/emqx_management/src/emqx_mgmt_api_clients.erl
@@ -78,7 +78,7 @@ api_spec() ->
 paths() ->
     [ "/clients"
     , "/clients/:clientid"
-    , "/clients/:clientid/authz_cache"
+    , "/clients/:clientid/authorization/cache"
     , "/clients/:clientid/subscriptions"
     , "/clients/:clientid/subscribe"
     , "/clients/:clientid/unsubscribe"
@@ -190,11 +190,11 @@ schema("/clients/:clientid") ->
         }
     };
 
-schema("/clients/:clientid/authz_cache") ->
+schema("/clients/:clientid/authorization/cache") ->
     #{
         'operationId' => authz_cache,
         get => #{
-            description => <<"Get client authz cache">>,
+            description => <<"Get client authz cache in the cluster.">>,
             parameters => [{clientid, hoconsc:mk(binary(), #{in => path})}],
             responses => #{
                 200 => hoconsc:mk(hoconsc:ref(?MODULE, authz_cache), #{}),
@@ -203,7 +203,7 @@ schema("/clients/:clientid/authz_cache") ->
             }
         },
         delete => #{
-            description => <<"Clean client authz cache">>,
+            description => <<"Clean client authz cache in the cluster.">>,
             parameters => [{clientid, hoconsc:mk(binary(), #{in => path})}],
             responses => #{
                 204 => <<"Kick out client successfully">>,