57 lines
2.3 KiB
Erlang
57 lines
2.3 KiB
Erlang
%%--------------------------------------------------------------------
|
|
%% 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_mgmt_api_routes_SUITE).
|
|
|
|
-compile(export_all).
|
|
-compile(nowarn_export_all).
|
|
|
|
-include_lib("eunit/include/eunit.hrl").
|
|
|
|
all() ->
|
|
emqx_common_test_helpers:all(?MODULE).
|
|
|
|
init_per_suite(Config) ->
|
|
emqx_mgmt_api_test_util:init_suite(),
|
|
Config.
|
|
|
|
end_per_suite(_) ->
|
|
emqx_mgmt_api_test_util:end_suite().
|
|
|
|
t_nodes_api(_) ->
|
|
Topic = <<"test_topic">>,
|
|
{ok, Client} = emqtt:start_link(#{username => <<"routes_username">>, clientid => <<"routes_cid">>}),
|
|
{ok, _} = emqtt:connect(Client),
|
|
{ok, _, _} = emqtt:subscribe(Client, Topic),
|
|
|
|
Path = emqx_mgmt_api_test_util:api_path(["routes"]),
|
|
{ok, Response} = emqx_mgmt_api_test_util:request_api(get, Path),
|
|
RoutesData = emqx_json:decode(Response, [return_maps]),
|
|
Meta = maps:get(<<"meta">>, RoutesData),
|
|
?assertEqual(1, maps:get(<<"page">>, Meta)),
|
|
?assertEqual(emqx_mgmt:max_row_limit(), maps:get(<<"limit">>, Meta)),
|
|
?assertEqual(1, maps:get(<<"count">>, Meta)),
|
|
Data = maps:get(<<"data">>, RoutesData),
|
|
Route = erlang:hd(Data),
|
|
?assertEqual(Topic, maps:get(<<"topic">>, Route)),
|
|
?assertEqual(atom_to_binary(node(), utf8), maps:get(<<"node">>, Route)),
|
|
|
|
%% get routes/:topic
|
|
RoutePath = emqx_mgmt_api_test_util:api_path(["routes", Topic]),
|
|
{ok, RouteResponse} = emqx_mgmt_api_test_util:request_api(get, RoutePath),
|
|
RouteData = emqx_json:decode(RouteResponse, [return_maps]),
|
|
?assertEqual(Topic, maps:get(<<"topic">>, RouteData)),
|
|
?assertEqual(atom_to_binary(node(), utf8), maps:get(<<"node">>, RouteData)).
|