%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2001-2019. 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.
%%
%% %CopyrightEnd%
%%
%%
%%----------------------------------------------------------------------
%% Purpose: Test application config
%%----------------------------------------------------------------------
-module(megaco_examples_test).
-compile(export_all).
-include("megaco_test_lib.hrl").
-include_lib("megaco/include/megaco.hrl").
-include_lib("megaco/include/megaco_message_v1.hrl").
t() -> megaco_test_lib:t(?MODULE).
t(Case) -> megaco_test_lib:t({?MODULE, Case}).
%% Test server callbacks
init_per_testcase(Case, Config) ->
put(dbg,true),
purge_examples(),
load_examples(),
megaco:enable_trace(max, io),
megaco_test_lib:init_per_testcase(Case, Config).
end_per_testcase(Case, Config) ->
purge_examples(),
erase(dbg),
megaco:disable_trace(),
megaco_test_lib:end_per_testcase(Case, Config).
example_modules() ->
[megaco_simple_mg, megaco_simple_mgc].
load_examples() ->
case code:lib_dir(megaco) of
{error, Reason} ->
{error, Reason};
Dir ->
[code:load_abs(filename:join([Dir, examples, simple, M])) ||
M <- example_modules()]
end.
purge_examples() ->
case code:lib_dir(megaco) of
{error, Reason} ->
{error, Reason};
_Dir ->
[code:purge(M) || M <- example_modules()]
end.
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%% Top test case
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
all() ->
[simple].
groups() ->
[].
init_per_group(_GroupName, Config) ->
Config.
end_per_group(_GroupName, Config) ->
Config.
simple(suite) ->
[];
simple(Config) when is_list(Config) ->
?ACQUIRE_NODES(1, Config),
d("simple -> proxy start"),
ProxyPid = megaco_test_lib:proxy_start({?MODULE, ?LINE}),
d("simple -> start megaco"),
?VERIFY(ok, megaco:start()),
start_mgc(ProxyPid),
?SLEEP(1000), % This is just to make it easier to read the test logs
start_mg(ProxyPid),
?SLEEP(1000), % This is just to make it easier to read the test logs
d("simple -> verify info()"),
info(),
d("simple -> verify system_info(users)"),
users(),
d("simple -> stop mgc"),
?VERIFY(5, length(megaco_simple_mgc:stop())),
?SLEEP(1000), % This is just to make it easier to read the test logs
d("simple -> verify system_info(users)"),
users(),
d("simple -> stop megaco"),
?VERIFY(ok, megaco:stop()),
?SLEEP(1000), % This is just to make it easier to read the test logs
d("simple -> kill (exit) ProxyPid: ~p", [ProxyPid]),
exit(ProxyPid, shutdown), % Controlled kill of transport supervisors
ok.
start_mgc(ProxyPid) ->
d("start_mgc -> start"),
?APPLY(ProxyPid, fun() -> megaco_simple_mgc:start() end),
receive
{res, _, {ok, MgcAll}} when is_list(MgcAll) ->
?SLEEP(1000), % This is just to make it easier to read the test logs
d("start_mgc -> received MGC response: "
"~n ~p", [MgcAll]),
MgcBad = [MgcRes || MgcRes <- MgcAll, element(1, MgcRes) /= ok],
?VERIFY([], MgcBad),
ok;
Error ->
?ERROR(Error)
end.
start_mg(ProxyPid) ->
d("start_mg -> start"),
?APPLY(ProxyPid, fun() -> megaco_simple_mg:start() end),
receive
{res, _, MgList} when is_list(MgList) andalso (length(MgList) =:= 4) ->
?SLEEP(1000), % This is just to make it easier to read the test logs
d("start_mg -> received MG response: "
"~n ~p", [MgList]),
Verify =
fun({_MgMid, {TransId, Res}}) when TransId =:= 1 ->
case Res of
{ok, [AR]} when is_record(AR, 'ActionReply') ->
case AR#'ActionReply'.commandReply of
[{serviceChangeReply, SCR}] ->
case SCR#'ServiceChangeReply'.serviceChangeResult of
{serviceChangeResParms, MgcMid}
when MgcMid =/= asn1_NOVALUE ->
ok;
Error ->
d("start_mg -> "
"invalid service "
"change parms: "
"~n ~p", [SCR]),
?ERROR(Error)
end;
Error ->
d("start_mg -> "
"invalid service change reply: "
"~n ~p", [Error]),
?ERROR(Error)
end;
Error ->
d("start_mg -> "
"invalid result: "
"~n ~p", [Error]),
?ERROR(Error)
end;
(Error) ->
d("start_mg -> "
"invalid reply: "
"~n ~p", [Error]),
?ERROR(Error)
end,
lists:map(Verify, MgList);
Error ->
d("start_mg -> "
"invalid result: "
"~n ~p", [Error]),
?ERROR(Error)
end.
info() ->
case (catch megaco:info()) of
{'EXIT', _} = Error ->
?ERROR(Error);
Info ->
?LOG("Ok, ~p~n", [Info])
end.
users() ->
case (catch megaco:system_info(users)) of
{'EXIT', _} = Error ->
?ERROR(Error);
Users ->
?LOG("Ok, ~p~n", [Users])
end.
d(F) ->
d(F, []).
d(F, A) ->
d(get(dbg), F, A).
d(true, F, A) ->
io:format("DBG: ~s " ++ F ++ "~n", [?FT() | A]);
d(_, _F, _A) ->
ok.
