%% coding: utf-8
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2013. All Rights Reserved.
%%
%% The contents of this file are subject to the Erlang Public License,
%% Version 1.1, (the "License"); you may not use this file except in
%% compliance with the License. You should have received a copy of the
%% Erlang Public License along with this software. If not, it can be
%% retrieved online at http://www.erlang.org/.
%%
%% Software distributed under the License is distributed on an "AS IS"
%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
%% the License for the specific language governing rights and limitations
%% under the License.
%%
%% %CopyrightEnd%
%%
%%
%% Test service and transport config. In particular, of the detection
%% of config errors.
%%
-module(diameter_config_SUITE).
-export([suite/0,
all/0]).
%% testcases
-export([start/1,
start_service/1,
add_transport/1,
stop/1]).
-define(util, diameter_util).
%% Lists of {Key, GoodConfigList, BadConfigList} with which to
%% configure.
-define(SERVICE_CONFIG,
[{application,
[[[{dictionary, diameter_gen_base_rfc6733},
{module, ?MODULE}]]
| [[[{dictionary, D},
{module, M},
{alias, A},
{state, S},
{answer_errors, AE},
{request_errors, RE},
{call_mutates_state, C}]]
|| D <- [diameter_gen_base_rfc3588, diameter_gen_base_rfc6733],
M <- [?MODULE, [?MODULE, now()]],
A <- [0, common, make_ref()],
S <- [[], make_ref()],
AE <- [report, callback, discard],
RE <- [answer_3xxx, answer, callback],
C <- [true, false]]],
[[x],
[[]],
[[{dictionary, diameter_gen_base_rfc3588}]],
[[{module, ?MODULE}]]
| [[[{dictionary, diameter_gen_base_rfc6733},
{module, ?MODULE},
{K,x}]]
|| K <- [answer_errors,
request_errors,
call_mutates_state]]]},
{restrict_connections,
[[false], [node], [nodes], [[node(), node()]]],
[]},
{sequence,
[[{0,32}], [{1,31}]],
[[{2,31}]]},
{share_peers,
[[true],
[false],
[[node()]]],
[[x]]},
{use_shared_peers,
[[true],
[false],
[[node(), node()]]],
[[x]]}]).
-define(TRANSPORT_CONFIG,
[{transport_module,
[[?MODULE]],
[[[?MODULE]]]},
{transport_config,
[[{}, 3000],
[{}, infinity]],
[[{}, x]]},
{applications,
[[[1, a, [x]]]],
[[x]]},
{capabilities,
[[[{'Origin-Host', "diameter.erlang.org"}]],
[[{'Origin-Realm', "erlang.org"}]]]
++ [[[{'Host-IP-Address', L}]]
|| L <- [[{127,0,0,1}],
["127.0.0.1"],
["127.0.0.1", "FFFF::1", "::1", {1,2,3,4,5,6,7,8}]]]
++ [[[{'Product-Name', N}]]
|| N <- [["Product", $-, ["Name"]],
"Norðurálfa",
"ᚠᚢᚦᚨᚱᚲ"]]
++ [[[{K,V}]]
|| K <- ['Vendor-Id',
'Origin-State-Id',
'Firmware-Revision'],
V <- [0, 256, 16#FFFF]]
++ [[[{K,V}]]
|| K <- ['Supported-Vendor-Id',
'Auth-Application-Id',
'Acct-Application-Id',
'Inband-Security-Id'],
V <- [[17], [0, 256, 16#FFFF]]]
++ [[[{'Vendor-Specific-Application-Id',
[[{'Vendor-Id', V},
{'Auth-Application-Id', [0]},
{'Acct-Application-Id', [4]}]]}]]
|| V <- [1, [1]]],
[[x], [[{'Origin-Host', "ᚠᚢᚦᚨᚱᚲ"}]]]
++ [[[{'Host-IP-Address', A}]]
|| A <- [{127,0,0,1}]]
++ [[[{'Product-Name', N}]]
|| N <- [x, 1]]
++ [[[{K,V}]]
|| K <- ['Vendor-Id',
'Origin-State-Id',
'Firmware-Revision'],
V <- [x, [0], -1, 1 bsl 32]]
++ [[[{K,V}]]
|| K <- ['Supported-Vendor-Id',
'Auth-Application-Id',
'Acct-Application-Id',
'Inband-Security-Id'],
V <- [x, 17, [-1], [1 bsl 32]]]
++ [[[{'Vendor-Specific-Application-Id', V}]]
|| V <- [x,
[[{'Vendor-Id', 1 bsl 32}]],
[[{'Auth-Application-Id', 1}]]]]},
{capabilities_cb,
[[x]],
[]},
{capx_timeout,
[[3000]],
[[{?MODULE, tmo, []}]]},
{disconnect_cb,
[[x]],
[]},
{length_errors,
[[exit], [handle], [discard]],
[[x]]},
{reconnect_timer,
[[3000]],
[[infinity]]},
{watchdog_timer,
[[3000],
[{?MODULE, tmo, []}]],
[[infinity],
[-1]]},
{watchdog_config,
[[[{okay, 0}, {suspect, 0}]],
[[{okay, 1}]],
[[{suspect, 2}]]],
[[x],
[[{open, 0}]]]}]).
%% ===========================================================================
suite() ->
[{timetrap, {seconds, 60}}].
all() ->
[start,
start_service,
add_transport,
stop].
%% ===========================================================================
start(_) ->
ok = diameter:start().
start_service(T)
when is_tuple(T) ->
do(fun start/3, T);
start_service(_) ->
[] = ?util:run([{?MODULE, start_service, [T]}
|| T <- [lists:keyfind(capabilities, 1, ?TRANSPORT_CONFIG)
| ?SERVICE_CONFIG]]).
add_transport(T)
when is_tuple(T) ->
do(fun add/3, T);
add_transport(_) ->
[] = ?util:run([{?MODULE, add_transport, [T]}
|| T <- ?TRANSPORT_CONFIG]).
stop(_) ->
ok = diameter:stop().
%% ===========================================================================
%% do/2
do(F, {Key, Good, Bad}) ->
F(Key, Good, Bad).
%% add/3
add(Key, Good, Bad) ->
{[],[]} = {[{Vs,T} || Vs <- Good,
T <- [add(Key, Vs)],
[T] /= [T || {ok,_} <- [T]]],
[{Vs,T} || Vs <- Bad,
T <- [add(Key, Vs)],
[T] /= [T || {error,_} <- [T]]]}.
add(Key, Vs) ->
T = list_to_tuple([Key | Vs]),
diameter:add_transport(make_ref(), {connect, [T]}).
%% start/3
start(Key, Good, Bad) ->
{[],[]} = {[{Vs,T} || Vs <- Good,
T <- [start(Key, Vs)],
T /= ok],
[{Vs,T} || Vs <- Bad,
T <- [start(Key, Vs)],
[T] /= [T || {error,_} <- [T]]]}.
start(capabilities = K, [Vs]) ->
if is_list(Vs) ->
start(make_ref(), Vs ++ apps(K));
true ->
{error, Vs}
end;
start(Key, Vs)
when is_atom(Key) ->
start(make_ref(), [list_to_tuple([Key | Vs]) | apps(Key)]);
start(SvcName, Opts) ->
try
diameter:start_service(SvcName, Opts)
after
diameter:stop_service(SvcName)
end.
apps(application) ->
[];
apps(_) ->
[{application, [{dictionary, diameter_gen_base_rfc6733},
{module, ?MODULE}]}].
