fix(api): DELETE success wrongly returned code 200
This commit is contained in:
parent
59e6b6ee5b
commit
106aa559e0
|
@ -186,7 +186,7 @@ schema("/authentication/:id") ->
|
||||||
description => <<"Delete authenticator from global authentication chain">>,
|
description => <<"Delete authenticator from global authentication chain">>,
|
||||||
parameters => [{id, mk(binary(), #{in => path, desc => <<"Authenticator ID">>})}],
|
parameters => [{id, mk(binary(), #{in => path, desc => <<"Authenticator ID">>})}],
|
||||||
responses => #{
|
responses => #{
|
||||||
200 => <<"Authenticator deleted">>,
|
204 => <<"Authenticator deleted">>,
|
||||||
404 => error_codes([?NOT_FOUND], <<"Not Found">>)
|
404 => error_codes([?NOT_FOUND], <<"Not Found">>)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -148,7 +148,7 @@ schema("/authorization/sources/built-in-database/username/:username") ->
|
||||||
description => <<"Delete one record for username">>,
|
description => <<"Delete one record for username">>,
|
||||||
parameters => [hoconsc:ref(username)],
|
parameters => [hoconsc:ref(username)],
|
||||||
responses => #{
|
responses => #{
|
||||||
204 => <<"No Content">>,
|
204 => <<"Deleted">>,
|
||||||
400 => emqx_dashboard_swagger:error_codes([?BAD_REQUEST], <<"Bad username">>)
|
400 => emqx_dashboard_swagger:error_codes([?BAD_REQUEST], <<"Bad username">>)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -183,7 +183,7 @@ schema("/authorization/sources/built-in-database/clientid/:clientid") ->
|
||||||
description => <<"Delete one record for clientid">>,
|
description => <<"Delete one record for clientid">>,
|
||||||
parameters => [hoconsc:ref(clientid)],
|
parameters => [hoconsc:ref(clientid)],
|
||||||
responses => #{
|
responses => #{
|
||||||
204 => <<"No Content">>,
|
204 => <<"Deleted">>,
|
||||||
400 => emqx_dashboard_swagger:error_codes([?BAD_REQUEST], <<"Bad clientid">>)
|
400 => emqx_dashboard_swagger:error_codes([?BAD_REQUEST], <<"Bad clientid">>)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -216,7 +216,7 @@ schema("/authorization/sources/built-in-database/purge-all") ->
|
||||||
tags => [<<"authorization">>],
|
tags => [<<"authorization">>],
|
||||||
description => <<"Purge all records">>,
|
description => <<"Purge all records">>,
|
||||||
responses => #{
|
responses => #{
|
||||||
204 => <<"No Content">>,
|
204 => <<"Deleted">>,
|
||||||
400 => emqx_dashboard_swagger:error_codes([?BAD_REQUEST], <<"Bad Request">>)
|
400 => emqx_dashboard_swagger:error_codes([?BAD_REQUEST], <<"Bad Request">>)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -250,7 +250,7 @@ source_api() ->
|
||||||
}
|
}
|
||||||
],
|
],
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"204">> => #{description => <<"No Content">>},
|
<<"204">> => #{description => <<"Deleted">>},
|
||||||
<<"400">> => emqx_mgmt_util:bad_request()
|
<<"400">> => emqx_mgmt_util:bad_request()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -104,7 +104,7 @@ crud_bridges_apis() ->
|
||||||
description => <<"Delete a bridge">>,
|
description => <<"Delete a bridge">>,
|
||||||
parameters => [param_path_id()],
|
parameters => [param_path_id()],
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"200">> => emqx_mgmt_util:schema(<<"Bridge deleted">>),
|
<<"204">> => emqx_mgmt_util:schema(<<"Bridge deleted">>),
|
||||||
<<"404">> => emqx_mgmt_util:error_schema(<<"Bridge not found">>, ['NOT_FOUND'])
|
<<"404">> => emqx_mgmt_util:error_schema(<<"Bridge not found">>, ['NOT_FOUND'])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -131,7 +131,7 @@ schema("/users/:username") ->
|
||||||
parameters => [{username, mk(binary(),
|
parameters => [{username, mk(binary(),
|
||||||
#{in => path, example => <<"admin">>})}],
|
#{in => path, example => <<"admin">>})}],
|
||||||
responses => #{
|
responses => #{
|
||||||
200 => <<"Delete User successfully">>,
|
204 => <<"Delete User successfully">>,
|
||||||
400 => [
|
400 => [
|
||||||
{code, mk(string(), #{example => 'CANNOT_DELETE_ADMIN'})},
|
{code, mk(string(), #{example => 'CANNOT_DELETE_ADMIN'})},
|
||||||
{message, mk(string(), #{example => "CANNOT DELETE ADMIN"})}]}}
|
{message, mk(string(), #{example => "CANNOT DELETE ADMIN"})}]}}
|
||||||
|
@ -220,7 +220,7 @@ user(delete, #{bindings := #{username := Username}}) ->
|
||||||
message => <<"Cannot delete admin">>}};
|
message => <<"Cannot delete admin">>}};
|
||||||
false ->
|
false ->
|
||||||
_ = emqx_dashboard_admin:remove_user(Username),
|
_ = emqx_dashboard_admin:remove_user(Username),
|
||||||
{200}
|
{204}
|
||||||
end.
|
end.
|
||||||
|
|
||||||
change_pwd(put, #{bindings := #{username := Username}, body := Params}) ->
|
change_pwd(put, #{bindings := #{username := Username}, body := Params}) ->
|
||||||
|
|
|
@ -56,7 +56,7 @@ schema("/alarms") ->
|
||||||
delete => #{
|
delete => #{
|
||||||
description => <<"Remove all deactivated alarms">>,
|
description => <<"Remove all deactivated alarms">>,
|
||||||
responses => #{
|
responses => #{
|
||||||
200 => <<"Remove all deactivated alarms ok">>
|
204 => <<"Remove all deactivated alarms ok">>
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}.
|
}.
|
||||||
|
@ -94,7 +94,7 @@ alarms(get, #{query_string := Qs}) ->
|
||||||
|
|
||||||
alarms(delete, _Params) ->
|
alarms(delete, _Params) ->
|
||||||
_ = emqx_mgmt:delete_all_deactivated_alarms(),
|
_ = emqx_mgmt:delete_all_deactivated_alarms(),
|
||||||
{200}.
|
{204}.
|
||||||
|
|
||||||
%%%==============================================================================================
|
%%%==============================================================================================
|
||||||
%% internal
|
%% internal
|
||||||
|
|
|
@ -82,7 +82,7 @@ schema("/banned/:as/:who") ->
|
||||||
example => <<"Badass">>})}
|
example => <<"Badass">>})}
|
||||||
],
|
],
|
||||||
responses => #{
|
responses => #{
|
||||||
200 => <<"Delete banned success">>,
|
204 => <<"Delete banned success">>,
|
||||||
404 => emqx_dashboard_swagger:error_codes(['RESOURCE_NOT_FOUND'],
|
404 => emqx_dashboard_swagger:error_codes(['RESOURCE_NOT_FOUND'],
|
||||||
<<"Banned not found">>)
|
<<"Banned not found">>)
|
||||||
}
|
}
|
||||||
|
@ -146,7 +146,7 @@ delete_banned(delete, #{bindings := Params}) ->
|
||||||
{404, #{code => 'RESOURCE_NOT_FOUND', message => Message}};
|
{404, #{code => 'RESOURCE_NOT_FOUND', message => Message}};
|
||||||
_ ->
|
_ ->
|
||||||
ok = emqx_banned:delete(Params),
|
ok = emqx_banned:delete(Params),
|
||||||
{200}
|
{204}
|
||||||
end.
|
end.
|
||||||
|
|
||||||
format(Banned) ->
|
format(Banned) ->
|
||||||
|
|
|
@ -342,7 +342,7 @@ client_api() ->
|
||||||
}],
|
}],
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"404">> => emqx_mgmt_util:error_schema(<<"Client id not found">>),
|
<<"404">> => emqx_mgmt_util:error_schema(<<"Client id not found">>),
|
||||||
<<"200">> => emqx_mgmt_util:schema(client, <<"List clients 200 OK">>)}}},
|
<<"204">> => emqx_mgmt_util:schema(<<"Kick out client successfully">>)}}},
|
||||||
{"/clients/:clientid", Metadata, client}.
|
{"/clients/:clientid", Metadata, client}.
|
||||||
|
|
||||||
clients_authz_cache_api() ->
|
clients_authz_cache_api() ->
|
||||||
|
@ -368,7 +368,7 @@ clients_authz_cache_api() ->
|
||||||
}],
|
}],
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"404">> => emqx_mgmt_util:error_schema(<<"Client id not found">>),
|
<<"404">> => emqx_mgmt_util:error_schema(<<"Client id not found">>),
|
||||||
<<"200">> => emqx_mgmt_util:schema(<<"Delete clients 200 OK">>)}}},
|
<<"204">> => emqx_mgmt_util:schema(<<"Clean client authz cache successfully">>)}}},
|
||||||
{"/clients/:clientid/authz_cache", Metadata, authz_cache}.
|
{"/clients/:clientid/authz_cache", Metadata, authz_cache}.
|
||||||
|
|
||||||
clients_subscriptions_api() ->
|
clients_subscriptions_api() ->
|
||||||
|
@ -506,7 +506,7 @@ lookup(#{clientid := ClientID}) ->
|
||||||
|
|
||||||
kickout(#{clientid := ClientID}) ->
|
kickout(#{clientid := ClientID}) ->
|
||||||
emqx_mgmt:kickout_client(ClientID),
|
emqx_mgmt:kickout_client(ClientID),
|
||||||
{200}.
|
{204}.
|
||||||
|
|
||||||
get_authz_cache(#{clientid := ClientID})->
|
get_authz_cache(#{clientid := ClientID})->
|
||||||
case emqx_mgmt:list_authz_cache(ClientID) of
|
case emqx_mgmt:list_authz_cache(ClientID) of
|
||||||
|
|
|
@ -110,7 +110,7 @@ api_list_update_listeners_by_id() ->
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"404">> =>
|
<<"404">> =>
|
||||||
emqx_mgmt_util:error_schema(?LISTENER_NOT_FOUND, ['BAD_LISTENER_ID']),
|
emqx_mgmt_util:error_schema(?LISTENER_NOT_FOUND, ['BAD_LISTENER_ID']),
|
||||||
<<"200">> =>
|
<<"204">> =>
|
||||||
emqx_mgmt_util:schema(<<"Delete listener successfully">>)}}
|
emqx_mgmt_util:schema(<<"Delete listener successfully">>)}}
|
||||||
},
|
},
|
||||||
{"/listeners/:id", Metadata, crud_listeners_by_id}.
|
{"/listeners/:id", Metadata, crud_listeners_by_id}.
|
||||||
|
@ -160,7 +160,7 @@ api_get_update_listener_by_id_on_node() ->
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"404">> =>
|
<<"404">> =>
|
||||||
emqx_mgmt_util:error_schema(?LISTENER_NOT_FOUND, ['BAD_LISTENER_ID']),
|
emqx_mgmt_util:error_schema(?LISTENER_NOT_FOUND, ['BAD_LISTENER_ID']),
|
||||||
<<"200">> =>
|
<<"204">> =>
|
||||||
emqx_mgmt_util:schema(<<"Delete listener successfully">>)}}
|
emqx_mgmt_util:schema(<<"Delete listener successfully">>)}}
|
||||||
},
|
},
|
||||||
{"/nodes/:node/listeners/:id", Metadata, crud_listener_by_id_on_node}.
|
{"/nodes/:node/listeners/:id", Metadata, crud_listener_by_id_on_node}.
|
||||||
|
@ -251,7 +251,7 @@ crud_listeners_by_id(put, #{bindings := #{id := Id}, body := Conf}) ->
|
||||||
crud_listeners_by_id(delete, #{bindings := #{id := Id}}) ->
|
crud_listeners_by_id(delete, #{bindings := #{id := Id}}) ->
|
||||||
Results = emqx_mgmt:remove_listener(Id),
|
Results = emqx_mgmt:remove_listener(Id),
|
||||||
case lists:filter(fun filter_errors/1, Results) of
|
case lists:filter(fun filter_errors/1, Results) of
|
||||||
[] -> {200};
|
[] -> {204};
|
||||||
Errors -> {500, #{code => 'UNKNOW_ERROR', message => err_msg(Errors)}}
|
Errors -> {500, #{code => 'UNKNOW_ERROR', message => err_msg(Errors)}}
|
||||||
end.
|
end.
|
||||||
|
|
||||||
|
@ -291,7 +291,7 @@ crud_listener_by_id_on_node(put, #{bindings := #{id := Id, node := Node}, body :
|
||||||
end;
|
end;
|
||||||
crud_listener_by_id_on_node(delete, #{bindings := #{id := Id, node := Node}}) ->
|
crud_listener_by_id_on_node(delete, #{bindings := #{id := Id, node := Node}}) ->
|
||||||
case emqx_mgmt:remove_listener(atom(Node), Id) of
|
case emqx_mgmt:remove_listener(atom(Node), Id) of
|
||||||
ok -> {200};
|
ok -> {204};
|
||||||
{error, Reason} -> {500, #{code => 'UNKNOW_ERROR', message => err_msg(Reason)}}
|
{error, Reason} -> {500, #{code => 'UNKNOW_ERROR', message => err_msg(Reason)}}
|
||||||
end.
|
end.
|
||||||
|
|
||||||
|
|
|
@ -90,7 +90,7 @@ schema("/mqtt/delayed/messages/:msgid") ->
|
||||||
description => <<"Delete delayed message">>,
|
description => <<"Delete delayed message">>,
|
||||||
parameters => [{msgid, mk(binary(), #{in => path, desc => <<"delay message ID">>})}],
|
parameters => [{msgid, mk(binary(), #{in => path, desc => <<"delay message ID">>})}],
|
||||||
responses => #{
|
responses => #{
|
||||||
200 => <<"Delete delayed message success">>,
|
204 => <<"Delete delayed message success">>,
|
||||||
400 => emqx_dashboard_swagger:error_codes([?MESSAGE_ID_SCHEMA_ERROR], <<"Bad MsgId format">>),
|
400 => emqx_dashboard_swagger:error_codes([?MESSAGE_ID_SCHEMA_ERROR], <<"Bad MsgId format">>),
|
||||||
404 => emqx_dashboard_swagger:error_codes([?MESSAGE_ID_NOT_FOUND], <<"MsgId not found">>)
|
404 => emqx_dashboard_swagger:error_codes([?MESSAGE_ID_NOT_FOUND], <<"MsgId not found">>)
|
||||||
}
|
}
|
||||||
|
@ -166,7 +166,7 @@ delayed_message(delete, #{bindings := #{msgid := Id}}) ->
|
||||||
case emqx_delayed:get_delayed_message(Id) of
|
case emqx_delayed:get_delayed_message(Id) of
|
||||||
{ok, _Message} ->
|
{ok, _Message} ->
|
||||||
_ = emqx_delayed:delete_delayed_message(Id),
|
_ = emqx_delayed:delete_delayed_message(Id),
|
||||||
{200};
|
{204};
|
||||||
{error, id_schema_error} ->
|
{error, id_schema_error} ->
|
||||||
{400, generate_http_code_map(id_schema_error, Id)};
|
{400, generate_http_code_map(id_schema_error, Id)};
|
||||||
{error, not_found} ->
|
{error, not_found} ->
|
||||||
|
|
|
@ -115,7 +115,7 @@ operation_topic_metrics_api() ->
|
||||||
description => <<"Deregister topic metrics">>,
|
description => <<"Deregister topic metrics">>,
|
||||||
parameters => [topic_param()],
|
parameters => [topic_param()],
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"200">> => schema(<<"Deregister topic metrics">>),
|
<<"204">> => schema(<<"Deregister topic metrics">>),
|
||||||
<<"404">> => error_schema(<<"Topic not found">>, [?ERROR_TOPIC])
|
<<"404">> => error_schema(<<"Topic not found">>, [?ERROR_TOPIC])
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -88,7 +88,7 @@ with_topic_api() ->
|
||||||
description => <<"delete matching messages">>,
|
description => <<"delete matching messages">>,
|
||||||
parameters => parameters(),
|
parameters => parameters(),
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"200">> => schema(<<"Successed">>),
|
<<"204">> => schema(<<"Successed">>),
|
||||||
<<"405">> => schema(<<"NotAllowed">>)
|
<<"405">> => schema(<<"NotAllowed">>)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -147,7 +147,7 @@ with_topic(get, #{bindings := Bindings} = Params) ->
|
||||||
with_topic(delete, #{bindings := Bindings}) ->
|
with_topic(delete, #{bindings := Bindings}) ->
|
||||||
Topic = maps:get(topic, Bindings),
|
Topic = maps:get(topic, Bindings),
|
||||||
emqx_retainer_mnesia:delete_message(undefined, Topic),
|
emqx_retainer_mnesia:delete_message(undefined, Topic),
|
||||||
{200}.
|
{204}.
|
||||||
|
|
||||||
-spec lookup(undefined | binary(),
|
-spec lookup(undefined | binary(),
|
||||||
map(),
|
map(),
|
||||||
|
|
|
@ -104,7 +104,7 @@ api_rules_crud() ->
|
||||||
description => <<"Delete a rule by given Id from all nodes in the cluster">>,
|
description => <<"Delete a rule by given Id from all nodes in the cluster">>,
|
||||||
parameters => [param_path_id()],
|
parameters => [param_path_id()],
|
||||||
responses => #{
|
responses => #{
|
||||||
<<"200">> =>
|
<<"204">> =>
|
||||||
emqx_mgmt_util:schema(<<"Delete rule successfully">>)}}
|
emqx_mgmt_util:schema(<<"Delete rule successfully">>)}}
|
||||||
},
|
},
|
||||||
{"/rules/:id", Metadata, crud_rules_by_id}.
|
{"/rules/:id", Metadata, crud_rules_by_id}.
|
||||||
|
@ -291,7 +291,7 @@ crud_rules_by_id(put, #{bindings := #{id := Id}, body := Params}) ->
|
||||||
crud_rules_by_id(delete, #{bindings := #{id := Id}}) ->
|
crud_rules_by_id(delete, #{bindings := #{id := Id}}) ->
|
||||||
ConfPath = emqx_rule_engine:config_key_path() ++ [Id],
|
ConfPath = emqx_rule_engine:config_key_path() ++ [Id],
|
||||||
case emqx:remove_config(ConfPath, #{}) of
|
case emqx:remove_config(ConfPath, #{}) of
|
||||||
{ok, _} -> {200};
|
{ok, _} -> {204};
|
||||||
{error, Reason} ->
|
{error, Reason} ->
|
||||||
?SLOG(error, #{msg => "delete_rule_failed",
|
?SLOG(error, #{msg => "delete_rule_failed",
|
||||||
id => Id, reason => Reason}),
|
id => Id, reason => Reason}),
|
||||||
|
|
Loading…
Reference in New Issue