Add eunit tests to increase coverage.
This commit is contained in:
Gilbert Wong
Gilbert
parent
295a9d692e
commit
61030c8d10
|
|
@ -0,0 +1,130 @@
|
|||
%% Copyright (c) 2018 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_reason_codes_tests).
|
||||
|
||||
-include_lib("eunit/include/eunit.hrl").
|
||||
|
||||
-include("emqx_mqtt.hrl").
|
||||
|
||||
-import(lists, [seq/2, zip/2, foreach/2]).
|
||||
|
||||
-define(MQTTV4_CODE_NAMES, [connection_acceptd,
|
||||
unacceptable_protocol_version,
|
||||
client_identifier_not_valid,
|
||||
server_unavaliable,
|
||||
malformed_username_or_password,
|
||||
unauthorized_client,
|
||||
unknown_error]).
|
||||
|
||||
-define(MQTTV5_CODE_NAMES, [success, granted_qos1, granted_qos2, disconnect_with_will_message,
|
||||
no_matching_subscribers, no_subscription_existed, continue_authentication,
|
||||
re_authenticate, unspecified_error, malformed_Packet, protocol_error,
|
||||
implementation_specific_error, unsupported_protocol_version,
|
||||
client_identifier_not_valid, bad_username_or_password, not_authorized,
|
||||
server_unavailable, server_busy, banned,server_shutting_down,
|
||||
bad_authentication_method, keepalive_timeout, session_taken_over,
|
||||
topic_filter_invalid, topic_name_invalid, packet_identifier_inuse,
|
||||
packet_identifier_not_found, receive_maximum_exceeded, topic_alias_invalid,
|
||||
packet_too_large, message_rate_too_high, quota_exceeded,
|
||||
administrative_action, payload_format_invalid, retain_not_supported,
|
||||
qos_not_supported, use_another_server, server_moved,
|
||||
shared_subscriptions_not_supported, connection_rate_exceeded,
|
||||
maximum_connect_time, subscription_identifiers_not_supported,
|
||||
wildcard_subscriptions_not_supported, unknown_error]).
|
||||
|
||||
-define(MQTTV5_CODES, [16#00, 16#01, 16#02, 16#04, 16#10, 16#11, 16#18, 16#19, 16#80, 16#81, 16#82,
|
||||
16#83, 16#84, 16#85, 16#86, 16#87, 16#88, 16#89, 16#8A, 16#8B, 16#8C, 16#8D,
|
||||
16#8E, 16#8F, 16#90, 16#91, 16#92, 16#93, 16#94, 16#95, 16#96, 16#97, 16#98,
|
||||
16#99, 16#9A, 16#9B, 16#9C, 16#9D, 16#9E, 16#9F, 16#A0, 16#A1, 16#A2, code]).
|
||||
|
||||
-define(MQTTV5_TXT, [<<"Success">>, <<"Granted QoS 1">>, <<"Granted QoS 2">>,
|
||||
<<"Disconnect with Will Message">>, <<"No matching subscribers">>,
|
||||
<<"No subscription existed">>, <<"Continue authentication">>,
|
||||
<<"Re-authenticate">>, <<"Unspecified error">>, <<"Malformed Packet">>,
|
||||
<<"Protocol Error">>, <<"Implementation specific error">>,
|
||||
<<"Unsupported Protocol Version">>, <<"Client Identifier not valid">>,
|
||||
<<"Bad User Name or Password">>, <<"Not authorized">>,
|
||||
<<"Server unavailable">>, <<"Server busy">>, <<"Banned">>,
|
||||
<<"Server shutting down">>, <<"Bad authentication method">>,
|
||||
<<"Keep Alive timeout">>, <<"Session taken over">>,
|
||||
<<"Topic Filter invalid">>, <<"Topic Name invalid">>,
|
||||
<<"Packet Identifier in use">>, <<"Packet Identifier not found">>,
|
||||
<<"Receive Maximum exceeded">>, <<"Topic Alias invalid">>,
|
||||
<<"Packet too large">>, <<"Message rate too high">>, <<"Quota exceeded">>,
|
||||
<<"Administrative action">>, <<"Payload format invalid">>,
|
||||
<<"Retain not supported">>, <<"QoS not supported">>,
|
||||
<<"Use another server">>, <<"Server moved">>,
|
||||
<<"Shared Subscriptions not supported">>, <<"Connection rate exceeded">>,
|
||||
<<"Maximum connect time">>, <<"Subscription Identifiers not supported">>,
|
||||
<<"Wildcard Subscriptions not supported">>, <<"Unknown error">>]).
|
||||
|
||||
-define(COMPAT_CODES_V5, [16#80, 16#81, 16#82, 16#83, 16#84, 16#85, 16#86, 16#87,
|
||||
16#88, 16#89, 16#8A, 16#8B, 16#8C, 16#97, 16#9C, 16#9D,
|
||||
16#9F]).
|
||||
|
||||
-define(COMPAT_CODES_V4, [?CONNACK_PROTO_VER, ?CONNACK_PROTO_VER, ?CONNACK_PROTO_VER,
|
||||
?CONNACK_PROTO_VER, ?CONNACK_PROTO_VER,
|
||||
?CONNACK_INVALID_ID,
|
||||
?CONNACK_CREDENTIALS,
|
||||
?CONNACK_AUTH,
|
||||
?CONNACK_SERVER,
|
||||
?CONNACK_SERVER,
|
||||
?CONNACK_AUTH,
|
||||
?CONNACK_SERVER,
|
||||
?CONNACK_AUTH,
|
||||
?CONNACK_SERVER, ?CONNACK_SERVER, ?CONNACK_SERVER, ?CONNACK_SERVER]).
|
||||
|
||||
mqttv4_name_test() ->
|
||||
(((codes_test(?MQTT_PROTO_V4))
|
||||
(seq(0,6)))
|
||||
(?MQTTV4_CODE_NAMES))
|
||||
(fun emqx_reason_codes:name/2).
|
||||
|
||||
mqttv5_name_test() ->
|
||||
(((codes_test(?MQTT_PROTO_V5))
|
||||
(?MQTTV5_CODES))
|
||||
(?MQTTV5_CODE_NAMES))
|
||||
(fun emqx_reason_codes:name/2).
|
||||
|
||||
text_test() ->
|
||||
(((codes_test(?MQTT_PROTO_V5))
|
||||
(?MQTTV5_CODES))
|
||||
(?MQTTV5_TXT))
|
||||
(fun emqx_reason_codes:text/1).
|
||||
|
||||
compat_test() ->
|
||||
(((codes_test(connack))
|
||||
(?COMPAT_CODES_V5))
|
||||
(?COMPAT_CODES_V4))
|
||||
(fun emqx_reason_codes:compat/2),
|
||||
(((codes_test(suback))
|
||||
([0,1,2, 16#80]))
|
||||
([0,1,2, 16#80]))
|
||||
(fun emqx_reason_codes:compat/2).
|
||||
|
||||
codes_test(AsistVar) ->
|
||||
fun(CODES) ->
|
||||
fun(NAMES) ->
|
||||
fun(Procedure) ->
|
||||
foreach(fun({Code, Result}) ->
|
||||
?assertEqual(Result, case erlang:fun_info(Procedure, name) of
|
||||
{name, text} -> Procedure(Code);
|
||||
{name, name} -> Procedure(Code, AsistVar);
|
||||
{name, compat} -> Procedure(AsistVar, Code)
|
||||
end)
|
||||
end, zip(CODES, NAMES))
|
||||
end
|
||||
end
|
||||
end.
|
||||
Loading…
Reference in New Issue